From 55cf372318360affa2c887969169606d2009a86c Mon Sep 17 00:00:00 2001 From: "jhforever.wang@estsh.com" Date: Mon, 20 May 2024 10:37:13 +0800 Subject: [PATCH] =?UTF-8?q?yfai=20=E6=95=B0=E6=8D=AE=E6=BA=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ext/mes/apiservice/cus_suit/CusProperties.java | 73 ++++++++++++++++++++++ .../ext/mes/apiservice/cus_suit/MesProperties.java | 70 +++++++++++++++++++++ .../mes/apiservice/cus_suit/yfas/YfasBusiTool.java | 65 +++++++++++++++++++ 3 files changed, 208 insertions(+) create mode 100644 modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/cus_suit/CusProperties.java create mode 100644 modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/cus_suit/MesProperties.java create mode 100644 modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/cus_suit/yfas/YfasBusiTool.java diff --git a/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/cus_suit/CusProperties.java b/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/cus_suit/CusProperties.java new file mode 100644 index 0000000..4a8768a --- /dev/null +++ b/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/cus_suit/CusProperties.java @@ -0,0 +1,73 @@ +package cn.estsh.i3plus.ext.mes.apiservice.cus_suit; + +import cn.estsh.i3plus.platform.common.util.CommonConstWords; +import cn.estsh.i3plus.platform.plugin.datasource.DynamicDataSourceProxy; +import lombok.Getter; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +import java.util.concurrent.TimeUnit; + +/** + * @Description : 客户定制化配置，对应配置文件 + * @Reference : + * @Author : alwaysfrin + * @CreateDate : 2019-06-11 14:26 + * @Modify: + **/ +@Configuration +//@PropertySource(value="classpath:/cus_config/cus-datasource.properties",encoding = "UTF-8") +public class CusProperties { + + public static final Logger LOGGER = LoggerFactory.getLogger(CommonConstWords.SYSTEM_LOG); + + /*********************** + * 安道拓数据源配置 + */ + @Value("${impp.yfas.datasource.isopen}") + @Getter + private boolean yfasIsOpen; + + @Value("${impp.yfas.datasource.driver-class-name}") + @Getter + private String yfasDriverClassName; + + @Value("${impp.yfas.datasource.alias}") + @Getter + private String yfasDsAlias; + + @Value("${impp.yfas.datasource.jdbc-url}") + @Getter + private String yfasDsJdbcUrl; + + @Value("${impp.yfas.datasource.username}") + @Getter + private String yfasDsUsername; + + @Value("${impp.yfas.datasource.password}") + @Getter + private String yfasDsPassword; + + @ConditionalOnExpression("'${impp.yfas.datasource.isopen:false}' == 'true'") + @Bean(name = "yfasDataSource") + public DynamicDataSourceProxy initYfasCustomerSet(){ + LOGGER.info("【初始化客户定制化...】"); + + /** + * 注册客户定制数据源 + */ + LOGGER.info("【客户定制化：安道拓数据源加载...】"); + //安道拓定制业务 + DynamicDataSourceProxy yfasDataSource = DynamicDataSourceProxy.initDataSourceFactory(this.getYfasDriverClassName(), + this.getYfasDsJdbcUrl(),this.getYfasDsUsername(),this.getYfasDsPassword(),TimeUnit.MINUTES.toMillis(30)); + + //手动注册DataSource到spring中 + //SpringContextsUtil.registBean(this.getYfasDsAlias(),yfasDataSource); + + return yfasDataSource; + } +} diff --git a/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/cus_suit/MesProperties.java b/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/cus_suit/MesProperties.java new file mode 100644 index 0000000..f629e3e --- /dev/null +++ b/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/cus_suit/MesProperties.java @@ -0,0 +1,70 @@ +package cn.estsh.i3plus.ext.mes.apiservice.cus_suit; + +import cn.estsh.i3plus.platform.common.util.CommonConstWords; +import cn.estsh.i3plus.platform.plugin.datasource.DynamicDataSourceProxy; +import lombok.Getter; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +import java.util.concurrent.TimeUnit; + +/** + * @Description : mes 直连数据源 + * @Reference : + * @Author : Rock.Yu + * @CreateDate : 2019-06-13 20:40 + * @Modify: + **/ +@Configuration +//@PropertySource(value="classpath:/cus_config/cus-datasource.properties",encoding = "UTF-8") +public class MesProperties { + + public static final Logger LOGGER = LoggerFactory.getLogger(CommonConstWords.SYSTEM_LOG); + + /*********************** + * mes直连数据源配置 + */ + @Value("${impp.mes.datasource.isopen}") + @Getter + private boolean mesIsOpen; + + @Value("${impp.mes.datasource.driver-class-name}") + @Getter + private String mesDriverClassName; + + @Value("${impp.mes.datasource.alias}") + @Getter + private String mesDsAlias; + + @Value("${impp.mes.datasource.jdbc-url}") + @Getter + private String mesDsJdbcUrl; + + @Value("${impp.mes.datasource.username}") + @Getter + private String mesDsUsername; + + @Value("${impp.mes.datasource.password}") + @Getter + private String mesDsPassword; + + @ConditionalOnExpression("'${impp.mes.datasource.isopen:false}' == 'true'") + @Bean(name = "mesDataSource") + + public DynamicDataSourceProxy initmesCustomerSet(){ + LOGGER.info("【初始化客户定制化-mes直连...】"); + /** + * 注册客户定制数据源 + */ + LOGGER.info("【客户定制化：mes直连数据源加载...】"); + //安道拓定制业务 + DynamicDataSourceProxy mesDataSource = DynamicDataSourceProxy.initDataSourceFactory(this.getMesDriverClassName(), + this.getMesDsJdbcUrl(),this.getMesDsUsername(),this.getMesDsPassword(),TimeUnit.MINUTES.toMillis(30)); + + return mesDataSource; + } +} diff --git a/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/cus_suit/yfas/YfasBusiTool.java b/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/cus_suit/yfas/YfasBusiTool.java new file mode 100644 index 0000000..dbc8182 --- /dev/null +++ b/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/cus_suit/yfas/YfasBusiTool.java @@ -0,0 +1,65 @@ +package cn.estsh.i3plus.ext.mes.apiservice.cus_suit.yfas; + +import cn.estsh.i3plus.platform.plugin.datasource.DynamicDataSourceProxy; +import cn.estsh.i3plus.pojo.mes.bean.BasVendor; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.sql.SQLException; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * @Description : 安道拓服务 + * @Reference : 为了防止和原有事务Service拦截冲突，命名时注意不要使用service + * @Author : alwaysfrin + * @CreateDate : 2019-06-11 14:35 + * @Modify: + **/ +@Component +public class YfasBusiTool { + + @Resource(name="yfasDataSource") + private DynamicDataSourceProxy dataSourceProxy; + + public void execute(String sql) throws SQLException { + dataSourceProxy.execute(sql); + } + + public void insert(String tableName,HashMap objMap) throws SQLException { + dataSourceProxy.insert(tableName,objMap); + } + + public void update(String tableName,HashMap conditionMap,HashMap setValueMap) throws SQLException { + dataSourceProxy.update(tableName,conditionMap,setValueMap); + } + + public void detelte(String tableName,HashMap conditionMap) throws SQLException { + dataSourceProxy.delete(tableName,conditionMap); + } + + public List> listMap(String sql) throws SQLException { + return dataSourceProxy.queryMapList(sql); + } + + public BasVendor get(String sql) throws SQLException, IllegalAccessException, InstantiationException { + return dataSourceProxy.queryObject(sql,BasVendor.class); + } + + public List listObject(String sql) throws SQLException, IllegalAccessException, InstantiationException { + return dataSourceProxy.queryObjectList(sql,BasVendor.class); + } + + public BasVendor get(String tableName,HashMap conditionMap) throws SQLException, IllegalAccessException, InstantiationException { + return dataSourceProxy.queryObject(tableName,conditionMap,BasVendor.class); + } + + public List listObject(String tableName,HashMap conditionMap) throws SQLException, IllegalAccessException, InstantiationException { + return dataSourceProxy.queryObjectList(tableName,conditionMap,BasVendor.class); + } + + public int[] executeAsBatch(String[] sqlArr) throws SQLException { + return dataSourceProxy.executeAsBatch(sqlArr); + } +}