提交schedule测试

wangrong

2022-07-08 7e9badac4f3df3650e72bd419f9cdaa485b054d6

提交schedule测试

 src/app/modules/business/entity/periodicsetting.ts

@@ -9,7 +9,7 @@
  @Column({ comment: '周期任务', type: 'varchar', default: '', length: 255 })
  crontab_rule: string;

  @Column({ comment: '任务开始时间', type: 'datetime' })
  @Column({ comment: '任务开始时间', default: null, type: 'datetime' })
  start_time: Date;

  @Column({ comment: '任务结束时间', type: 'datetime' })

 src/schedule/taskSchedule.js

@@ -44,8 +44,20 @@
schedule.scheduleJob(rule_task, async () => {//每分钟读取周期任务 并将任务分解执行
    // let res = httpGet('http://127.0.0.1:8001/admin/business/periodicsetting/getdata?bid=getPeriodTaskList');
    axios.get('http://127.0.0.1:8001/admin/business/periodicsetting/getdata?bid=getPeriodTaskList').then(response => {
        periodTasklist = response.data.data;
        console.log(periodTasklist)
        response.data.data.every(taskinfo => {
            console.log(taskinfo) 
            
            let subcommd = taskinfo.task_type < 3 ? taskinfo.task_type : 4;
            periodTasklist.push({
                source: "system",
                syscommand: taskinfo.task_type,
                subcommand: subcommd,
                generatetime: "1",
                targetclient: "111",
                returnserver: "server0",
                taskuuid: taskinfo.id 
            })
        })
    }).catch(error => {
        console.log(error);
    });
@@ -68,7 +80,7 @@
    let buffer = CommandMessage.encode(message).finish();
    let msg = CommandMessage.decode(buffer);
    console.log('-------step in-------------------------')
    let urlstr = "http://192.168.1.4:5000/api";
    let urlstr = "http://192.168.0.209:5000/api";
    axios({
        method: 'post',
        url: urlstr,