|
|
@@ -30,6 +30,13 @@ public class ToDoMessagePushJob extends BaseJob2 {
|
|
|
// 待办处理后 删除过期事务表数据
|
|
|
commonDao.execute("delete from t_gqswb where shi_wu_id_ not in (select id_ from ibps_bpm_tasks)");
|
|
|
|
|
|
+ // delete processed task message
|
|
|
+ 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)");
|
|
|
+
|
|
|
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_ where t.id_ not in (select shi_wu_id_ from t_gqswb)";
|
|
|
@SuppressWarnings("unchecked")
|
|
|
@@ -109,13 +116,6 @@ public class ToDoMessagePushJob extends BaseJob2 {
|
|
|
// 添加过期事务表数据
|
|
|
addGqswData(task , taskId , createTime , send);
|
|
|
|
|
|
- // delete processed task message
|
|
|
- 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)");
|
|
|
-
|
|
|
}
|
|
|
}
|
|
|
}catch (Exception e){
|