amos-boot-module-jxiop-monitor-bize 支持多数据源

amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/java/com/yeejoin/amos/boot/module/jxiop/api/entity/StationBasic.java

@@ -134,7 +134,7 @@ public class StationBasic extends BaseEntity {
     @TableField("platform_station_id")
     private String platformStationId;
 
-    @TableField("jumpPath")
+    @TableField("jump_path")
     private String jumpPath;
 
     @TableField(exist =false)

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/pom.xml

@@ -15,11 +15,6 @@
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
   </properties>
   <dependencies>
-   <dependency>
-            <groupId>com.amosframework.boot</groupId>
-            <artifactId>amos-boot-module-ugp-api</artifactId>
-            <version>${amos-biz-boot.version}</version>
-        </dependency>
         <dependency>
             <groupId>com.amosframework.boot</groupId>
             <artifactId>amos-boot-module-common-biz</artifactId>

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/AmosJxiopMonitorApplication.java

 package com.yeejoin.amos;
 
+import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure;
 import com.yeejoin.amos.boot.biz.common.utils.oConvertUtils;
 
 import org.mybatis.spring.annotation.MapperScan;
@@ -8,6 +9,8 @@ import org.slf4j.LoggerFactory;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
+import org.springframework.boot.context.properties.ConfigurationPropertiesScan;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.boot.web.servlet.ServletComponentScan;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@@ -32,7 +35,6 @@ import java.net.InetAddress;
  *
  * @author DELL
  */
-@SpringBootApplication
 @EnableTransactionManagement
 @EnableConfigurationProperties
 @ServletComponentScan
@@ -45,6 +47,8 @@ import java.net.InetAddress;
 		"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.*" })
 @ComponentScan(basePackages = { "org.typroject", "com.yeejoin.amos" })
+@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class, DruidDataSourceAutoConfigure.class})
+//@SpringBootApplication
 public class AmosJxiopMonitorApplication {
 
 	private static final Logger logger = LoggerFactory.getLogger(AmosJxiopMonitorApplication.class);

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/config/ClusterDbConfig.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.SqlSessionFactoryBean;
+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;
+import java.sql.SQLException;
+
+/**
+ * 从数据源配置
+ * 若需要配置更多数据源 , 直接在yml中添加数据源配置再增加相应的新的数据源配置类即可
+ */
+@Configuration
+@MapperScan(basePackages = "com.yeejoin.amos.boot.module.jxiop.biz.mapper2", sqlSessionFactoryRef = "clusterSqlSessionFactory")
+public class ClusterDbConfig {
+    private Logger logger = LoggerFactory.getLogger(ClusterDbConfig.class);
+    // 精确到 cluster 目录，以便跟其他数据源隔离
+    private static final String MAPPER_LOCATION = "classpath*:mapper/cluster/*.xml";
+
+
+    @Value("${spring.db2.datasource.url}")
+    private String dbUrl;
+
+    @Value("${spring.db2.datasource.username}")
+    private String username;
+
+    @Value("${spring.db2.datasource.password}")
+    private String password;
+
+    @Value("${spring.db2.datasource.driver-class-name}")
+    private String driverClassName;
+
+
+    @Bean(name = "clusterDataSource")   //声明其为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 = "clusterSqlSessionFactory")
+    public SqlSessionFactory clusterSqlSessionFactory(@Qualifier("clusterDataSource") DataSource culsterDataSource)
+            throws Exception {
+        final MybatisSqlSessionFactoryBean sessionFactory = new MybatisSqlSessionFactoryBean();
+        sessionFactory.setDataSource(culsterDataSource);
+        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
+                .getResources(ClusterDbConfig.MAPPER_LOCATION));
+        sessionFactory.setTypeAliasesPackage("com.yeejoin.amos.boot.module.jxiop.biz.entity");
+        //mybatis 数据库字段与实体类属性驼峰映射配置
+        sessionFactory.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);
+        return sessionFactory.getObject();
+    }
+}
+

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/config/DataSource2Config.java

+//package com.yeejoin.amos.boot.module.jxiop.biz.config;
+//import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
+//import org.apache.ibatis.session.SqlSessionFactory;
+//import org.apache.ibatis.type.JdbcType;
+//import org.mybatis.spring.SqlSessionFactoryBean;
+//import org.mybatis.spring.boot.autoconfigure.MybatisProperties;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.beans.factory.annotation.Qualifier;
+//import org.springframework.boot.context.properties.ConfigurationProperties;
+//import org.springframework.boot.context.properties.EnableConfigurationProperties;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.context.annotation.Primary;
+//import org.springframework.core.io.Resource;
+//import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
+//import org.springframework.jdbc.core.JdbcTemplate;
+//import org.springframework.jdbc.datasource.DataSourceTransactionManager;
+//
+//import javax.sql.DataSource;
+//import java.io.IOException;
+//import java.util.Optional;
+//import java.util.stream.Stream;
+//
+//@Configuration
+//@EnableConfigurationProperties(MybatisProperties.class)
+//public class DataSource2Config {
+//    @Bean(name = "db2DataSource")
+//    @ConfigurationProperties(prefix = "spring.db2.datasource")
+//    public DataSource db3DataSource() {
+//        return DruidDataSourceBuilder.create().build();
+//    }
+//
+//    @Bean(name = "db2SqlSessionFactory")
+//    public SqlSessionFactory db2SqlSessionFactory(@Qualifier("db2DataSource") DataSource datasource)
+//            throws Exception {
+//        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
+//        bean.setDataSource(datasource);
+//        bean.setMapperLocations(
+//                new PathMatchingResourcePatternResolver().getResources("classpath*:oraclemappers/*.xml"));
+//        return bean.getObject();
+//    }
+//
+//    @Bean(name="db2transactionManager")
+//    public DataSourceTransactionManager transactionManagerOne(){
+//        return  new DataSourceTransactionManager(db3DataSource());
+//    }
+//
+//    @Bean(name = "db2JdbcTemplate")
+//    public JdbcTemplate jdbcTemplate(
+//            @Qualifier("db2DataSource") DataSource dataSource) {
+//        return new JdbcTemplate(dataSource);
+//    }
+//}

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/config/MasterDbConfig.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.SqlSessionFactoryBean;
+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.context.annotation.Primary;
+import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
+
+import javax.sql.DataSource;
+import java.sql.SQLException;
+
+
+@Configuration
+@MapperScan(basePackages  = "com.yeejoin.amos.boot.module.jxiop.api.mapper", sqlSessionFactoryRef = "masterSqlSessionFactory1")
+public class MasterDbConfig {
+    private Logger logger = LoggerFactory.getLogger(MasterDbConfig.class);
+    // 精确到 master 目录，以便跟其他数据源隔离
+
+    private static final String MAPPER_LOCATION = "classpath*:mapper/*.xml";
+
+    @Value("${spring.db1.datasource.url}")
+    private String dbUrl;
+
+    @Value("${spring.db1.datasource.username}")
+    private String username;
+
+    @Value("${spring.db1.datasource.password}")
+    private String password;
+
+    @Value("${spring.db1.datasource.driver-class-name}")
+    private String driverClassName;
+
+
+    @Bean(name="masterDataSource")   //声明其为Bean实例
+    @Primary  //在同样的DataSource中，首先使用被标注的DataSource
+    public DataSource masterDataSource() {
+        DruidDataSource datasource = new DruidDataSource();
+        datasource.setUrl(this.dbUrl);
+        datasource.setUsername(username);
+        datasource.setPassword(password);
+        datasource.setDriverClassName(driverClassName);
+        return datasource;
+    }
+
+    @Bean(name = "masterTransactionManager")
+    @Primary
+    public DataSourceTransactionManager masterTransactionManager() {
+        return new DataSourceTransactionManager(masterDataSource());
+    }
+
+    @Bean(name = "masterSqlSessionFactory1")
+    @Primary
+    public SqlSessionFactory masterSqlSessionFactory(@Qualifier("masterDataSource") DataSource masterDataSource)
+            throws Exception {
+        final MybatisSqlSessionFactoryBean sessionFactory = new MybatisSqlSessionFactoryBean();
+        sessionFactory.setDataSource(masterDataSource);
+        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
+                .getResources(MasterDbConfig.MAPPER_LOCATION));
+        sessionFactory.setTypeAliasesPackage("com.yeejoin.amos.boot.module.jxiop.api.entity");
+        //mybatis 数据库字段与实体类属性驼峰映射配置
+        sessionFactory.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);
+        return sessionFactory.getObject();
+    }
+}

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/config/PrimaryDataSourceConfig.java

+//package com.yeejoin.amos.boot.module.jxiop.biz.config;
+//import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
+//import org.apache.ibatis.session.SqlSessionFactory;
+//import org.apache.ibatis.type.JdbcType;
+//import org.mybatis.spring.SqlSessionFactoryBean;
+//import org.mybatis.spring.annotation.MapperScan;
+//import org.mybatis.spring.boot.autoconfigure.MybatisProperties;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.beans.factory.annotation.Qualifier;
+//import org.springframework.boot.context.properties.ConfigurationProperties;
+//import org.springframework.boot.context.properties.EnableConfigurationProperties;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.context.annotation.Primary;
+//import org.springframework.core.io.Resource;
+//import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
+//import org.springframework.jdbc.datasource.DataSourceTransactionManager;
+//
+//import javax.sql.DataSource;
+//import java.io.IOException;
+//import java.util.Optional;
+//import java.util.stream.Stream;
+//@Configuration
+//@MapperScan(value = { "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.*" },sqlSessionFactoryRef = "sql1SessionFactory")
+//public class PrimaryDataSourceConfig {
+//
+//    @Bean(name = "db1DataSource")
+//   // @ConfigurationProperties(prefix = "spring.db1.datasource")
+//    @Primary
+//    public DataSource db1DataSource() {
+//        return DruidDataSourceBuilder.create().build();
+//    }
+//
+//    @Bean(name = "sql1SessionFactory")
+//    @ConfigurationProperties(prefix = "mybatis")
+//    @Primary
+//    public SqlSessionFactory sql1SessionFactory(@Qualifier("db1DataSource") DataSource dataSource) throws Exception {
+//        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
+//        bean.setDataSource(dataSource);
+//        bean.setMapperLocations(
+//                new PathMatchingResourcePatternResolver().getResources("classpath*:mappers/*.xml"));
+//        return bean.getObject();
+//    }
+//
+//    private Resource[] resolveMapperLocations(String[] mapperLocations) {
+//        PathMatchingResourcePatternResolver pathMatchingResourcePatternResolver = new PathMatchingResourcePatternResolver();
+//
+//        return Stream.of(Optional.ofNullable(mapperLocations).orElse(new String[0]))
+//                .flatMap(location -> Stream.of(getResources(pathMatchingResourcePatternResolver, location))).toArray(Resource[]::new);
+//    }
+//
+//    private Resource[] getResources(PathMatchingResourcePatternResolver pathMatchingResourcePatternResolver, String location) {
+//        try {
+//            return pathMatchingResourcePatternResolver.getResources(location);
+//        } catch (IOException e) {
+//            return new Resource[0];
+//        }
+//    }
+//
+//    @Bean(name = "db1TransactionManager")
+//    @Primary
+//    public DataSourceTransactionManager testTransactionManager(@Qualifier("db1DataSource") DataSource dataSource) {
+//        return new DataSourceTransactionManager(dataSource);
+//    }
+//}

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/DemoController.java

@@ -3,42 +3,47 @@ package com.yeejoin.amos.boot.module.jxiop.biz.controller;
 
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
 import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
-import com.yeejoin.amos.boot.module.common.api.dto.ExcelDto;
-import com.yeejoin.amos.boot.module.jxiop.api.Enum.ExcelEnums;
-import com.yeejoin.amos.component.feign.config.InnerInvokException;
+import com.yeejoin.amos.boot.module.jxiop.api.entity.StationBasic;
+import com.yeejoin.amos.boot.module.jxiop.api.mapper.StationBasicMapper;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity.Test;
+import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.StationBasicServiceImpl;
+import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.TestServiceImpl;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpStatus;
 import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
 import org.typroject.tyboot.core.foundation.enumeration.UserType;
 import org.typroject.tyboot.core.restful.doc.TycloudOperation;
-import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
-import org.typroject.tyboot.core.restful.utils.ResponseHelper;
-import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
-import javax.servlet.http.HttpServletResponse;
-import java.util.Map;
+import java.util.List;
 
 @RestController
 @Api(tags = "Demo-test")
 @RequestMapping(value = "/demo")
 public class DemoController extends BaseController {
 
-
+    @Autowired
+    StationBasicServiceImpl stationBasicServiceimpl;
+    @Autowired
+    TestServiceImpl testServiceimpl;
     @Autowired
     RedisUtils redisUtils;
 
+    @Autowired
+    StationBasicMapper stationBasicMapper;
 
 
     @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
-    @ApiOperation(value = "下载模板")
+    @ApiOperation(value = "demo测试")
     @GetMapping("/test")
-    public String demoTest() {
-     return  "amos-jxiop-monitor-demo";
+    public StationBasic demoTest() {
+        return stationBasicServiceimpl.getById(1660231556607774721L);
+    }
+    @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
+    @ApiOperation(value = "demo测试1")
+    @GetMapping("/test1")
+    public List<Test> demoTest1() {
+        return testServiceimpl.getList();
     }
-
-
 
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/entity/Test.java

+package com.yeejoin.amos.boot.module.jxiop.biz.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.util.Date;
+
+/**
+ * 
+ *
+ * @author system_generator
+ * @date 2023-06-08
+ */
+@Data
+@Accessors(chain = true)
+@TableName("test")
+public class Test {
+
+    private static final long serialVersionUID = 1L;
+
+
+    /**
+     * 
+     */
+	@TableField("name")
+    private String Test;
+
+}

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/mapper2/TestMapper.java

+package com.yeejoin.amos.boot.module.jxiop.biz.mapper2;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yeejoin.amos.boot.module.jxiop.api.entity.Region;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity.Test;
+
+/**
+ *  Mapper 接口
+ *
+ * @author system_generator
+ * @date 2023-06-08
+ */
+public interface TestMapper extends BaseMapper<Test> {
+
+}

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/ItestService.java

+package com.yeejoin.amos.boot.module.jxiop.biz.service;
+
+import org.springframework.stereotype.Service;
+
+public interface ItestService {
+}

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

+package com.yeejoin.amos.boot.module.jxiop.biz.service.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.module.jxiop.api.dto.StationBasicDto;
+import com.yeejoin.amos.boot.module.jxiop.api.dto.StationInfoDto;
+import com.yeejoin.amos.boot.module.jxiop.api.dto.StationRecordInfo;
+import com.yeejoin.amos.boot.module.jxiop.api.entity.*;
+import com.yeejoin.amos.boot.module.jxiop.api.mapper.StationBasicMapper;
+import com.yeejoin.amos.boot.module.jxiop.api.service.IStationBasicService;
+import com.yeejoin.amos.component.feign.model.FeignClientResult;
+import com.yeejoin.amos.feign.privilege.Privilege;
+import com.yeejoin.amos.feign.privilege.model.CompanyModel;
+import com.yeejoin.amos.feign.systemctl.Systemctl;
+import com.yeejoin.amos.feign.systemctl.model.DictionarieValueModel;
+import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.CollectionUtils;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+
+import java.util.ArrayList;
+import java.util.LinkedList;
+import java.util.List;
+
+/**
+ * 场站基础信息表服务实现类
+ *
+ * @author system_generator
+ * @date 2023-04-20
+ */
+@Service
+public class StationBasicServiceImpl extends BaseService<StationBasicDto, StationBasic, StationBasicMapper> implements IStationBasicService {
+
+
+
+    @Autowired
+    StationBasicMapper stationBasicMapper;
+
+    private final String CZLX = "CZLX";
+
+    /**
+     * 分页查询
+     */
+    public Page<StationBasicDto> queryForStationBasicPage(Page<StationBasicDto> page) {
+        return this.queryForPage(page, null, false);
+    }
+
+
+    /**
+     * 分页查询
+     */
+    public Page<StationBasicDto> queryPage(Page<StationBasicDto> page,
+                                           String stationMasterName,
+                                           String stationName,
+                                           String stationType,
+                                           String orgCode
+    ) {
+        List<StationBasicDto> list = stationBasicMapper.queryPage((page.getCurrent() - 1) * page.getSize(), page.getSize(), stationMasterName,
+                stationName,
+                stationType, orgCode);
+        List<StationBasicDto> listcount = stationBasicMapper.queryPagecount(stationMasterName,
+                stationName,
+                stationType,
+                orgCode);
+        page.setTotal(listcount.size());
+        page.setRecords(list);
+        return page;
+    }
+
+
+    /**
+     * 列表查询 示例
+     */
+    public List<StationBasicDto> queryForStationBasicList() {
+        return this.queryForList("", false);
+    }
+
+
+
+
+    private CompanyModel addCompanyModel(CompanyModel companyModel) {
+        FeignClientResult<CompanyModel> Model = Privilege.companyClient.create(companyModel);
+        CompanyModel user = new CompanyModel();
+
+        if (!ObjectUtils.isEmpty(Model)) {
+            if (Model.getStatus() == 200) {
+                user = Model.getResult();
+            } else {
+                throw new RuntimeException(Model.getMessage());
+            }
+        }
+        return user;
+    }
+
+    private void deleteCompany(String ids) {
+        FeignClientResult Model = Privilege.companyClient.deleteCompany(ids);
+
+        CompanyModel user = new CompanyModel();
+
+        if (!ObjectUtils.isEmpty(Model)) {
+            if (Model.getStatus() != 200) {
+                throw new RuntimeException(Model.getMessage());
+            }
+        }
+
+    }
+
+
+    private String queryByCode(String dictCode, String dictDataKey) {
+        FeignClientResult<DictionarieValueModel> Model = Systemctl.dictionarieClient.value(dictCode, dictDataKey);
+        DictionarieValueModel user = new DictionarieValueModel();
+
+        if (!ObjectUtils.isEmpty(Model)) {
+            if (Model.getStatus() == 200) {
+                user = Model.getResult();
+            } else {
+                throw new RuntimeException(Model.getMessage());
+            }
+        }
+        return user.getDictDataValue();
+    }
+
+
+    private CompanyModel updateCompanyModel(CompanyModel companyModel, Long sequenceNbr) {
+        FeignClientResult<CompanyModel> Model = Privilege.companyClient.update(companyModel, sequenceNbr);
+        CompanyModel user = new CompanyModel();
+
+        if (!ObjectUtils.isEmpty(Model)) {
+            if (Model.getStatus() == 200) {
+                user = Model.getResult();
+            } else {
+                throw new RuntimeException(Model.getMessage());
+            }
+        }
+        return user;
+    }
+
+
+
+
+
+    public int deleteList(String ids) {
+        QueryWrapper<StationBasic> wrapper = new QueryWrapper();
+        wrapper.in("sequence_nbr", ids);
+        List<StationBasic> list = this.list(wrapper);
+        List<String> idscom = new ArrayList<>();
+        for (StationBasic personAccount : list) {
+            idscom.add(personAccount.getPlatformStationId());
+        }
+        //删除平台
+        int deleteResult = stationBasicMapper.deleteList(ids);
+        this.deleteCompany(String.join(",", idscom));
+        return deleteResult;
+    }
+
+
+
+
+    public int getStationPersonByStationID(String id) {
+        return stationBasicMapper.getStationPersonByStationID(id);
+    }
+
+
+}
\ No newline at end of file

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

+package com.yeejoin.amos.boot.module.jxiop.biz.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.netflix.loadbalancer.RetryRule;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity.Test;
+import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.TestMapper;
+import com.yeejoin.amos.boot.module.jxiop.biz.service.ItestService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class TestServiceImpl implements ItestService {
+    @Autowired
+    TestMapper testMapper;
+
+   public List<Test> getList(){
+        return  testMapper.selectList(new QueryWrapper<Test>().isNotNull("name"));
+    }
+}

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

 ## DB properties:
-spring.datasource.url=jdbc:mysql://172.16.10.220:3306/production?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
-spring.datasource.username=root
-spring.datasource.password=Yeejoin@2020
+## db1-production database
+spring.db1.datasource.type: com.alibaba.druid.pool.DruidDataSource
+spring.db1.datasource.url=jdbc:mysql://139.9.173.44:3306/production?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
+spring.db1.datasource.username=root
+spring.db1.datasource.password=Yeejoin@2020
+spring.db1.datasource.driver-class-name: com.mysql.cj.jdbc.Driver
+## db2-sync_data
+spring.db2.datasource.type: com.alibaba.druid.pool.DruidDataSource
+spring.db2.datasource.url=jdbc:mysql://139.9.173.44:3306/jxiop_sync_data?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
+spring.db2.datasource.username=root
+spring.db2.datasource.password=Yeejoin@2020
+spring.db2.datasource.driver-class-name: com.mysql.cj.jdbc.Driver
+#spring.datasource.type: com.alibaba.druid.pool.DruidDataSource
+#spring.datasource.url=jdbc:mysql://139.9.173.44:3306/jxiop_sync_data?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
+#spring.datasourceusername=root
+#spring.datasource.password=Yeejoin@2020
+#spring.datasource.driver-class-name: com.mysql.cj.jdbc.Driver
+#
+#
+#
+#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
+#spring.datasource.type=com.zaxxer.hikari.HikariDataSource
+#spring.datasource.hikari.minimum-idle=10
+#spring.datasource.hikari.maximum-pool-size=25
+#spring.datasource.hikari.auto-commit=true
+#spring.datasource.hikari.idle-timeout=30000
+#spring.datasource.hikari.pool-name=DatebookHikariCP
+#spring.datasource.hikari.max-lifetime=120000
+#spring.datasource.hikari.connection-timeout=30000
+#spring.datasource.hikari.connection-test-query=SELECT 1
+#spring.datasource.url=jdbc:mysql://172.16.10.220:3306/production?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
+#spring.datasource.username=root
+#spring.datasource.password=Yeejoin@2020
+
+
+#spring.jpa.database-platform=org.hibernate.dialect.MySQL8Dialect
+#spring.datasource.master.jdbc-url=jdbc:mysql://139.9.173.44:3306/amos_idx?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useOldAliasMetadataBehavior=true
+#spring.datasource.master.username=root
+#spring.datasource.master.password=Yeejoin@2020
+#spring.datasource.master.driver-Class-Name=com.mysql.cj.jdbc.Driver
+#spring.datasource.master.minimum-idle=10
+#spring.datasource.master.max-wait=10000
+#spring.datasource.master.initial-size=10
+#spring.datasource.master.maximum-pool-size=100
+#spring.datasource.master.max-lifetime=1800000
+#spring.datasource.master.idle-timeout=60000
+#spring.datasource.master.connection-timeout=60000
+##\u6570\u636E\u6E902
+#spring.datasource.slave.jdbc-url=jdbc:mysql://139.9.173.44:3306/amos_idx_biz?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useOldAliasMetadataBehavior=true
+#spring.datasource.slave.username=root
+#spring.datasource.slave.password=Yeejoin@2020
+#spring.datasource.slave.driver-class-name=com.mysql.cj.jdbc.Driver
+#spring.datasource.slave.minimum-idle=10
+#spring.datasource.slave.max-wait=10000
+#spring.datasource.slave.initial-size=10
+#spring.datasource.slave.maximum-pool-size=100
+#spring.datasource.slave.max-lifetime=1800000
+#spring.datasource.slave.idle-timeout=60000
+#spring.datasource.slave.connection-timeout=60000
+
+
+
 ## 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-monitor-biz/src/main/resources/application.properties

@@ -11,22 +11,27 @@ logging.config=classpath:logback-${spring.profiles.active}.xml
 ## mybatis-plus配置控制台打印完整带参数SQL语句
 mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
 
-## DB properties:
-spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
-spring.datasource.type=com.zaxxer.hikari.HikariDataSource
-spring.datasource.hikari.minimum-idle=10
-spring.datasource.hikari.maximum-pool-size=25
-spring.datasource.hikari.auto-commit=true
-spring.datasource.hikari.idle-timeout=30000
-spring.datasource.hikari.pool-name=DatebookHikariCP
-spring.datasource.hikari.max-lifetime=120000
-spring.datasource.hikari.connection-timeout=30000
-spring.datasource.hikari.connection-test-query=SELECT 1
-
+### DB properties:
+#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
+#spring.datasource.type=com.zaxxer.hikari.HikariDataSource
+#spring.datasource.hikari.minimum-idle=10
+#spring.datasource.hikari.maximum-pool-size=25
+#spring.datasource.hikari.auto-commit=true
+#spring.datasource.hikari.idle-timeout=30000
+#spring.datasource.hikari.pool-name=DatebookHikariCP
+#spring.datasource.hikari.max-lifetime=120000
+#spring.datasource.hikari.connection-timeout=30000
+#spring.datasource.hikari.connection-test-query=SELECT 1
+#JPA Configuration:
+spring.jpa.show-sql=false
+spring.jpa.open-in-view=true
+#spring.jpa.hibernate.ddl-auto=update
+spring.jpa.hibernate.naming.implicit-strategy=org.hibernate.boot.model.naming.ImplicitNamingStrategyLegacyJpaImpl
+spring.jpa.hibernate.naming.physical-strategy=org.hibernate.boot.model.naming.PhysicalNamingStrategyStandardImpl
 
 ##liquibase
 spring.liquibase.change-log=classpath:/db/changelog/changelog-master.xml
-spring.liquibase.enabled=true
+spring.liquibase.enabled=false
 
 
 ## eureka properties:

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/resources/mapper.cluster/TestMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.yeejoin.amos.boot.module.jxiop.biz.mapper2.TestMapper">
+
+</mapper>