【情报二期】数据域服务 - 预警数据消费逻辑调整

src/main/java/com/hhwy/qbeqsjy/kafka/service/ConsumeService.java

@@ -1052,13 +1052,6 @@ public class ConsumeService implements ApplicationListener<ContextRefreshedEvent
                                             }
                                         }
                                     }
-                                    /*else {
-                                        if(gjsjDateObj.compareTo(bkkssj) >= 0 && gjsjDateObj.compareTo(bkjssj) <= 0){
-                                            warningInfoList.add(new Object[]{rwbh, rwmc, rwlx, rwlxmc, rwdxlxmc, yjxxbh, yjryXm, gjryZjhm, yjrySjh, yjxxsm.toString(), yjzt, Constants.YJZT_WD, gjsjDateObj, zrjz, zrmjid, zrmjxm, zrmjjh, zrmjlxfs, zrdwbm, CommonUtil.getConfValueByKeyDept(zrdwbm), zrbmbm, CommonUtil.getConfValueByKeyDept(zrbmbm), sqrXm, sqrSfzh, sqrJh, sqrDwbm, sqrDwmc, yjryLb, yjryBq, gkjb, gkjbmc, resourceCode, jd, wd, currentTime, currentTime, null, null, null, Constants.QYMC_TJS, addressName, yjlx, Constants.YJLX_DRYJ, null, null});
-                                            yjxxsm.setLength(0);
-                                            break;
-                                        }
-                                    }*/
                                 }
                             }
                             yjxxsm.setLength(0);

src/main/java/com/hhwy/qbeqsjy/service/CtrlService.java

@@ -572,6 +572,7 @@ public class CtrlService {
     /**
      * 增量查询布控任务预警结果数据
      * @return
+     *
      */
     public List<Map<String, Object>> getWarningInfoByInc(){
         // 1.获取预警数据查询记录表中的起始查询时间