水池液位等添加预警详情信息

amos-boot-module/amos-boot-module-api/amos-boot-module-equip-api/src/main/java/com/yeejoin/equipmanage/common/vo/TableContentVo.java

@@ -20,4 +20,14 @@ public class TableContentVo {
     private Object value;
 
     private String type;
+
+    public TableContentVo() {
+
+    }
+    public TableContentVo(String label, String type, Object value, String key) {
+        this.label = label;
+        this.type = type;
+        this.value = value;
+        this.key = key;
+    }
 }

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/MqttReceiveServiceImpl.java

 package com.yeejoin.equipmanage.service.impl;
 
+import cn.hutool.core.date.DateUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
@@ -27,6 +28,7 @@ import com.yeejoin.equipmanage.common.utils.UUIDUtils;
 import com.yeejoin.equipmanage.common.vo.*;
 import com.yeejoin.equipmanage.common.vo.BizMessage;
 import com.yeejoin.equipmanage.common.vo.CustomizeItems;
+import com.yeejoin.equipmanage.dto.TabContent;
 import com.yeejoin.equipmanage.fegin.IotFeign;
 import com.yeejoin.equipmanage.fegin.SystemctlFeign;
 import com.yeejoin.equipmanage.mapper.*;
@@ -1377,6 +1379,12 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         extra.put("problemReception", "station");
         extra.put("bussId", String.valueOf(equipmentSpecificIndex.getEquipmentSpecificId()));
         extra.put("clearUniqueCode", "equip-level");
+
+        TableContentVo tableContentVo = new TableContentVo("报警类型", "text", "液位超出阈值", "1");
+        TableContentVo tableContentVo1 = new TableContentVo("报警部位", "text", equipmentSpecificIndex.getLocation(), "2");
+        TableContentVo tableContentVo2 = new TableContentVo("报警时间", "text", DateUtil.now(), "3");
+        TableContentVo tableContentVo3 = new TableContentVo("报警对象", "text", equipmentSpecificIndex.getEquipmentSpecificName(), "4");
+        List<TableContentVo> tableContentVos = Arrays.asList(tableContentVo, tableContentVo1, tableContentVo2, tableContentVo3);
         handleWarning(minValue,
                 maxValue,
                 nowValue,
@@ -1385,7 +1393,8 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                 "fireIot/data/analysis",
                 indexKey,
                 extra,
-                "cafsWaterLevelOver");
+                "cafsWaterLevelOver",
+                tableContentVos);
 
         if (nowValue.compareTo(minValue) < 0 || nowValue.compareTo(maxValue) > 0) {
             String body = "";
@@ -1470,6 +1479,12 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                 extra.put("problemReception", "station");
                 extra.put("bussId", map.get("id").toString());
                 extra.put("clearUniqueCode", "water-resource");
+                TableContentVo tableContentVo = new TableContentVo("报警类型", "text", "液位超出阈值", "1");
+                TableContentVo tableContentVo1 = new TableContentVo("报警部位", "text", equipmentSpecificIndex.getLocation(), "2");
+                TableContentVo tableContentVo2 = new TableContentVo("报警时间", "text", DateUtil.now(), "3");
+                TableContentVo tableContentVo3 = new TableContentVo("报警对象", "text", map.getOrDefault("name", "").toString(), "4");
+                List<TableContentVo> tableContentVos = Arrays.asList(tableContentVo, tableContentVo1, tableContentVo2, tableContentVo3);
+
                 //预警业务  消防水池和消防水箱
                 handleWarning(minValue,
                         maxValue,
@@ -1479,7 +1494,8 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                         "fireIot/data/analysis",
                         "WATER_POOL_LEVEL",
                         extra,
-                        "waterLevelOver");
+                        "waterLevelOver",
+                        tableContentVos);
             }
 
             if (nowValue.compareTo(minValue) < 0 || nowValue.compareTo(maxValue) > 0) {
@@ -1528,7 +1544,8 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                                String topic,
                                String indexKey,
                                Object extra,
-                               String source) {
+                               String source,
+                               List<TableContentVo> tableContentVos) {
         if (minValue.compareTo(new BigDecimal(0)) > 0
                 && maxValue.compareTo(new BigDecimal(0)) > 0) {
             BigDecimal divide = new BigDecimal(0);
@@ -1542,6 +1559,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
             bizMessage.setIndexKey(indexKey);
             bizMessage.setIndexValue(String.valueOf(divide));
             RiskBizInfoVo riskBizInfoVo = fetchData(equipmentSpecificIndex, extra, source);
+            riskBizInfoVo.getDynamicDetails().get(0).setTabContent(tableContentVos);
             bizMessage.setBizInfo(riskBizInfoVo);
             bizMessage.setTraceId(businessId);
             try {