Pārlūkot izejas kodu

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

szjbdgzl 2 gadi atpakaļ
vecāks
revīzija
9017517294

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

@@ -109,8 +109,11 @@ public class ToDoMessagePushJob extends BaseJob2 {
                             addGqswData(task , taskId , createTime , send);
 
                             // delete processed task message
-                            String sQL = "delete from ibps_msg_inner where task_id_ <>'' and task_id_ not in(select id_ from ibps_bpm_tasks)";
-                            commonDao.execute(sQL);
+                            commonDao.execute("delete from ibps_msg_inner where task_id_ <>'' and task_id_ not in(select id_ from ibps_bpm_tasks)");
+
+                            commonDao.execute("delete from ibps_msg_read where MSG_ID_ not in(select id_ from ibps_msg_inner)");
+
+                            commonDao.execute("delete from ibps_msg_receiver where MSG_ID_ not in(select id_ from ibps_msg_inner)");
 
                         }
                     }