feat(jyjc):jyjc集成seata

amos-boot-biz-common/pom.xml

@@ -142,11 +142,6 @@
             <groupId>com.yeejoin</groupId>
             <artifactId>amos-feign-systemctl</artifactId>
         </dependency>
-        <dependency>
-            <groupId>io.seata</groupId>
-            <artifactId>seata-spring-boot-starter</artifactId>
-            <version>1.8.0</version>
-        </dependency>
     </dependencies>
 
 </project>

amos-boot-biz-common/src/main/java/com/yeejoin/amos/boot/biz/common/feign/XidFeignConfiguration.java → amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/config/XidFeignConfiguration.java

-package com.yeejoin.amos.boot.biz.common.feign;
+package com.yeejoin.amos.boot.module.jg.biz.config;
 
 import feign.RequestInterceptor;
 import feign.RequestTemplate;

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/feign/TaskV2FeignService.java

 package com.yeejoin.amos.boot.module.jg.biz.feign;
 
-import com.yeejoin.amos.boot.biz.common.feign.XidFeignConfiguration;
+import com.yeejoin.amos.boot.module.jg.biz.config.XidFeignConfiguration;
 import com.yeejoin.amos.component.feign.config.InnerInvokException;
 import com.yeejoin.amos.component.feign.model.FeignClientResult;
 import com.yeejoin.amos.feign.systemctl.model.TaskV2Model;

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/feign/WorkFlowFeignService.java

 package com.yeejoin.amos.boot.module.jg.biz.feign;
 
 import com.alibaba.fastjson.JSONObject;
-import com.yeejoin.amos.boot.biz.common.feign.XidFeignConfiguration;
+import com.yeejoin.amos.boot.module.jg.biz.config.XidFeignConfiguration;
 import com.yeejoin.amos.component.feign.model.FeignClientResult;
 import com.yeejoin.amos.feign.workflow.model.*;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.*;
+
 import java.util.List;
 import java.util.Map;
 

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-biz/src/main/java/com/yeejoin/amos/boot/module/jyjc/biz/config/XidFeignConfiguration.java

+package com.yeejoin.amos.boot.module.jyjc.biz.config;
+
+import feign.RequestInterceptor;
+import feign.RequestTemplate;
+import feign.codec.Encoder;
+import feign.form.spring.SpringFormEncoder;
+import io.seata.core.context.RootContext;
+import org.springframework.beans.factory.ObjectFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
+import org.springframework.cloud.openfeign.support.SpringEncoder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.util.StringUtils;
+import org.springframework.web.context.request.RequestContextListener;
+
+@Configuration
+public class XidFeignConfiguration implements RequestInterceptor {
+    @Autowired
+    private ObjectFactory<HttpMessageConverters> messageConverters;
+
+    @Bean
+    public Encoder feignFormEncoder() {
+        return new SpringFormEncoder(new SpringEncoder(messageConverters));
+    }
+    /**
+     * 创建Feign请求拦截器，在发送请求前设置认证的token,各个微服务将token设置到环境变量中来达到通用
+     * @return
+     */
+    @Bean
+    public RequestContextListener requestInterceptor() {
+        return new RequestContextListener();
+    }
+
+    @Override
+    public void apply(RequestTemplate template) {
+        String xid = RootContext.getXID();
+        if(StringUtils.hasText(xid)){
+            template.header(RootContext.KEY_XID, xid);
+        }
+    }
+}
\ No newline at end of file

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-biz/src/main/java/com/yeejoin/amos/boot/module/jyjc/biz/feign/WorkflowFeignClient.java

 package com.yeejoin.amos.boot.module.jyjc.biz.feign;
 
 import com.alibaba.fastjson.JSONObject;
-import com.yeejoin.amos.boot.biz.common.feign.XidFeignConfiguration;
+import com.yeejoin.amos.boot.module.jyjc.biz.config.XidFeignConfiguration;
 import com.yeejoin.amos.component.feign.model.FeignClientResult;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.*;

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-biz/src/main/resources/application-dev.properties

@@ -49,7 +49,7 @@ elasticsearch.password= a123456
 
 #Seata Config
 seata.tx-service-group= tzs-seata
-seata.service.grouplist.tzs-seata=172.16.10.243:8091
+seata.service.grouplist.tzs-seata= 172.16.10.243:8091
 
 #检验检测流程KEY
 process-definition-key.jyjc.openapplication=inspectionBusinessOpened