[bug-1940]240830周巡检日志报错

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

@@ -158,7 +158,7 @@ public class BinXiangJob extends AbstractJob {
     }
 
     private void startFlowStep() {
-        String fetchSql = "SELECT id_ FROM t_sshjskycljlb WHERE shi_fou_guo_shen_ ='待分析处理'";
+        String fetchSql = "SELECT id_ FROM t_sshjskycljlb WHERE shi_fou_guo_shen_ ='待分析处理' and DATE_FORMAT(create_time_,'%Y-%m-%d %H')=DATE_FORMAT(CURRENT_TIME,'%Y-%m-%d %H')";
         List<Map<String, Object>> list =  (List<Map<String, Object>>) commonDao.query(fetchSql);
         if (BeanUtils.isEmpty(list)) {
             return;

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

@@ -91,31 +91,31 @@ public class ToDoMessagePushJob extends BaseJob2 {
                                 send = 0;
                             }
                         }
-                        if (send !=0){
-                            String theme = content.toString();
-                            subject = subject.substring(0, subject.lastIndexOf("#")).trim();
-                            if (send ==1){
-                                subject = subject +"；已超时，请及时处理！";
-                            }else {
-                                subject = subject +"；即将超时，请及时处理！";
-                            }
-                            // 发送消息
-                            Map<String, Object> vars = new HashMap<>();
-                            vars.put("taskId",taskId);
-                            MessageQueueProductorUtil.send("job_task_", "job_task_" , "inner" , receiver,null , theme, subject, null, null, vars);
-                            //MessageQueueProductorUtil.send("inner" , receiver ,null , theme , subject ,null );
+                    }
+                    if (send !=0){
+                        String theme = content.toString();
+                        subject = subject.substring(0, subject.lastIndexOf("#")).trim();
+                        if (send ==1){
+                            subject = subject +"；已超时，请及时处理！";
+                        }else {
+                            subject = subject +"；即将超时，请及时处理！";
+                        }
+                        // 发送消息
+                        Map<String, Object> vars = new HashMap<>();
+                        vars.put("taskId",taskId);
+                        MessageQueueProductorUtil.send("job_task_", "job_task_" , "inner" , receiver,null , theme, subject, null, null, vars);
+                        //MessageQueueProductorUtil.send("inner" , receiver ,null , theme , subject ,null );
 
-                            // 添加过期事务表数据
-                            addGqswData(task , taskId , createTime , send);
+                        // 添加过期事务表数据
+                        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)");
+                        // 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_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)");
+                        commonDao.execute("delete from ibps_msg_receiver where MSG_ID_ not in(select id_ from ibps_msg_inner)");
 
-                        }
                     }
                 }
             }catch (Exception e){