计划任务更新

Ben Lin

2024-10-27 914c18aa66a7fbde2d54a05cdf583138bf7f230b

 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,
    },
  );
};