仓库汇总报表

Ben Lin

2025-03-11 8e977a7ec92bc1845079eda2473e9c3fc4691c8d

 src/api/tigerapi/tsk/tsk_job.ts

@@ -1,56 +1,54 @@
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';


const globSetting = useGlobSetting();
/*
 * 获取角色分页列表
 */
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) },
      { 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) },
  //     {
@@ -81,76 +79,82 @@
  return model;
}

export const SaveTsk_Job = async (params: Tsk_JobListItem, isUpdate: boolean) => {
  let data;
  if (isUpdate) {
    params.uPeriod = params.Period
    data = await defHttp.post(
      { url: Api.UpdateJob, params: genAction('TSK_JOB',params)},
      {
        errorMessageMode: 'none',
        isTransformResponse: false,
        apiUrl: globSetting.taskApiUrl
      },
    );
  } else {
    params.ID = buildUUID(); //生成GUID
    data = await defHttp.post(
      { url: Api.AddJob, params: genActionjob(params.JobType, params.AssemblyName,params.JobName,params.Period,params.Remark) },
      {
        errorMessageMode: 'none',
        isTransformResponse: false,
        apiUrl: globSetting.taskApiUrl
      },
    );
    // //添加任务数据到数据库
    // data.Data.JobName=params.JobName;
    // data.Data.Remark=params.Remark;
    // data.Data.JobType=params.JobType;
    // var job=await defHttp.post(
    // {
    //   url:Api.AddEntity,params:genAction('TSK_JOB',data.Data)
    // },
    // {
    //   errorMessageMode:'none',
    //   isTransformResponse:false,
    //   apiUrl: globSetting.taskApiUrl
    // });
    // data.Data.Triggers[0].Args=params.Time*60*1000
    // data.Data.Triggers[0].JobId=data.Data.ID
    // var trig = defHttp.post(
    // {
    //   url:Api.AddEntity,params:genAction('TSK_TRIG',data.Data.Triggers[0])
    // },
    // {
    //   errorMessageMode:'none',
    //   isTransformResponse:false,
    //   apiUrl: globSetting.taskApiUrl
    // });
  }
  
  return data;
};
//删除
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
    },);
/**
 * 保存任务
 */
export const SaveTskJob = async (params: TskParameter) => {
  const usParams = genAction('TSK_JOB', params);
  return await defHttp.post(
    { url: Api.DeleteList, params: usParams },
    { url: Api.SaveTskJob, params: usParams },
    {
      errorMessageMode: 'none',
      isTransformResponse: false,
      apiUrl: globSetting.taskApiUrl
      apiUrl: globSetting.taskApiUrl,
    },
  );
};
//开始任务

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

/**
 * @desc 立即运行任务
 */
export const ImmediateRun = async (params: FluentJobParam) => {
  const usParams = generateAction(params.DataType, params.AssemblyName, params.JobName);
  return await defHttp.post(
    { url: Api.ImmediateRun, params: usParams },
    {
      errorMessageMode: 'none',
      isTransformResponse: false,
      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);
  return await defHttp
    .post(
      { url: Api.DeleteList, params: usParams },
      {
        errorMessageMode: 'none',
        isTransformResponse: false,
        apiUrl: globSetting.taskApiUrl,
      },
    )
    .then(() => {
      defHttp.post(
        { url: Api.DeleteList, params: usParamstrig },
        {
          errorMessageMode: 'none',
          isTransformResponse: false,
          apiUrl: globSetting.taskApiUrl,
        },
      );
    });
};
/**
 * @desc 开始任务
 */
export const StartTsk_Job = async (params: Recordable) => {
  const usParams = genAction('TSK_JOB', params.JobName);
  return await defHttp.post(
@@ -158,31 +162,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,
    },
  );
};