[task-2654]设施与环境失控及处理记录

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

@@ -126,7 +126,8 @@ public class BinXiangJob extends AbstractJob {
         data.put("fang_jian_", "");
         data.put("jie_guo_", "是");
         data.put("qing_kuang_", "设备号为："+map.get("bing_xiang_id_")+" 的设备在一小时内温湿度连续超出限定范围，\n失控记录：\n"+beiZhu);
-        data.put("shi_fou_guo_shen_", "待分析处理");
+        data.put("shi_fou_guo_shen_", "待处理");
+        data.put("shu_ju_lei_xing_","1");
         commonDao.execute(this.buildInsertSql(data,"t_sshjskycljlb"));
     }
 
@@ -148,14 +149,15 @@ public class BinXiangJob extends AbstractJob {
             data.put("di_dian_", "");
             data.put("jie_guo_", "是");
             data.put("qing_kuang_", beiZhu + "\n 请检查采集器配置或采集数据！");
-            data.put("shi_fou_guo_shen_", "待分析处理");
+            data.put("shi_fou_guo_shen_", "待处理");
+            data.put("shu_ju_lei_xing_","1");
             commonDao.execute(this.buildInsertSql(data,"t_sshjskycljlb"));
             logger.warn("addNoCollectData");
         }
     }
 
     private void startFlowStep() {
-        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')";
+        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;