消防储水量不少于4000m³ 预警问题

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/controller/PoolStatisticController.java

@@ -119,7 +119,7 @@ public class PoolStatisticController {
     @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
     @RequestMapping(value = "/panel/station/statistic", method = RequestMethod.GET)
     @ApiOperation(httpMethod = "GET", value = "获取水池统计信息", notes = "获取水池统计信息")
-    public ResponseModel getStationWaterPanelInfo( @RequestParam(required = false) String bizOrgCode) {
+    public ResponseModel<List<Map<String, Object>>> getStationWaterPanelInfo( @RequestParam(required = false) String bizOrgCode) {
         List<Map<String, Object>> infoList = fireFightingSystemMapper.getWaterInfoBySuper(bizOrgCode);
         List<Map<String, Object>> normalList = new ArrayList<>();
         List<Map<String, Object>> abNormalList = new ArrayList<>();
@@ -140,10 +140,14 @@ public class PoolStatisticController {
                     BigDecimal bigDecimal = new BigDecimal(String.valueOf(m.get("volume"))).multiply(new BigDecimal(String.valueOf(transResult.get("abs")))).divide(divide, 0, RoundingMode.HALF_UP);
                     m.put("volume", bigDecimal + "m³");
                     m.put("levelAbs",  transResult.get("abs") + "%");
+                    // 预警使用以下字段
+                    m.put("volumeBigDecimal", bigDecimal);
                 } else if (String.valueOf(transResult.get("abs")).equals("100") && String.valueOf(transResult.get("status")).equals("1")) {
                     BigDecimal bigDecimal = new BigDecimal(String.valueOf(m.get("volume")));
                     m.put("volume", bigDecimal + "m³");
                     m.put("levelAbs",  transResult.get("abs") + "%");
+                    // 预警使用以下字段
+                    m.put("volumeBigDecimal", bigDecimal);
                 } else {
                     m.put("levelAbs", transResult.get("abs"));
                 }

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

@@ -29,6 +29,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.controller.PoolStatisticController;
 import com.yeejoin.equipmanage.dto.TabContent;
 import com.yeejoin.equipmanage.fegin.IotFeign;
 import com.yeejoin.equipmanage.fegin.SystemctlFeign;
@@ -186,6 +187,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
 
     @Autowired
     private ManufacturerInfoMapper manufacturerInfoMapper;
+
+    @Autowired
+    private PoolStatisticController poolStatisticController;
 //    @Autowired
 //    private AmosRequestContext amosAuth;
     @Value("${equipManage.name}")
@@ -1130,6 +1134,8 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                             iotDataVO.getKey().equalsIgnoreCase(FHS_WirelessliquidDetector_WaterLevel) ||
                             iotDataVO.getKey().equalsIgnoreCase(FHS_LevelDetector_WaterLevel)) {
                         alarmFlag = doWaterPoolLevel(iotDataVO, equipmentSpecificIndex, messageBodyMap);
+                        // 处理每站消防储水量不少于4000m³ 预警问题
+                        doWaterStationWarning(equipmentSpecificIndex.getBizOrgCode(), equipmentSpecificIndex.getBizOrgName());
                     }
                     //稳压泵启停次数大于15次触发预警
                     if (iotDataVO.getKey().equalsIgnoreCase(FHS_PressurePump_Start) ||
@@ -1456,6 +1462,58 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         return alarmFlag;
     }
 
+    private void doWaterStationWarning(String bizOrgCode, String bizOrgName) {
+        List<Map<String, Object>> result = poolStatisticController.getStationWaterPanelInfo(bizOrgCode).getResult();
+        String indexValue = result.stream()
+                .map(map -> (BigDecimal) map.get("volumeBigDecimal"))
+                .reduce(BigDecimal.ZERO, BigDecimal::add).toString();
+        doWaterStationInfo(bizOrgCode, bizOrgName, indexValue);
+    }
+
+    private void doWaterStationInfo(String bizOrgCode, String bizOrgName, String indexValue) {
+        String indexKey = "WATER_CAPACITY";
+        String warningObjectCode = bizOrgCode + "@" + indexKey;
+        HashMap<String, String> extra = new HashMap<>();
+        extra.put("useSource", "center");
+        extra.put("codingSystem", "center");
+        extra.put("codingType", "station");
+        extra.put("problemReception", "station");
+        extra.put("bussId", warningObjectCode);
+        extra.put("clearUniqueCode", "station-WATER_CAPACITY");
+        TableContentVo tableContentVo = new TableContentVo("分析结果", "text", "消防水池+工业水池储水量＜4000m³", "1");
+        TableContentVo tableContentVo1 = new TableContentVo("管理要求", "text", "每站消防储水量不少于4000m³", "2");
+        TableContentVo tableContentVo2 = new TableContentVo("管理依据", "text", "换流站消防系统运行规程", "3");
+        List<TableContentVo> tableContentVos = Arrays.asList(tableContentVo, tableContentVo1, tableContentVo2);
+        // 触发预警业务
+        BizMessage bizMessage = new BizMessage();
+        bizMessage.setIndexKey(indexKey);
+        bizMessage.setIndexValue(indexValue);
+        RiskBizInfoVo riskBizInfoVo = new RiskBizInfoVo();
+        riskBizInfoVo.setWarningObjectName("消防储水量");
+        riskBizInfoVo.setWarningObjectCode(warningObjectCode);
+        riskBizInfoVo.setSourceAttribution(bizOrgCode);
+        riskBizInfoVo.setSourceAttributionDesc(bizOrgName);
+        List<RiskDynamicDetailsVo> detailsVos = new ArrayList<>();
+        RiskDynamicDetailsVo dynamicDetailsVo = new RiskDynamicDetailsVo();
+        dynamicDetailsVo.setTabName("预警详情");
+        detailsVos.add(dynamicDetailsVo);
+        riskBizInfoVo.setDynamicDetails(detailsVos);
+        CustomizeItems customizeItems = new CustomizeItems();
+        customizeItems.setWarningContent("消防水池+工业水池储水量＜4000m³");
+        riskBizInfoVo.setCustomizeItems(customizeItems);
+        riskBizInfoVo.setExtra(extra);
+        riskBizInfoVo.setType("waterCapacity");
+        riskBizInfoVo.getDynamicDetails().get(0).setTabContent(tableContentVos);
+        bizMessage.setBizInfo(riskBizInfoVo);
+        bizMessage.setTraceId(warningObjectCode);
+        try {
+            emqKeeper.getMqttClient().publish("fireIot/data/analysis",
+                    JSON.toJSONString(bizMessage).getBytes(StandardCharsets.UTF_8), 2, false);
+        } catch (MqttException e) {
+            e.printStackTrace();
+        }
+    }
+
     private void doPressurePumInfo(TopicEntityVo topicEntity, EquipmentSpecificIndex equipmentSpecificIndex) {
         // 查询iot该稳压泵的启停次数 一个小时内
         String startDate = DateUtil.format(new Date(), DatePattern.NORM_DATETIME_PATTERN);