分析服务触发预警携带跳转URL

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

@@ -50,7 +50,7 @@ import java.net.InetAddress;
 @EnableScheduling
 @MapperScan({ "org.typroject.tyboot.demo.face.orm.dao*", "org.typroject.tyboot.face.*.orm.dao*",
 		"org.typroject.tyboot.core.auth.face.orm.dao*", "org.typroject.tyboot.component.*.face.orm.dao*",
-		"com.yeejoin.amos.boot.module.**.api.mapper", "com.yeejoin.amos.boot.biz.common.dao.mapper","com.yeejoin.amos.boot.module.common.biz.*","com.yeejoin.amos.boot.module.jxiop.api.mapper","com.yeejoin.amos.boot.module.jxiop.biz.tdmapper" })
+		"com.yeejoin.amos.boot.module.**.api.mapper", "com.yeejoin.amos.boot.biz.common.dao.mapper","com.yeejoin.amos.boot.module.common.biz.*","com.yeejoin.amos.boot.module.jxiop.api.mapper","com.yeejoin.amos.boot.module.jxiop.biz.tdmapper","com.yeejoin.amos.boot.module.jxiop.biz.mapper5" })
 @ComponentScan(basePackages = { "org.typroject", "com.yeejoin.amos" })
 @SpringBootApplication(exclude = {DataSourceAutoConfiguration.class, DruidDataSourceAutoConfigure.class})
 //@SpringBootApplication

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/config/sysDb5Config.java

+package com.yeejoin.amos.boot.module.jxiop.biz.config;
+
+
+import com.alibaba.druid.pool.DruidDataSource;
+import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
+import org.apache.ibatis.session.SqlSessionFactory;
+import org.mybatis.spring.annotation.MapperScan;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
+
+import javax.sql.DataSource;
+
+/**
+ * 从数据源配置
+ * 若需要配置更多数据源 , 直接在yml中添加数据源配置再增加相应的新的数据源配置类即可
+ */
+@Configuration
+@MapperScan(basePackages = "com.yeejoin.amos.boot.module.jxiop.biz.mapper5", sqlSessionFactoryRef = "clusterSqlSessionFactory5")
+public class sysDb5Config {
+    // 精确到 cluster 目录，以便跟其他数据源隔离
+    private static final String MAPPER_LOCATION = "classpath*:mapper/mapper5/*.xml";
+
+
+    @Value("${spring.db5.datasource.url}")
+    private String dbUrl;
+
+    @Value("${spring.db5.datasource.username}")
+    private String username;
+
+    @Value("${spring.db5.datasource.password}")
+    private String password;
+
+    @Value("${spring.db5.datasource.driver-class-name}")
+    private String driverClassName;
+
+
+    @Bean(name = "clusterDataSource5")   //声明其为Bean实例
+    public DataSource clusterDataSource() {
+        DruidDataSource datasource = new DruidDataSource();
+
+        datasource.setUrl(this.dbUrl);
+        datasource.setUsername(username);
+        datasource.setPassword(password);
+        datasource.setDriverClassName(driverClassName);
+        return datasource;
+    }
+
+    @Bean(name = "clusterTransactionManager")
+    public DataSourceTransactionManager clusterTransactionManager() {
+        return new DataSourceTransactionManager(clusterDataSource());
+    }
+
+    @Bean(name = "clusterSqlSessionFactory5")
+    public SqlSessionFactory clusterSqlSessionFactory5(@Qualifier("clusterDataSource5") DataSource culsterDataSource)
+            throws Exception {
+        final MybatisSqlSessionFactoryBean sessionFactory = new MybatisSqlSessionFactoryBean();
+        sessionFactory.setDataSource(culsterDataSource);
+        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
+                .getResources(MAPPER_LOCATION));
+        sessionFactory.setTypeAliasesPackage("com.yeejoin.amos.boot.module.jxiop.biz.entity5");
+        //mybatis 数据库字段与实体类属性驼峰映射配置
+        sessionFactory.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);
+        return sessionFactory.getObject();
+    }
+}
+

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/entity5/JumpConfig.java

+package com.yeejoin.amos.boot.module.jxiop.biz.entity5;
+
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+@TableName("jump_config")
+public class JumpConfig {
+    @TableField("id")
+    private Integer id;
+    @TableField("url")
+    private String url;
+    @TableField("type")
+    private String type;
+}

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/mapper5/JumpConfigMapper.java

+package com.yeejoin.amos.boot.module.jxiop.biz.mapper5;
+
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity5.JumpConfig;
+
+public interface JumpConfigMapper extends BaseMapper<JumpConfig> {
+}

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

@@ -16,7 +16,9 @@ import com.yeejoin.amos.boot.module.jxiop.api.mapper.StationBasicMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.Enum.WarningNameEnum;
 import com.yeejoin.amos.boot.module.jxiop.biz.constants.CommonConstans;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.*;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity5.JumpConfig;
 import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.*;
+import com.yeejoin.amos.boot.module.jxiop.biz.mapper5.JumpConfigMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.tdMapper2.*;
 import com.yeejoin.amos.boot.module.jxiop.biz.tdengine.*;
 import lombok.extern.slf4j.Slf4j;
@@ -1155,7 +1157,21 @@ public class HealthStatusIndicatorServiceImpl {
         fetchDataFan(tdFanWarningRecordList, stationMap);
     }
 
+    @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();
+            }
+        }
+        return jumpUrl;
+    }
     /**
      * 光伏 - 触发预控模型生成预警
      * @param idxBizPvWarningRecords
@@ -1163,6 +1179,7 @@ public class HealthStatusIndicatorServiceImpl {
      */
     @Async
     public void fetchDataPv(List<PvWarningRecord> idxBizPvWarningRecords, HashMap<String, StationBasic> stationMap) {
+        List<JumpConfig> jumpConfigs = jumpConfigMapper.selectList(null);
         log.info("===开始触发风险预警模型===数量为：{}", idxBizPvWarningRecords.size());
         idxBizPvWarningRecords.stream().forEach(idxBizPvWarningRecord -> {
             BizMessage bizMessage = new BizMessage();
@@ -1176,6 +1193,7 @@ public class HealthStatusIndicatorServiceImpl {
             riskBizInfoVo.setSourceAttributionDesc(idxBizPvWarningRecord.getStation());
             riskBizInfoVo.setWarningObjectType("equip");
             riskBizInfoVo.setWarningTime(DateUtil.now());
+            riskBizInfoVo.setWarningObjectLinkUrl(getJumpUrlByInfo(idxBizPvWarningRecord.getEquipmentName(), jumpConfigs));
             List<RiskDynamicDetailsVo> detailsVos = new ArrayList<>();
             RiskDynamicDetailsVo dynamicDetailsVo = new RiskDynamicDetailsVo();
             dynamicDetailsVo.setTabName("预警详情");
@@ -1226,6 +1244,7 @@ public class HealthStatusIndicatorServiceImpl {
      */
     @Async
     public void fetchDataFan(List<FanWarningRecord> idxBizFanWarningRecords, HashMap<String, StationBasic> stationMap) {
+        List<JumpConfig> jumpConfigs = jumpConfigMapper.selectList(null);
         log.info("===开始触发风险预警模型===数量为：{}", idxBizFanWarningRecords.size());
         idxBizFanWarningRecords.stream().forEach(idxBizFanWarningRecord -> {
             BizMessage bizMessage = new BizMessage();
@@ -1239,6 +1258,7 @@ public class HealthStatusIndicatorServiceImpl {
             riskBizInfoVo.setSourceAttributionDesc(idxBizFanWarningRecord.getStation());
             riskBizInfoVo.setWarningObjectType("equip");
             riskBizInfoVo.setWarningTime(DateUtil.now());
+            riskBizInfoVo.setWarningObjectLinkUrl(getJumpUrlByInfo(idxBizFanWarningRecord.getEquipmentName(), jumpConfigs));
             List<RiskDynamicDetailsVo> detailsVos = new ArrayList<>();
             RiskDynamicDetailsVo dynamicDetailsVo = new RiskDynamicDetailsVo();
             dynamicDetailsVo.setTabName("预警详情");

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/application-dev.properties

@@ -12,6 +12,13 @@ spring.db2.datasource.username=root
 spring.db2.datasource.password=Yeejoin@2020
 spring.db2.datasource.driver-class-name: com.mysql.cj.jdbc.Driver
 
+## db5-sync_data
+spring.db5.datasource.type: com.alibaba.druid.pool.DruidDataSource
+spring.db5.datasource.url=jdbc:mysql://139.9.173.44:3306/jxiop_sync_data?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
+spring.db5.datasource.username=root
+spring.db5.datasource.password=Yeejoin@2020
+spring.db5.datasource.driver-class-name: com.mysql.cj.jdbc.Driver
+
 ## eureka properties:
 eureka.instance.hostname=172.16.10.220
 eureka.client.serviceUrl.defaultZone=http://admin:a1234560@${eureka.instance.hostname}:10001/eureka/

amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/java/com/yeejoin/amos/boot/module/jxiop/api/dto/RiskBizInfoVo.java

@@ -22,4 +22,5 @@ public class RiskBizInfoVo {
     private List<RiskDynamicDetailsVo> dynamicDetails;
     private String warningObjectType;
     private CustomizeItems customizeItems;
+    private String warningObjectLinkUrl;
 }