根据热工院提供 根据kks码判断设备类型

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

@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.jxiop.biz.service.impl;
 
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.yeejoin.amos.boot.biz.common.utils.DateUtils;
@@ -1160,17 +1161,24 @@ public class HealthStatusIndicatorServiceImpl {
     @Autowired
     private JumpConfigMapper jumpConfigMapper;
 
-    public String getJumpUrlByInfo(String objectName, List<JumpConfig> jumpConfigs) {
-        String jumpUrl = null;
-        for (JumpConfig jumpConfig : jumpConfigs) {
-            if (jumpConfig.getType().equals("默认")) {
-                jumpUrl = jumpConfig.getUrl();
-            }
-            if (objectName.contains(jumpConfig.getType())) {
-                return jumpConfig.getUrl();
-            }
+    public String getJumpUrlByInfo(String sbbm, List<JumpConfig> jumpConfigs) {
+        Map<String, String> collect = jumpConfigs.stream().collect(Collectors.toMap(JumpConfig::getType, JumpConfig::getUrl));
+        if (StrUtil.isEmpty(sbbm)) {
+            return "";
+        }
+        if (sbbm.indexOf("BAT") != -1) {
+            return collect.get("箱变");
+        } else if (sbbm.indexOf("WG") != -1) {
+            return collect.get("汇流箱");
+        } else if (sbbm.indexOf("WC") != -1) {
+            return collect.get("逆变器");
+        } else if (sbbm.length() == 12 && sbbm.indexOf("MD") != -1) {
+            return collect.get("风机");
+        } else if (sbbm.length() > 12 && sbbm.indexOf("MD") != -1) {
+            return collect.get("风机子系统");
+        } else {
+            return collect.get("默认");
         }
-        return jumpUrl;
     }
     /**
      * 光伏 - 触发预控模型生成预警
@@ -1193,7 +1201,7 @@ public class HealthStatusIndicatorServiceImpl {
             riskBizInfoVo.setSourceAttributionDesc(idxBizPvWarningRecord.getStation());
             riskBizInfoVo.setWarningObjectType("equip");
             riskBizInfoVo.setWarningTime(DateUtil.now());
-            riskBizInfoVo.setWarningObjectLinkUrl(getJumpUrlByInfo(idxBizPvWarningRecord.getEquipmentName(), jumpConfigs));
+            riskBizInfoVo.setWarningObjectLinkUrl(getJumpUrlByInfo(idxBizPvWarningRecord.getKks(), jumpConfigs));
             List<RiskDynamicDetailsVo> detailsVos = new ArrayList<>();
             RiskDynamicDetailsVo dynamicDetailsVo = new RiskDynamicDetailsVo();
             dynamicDetailsVo.setTabName("预警详情");
@@ -1258,7 +1266,7 @@ public class HealthStatusIndicatorServiceImpl {
             riskBizInfoVo.setSourceAttributionDesc(idxBizFanWarningRecord.getStation());
             riskBizInfoVo.setWarningObjectType("equip");
             riskBizInfoVo.setWarningTime(DateUtil.now());
-            riskBizInfoVo.setWarningObjectLinkUrl(getJumpUrlByInfo(idxBizFanWarningRecord.getEquipmentName(), jumpConfigs));
+            riskBizInfoVo.setWarningObjectLinkUrl(getJumpUrlByInfo(idxBizFanWarningRecord.getKks(), jumpConfigs));
             List<RiskDynamicDetailsVo> detailsVos = new ArrayList<>();
             RiskDynamicDetailsVo dynamicDetailsVo = new RiskDynamicDetailsVo();
             dynamicDetailsVo.setTabName("预警详情");