yfai 数据源

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;
+    }
+}

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;
+    }
+}

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<String,Object> objMap) throws SQLException {
+        dataSourceProxy.insert(tableName,objMap);
+    }
+
+    public void update(String tableName,HashMap<String,Object> conditionMap,HashMap<String,Object> setValueMap) throws SQLException {
+        dataSourceProxy.update(tableName,conditionMap,setValueMap);
+    }
+
+    public void detelte(String tableName,HashMap<String,Object> conditionMap) throws SQLException {
+        dataSourceProxy.delete(tableName,conditionMap);
+    }
+
+    public List<Map<String,Object>> 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<BasVendor> listObject(String sql) throws SQLException, IllegalAccessException, InstantiationException {
+        return dataSourceProxy.queryObjectList(sql,BasVendor.class);
+    }
+
+    public BasVendor get(String tableName,HashMap<String,Object> conditionMap) throws SQLException, IllegalAccessException, InstantiationException {
+        return dataSourceProxy.queryObject(tableName,conditionMap,BasVendor.class);
+    }
+
+    public List<BasVendor> listObject(String tableName,HashMap<String,Object> conditionMap) throws SQLException, IllegalAccessException, InstantiationException {
+        return dataSourceProxy.queryObjectList(tableName,conditionMap,BasVendor.class);
+    }
+
+    public int[] executeAsBatch(String[] sqlArr) throws SQLException {
+        return dataSourceProxy.executeAsBatch(sqlArr);
+    }
+}