OperationalService/api/app/lib/schedule/workOrder.js

const schedule = require('node-schedule');
const moment = require('moment')

module.exports = function (app, opts) {
   const updateAttendance = app.fs.scheduleInit(
      {
         interval: '34 21 4 * * *',
         // interval: '34 */15 * * * *',
         immediate: true,
         proRun: true,
      },
      async()=>{
         try{
            const startTime = moment()
            const { models } = app.fs.dc
            const { clickHouse } = app.fs
            const { database: camWorkflow } = clickHouse.camWorkflow.opts.config
            //工单数据
            let workOrderNeedData = {
               projectName: {
                  keyWord: ['项目名称'],
                  require: true,
               },
               applyTime: {
                  keyWord: ['申请时间'],
                  require: true,
               },
               completionTime: {
                  keyWord: ['处理完成时间'],
                  require: true,
               },
               state:{
                  keyWord:[''],
                  require: true,
               },
               









             
            
            }
            const attendanceRes = await clickHouse.pepEmis.query(
               `
                  SELECT 
                     story.id AS historyId,
                     story.apply_user AS pepUserId,
                     story.form_data AS formData,
                     story.submit_form_data AS submitFormData,
                     fform.form_schema AS formSchema,
                     fprocess.name AS processName,
                     procin.state_ AS state,
                     fform.id AS formId,
                     fversion.id AS versionId,
                     fgroup.name AS groupName 
                  FROM 
                     workflow_process_history AS story
                  INNER JOIN workflow_process_version AS fversion
                     ON fversion.id = story.version_id
                  INNER JOIN workflow_process_form AS fform
                     ON fform.id = fversion.form_id
                  INNER JOIN workflow_process AS fprocess
                     ON fprocess.id = fform.process_id
                  INNER JOIN workflow_group AS fgroup
                     ON fgroup.id = fprocess.group_id
                     AND fgroup.name = ''
                  INNER JOIN ${camWorkflow}.act_hi_procinst AS procin
                     ON procin.id_ = story.procinst_id` 
                     +` ${existOvertimeCount || existVacateCount ?`WHERE story.create_at > '2023-03-16 00:00:00'`: ''}`
            ).toPromise()






























         }catch(error){

         }
      }
    );
   return {
      updateAttendance,
   }
}