项目初始化

datax-config/src/main/resources/config/datax-service-workflow-dev.yml

+# 数据源配置
+spring:
+  redis:
+    database: 1
+    host: localhost
+    port: 6379
+    password: 1234@abcd   # 密码（默认为空）
+    timeout: 6000ms       # 连接超时时长（毫秒）
+    lettuce:
+      pool:
+        max-active: 1000  # 连接池最大连接数（使用负值表示没有限制）
+        max-wait: -1ms    # 连接池最大阻塞等待时间（使用负值表示没有限制）
+        max-idle: 10      # 连接池中的最大空闲连接
+        min-idle: 5       # 连接池中的最小空闲连接
+  datasource:
+    dynamic:
+      primary: mysql
+      datasource:
+        mysql:
+          driver-class-name: com.p6spy.engine.spy.P6SpyDriver
+          url: jdbc:p6spy:mysql://localhost:3306/data_test?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+          username: root
+          password: 1234@abcd
+        flowable:
+          driver-class-name: com.mysql.cj.jdbc.Driver
+          username: root
+          password: 1234@abcd
+          # 如果不加这个参数，建表会失败：nullCatalogMeansCurrent=true
+          url: jdbc:mysql://localhost:3306/data_cloud_flowable?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&nullCatalogMeansCurrent=true
+#    primary:
+#      driver-class-name: com.mysql.cj.jdbc.Driver
+#      username: root
+#      password: 1234@abcd
+#      url: jdbc:mysql://localhost:3306/data_test?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+#    flowable:
+#      driver-class-name: com.mysql.cj.jdbc.Driver
+#      username: root
+#      password: 1234@abcd
+#      # 如果不加这个参数，建表会失败：nullCatalogMeansCurrent=true
+#      url: jdbc:mysql://localhost:3306/data_cloud_flowable?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&nullCatalogMeansCurrent=true
+flowable:
+  # 关闭定时任务JOB
+  async-executor-activate: false
+  # 将databaseSchemaUpdate设置为true。当Flowable发现库与数据库表结构不一致时，会自动将数据库表结构升级至新版本。
+  database-schema-update: true
+
+mybatis-plus:
+  mapper-locations: classpath*:mapper/*Mapper.xml
+  type-aliases-package: cn.datax.service.workflow.api.entity
+  global-config:
+    db-config:
+      id-type: ASSIGN_ID
+    banner: false
+  configuration:
+    map-underscore-to-camel-case: true
+    cache-enabled: false
+    call-setters-on-nulls: true
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+
+# spring security 配置
+security:
+  oauth2:
+    client:
+      access-token-uri: http://localhost:8612/auth/oauth/token
+      user-authorization-uri: http://localhost:8612/auth/oauth/authorize
+      client-id: datax
+      client-secret: 123456
+      scope: all
+    resource:
+      loadBalanced: true
+      token-info-uri: http://localhost:8612/auth/oauth/check_token
+
+# Swagger界面内容配置
+swagger:
+  enable: true
+  title: API接口文档
+  description: Api Documentation
+  version: 1.0.0
+  basePackage: cn.datax.service.workflow.controller
+  termsOfServiceUrl: http://www.baidu.com
+  contact:
+    name: yuwei
+    url: http://www.baidu.com
+    email: 312075478@qq.com
\ No newline at end of file

datax-modules/workflow-service-parent/workflow-service/pom.xml

@@ -48,12 +48,12 @@
             <groupId>cn.datax</groupId>
             <artifactId>datax-common-mybatis</artifactId>
             <version>2.0.0</version>
-            <exclusions>
-                <exclusion>
-                    <groupId>com.baomidou</groupId>
-                    <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
-                </exclusion>
-            </exclusions>
+<!--            <exclusions>-->
+<!--                <exclusion>-->
+<!--                    <groupId>com.baomidou</groupId>-->
+<!--                    <artifactId>dynamic-datasource-spring-boot-starter</artifactId>-->
+<!--                </exclusion>-->
+<!--            </exclusions>-->
         </dependency>
         <dependency>
             <groupId>cn.datax</groupId>

datax-modules/workflow-service-parent/workflow-service/src/main/java/cn/datax/service/workflow/config/ProcessEngineConfig.java

 package cn.datax.service.workflow.config;
 
+import com.baomidou.dynamic.datasource.DynamicRoutingDataSource;
 import com.zaxxer.hikari.HikariDataSource;
+import lombok.AllArgsConstructor;
 import org.flowable.engine.ProcessEngineConfiguration;
 import org.flowable.spring.SpringProcessEngineConfiguration;
 import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
@@ -10,36 +12,41 @@ import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Primary;
 import org.springframework.jdbc.datasource.DataSourceTransactionManager;
 
+import javax.sql.DataSource;
+
 @Configuration
+@AllArgsConstructor
 public class ProcessEngineConfig {
 
-    @Bean
-    @Primary
-    @ConfigurationProperties("spring.datasource.primary")
-    public DataSourceProperties primaryDataSourceProperties() {
-        return new DataSourceProperties();
-    }
-
-    @Bean
-    @Primary
-    @ConfigurationProperties("spring.datasource.primary.configuration")
-    public HikariDataSource firstDataSource() {
-        return primaryDataSourceProperties().initializeDataSourceBuilder()
-                .type(HikariDataSource.class).build();
-    }
+    private final DataSource dataSource;
 
-    @Bean
-    @ConfigurationProperties("spring.datasource.flowable")
-    public DataSourceProperties flowableDataSourceProperties() {
-        return new DataSourceProperties();
-    }
-
-    @Bean
-    @ConfigurationProperties("spring.datasource.flowable.configuration")
-    public HikariDataSource flowableDataSource() {
-        return flowableDataSourceProperties().initializeDataSourceBuilder()
-                .type(HikariDataSource.class).build();
-    }
+//    @Bean
+//    @Primary
+//    @ConfigurationProperties("spring.datasource.primary")
+//    public DataSourceProperties primaryDataSourceProperties() {
+//        return new DataSourceProperties();
+//    }
+//
+//    @Bean
+//    @Primary
+//    @ConfigurationProperties("spring.datasource.primary.configuration")
+//    public HikariDataSource firstDataSource() {
+//        return primaryDataSourceProperties().initializeDataSourceBuilder()
+//                .type(HikariDataSource.class).build();
+//    }
+//
+//    @Bean
+//    @ConfigurationProperties("spring.datasource.flowable")
+//    public DataSourceProperties flowableDataSourceProperties() {
+//        return new DataSourceProperties();
+//    }
+//
+//    @Bean
+//    @ConfigurationProperties("spring.datasource.flowable.configuration")
+//    public HikariDataSource flowableDataSource() {
+//        return flowableDataSourceProperties().initializeDataSourceBuilder()
+//                .type(HikariDataSource.class).build();
+//    }
 
     /**
      * ProcessEngine 配置，注入DataSourceTransactionManager和DataSource
@@ -48,8 +55,11 @@ public class ProcessEngineConfig {
     @Bean
     public SpringProcessEngineConfiguration springProcessEngineConfiguration() {
         SpringProcessEngineConfiguration springProcessEngineConfiguration = new SpringProcessEngineConfiguration();
-        springProcessEngineConfiguration.setDataSource(flowableDataSource());
-        springProcessEngineConfiguration.setTransactionManager(new DataSourceTransactionManager(flowableDataSource()));
+        // 手动从多数据源中获取 quartz数据源
+        DynamicRoutingDataSource ds = (DynamicRoutingDataSource) dataSource;
+        DataSource flowable = ds.getDataSource("flowable");
+        springProcessEngineConfiguration.setDataSource(flowable);
+        springProcessEngineConfiguration.setTransactionManager(new DataSourceTransactionManager(flowable));
         // 不添加此项配置，在没创建表时，会抛出FlowableWrongDbException异常
         springProcessEngineConfiguration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
         return springProcessEngineConfiguration;