From 914c18aa66a7fbde2d54a05cdf583138bf7f230b Mon Sep 17 00:00:00 2001
From: Ben Lin <maobin001@msn.com>
Date: 星期日, 27 十月 2024 16:59:19 +0800
Subject: [PATCH] 计划任务更新
---
src/api/tigerapi/tsk/tsk_job.ts | 109 +++++++++++++++++++++++++++++++++---------------------
1 files changed, 67 insertions(+), 42 deletions(-)
diff --git a/src/api/tigerapi/tsk/tsk_job.ts b/src/api/tigerapi/tsk/tsk_job.ts
index 3f25fb4..189c9bf 100644
--- a/src/api/tigerapi/tsk/tsk_job.ts
+++ b/src/api/tigerapi/tsk/tsk_job.ts
@@ -1,13 +1,12 @@
-import { buildUUID } from '../../../utils/uuid';
import { ApiAction, ApiActionPage } from '../../model/baseModel';
import {
- Tsk_JobListItem,
+ FluentJobParam,
Tsk_JobPageListGetResultModel,
Tsk_JobPageParams,
Tsk_TrigListItem,
TskParameter,
} from '../model/tskModel';
-import { genAction,genActionjob, Api, genActionPage } from '../system';
+import { genAction, Api, genActionPage, generateAction } from '../system';
import { defHttp } from '/@/utils/http/axios';
import { useGlobSetting } from '/@/hooks/setting';
@@ -16,41 +15,40 @@
* 鑾峰彇瑙掕壊鍒嗛〉鍒楄〃
*/
export const getTsk_JobListByPage = async (params: Tsk_JobPageParams) => {
- var id='';
- if(params?.Status != undefined && params?.Status != ''){
- let sqlcmdt='';
- sqlcmdt += " STATUS = '" + params?.Status + "'";;
+ const id = '';
+ if (params?.Status != undefined && params?.Status != '') {
+ let sqlcmdt = '';
+ sqlcmdt += " STATUS = '" + params?.Status + "'";
const _data = await defHttp.post<ApiAction<Tsk_TrigListItem[]>>(
{ url: Api.EntityList, params: genAction('TSK_TRIG', sqlcmdt, undefined, true) },
{
isTransformResponse: false,
- apiUrl: globSetting.taskApiUrl
+ apiUrl: globSetting.taskApiUrl,
},
);
- let sqlcmd='';
- _data.Data.forEach((item,index) => {
- if(index==0){
- sqlcmd+="and ID='"+item.JobId+"'"
- }else{
- sqlcmd+="Or ID='"+item.JobId+"'"
- }
-
- });
- const rParams = genActionPage('TSK_JOB', sqlcmd, params.page, params.pageSize);
- return getTsk_JobListByPageAsync(rParams);
- }else{
let sqlcmd = '';
- if (id!= undefined && id != '') {
+ _data.Data.forEach((item, index) => {
+ if (index == 0) {
+ sqlcmd += "and ID='" + item.JobId + "'";
+ } else {
+ sqlcmd += "Or ID='" + item.JobId + "'";
+ }
+ });
+ const rParams = genActionPage('TSK_JOB', sqlcmd, params.page, params.pageSize);
+ return getTsk_JobListByPageAsync(rParams);
+ } else {
+ let sqlcmd = '';
+ if (id != undefined && id != '') {
sqlcmd += " And ID = '" + id + "'";
}
if (params?.JobName != undefined && params?.JobName != '') {
sqlcmd += " And JobName like '%" + params?.JobName + "%'";
}
if (params?.CREATE_TIME != undefined && params?.CREATE_TIME != '') {
- sqlcmd += "And CREATE_TIME > '" + params?.CREATE_TIME[0]+"'";
+ sqlcmd += "And CREATE_TIME > '" + params?.CREATE_TIME[0] + "'";
}
if (params?.CREATE_TIME != undefined && params?.CREATE_TIME != '') {
- sqlcmd += "And CREATE_TIME < '" + params?.CREATE_TIME[1]+"'";
+ sqlcmd += "And CREATE_TIME < '" + params?.CREATE_TIME[1] + "'";
}
const rParams = genActionPage('TSK_JOB', sqlcmd, params.page, params.pageSize);
return getTsk_JobListByPageAsync(rParams);
@@ -61,7 +59,7 @@
{ url: Api.EntityPageList, params },
{
isTransformResponse: false,
- apiUrl: globSetting.taskApiUrl
+ apiUrl: globSetting.taskApiUrl,
},
);
const model: Tsk_JobPageListGetResultModel = {
@@ -69,7 +67,7 @@
total: data.Data.totals,
};
// data.Data.data.forEach(function(item) {
-
+
// defHttp.post(
// { url: Api.AddJob, params: genActionjob(item.JobType, item.AssemblyName,item.JobName,item.Triggers[0].Args) },
// {
@@ -91,30 +89,54 @@
{
errorMessageMode: 'none',
isTransformResponse: false,
- apiUrl: globSetting.taskApiUrl
+ apiUrl: globSetting.taskApiUrl,
},
);
};
-//鍒犻櫎
-export const DeleteTsk_Job = async (params: Recordable) => {
- const usParams = genAction('TSK_JOB', [params]);
- const usParamstrig = genAction('TSK_TRIG', [params.Triggers]);
- defHttp.post({ url: Api.DeleteList, params: usParamstrig },
+
+/**
+ * @desc 娣诲姞浠诲姟
+ * @param {FluentJobParam} params - 鍙傛暟鍒楄〃
+ */
+export const AddTskJob = async (params: FluentJobParam) => {
+ const usParams = generateAction(params.DataType, params.AssemblyName, params);
+ return await defHttp.post(
+ { url: Api.AddTskJob, params: usParams },
{
errorMessageMode: 'none',
isTransformResponse: false,
- apiUrl: globSetting.taskApiUrl
- },);
+ apiUrl: globSetting.taskApiUrl,
+ },
+ );
+};
+
+/**
+ * @desc 鍒犻櫎
+ * @param {Recordable} params - 璁板綍
+ */
+export const DeleteTsk_Job = async (params: Recordable) => {
+ const usParams = genAction('TSK_JOB', [params]);
+ const usParamstrig = genAction('TSK_TRIG', [params.Triggers]);
+ defHttp.post(
+ { url: Api.DeleteList, params: usParamstrig },
+ {
+ errorMessageMode: 'none',
+ isTransformResponse: false,
+ apiUrl: globSetting.taskApiUrl,
+ },
+ );
return await defHttp.post(
{ url: Api.DeleteList, params: usParams },
{
errorMessageMode: 'none',
isTransformResponse: false,
- apiUrl: globSetting.taskApiUrl
+ apiUrl: globSetting.taskApiUrl,
},
);
};
-//寮�濮嬩换鍔�
+/**
+ * @desc 寮�濮嬩换鍔�
+ */
export const StartTsk_Job = async (params: Recordable) => {
const usParams = genAction('TSK_JOB', params.JobName);
return await defHttp.post(
@@ -122,31 +144,34 @@
{
errorMessageMode: 'none',
isTransformResponse: false,
- apiUrl: globSetting.taskApiUrl
+ apiUrl: globSetting.taskApiUrl,
},
);
};
-//鍋滄浠诲姟
+
+/**
+ * @desc 鍋滄浠诲姟
+ */
export const StopTsk_Job = async (params: Recordable) => {
const usParams = genAction('TSK_JOB', params.JobName);
return await defHttp.post(
- { url: Api.StopJob, params: usParams },
+ { url: Api.RemoveTskJob, params: usParams },
{
errorMessageMode: 'none',
isTransformResponse: false,
- apiUrl: globSetting.taskApiUrl
+ apiUrl: globSetting.taskApiUrl,
},
);
};
//涓嬫媺鍒楄〃
-export const optionsListApi = async (params: Recordable) => {
- const usParams = genAction('TSK_TRIG+Statuss', "");
+export const optionsListApi = async () => {
+ const usParams = genAction('TSK_TRIG+Statuss', '');
return await defHttp.post(
{ url: Api.urlQueryEnum, params: usParams },
{
errorMessageMode: 'none',
isTransformResponse: false,
- apiUrl: globSetting.taskApiUrl
+ apiUrl: globSetting.taskApiUrl,
},
);
};
--
Gitblit v1.9.3