网格排行定时任务

epdc-cloud-job/pom.xml

@@ -160,12 +160,12 @@
                 <spring.profiles.active>dev</spring.profiles.active>
                 <docker.tag>dev</docker.tag>
 
-                <server.port>10013</server.port>
+                <server.port>9061</server.port>
 
-                <spring.redis.index>9</spring.redis.index>
-                <spring.redis.host>114.215.125.123</spring.redis.host>
-                <spring.redis.port>9603</spring.redis.port>
-                <spring.redis.password>epdc!redis@master1405</spring.redis.password>
+                <spring.redis.index>8</spring.redis.index>
+                <spring.redis.host>r-m5eh5czgb1nucti6azpd.redis.rds.aliyuncs.com</spring.redis.host>
+                <spring.redis.port>10001</spring.redis.port>
+                <spring.redis.password>elink!888</spring.redis.password>
 
                 <spring.datasource.druid.url>
                     <![CDATA[jdbc:mysql://rm-m5eguiv2827bdye798o.mysql.rds.aliyuncs.com:10001/yushan_esua_epdc_job?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai]]>
@@ -174,9 +174,9 @@
                 <spring.datasource.druid.password>elink-epdc@yushan</spring.datasource.druid.password>
 
                 <nacos.register-enabled>false</nacos.register-enabled>
-                <nacos.server-addr>47.104.224.45:8848</nacos.server-addr>
+                <nacos.server-addr>115.29.142.202:8848</nacos.server-addr>
                 <nacos.ip></nacos.ip>
-                <nacos.namespace>6a3577b4-7b79-43f6-aebb-9c3f31263f6a</nacos.namespace>
+                <nacos.namespace>8831513c-2f72-42e8-899f-eb6c2c5ae110</nacos.namespace>
             </properties>
         </profile>
 
@@ -188,10 +188,10 @@
 
                 <server.port>10013</server.port>
 
-                <spring.redis.index>2</spring.redis.index>
-                <spring.redis.host>114.215.125.123</spring.redis.host>
-                <spring.redis.port>9603</spring.redis.port>
-                <spring.redis.password>epdc!redis@master1405</spring.redis.password>
+                <spring.redis.index>8</spring.redis.index>
+                <spring.redis.host>r-m5eh5czgb1nucti6azpd.redis.rds.aliyuncs.com</spring.redis.host>
+                <spring.redis.port>10001</spring.redis.port>
+                <spring.redis.password>elink!888</spring.redis.password>
 
                 <spring.datasource.druid.url>
                     <![CDATA[jdbc:mysql://rm-m5eguiv2827bdye798o.mysql.rds.aliyuncs.com:10001/yushan_esua_epdc_job?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai]]>
@@ -201,8 +201,8 @@
 
                 <!-- nacos -->
                 <nacos.register-enabled>true</nacos.register-enabled>
-                <nacos.server-addr>192.168.0.59:8848</nacos.server-addr>
-                <nacos.ip>192.168.0.59</nacos.ip>
+                <nacos.server-addr>115.29.142.202:8848</nacos.server-addr>
+                <nacos.ip>115.29.142.202</nacos.ip>
                 <nacos.namespace>8831513c-2f72-42e8-899f-eb6c2c5ae110</nacos.namespace>
             </properties>
         </profile>

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

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

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

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