# update

datacenter-job/datacenter-base/base-sync-ebay/pom.xml

@@ -25,6 +25,11 @@
             <artifactId>ebaycalls</artifactId>
             <version>1065</version>
         </dependency>
+
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-task</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

datacenter-job/datacenter-base/base-sync-ebay/src/main/java/com/bailuntec/job/DataSourceConfig.java

 package com.bailuntec.job;
 
-import com.zaxxer.hikari.HikariConfig;
-import com.zaxxer.hikari.HikariDataSource;
-import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.boot.jdbc.DataSourceBuilder;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
 
 import javax.sql.DataSource;
 
@@ -19,22 +19,19 @@ import javax.sql.DataSource;
 @Configuration
 public class DataSourceConfig {
 
-    @Value("${spring.datasource.url}")
-    String url;
-    @Value("${spring.datasource.username}")
-    String username;
-    @Value("${spring.datasource.password}")
-    String password;
-    @Value("${spring.datasource.driver-class-name}")
-    String driverClassName;
 
     @Bean
-    public DataSource dataSource() {
-        HikariConfig hikariConfig = new HikariConfig();
-        hikariConfig.setDriverClassName(driverClassName);
-        hikariConfig.setJdbcUrl(url);
-        hikariConfig.setUsername(username);
-        hikariConfig.setPassword(password);
-        return new HikariDataSource(hikariConfig);
+    @ConfigurationProperties(prefix = "spring.dataflow-datasource")
+    public DataSource dataflowDataSource() {
+        return DataSourceBuilder.create().build();
     }
+
+
+    @Primary
+    @Bean
+    @ConfigurationProperties(prefix = "spring.dataflow")
+    public DataSource bizDataSource() {
+        return DataSourceBuilder.create().build();
+    }
+
 }

datacenter-job/datacenter-base/base-sync-ebay/src/main/java/com/bailuntec/job/EbayFinanceJob.java → datacenter-job/datacenter-base/base-sync-ebay/src/main/java/com/bailuntec/job/EbayFinanceTaskApp.java

 package com.bailuntec.job;
 
-import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.openfeign.EnableFeignClients;
@@ -19,9 +18,9 @@ import org.springframework.scheduling.annotation.EnableScheduling;
 @EnableScheduling
 @ComponentScan("com.bailuntec")
 @EnableFeignClients(basePackages = {"com.bailuntec.api", "com.bailuntec.*.api"})
-public class EbayFinanceJob {
+public class EbayFinanceTaskApp {
 
     public static void main(String[] args) {
-        SpringApplication.run(EbayFinanceJob.class, args);
+        SpringApplication.run(EbayFinanceTaskApp.class, args);
     }
 }

datacenter-job/datacenter-base/base-sync-ebay/src/main/java/com/bailuntec/job/GeneratorTaskConfigurer.java

+package com.bailuntec.job;
+
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.cloud.task.configuration.DefaultTaskConfigurer;
+import org.springframework.context.annotation.Configuration;
+
+import javax.sql.DataSource;
+
+/**
+ * <p>
+ *
+ * </p>
+ *
+ * @author robbendev
+ * @since 2021/1/21 9:31 上午
+ */
+@Configuration
+public class GeneratorTaskConfigurer extends DefaultTaskConfigurer {
+
+    public GeneratorTaskConfigurer(@Qualifier("dataflowDataSource") DataSource dataSource) {
+        super(dataSource);
+    }
+}

datacenter-job/datacenter-base/base-sync-ebay/src/main/resources/application-prod.yml

@@ -8,6 +8,13 @@ spring:
     username: root
     password: '#7kfnymAM$Y9-Ntf'
     driver-class-name: com.mysql.jdbc.Driver
+  dataflow-dataSource:
+    url: jdbc:mysql://${MYSQL_SERVICE_HOST}:${MYSQL_SERVICE_PORT}/mysql
+    username: root
+    password: ${mysql-root-password}
+    driverClassName: org.mariadb.jdbc.Driver
+    testOnBorrow: true
+    validationQuery: "SELECT 1"
   main:
     allow-bean-definition-overriding: true
   batch:

datacenter-job/datacenter-base/base-sync-ebay/src/main/resources/application-test.yml

@@ -4,7 +4,12 @@ spring:
     name: base-sync-ebay
   # 数据配置
   datasource:
-    url: jdbc:mysql://gz-cdb-kp7s5i79.sql.tencentcdb.com:61691/bailun_datecenter_test?serverTimezone=GMT%2B8&characterEncoding=utf-8&rewriteBatchedStatements=true
+    jdbcUrl: jdbc:mysql://gz-cdb-kp7s5i79.sql.tencentcdb.com:61691/bailun_datecenter_test?serverTimezone=GMT%2B8&characterEncoding=utf-8&rewriteBatchedStatements=true
+    username: root
+    password: '#7kfnymAM$Y9-Ntf'
+    driver-class-name: com.mysql.jdbc.Driver
+  dataflow-dataSource:
+    jdbcUrl: jdbc:mysql://gz-cdb-kp7s5i79.sql.tencentcdb.com:61691/bailun_datecenter_test?serverTimezone=GMT%2B8&characterEncoding=utf-8&rewriteBatchedStatements=true
     username: root
     password: '#7kfnymAM$Y9-Ntf'
     driver-class-name: com.mysql.jdbc.Driver