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(); + } +}