计划任务优化

Ben Lin

2024-10-28 08abfcfea8247c394b2034cad59734846b403dd9

 src/api/tigerapi/system.ts

@@ -31,9 +31,8 @@
  pParams,
} from './model/systemModel';
import { defHttp } from '/@/utils/http/axios';
import { isArray, isNullOrEmpty, isNullOrUnDef, isTimeViaRegExp8601 } from '/@/utils/is';
import { isArray, isNullOrEmpty, isTimeViaRegExp8601 } from '/@/utils/is';
import { isNumber } from 'xe-utils';
import { dateUtil, formatToDateTime } from '/@/utils/dateUtil';

export enum Api {
  QueryUrl = '/Base/Query',
@@ -66,7 +65,11 @@
  StartJob = '/Tsk/StartJob',
  StopJob = '/Tsk/PauseJob',
  AddJob = '/Tsk/AddJob',
  AddTskJob = '/Tsk/AddTskJob',
  ImmediateRun = '/Tsk/ImmediateRun',
  RemoveTskJob = '/Tsk/RemoveTskJob',
  UpdateJob = '/Tsk/UpdateJob',
  SaveTskJob = '/Tsk/SaveTskJob',
  urlQueryEnum = '/Base/QueryEnum',
  DeleteWareHouse = '/WMS/DelWareHouseModel',
  AddLocation = '/WMS/AddLoctionModel',
@@ -134,7 +137,7 @@
/*
 * 生成Action
 */
export function genAction<T>(datatype: string, data: T, option?: object) {
export function genAction<T>(datatype: string, data: T, option?: object, NeedInclude?: boolean) {
  const time = new Date();
  const params: ApiAction<T> = {
    ID: buildUUID(),
@@ -148,7 +151,23 @@
    StatusCode: 0,
    Data: data,
    LocaleMsg: undefined,
    NeedInclude: isNullOrEmpty(NeedInclude) ? false : NeedInclude,
  };
  return params;
}

/**
 * @desc 生成Action
 */
export function generateAction<T>(
  datatype: string,
  DataAssembly: string,
  data: T,
  option?: object,
  NeedInclude?: boolean,
) {
  const params = genAction(datatype, data, option, NeedInclude);
  params.DataAssembly = DataAssembly;
  return params;
}
export function genActionjob<sting>(
@@ -318,18 +337,18 @@
 */
export function findParent(tree: any[], nodeId: string): any | undefined {
  for (const node of tree) {
      if (node.children) {
          for (const child of node.children) {
              if (child.tid === nodeId) {
                  return node;
              }
              // 递归查找子树
              const potentialParent = findParent(node.children, nodeId);
              if (potentialParent) {
                  return potentialParent;
              }
          }
    if (node.children) {
      for (const child of node.children) {
        if (child.tid === nodeId) {
          return node;
        }
        // 递归查找子树
        const potentialParent = findParent(node.children, nodeId);
        if (potentialParent) {
          return potentialParent;
        }
      }
    }
  }
  return undefined; // 没有找到对应的父亲节点
}
@@ -753,6 +772,7 @@
          },
        },
    params['option'],
    params['NeedInclude'],
  );
  return getListByPageAsync(rParams, params['apiUrl']); //如果不想用默认的基础方法获取分页数据，可以换其他的api
}
@@ -790,15 +810,18 @@
      Keys[k] != 'option' &&
      Keys[k] != '0' &&
      Keys[k] != 'apiUrl' &&
      Keys[k] != 'NeedInclude' &&
      !Keys[k].toString().endsWith('PSelect_0')
    ) {
      if (!isNullOrEmpty(params[Keys[k]].length) && isTimeViaRegExp8601(params[Keys[k]][0])) {
        sqlcmd += ` And ${Keys[k]} > '${params[Keys[k]][0]}'`;
        sqlcmd += ` And ${Keys[k]} < '${params[Keys[k]][1]}'`;
      if (!isNullOrEmpty(params[Keys[k]].length) && isArray(params[Keys[k]])) {
        if (isTimeViaRegExp8601(params[Keys[k]][0])) {
          sqlcmd += ` And ${Keys[k]} > '${params[Keys[k]][0]}'`;
          sqlcmd += ` And ${Keys[k]} < '${params[Keys[k]][1]}'`;
        } else {
          sqlcmd += `And '${params[Keys[k]].join(',')}' like '%'+${Keys[k]}+'%'`;
        }
      } else if (isNumber(params[Keys[k]])) {
        sqlcmd += `And ${Keys[k]} = ${params[Keys[k]]}`;
      } else if (Keys[k] == 'sqlcmd') {
        sqlcmd += ` And ${params[Keys[k]]}`;
      } else {
        sqlcmd += `And ${Keys[k]} like '%${params[Keys[k]]}%'`;
      }
@@ -818,7 +841,7 @@
      },
    );
  } else {
    var check = await isExist(genAction(entityName, args[0]));
    const check = await isExist(genAction(entityName, args[0]));
    if (check.Data) {
      check.IsSuccessed = false;
      check.Message = '记录已经存在，不能新增！';
@@ -837,7 +860,7 @@
}

export async function AddListEntity<T>(params: T, entityName: string) {
  let data = await defHttp.post(
  const data = await defHttp.post(
    { url: Api.AddListEntity, params: genAction(entityName, params) },
    {
      errorMessageMode: 'none',
@@ -866,7 +889,7 @@
 * @return {*}
 */
export async function AddAfterDelete(entityName: string, items: [], where: string) {
  let data = await defHttp.post(
  const data = await defHttp.post(
    {
      url: Api.AddAfterDelete,
      params: genAction(entityName, {