diff --git a/epdc-cloud-job/pom.xml b/epdc-cloud-job/pom.xml index 69ad098..5db8a7b 100644 --- a/epdc-cloud-job/pom.xml +++ b/epdc-cloud-job/pom.xml @@ -160,12 +160,12 @@ dev dev - 10013 + 9061 - 9 - 114.215.125.123 - 9603 - epdc!redis@master1405 + 8 + r-m5eh5czgb1nucti6azpd.redis.rds.aliyuncs.com + 10001 + elink!888 @@ -174,9 +174,9 @@ elink-epdc@yushan false - 47.104.224.45:8848 + 115.29.142.202:8848 - 6a3577b4-7b79-43f6-aebb-9c3f31263f6a + 8831513c-2f72-42e8-899f-eb6c2c5ae110 @@ -188,10 +188,10 @@ 10013 - 2 - 114.215.125.123 - 9603 - epdc!redis@master1405 + 8 + r-m5eh5czgb1nucti6azpd.redis.rds.aliyuncs.com + 10001 + elink!888 @@ -201,8 +201,8 @@ true - 192.168.0.59:8848 - 192.168.0.59 + 115.29.142.202:8848 + 115.29.142.202 8831513c-2f72-42e8-899f-eb6c2c5ae110 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 741b8f9..40a8fb2 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 { /** @@ -727,4 +729,13 @@ public interface AnalysisFeignClient { @PostMapping("analysis/girdManager/gridManagerUploadEvent") Result selectGridManagerUploadEvent(ScreenJobFormDTO formDto); + /** + * @describe: 网格开通情况 + * @author wangtong + * @date 2021/8/24 14:57 + * @params [] + * @return void + */ + @GetMapping("analysis/user/gridOpeningJob") + void gridOpeningJob(); } 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 e9de33c..4fd9301 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 @@ -350,4 +350,9 @@ public class AnalysisFeignClientFallback implements AnalysisFeignClient { public Result selectGridManagerUploadEvent(ScreenJobFormDTO formDto) { return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "selectGridManagerUploadEvent",formDto); } + + @Override + public void gridOpeningJob( ) { + ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "gridOpeningJob"); + } } diff --git a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/analysis/GridOpeningTask.java b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/analysis/GridOpeningTask.java new file mode 100644 index 0000000..e0a3f8e --- /dev/null +++ b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/analysis/GridOpeningTask.java @@ -0,0 +1,14 @@ +package com.elink.esua.epdc.task.analysis; + + +public interface GridOpeningTask { + + /** + * @describe: 网格排行 + * @author wangtong + * @date 2021/8/24 14:50 + * @params [params] + * @return void + */ + void run(String params); +} diff --git a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/analysis/GridOpeningTaskImpl.java b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/analysis/GridOpeningTaskImpl.java new file mode 100644 index 0000000..b506540 --- /dev/null +++ b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/analysis/GridOpeningTaskImpl.java @@ -0,0 +1,23 @@ +package com.elink.esua.epdc.task.analysis; + +import com.elink.esua.epdc.feign.AnalysisFeignClient; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + + +@Component("GridOpeningTask") +public class GridOpeningTaskImpl implements GridOpeningTask { + + private Logger logger = LoggerFactory.getLogger(getClass()); + + @Autowired + private AnalysisFeignClient analysisFeignClient; + + @Override + public void run(String params){ + logger.debug("GridOpeningTask定时任务正在执行,参数为:{}", params); + analysisFeignClient.gridOpeningJob(); + } +}