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

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

@@ -71,6 +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());
         List<String> traceIds = taskList.stream().map(t -> t.get("extAttr1").toString()).collect(Collectors.toList());
 //        LambdaUpdateWrapper<IdxBizFanWarningRecord> lambda = new LambdaUpdateWrapper<>();
 //        lambda.set(IdxBizFanWarningRecord::getDisposotionState, "已确认");
@@ -96,6 +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());
         List<String> traceIds = taskList.stream().map(t -> t.get("extAttr1").toString()).collect(Collectors.toList());
 //        LambdaUpdateWrapper<IdxBizPvWarningRecord> lambda = new LambdaUpdateWrapper<>();
 //        lambda.set(IdxBizPvWarningRecord::getDisposotionState, "已处置");