From 4b94d43b6328d7857dd72b77552cf8dd97d12db7 Mon Sep 17 00:00:00 2001
From: Jackwang <wt373747285@163.com>
Date: Thu, 13 Jan 2022 11:11:35 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=E6=8E=A8?=
 =?UTF-8?q?=E9=80=81=E5=8E=BF=E5=B9=B3=E5=8F=B0=E6=9B=B4=E6=96=B0=E7=9A=84?=
 =?UTF-8?q?=E4=BA=BA=E5=91=98=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../esua/epdc/feign/AnalysisFeignClient.java  | 15 ++++++++++-
 .../fallback/AnalysisFeignClientFallback.java |  5 ++++
 .../esua/epdc/task/epimedic/UserInfoTask.java | 17 ++++++++++++
 .../task/epimedic/impl/UserInfoTaskImpl.java  | 27 +++++++++++++++++++
 4 files changed, 63 insertions(+), 1 deletion(-)
 create mode 100644 epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/epimedic/UserInfoTask.java
 create mode 100644 epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/epimedic/impl/UserInfoTaskImpl.java

diff --git a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java
index 2985659..626befa 100644
--- a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java
+++ b/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();
 }
diff --git a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java
index b3ac809..186918e 100644
--- a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java
+++ b/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");
+    }
 }
diff --git a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/epimedic/UserInfoTask.java b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/epimedic/UserInfoTask.java
new file mode 100644
index 0000000..c09887b
--- /dev/null
+++ b/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);
+}
diff --git a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/epimedic/impl/UserInfoTaskImpl.java b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/epimedic/impl/UserInfoTaskImpl.java
new file mode 100644
index 0000000..0e3fcf4
--- /dev/null
+++ b/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();
+    }
+}