定时任务推送县平台更新的人员信息

epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java

@@ -16,7 +16,9 @@ import org.springframework.web.bind.annotation.RequestBody;
  * @Author：liuchuang
  * @Date：2020/9/9 15:41
  */
-@FeignClient(name = ServiceConstant.EPDC_ANALYSIS_SERVER, fallback = AnalysisFeignClientFallback.class)
+@FeignClient(name = ServiceConstant.EPDC_ANALYSIS_SERVER, fallback = AnalysisFeignClientFallback.class
+//    ,url = "http://127.0.0.1:9077"
+)
 public interface AnalysisFeignClient {
 
     /**
@@ -785,4 +787,15 @@ public interface AnalysisFeignClient {
 
     @PostMapping("analysis/screen/job/yqfk/ymjzqk")
     Result yqfkYmjzqkJob();
+
+
+    /**
+    * @describe: 向县平台推送更新的人员数据
+    * @author wangtong
+    * @date 2022/1/12 13:51
+    * @params []
+    * @return com.elink.esua.epdc.commons.tools.utils.Result
+    */
+    @PostMapping("analysis/epidemicusersync/syncUser")
+    Result syncUser();
 }

epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java

@@ -380,4 +380,9 @@ public class AnalysisFeignClientFallback implements AnalysisFeignClient {
     public Result yqfkYmjzqkJob() {
         return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "yqfkYmjzqkJob");
     }
+
+    @Override
+    public Result syncUser() {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "syncUser");
+    }
 }

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/epimedic/UserInfoTask.java

@@ -0,0 +1,17 @@
+package com.elink.esua.epdc.task.epimedic;
+
+/**
+ * @Author：wangtong
+ * @Date：2022/1/12 11:01
+ */
+public interface UserInfoTask {
+
+    /**
+    * @describe:  向县平台推送更新的人员数据
+    * @author wangtong
+    * @date 2022/1/12 13:53
+    * @params [params]
+    * @return void
+    */
+    void run(String params);
+}

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/epimedic/impl/UserInfoTaskImpl.java

@@ -0,0 +1,27 @@
+package com.elink.esua.epdc.task.epimedic.impl;
+
+import com.elink.esua.epdc.feign.AnalysisFeignClient;
+import com.elink.esua.epdc.task.epimedic.UserInfoTask;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Author：wangtong
+ * @Date：2022/1/12 11:01
+ */
+@Component("UserInfoTask")
+public class UserInfoTaskImpl implements UserInfoTask {
+
+    private Logger logger = LoggerFactory.getLogger(getClass());
+
+    @Autowired
+    private AnalysisFeignClient analysisFeignClient;
+
+    @Override
+    public void run(String params){
+        logger.debug("UserInfoTask定时任务正在执行");
+        analysisFeignClient.syncUser();
+    }
+}