预警信息修改为已处置流程补充

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

@@ -104,19 +104,23 @@ public class WarningRecordStatusMessage extends EmqxListener {
         log.info("修改预警状态信息：{}", analysisResult);
         List<JSONObject> taskList = JSONObject.parseArray(analysisResult.toJSONString(), JSONObject.class);
         List<String> traceIds = taskList.stream().map(t -> t.get("extAttr1").toString()).collect(Collectors.toList());
-        LambdaUpdateWrapper<IdxBizFanWarningRecord> lambda = new LambdaUpdateWrapper<>();
-        lambda.set(IdxBizFanWarningRecord::getDisposotionState, "已处置");
-        lambda.set(IdxBizFanWarningRecord::getStatus, "1");
-        lambda.set(IdxBizFanWarningRecord::getDisposotionDate, new Date());
-        lambda.in(IdxBizFanWarningRecord::getSequenceNbr, traceIds);
-        idxBizFanWarningRecordService.update(lambda);
-
-        LambdaUpdateWrapper<FanWarningRecord> lambdaTd = new LambdaUpdateWrapper<>();
-        lambdaTd.set(FanWarningRecord::getDisposotionState, "已处置");
-        lambdaTd.set(FanWarningRecord::getStatus, "1");
-        lambdaTd.set(FanWarningRecord::getDisposotionDate, DateUtil.now());
-        lambdaTd.in(FanWarningRecord::getTs, traceIds);
-        fanWarningRecordService.update(lambdaTd);
+//        LambdaUpdateWrapper<IdxBizFanWarningRecord> lambda = new LambdaUpdateWrapper<>();
+//        lambda.set(IdxBizFanWarningRecord::getDisposotionState, "已处置");
+//        lambda.set(IdxBizFanWarningRecord::getStatus, "1");
+//        lambda.set(IdxBizFanWarningRecord::getDisposotionDate, new Date());
+//        lambda.in(IdxBizFanWarningRecord::getSequenceNbr, traceIds);
+//        idxBizFanWarningRecordService.update(lambda);
+
+        List<FanWarningRecord> list = new ArrayList<>();
+        for (String traceId : traceIds) {
+            FanWarningRecord fanWarningRecord = new FanWarningRecord();
+            fanWarningRecord.setTs(Long.valueOf(traceId));
+            fanWarningRecord.setDisposotionDate(DateUtil.now());
+            fanWarningRecord.setStatus("1");
+            fanWarningRecord.setDisposotionState("已处置");
+            list.add(fanWarningRecord);
+        }
+        fanWaringRecordMapper.updateStatusByTs(list);
 
     }
 
@@ -124,20 +128,22 @@ public class WarningRecordStatusMessage extends EmqxListener {
         log.info("修改预警状态信息：{}", analysisResult);
         List<JSONObject> taskList = JSONObject.parseArray(analysisResult.toJSONString(), JSONObject.class);
         List<String> traceIds = taskList.stream().map(t -> t.get("extAttr1").toString()).collect(Collectors.toList());
-        LambdaUpdateWrapper<IdxBizPvWarningRecord> lambda = new LambdaUpdateWrapper<>();
-        lambda.set(IdxBizPvWarningRecord::getDisposotionState, "已处置");
-        lambda.set(IdxBizPvWarningRecord::getStatus, "1");
-        lambda.set(IdxBizPvWarningRecord::getDisposotionDate, new Date());
-        lambda.in(IdxBizPvWarningRecord::getSequenceNbr, traceIds);
-        idxBizPvWarningRecordService.update(lambda);
-
+//        LambdaUpdateWrapper<IdxBizPvWarningRecord> lambda = new LambdaUpdateWrapper<>();
+//        lambda.set(IdxBizPvWarningRecord::getDisposotionState, "已处置");
+//        lambda.set(IdxBizPvWarningRecord::getStatus, "1");
+//        lambda.set(IdxBizPvWarningRecord::getDisposotionDate, new Date());
+//        lambda.in(IdxBizPvWarningRecord::getSequenceNbr, traceIds);
+//        idxBizPvWarningRecordService.update(lambda);
         // td
-
-        LambdaUpdateWrapper<PvWarningRecord> lambdaTd = new LambdaUpdateWrapper<>();
-        lambdaTd.set(PvWarningRecord::getDisposotionState, "已处置");
-        lambdaTd.set(PvWarningRecord::getStatus, "1");
-        lambdaTd.set(PvWarningRecord::getDisposotionDate, DateUtil.now());
-        lambdaTd.in(PvWarningRecord::getTs, traceIds);
-        pvWarningRecordService.update(lambdaTd);
+        List<PvWarningRecord> list = new ArrayList<>();
+        for (String traceId : traceIds) {
+            PvWarningRecord pvWarningRecord = new PvWarningRecord();
+            pvWarningRecord.setTs(Long.valueOf(traceId));
+            pvWarningRecord.setDisposotionDate(DateUtil.now());
+            pvWarningRecord.setStatus("1");
+            pvWarningRecord.setDisposotionState("已处置");
+            list.add(pvWarningRecord);
+        }
+        pvWaringRecordMapper.updateStatusByTs(list);
     }
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/tdMapper2/FanWaringRecordMapper.java

@@ -32,4 +32,6 @@ public interface FanWaringRecordMapper  extends BaseMapper<FanWarningRecord> {
 
  FanWarningRecord getInfoByTs(@Param("ts") Long ts);
 
+ int updateStatusByTs(@Param("list") List<FanWarningRecord> list);
+
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/tdMapper2/PvWaringRecordMapper.java

@@ -27,4 +27,6 @@ public interface PvWaringRecordMapper extends BaseMapper<PvWarningRecord> {
     Integer getInfoByPageTotal(@Param("dto") FanHealthIndexDto dto);
 
     PvWarningRecord getInfoByTs(@Param("ts") Long ts);
+
+    int updateStatusByTs(@Param("list") List<PvWarningRecord> list);
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/mapper/tdengine2/FanWarningRecord.xml

@@ -215,4 +215,22 @@
 <select id="getInfoByTs" resultType="com.yeejoin.amos.boot.module.jxiop.biz.tdengine.FanWarningRecord">
     select * from analysis_data.fan_warning_record where ts = #{ts,jdbcType=TIMESTAMP} limit 1
     </select>
+
+<insert id="updateStatusByTs">
+    insert
+    into
+    fan_warning_record
+        (ts,
+         disposotion_state,
+         disposotion_date,
+        status)
+    values
+    <foreach collection="list" separator="," item="item" index="index">
+        (#{item.ts, jdbcType=TIMESTAMP},
+        #{item.disposotionState, jdbcType=VARCHAR},
+        #{item.disposotionDate, jdbcType=VARCHAR},
+        #{item.status, jdbcType=VARCHAR})
+    </foreach>
+
+</insert>
 </mapper>

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/mapper/tdengine2/PvWarningRecord.xml

@@ -231,4 +231,21 @@
 <select id="getInfoByTs" resultType="com.yeejoin.amos.boot.module.jxiop.biz.tdengine.PvWarningRecord">
     select * from analysis_data.pv_warning_record where ts = #{ts,jdbcType=TIMESTAMP} limit 1
     </select>
+
+<insert id="updateStatusByTs">
+    insert
+    into
+    pv_warning_record
+    (ts,
+    disposotion_state,
+    disposotion_date,
+    status)
+    values
+    <foreach collection="list" separator="," item="item" index="index">
+        (#{item.ts, jdbcType=TIMESTAMP},
+        #{item.disposotionState, jdbcType=VARCHAR},
+        #{item.disposotionDate, jdbcType=VARCHAR},
+        #{item.status, jdbcType=VARCHAR})
+    </foreach>
+    </insert>
 </mapper>