[task-1368] 系统超时事务消息推送功能开发

ibps-provider-root/modules/provider-platform/src/main/java/com/lc/ibps/platform/plan/job/ToDoMessagePushJob.java

@@ -27,15 +27,15 @@ public class ToDoMessagePushJob extends BaseJob2 {
     @Override
     public void executeJob(JobExecutionContext context) throws Exception {
 
+        //  待办处理后 删除过期事务表数据
+        commonDao.execute("delete from t_gqswb where shi_wu_id_ not in (select id_ from ibps_bpm_tasks)");
+
         String sql = "select t.subject_,t.id_,t.create_time_,t.proc_def_name_,t.name_,t.status_,c.executor_ from ibps_bpm_tasks t " +
-                     "left join ibps_bpm_task_assign c on t.id_=c.task_id_";
+                     "left join ibps_bpm_task_assign c on t.id_=c.task_id_ where t.id_ not in (select shi_wu_id_ from t_gqswb)";
         @SuppressWarnings("unchecked")
         List<Map<String, Object>> taskList = (List<Map<String, Object>>) commonDao.query(sql);
         if (BeanUtils.isNotEmpty(taskList)) {
             try{
-                //  待办处理后 删除过期事务表数据
-                commonDao.execute("delete from t_gqswb where shi_wu_id_ not in (select id_ from ibps_bpm_tasks)");
-
                 for (Map<String, Object> task : taskList) {
                     // 0-未超时，不提醒  1-已超时  2-即将超时
                     int send = 0;
@@ -106,10 +106,8 @@ public class ToDoMessagePushJob extends BaseJob2 {
                             //MessageQueueProductorUtil.send("inner" , receiver ,null , theme , subject ,null );
 
                             // 添加过期事务表数据
-                            Map<String,Object> map = commonDao.queryOne("select shi_wu_id_ from t_gqswb where shi_wu_id_ = '"+ taskId +"'");
-                            if (BeanUtils.isEmpty(map)) {
-                                addGqswData(task , taskId , createTime , send);
-                            }
+                            addGqswData(task , taskId , createTime , send);
+
                         }
                     }
                 }