dbHelper.executeUpdate("update t_wfr_assignSendInfo set ISSEND = '1' where ISSEND = '0'",null);
dbHelper.executeUpdate("update t_wfr_assignSendInfo set ISSEND = '1' where ISSEND = '0'",null);
Console.log("定时器结束 toDoTaskList!");
Console.log("定时器结束 toDoTaskList!");
returnRestResponse.success("同步成功");
}
@Scheduled(fixedDelay=1000*10)
publicRestResponsetoDoTaskDetailList(){
Console.log("定时器开始 toDoTaskDetailList!");
Console.log("定时器开始 toDoTaskDetailList!");
DBHelperdbHelper=newDBHelper(dataSource);
dbHelper=newDBHelper(dataSource);
Resultresult=dbHelper.executeQuery("select ID from t_wfr_assignSendInfo where ISSEND = '1' and ISUPDATE = '0' and ID not in (select FASSIGNID from t_wfr_assign_view)",null);
result=dbHelper.executeQuery("select ID from t_wfr_assignSendInfo where ISSEND = '1' and ISUPDATE = '0' and ID not in (select FASSIGNID from t_wfr_assign_view)",null);
if(result==null)
if(result==null)
{
{
...
@@ -68,10 +63,10 @@ public class ToDoTaskJob {
...
@@ -68,10 +63,10 @@ public class ToDoTaskJob {
Console.log("result不为空df");
Console.log("result不为空df");
}
}
toDoTaskService.toDoTaskDetailList(result);
toDoTaskService.toDoTaskDetailList(result);
dbHelper.executeUpdate("delete t_wfr_assignSendInfo where ID not in (select FASSIGNID from t_wfr_assign_view)",null);
dbHelper.executeUpdate("delete t_wfr_assignSendInfo where ID not in (select FASSIGNID from t_wfr_assign_view)",null);