job定时任务

epmet-gateway/pom.xml

@@ -175,6 +175,8 @@
                 <!--  27、居民端-党建声音              -->
                 <gateway.routes.resi-voice-server.uri>lb://resi-voice-server</gateway.routes.resi-voice-server.uri>
                 <!--                <gateway.routes.resi-voice-server.uri>http://localhost:8106</gateway.routes.resi-voice-server.uri>-->
+                <gateway.routes.data-report-server.uri>lb://data-report-server</gateway.routes.data-report-server.uri>
+<!--                <gateway.routes.data-report-server.uri>http://localhost:8109</gateway.routes.data-report-server.uri>-->
             </properties>
         </profile>
         <profile>
@@ -251,6 +253,8 @@
                 <gateway.routes.gov-voice-server.uri>lb://gov-voice-server</gateway.routes.gov-voice-server.uri>
                 <!--  27、居民端-党建声音              -->
                 <gateway.routes.resi-voice-server.uri>lb://resi-voice-server</gateway.routes.resi-voice-server.uri>
+                <!--  28、政府端-数据首页              -->
+                <gateway.routes.data-report-server.uri>lb://data-report-server</gateway.routes.data-report-server.uri>
             </properties>
         </profile>
     </profiles>

epmet-gateway/src/main/resources/bootstrap.yml

@@ -259,6 +259,15 @@ spring:
           filters:
             - StripPrefix=1
             - CpAuth=true
+        #政府端-数据首页
+        - id: data-report-server
+          uri: @gateway.routes.data-report-server.uri@
+          order: 28
+          predicates:
+            - Path=${server.servlet.context-path}/data/report/**
+          filters:
+            - StripPrefix=1
+            - CpAuth=true
     nacos:
       discovery:
         server-addr: @nacos.server-addr@

epmet-module/data-statistical/data-statistical-client/src/main/java/feign/StatsPublicityFeignClient.java

@@ -60,5 +60,28 @@ public interface StatsPublicityFeignClient {
  @PostMapping(value = "data/stats/statspublicity/tagViewedMonthStatsjob")
  Result tagViewedMonthStatsjob();
 
+ /**
+  * @Description  统计 “网格小组”， dim：【网格-日】
+  * @param
+  * @author zxc
+  */
+ @PostMapping("/data/stats/statsgroup/groupgriddaily")
+ Result groupGridDaily();
+
+ /**
+  * @Description  统计 “网格小组”， dim：【机关-日】
+  * @param
+  * @author zxc
+  */
+ @PostMapping("/data/stats/statsgroup/groupagencydaily")
+ Result groupAgencyDaily();
+
+ /**
+  * @Description  统计 “网格小组”， dim：【机关-月】
+  * @param
+  * @author zxc
+  */
+ @PostMapping("/data/stats/statsgroup/groupagencymonthly")
+ Result groupAgencyMonthly();
 
 }

epmet-module/data-statistical/data-statistical-client/src/main/java/feign/impl/StatsPublicityFeignClientFallBack.java

@@ -72,4 +72,19 @@ public class StatsPublicityFeignClientFallBack implements StatsPublicityFeignCli
     public Result tagViewedMonthStatsjob() {
         return ModuleUtils.feignConError(ServiceConstant.GOV_ISSUE_SERVER, "tagViewedMonthStatsjob");
     }
+
+    @Override
+    public Result groupGridDaily() {
+        return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "groupGridDaily");
+    }
+
+    @Override
+    public Result groupAgencyDaily() {
+        return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "groupAgencyDaily");
+    }
+
+    @Override
+    public Result groupAgencyMonthly() {
+        return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "groupAgencyMonthly");
+    }
 }

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/StatsGroupService.java

@@ -0,0 +1,32 @@
+package com.epmet.service;
+
+import com.epmet.commons.tools.utils.Result;
+
+/**
+ * @Author zxc
+ * @CreateTime 2020/6/22 14:12
+ */
+public interface StatsGroupService {
+
+    /**
+     * @Description  统计 “网格小组”， dim：【网格-日】
+     * @param
+     * @author zxc
+     */
+    Result groupGridDaily();
+
+    /**
+     * @Description  统计 “网格小组”， dim：【机关-日】
+     * @param
+     * @author zxc
+     */
+    Result groupAgencyDaily();
+
+    /**
+     * @Description  统计 “网格小组”， dim：【机关-月】
+     * @param
+     * @author zxc
+     */
+    Result groupAgencyMonthly();
+
+}

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/StatsGroupServiceImpl.java

@@ -0,0 +1,30 @@
+package com.epmet.service.impl;
+
+import com.epmet.service.StatsGroupService;
+import feign.StatsPublicityFeignClient;
+import org.springframework.beans.factory.annotation.Autowired;
+
+/**
+ * @Author zxc
+ * @CreateTime 2020/6/22 14:13
+ */
+public class StatsGroupServiceImpl implements StatsGroupService {
+
+    @Autowired
+    private StatsPublicityFeignClient statsPublicityFeignClient;
+
+    @Override
+    public void groupGridDaily() {
+        statsPublicityFeignClient.groupGridDaily();
+    }
+
+    @Override
+    public void groupAgencyDaily() {
+        statsPublicityFeignClient.groupAgencyDaily();
+    }
+
+    @Override
+    public void groupAgencyMonthly() {
+        statsPublicityFeignClient.groupAgencyMonthly();
+    }
+}

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/StatsGroupAgencyDailyTask.java

@@ -0,0 +1,32 @@
+package com.epmet.task;
+
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.service.StatsGroupService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+
+/**
+ * @Author zxc
+ * @CreateTime 2020/6/22 14:09
+ *
+ * 统计 “网格小组”， dim：【机关-日】
+ */
+public class StatsGroupAgencyDailyTask implements ITask {
+
+    @Autowired
+    private StatsGroupService statsGroupService;
+
+    private Logger logger = LoggerFactory.getLogger(getClass());
+
+    @Override
+    public void run(String params) {
+        logger.debug("StatsGroupAgencyDailyTask定时任务正在执行，参数为：{}", params);
+        Result result = statsGroupService.groupGridDaily();
+        if (result.success()){
+            logger.debug("StatsGroupAgencyDailyTask定时任务正在执行定时任务执行成功");
+        }else {
+            logger.debug("StatsGroupAgencyDailyTask定时任务正在执行定时任务执行失败:" + result.getMsg());
+        }
+    }
+}

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/StatsGroupAgencyMonthlyTask.java

@@ -0,0 +1,32 @@
+package com.epmet.task;
+
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.service.StatsGroupService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+
+/**
+ * @Author zxc
+ * @CreateTime 2020/6/22 14:09
+ *
+ * 统计 “网格小组”， dim：【机关-日】
+ */
+public class StatsGroupAgencyMonthlyTask implements ITask {
+
+    @Autowired
+    private StatsGroupService statsGroupService;
+
+    private Logger logger = LoggerFactory.getLogger(getClass());
+
+    @Override
+    public void run(String params) {
+        logger.debug("StatsGroupAgencyMonthlyTask定时任务正在执行，参数为：{}", params);
+        Result result = statsGroupService.groupAgencyMonthly();
+        if (result.success()){
+            logger.debug("StatsGroupAgencyMonthlyTask定时任务正在执行定时任务执行成功");
+        }else {
+            logger.debug("StatsGroupAgencyMonthlyTask定时任务正在执行定时任务执行失败:" + result.getMsg());
+        }
+    }
+}

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/StatsGroupGridDailyTask.java

@@ -0,0 +1,33 @@
+package com.epmet.task;
+
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.service.StatsGroupService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+
+/**
+ * @Author zxc
+ * @CreateTime 2020/6/22 14:09
+ *
+ * 统计 “网格小组”， dim：【网格-日】
+ *
+ */
+public class StatsGroupGridDailyTask implements ITask {
+
+    @Autowired
+    private StatsGroupService statsGroupService;
+
+    private Logger logger = LoggerFactory.getLogger(getClass());
+
+    @Override
+    public void run(String params) {
+        logger.debug("StatsGroupGridDailyTask定时任务正在执行，参数为：{}", params);
+        Result result = statsGroupService.groupAgencyDaily();
+        if (result.success()){
+            logger.debug("StatsGroupGridDailyTask定时任务正在执行定时任务执行成功");
+        }else {
+            logger.debug("StatsGroupGridDailyTask定时任务正在执行定时任务执行失败:" + result.getMsg());
+        }
+    }
+}