seata分布式事务

SLN/%PUBPRJ%-app/%PUBPRJ%-app-%APP_PKGPATH%/src/main/java/%SYS_PKGPATH%/%APP_PKGPATH%/%APP%Application.java.ftl

@@ -27,6 +27,7 @@ import java.util.List;
 
 @Slf4j
 @Import({
+    com.alibaba.cloud.seata.feign.SeataFeignClientAutoConfiguration.class,
     FeignClientsConfiguration.class
 })
 @EnableDiscoveryClient

SLN/%PUBPRJ%-boot/src/main/java/%SYS_PKGPATH%/DevBootApplication.java.ftl

@@ -53,6 +53,7 @@ import java.util.List;
 //        }
 )
 @Import({
+        com.alibaba.cloud.seata.feign.SeataFeignClientAutoConfiguration.class,
         org.springframework.cloud.openfeign.FeignClientsConfiguration.class
 })
 @EnableAsync

SLN/%PUBPRJ%-dependencies/pom.xml.ftl

@@ -31,7 +31,7 @@ TARGET=PSSYSTEM
     <#--  properties, usually record jars version constants  -->
     <properties>
         <!--  Spring Cloud Alibaba(2.1.x.RELEASE) & Spring Cloud(Spring Cloud Greenwich) & Spring Boot(2.1.x.RELEASE) compatibility -->
-        <spring-cloud-alibaba.version>2.1.1.RELEASE</spring-cloud-alibaba.version>
+        <spring-cloud-alibaba.version>2.2.1.RELEASE</spring-cloud-alibaba.version>
 
         <spring-cloud-openfeign.version>2.2.1.RELEASE</spring-cloud-openfeign.version>
 
@@ -91,6 +91,12 @@ TARGET=PSSYSTEM
         <!-- eureka微服务注册中心 -->
         <eureka-client.version>2.2.1.RELEASE</eureka-client.version>
 
+        <!-- 阿里sentinel熔断器 -->
+        <alibaba-sentinel.version>2.1.1.RELEASE</alibaba-sentinel.version>
+
+        <!-- 阿里seata分布式事务 -->
+        <alibaba-seata.version>1.3.0</alibaba-seata.version>
+
         <#if sys.getAllPSSystemDBConfigs()??>
         <#list sys.getAllPSSystemDBConfigs() as dbConfig>
             <#if dbConfig.getDBType()=='MYSQL5'>
@@ -321,6 +327,7 @@ TARGET=PSSYSTEM
         <dependency>
             <groupId>com.alibaba.cloud</groupId>
             <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
+            <version>${r'${alibaba-sentinel.version}'}</version>
         </dependency>
 
         <!--  Lombok -->
@@ -388,6 +395,31 @@ TARGET=PSSYSTEM
         </dependency>
         </#if>
 
+        <!--  阿里seata分布式事务 -->
+        <dependency>
+            <groupId>io.seata</groupId>
+            <artifactId>seata-spring-boot-starter</artifactId>
+            <version>${r'${alibaba-seata.version}'}</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>com.alibaba</groupId>
+                    <artifactId>druid</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+
+        <dependency>
+            <groupId>com.alibaba.cloud</groupId>
+            <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
+            <version> ${r'${spring-cloud-alibaba.version}'}</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>io.seata</groupId>
+                    <artifactId>seata-spring-boot-starter</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+
     </dependencies>
 
 </project>

SLN/%PUBPRJ%-provider/%PUBPRJ%-provider-%SYSAPI_PKGPATH%/src/main/java/%SYS_PKGPATH%/%SYSAPI_PKGPATH%/%SYS%%API%Application.java.ftl

@@ -57,6 +57,7 @@ import java.util.List;
         </#if>
 })
 @Import({
+        com.alibaba.cloud.seata.feign.SeataFeignClientAutoConfiguration.class,
         org.springframework.cloud.openfeign.FeignClientsConfiguration.class
 })
 @EnableFeignClients(basePackages = {"${pub.getPKGCodeName()}" })

SLN/%PUBPRJ%-util/src/main/resources/application-sys.yml.ftl

@@ -26,6 +26,16 @@ TARGET=PSSYSTEM
     <#break>
     </#if>
 </#list>
+
+<#assign seataEnable="false">
+<#assign TcServerCluster="default">
+<#assign seataServerName="seata-server">
+<#assign nacosAddress="localhost">
+<#assign nacosGroup="DEFAULT_GROUP">
+<#assign nacosNamespace="">
+<#assign nacosUserName="">
+<#assign nacosPassWord="">
+
 <#comment>前端应用微服务平台配置</#comment>
 <#if sys.getAllPSDevSlnMSDepApps()??>
   <#list sys.getAllPSDevSlnMSDepApps() as depApp>
@@ -43,6 +53,30 @@ TARGET=PSSYSTEM
         <#if appPlatform.getUserParam("spring.data.mongodb.uri",mongodbUri)??>
             <#assign mongodbUri = appPlatform.getUserParam("spring.data.mongodb.uri",mongodbUri)>
         </#if>
+        <#if appPlatform.getUserParam("seata.enabled",seataEnable)??>
+              <#assign seataEnable = appPlatform.getUserParam("seata.enabled",seataEnable)>
+        </#if>
+        <#if appPlatform.getUserParam("seata.service.vgroup-mapping."+sys.getName()+"group",TcServerCluster)??>
+              <#assign TcServerCluster = appPlatform.getUserParam("seata.service.vgroup-mapping."+sys.getName()+"group",TcServerCluster)>
+        </#if>
+        <#if appPlatform.getUserParam("seata.registry.nacos.application",seataServerName)??>
+              <#assign seataServerName = appPlatform.getUserParam("seata.registry.nacos.application",seataServerName)>
+        </#if>
+        <#if appPlatform.getUserParam("seata.registry.nacos.server-addr",nacosAddress)??>
+              <#assign nacosAddress = appPlatform.getUserParam("seata.registry.nacos.server-addr",nacosAddress)>
+        </#if>
+        <#if appPlatform.getUserParam("seata.registry.nacos.group",nacosGroup)??>
+              <#assign nacosGroup = appPlatform.getUserParam("seata.registry.nacos.group",nacosGroup)>
+        </#if>
+        <#if appPlatform.getUserParam("seata.registry.nacos.namespace",nacosNamespace)??>
+              <#assign nacosNamespace = appPlatform.getUserParam("seata.registry.nacos.namespace",nacosNamespace)>
+        </#if>
+        <#if appPlatform.getUserParam("seata.registry.nacos.userName",nacosUserName)??>
+              <#assign nacosUserName = appPlatform.getUserParam("seata.registry.nacos.userName",nacosUserName)>
+        </#if>
+        <#if appPlatform.getUserParam("seata.registry.nacos.password",nacosPassWord)??>
+              <#assign nacosPassWord = appPlatform.getUserParam("seata.registry.nacos.password",nacosPassWord)>
+        </#if>
         <#break>
     </#if>
   </#list>
@@ -64,6 +98,30 @@ TARGET=PSSYSTEM
        <#if sysApiPlatform.getUserParam("spring.data.mongodb.uri",mongodbUri)??>
             <#assign mongodbUri = sysApiPlatform.getUserParam("spring.data.mongodb.uri",mongodbUri)>
        </#if>
+        <#if sysApiPlatform.getUserParam("seata.enabled",seataEnable)??>
+            <#assign seataEnable = sysApiPlatform.getUserParam("seata.enabled",seataEnable)>
+        </#if>
+        <#if sysApiPlatform.getUserParam("seata.service.vgroup-mapping."+sys.getName()+"group",TcServerCluster)??>
+            <#assign TcServerCluster = sysApiPlatform.getUserParam("seata.service.vgroup-mapping."+sys.getName()+"group",TcServerCluster)>
+        </#if>
+        <#if sysApiPlatform.getUserParam("seata.registry.nacos.application",seataServerName)??>
+            <#assign seataServerName = sysApiPlatform.getUserParam("seata.registry.nacos.application",seataServerName)>
+        </#if>
+        <#if sysApiPlatform.getUserParam("seata.registry.nacos.server-addr",nacosAddress)??>
+            <#assign nacosAddress = sysApiPlatform.getUserParam("seata.registry.nacos.server-addr",nacosAddress)>
+        </#if>
+        <#if sysApiPlatform.getUserParam("seata.registry.nacos.group",nacosGroup)??>
+            <#assign nacosGroup = sysApiPlatform.getUserParam("seata.registry.nacos.group",nacosGroup)>
+        </#if>
+        <#if sysApiPlatform.getUserParam("seata.registry.nacos.namespace",nacosNamespace)??>
+            <#assign nacosNamespace = sysApiPlatform.getUserParam("seata.registry.nacos.namespace",nacosNamespace)>
+        </#if>
+        <#if sysApiPlatform.getUserParam("seata.registry.nacos.userName",nacosUserName)??>
+            <#assign nacosUserName = sysApiPlatform.getUserParam("seata.registry.nacos.userName",nacosUserName)>
+        </#if>
+        <#if sysApiPlatform.getUserParam("seata.registry.nacos.password",nacosPassWord)??>
+            <#assign nacosPassWord = sysApiPlatform.getUserParam("seata.registry.nacos.password",nacosPassWord)>
+        </#if>
       <#break>
     </#if>
   </#list>
@@ -230,6 +288,23 @@ server:
     mime-types: application/javascript,text/css,application/json,application/xml,text/html,text/xml,text/plain
     min-response-size: 10240
 
+seata:
+  enabled: ${seataEnable}    #是否开启全局事务
+  application-id: ${sys.getName()}        #服务标识
+  tx-service-group: ${sys.getName()}group #事务组
+  service:
+    vgroup-mapping:
+      ${sys.getName()}group: ${TcServerCluster}   #指定事务组对应的Tc Server集群
+  registry:
+    type: nacos   #注册中心
+    nacos:
+      application: ${seataServerName}  #Tc Server服务标识
+      server-addr: ${nacosAddress}     #注册中心地址
+      group: ${nacosGroup}             #服务组
+      namespace: ${nacosNamespace}     #服务命名空间
+      userName: "${nacosUserName}"     #用户名
+      password: "${nacosPassWord}"     #密码
+
 <#macro singleDatasourceConfig>
   datasource:
     username: ${dbUserName}