做调度任务测试时报错

zhuyz0602

做调度任务测试时一直报错是哪里的问题，sql脚本写的没问题啊

1. let AbstractTrigger = require('AbstractTrigger');
   
2.   class MyTrigger extends AbstractTrigger {
   
3.     execute(context,param){
   
4.       //获取巡检计划明细信息
   
5.       
   
6.       var sql="select t.id,t.plan_name,t.device_name,t1.inspect_date,t1.inspect_person"+
   
7.              "  from  AT1A74E9283F600005.AT1A74E9283F600005.plan_detail t1"+
   
8.              "  left join AT1A74E9283F600005.AT1A74E9283F600005.inspect_plan t on t.id=t1.inspect_plan_id";
   
9.       var res = ObjectStore.queryByYonQL(sql);
   
10. 
    
11.       throw new Error(JSON.stringify(res));
    
12.       // //查询出距离巡检日期还有3天的巡检计划
    
13.       // var arr=[];
    
14.       // for (var i=0;i<res.length;i++){
    
15.       //   //获取巡检日期
    
16.       //   var inspectDate=res[i].inspect_date;
    
17.       //   var inspectTime=Date.parse(new Date(inspectDate));
    
18.       //   //获取当前系统日期
    
19.       //   var nowtime=Date.parse(new Date());
    
20.       //   //获取日期差小于等于3天的数据
    
21.       //   if(inspectTime-nowtime>0){
    
22.       //   const days=parseInt((inspectTime-nowtime)/(1000*3600*24));
    
23.       //   if(15>=days){
    
24.       //     res[i].days=days;
    
25.       //     arr.push(res[i]);
    
26.       //   }
    
27.       //   }
    
28.       // }
    
29.      
    
30.       // throw new Error(JSON.stringify(arr));
    
31.       // //发送代办消息
    
32.       // for(var i=0;i<arr.length;i++){
    
33.       //   var planName=arr[i].plan_name;
    
34.       //   var planId=arr[i].id;
    
35.       //   var inspectPerson=arr[i].inspect_person;
    
36.       //   //获取域名
    
37.       //   var envUrl = ObjectStore.env().url;
    
38.       //   var tenantId = ObjectStore.user().tenantId;
    
39.       //   //获取userId
    
40.       //   let body = {id:inspectPerson};
    
41.       //   let url = envUrl+"/iuap-api-gateway/yonbip/hrcloud/HRCloud/getStaffDetail"
    
42.       //   let apiResponse = openLinker("POST", url, "AT1A74E9283F600005", JSON.stringify(body));
    
43.         
    
44.       //   var userId=JSON.parse(apiResponse).data.userId;
    
45.         
    
46.       //   var receiver =[];
    
47.       //   receiver.push(userId);
    
48.       //   var channels = ["uspace"];
    
49.       //   var title = "巡检计划提醒";
    
50.       //   var content = planName+"距离巡检日期只有3天了，请做好准备！";
    
51.       //   var createToDoExt = {
    
52.       //   "webUrl":envUrl+"/mdf-node/meta/Voucher/inspect_plan/"+planId+"?domainKey=developplatform";
    
53.       //   }
    
54.       //   var messageInfo = {
    
55.       //   'sysId':'diwork',
    
56.       //   'tenantId':tenantId,
    
57.       //   'receiver':receiver,
    
58.       //   'channels':channels,
    
59.       //   'subject':title,
    
60.       //   'content':content,
    
61.       //   'messageType':'createToDo',
    
62.       //   'createToDoExt':createToDoExt
    
63.       //   };
    
64.       //   var result = sendMessage(messageInfo);
    
65.         
    
66.       // }
    
67.       
    
68.     return {};
    
69.     }
    
70.   }
    
71.   exports({"entryPoint":MyTrigger});
    

复制代码

zhuyz0602

已经解决！