收到预警数据改变的数据状态时未判断预警是否下发处理

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/emqx/WarningRecordStatusMessage.java

@@ -71,7 +71,7 @@ public class WarningRecordStatusMessage extends EmqxListener {
     public void jxIopUpdateFan(JSONArray analysisResult) {
         log.info("修改预警状态信息：{}", analysisResult);
         List<JSONObject> taskList = JSONObject.parseArray(analysisResult.toJSONString(), JSONObject.class);
-        taskList = taskList.stream().filter(t-> "1".equals(t.getString("processingStatus"))).collect(Collectors.toList());
+        taskList = taskList.stream().filter(t-> "2".equals(t.getString("processingStatus"))).collect(Collectors.toList());
         List<String> traceIds = taskList.stream().map(t -> t.get("extAttr1").toString()).collect(Collectors.toList());
 //        LambdaUpdateWrapper<IdxBizFanWarningRecord> lambda = new LambdaUpdateWrapper<>();
 //        lambda.set(IdxBizFanWarningRecord::getDisposotionState, "已确认");
@@ -97,7 +97,7 @@ public class WarningRecordStatusMessage extends EmqxListener {
     public void jxIopUpdatePv(JSONArray analysisResult) {
         log.info("修改预警状态信息：{}", analysisResult);
         List<JSONObject> taskList = JSONObject.parseArray(analysisResult.toJSONString(), JSONObject.class);
-        taskList = taskList.stream().filter(t-> "1".equals(t.getString("processingStatus"))).collect(Collectors.toList());
+        taskList = taskList.stream().filter(t-> "2".equals(t.getString("processingStatus"))).collect(Collectors.toList());
         List<String> traceIds = taskList.stream().map(t -> t.get("extAttr1").toString()).collect(Collectors.toList());
 //        LambdaUpdateWrapper<IdxBizPvWarningRecord> lambda = new LambdaUpdateWrapper<>();
 //        lambda.set(IdxBizPvWarningRecord::getDisposotionState, "已处置");

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/HealthStatusIndicatorServiceImpl.java

@@ -325,6 +325,7 @@ public class HealthStatusIndicatorServiceImpl {
 //        idxBizPvWarningRecordService.saveBatch(idxBizPvWarningRecordList);
 
         if (CollUtil.isNotEmpty(tdPvWarningRecordList)) {
+            log.info("==================光伏按时刻产生预警数据成功",JSON.toJSONString(tdPvWarningRecordList));
             // tdengine插入
             pvWaringRecordMapper.saveBatchWarningRecords(tdPvWarningRecordList);
         }
@@ -333,6 +334,7 @@ public class HealthStatusIndicatorServiceImpl {
 
     }
 
+
     /***
      * 每五小时获取一次最大粒度内的指数异常数据
      * 判断五小时内数据是否符合预警规则 符合则报警并在redis中缓存 同一级别的预警记录下次不生成