提交schedule测试

wangrong

2022-07-08 7e9badac4f3df3650e72bd419f9cdaa485b054d6

 src/schedule/taskSchedule.js

@@ -17,7 +17,7 @@

var periodTasklist = []

var payload = { source: "AwesomeString", syscommand: 1, subcommand: 2, generatetime: "2", targetclient:"111",returnserver:"#server#", taskuuid:"1234" };
var payload = { source: "AwesomeString", syscommand: 1, subcommand: 2, generatetime: "2", targetclient: "111", returnserver: "#server#", taskuuid: "1234" };

// Verify the payload if necessary (i.e. when possibly incomplete or invalid)
var errMsg = CommandMessage.verify(payload);
@@ -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);
    });
@@ -54,7 +66,7 @@
schedule.scheduleJob(rule, async () => {//每分钟读取周期任务 并将任务分解执行
    //http://192.168.1.4:5000/api
    // Exemplary payload
    var payload = { source: "AwesomeString", syscommand: 1, subcommand: 2, generatetime: "2", targetclient:"111",returnserver:"#server#", taskuuid:"1234" };
    var payload = { source: "AwesomeString", syscommand: 1, subcommand: 2, generatetime: "2", targetclient: "111", returnserver: "#server#", taskuuid: "1234" };

    // Verify the payload if necessary (i.e. when possibly incomplete or invalid)
    var errMsg = CommandMessage.verify(payload);
@@ -63,12 +75,12 @@

    // Create a new message
    var message = CommandMessage.create(payload); // or use .fromObject if conversion is necessary
    

    // let buffer = Buffer.from(command_req)
    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,