【大屏展示】-【大屏党建、服务、治理相关定时任务开发】-（王童）-2020/9/2

esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/CloudAnalysisFeignClient.java

@@ -57,4 +57,83 @@ public interface CloudAnalysisFeignClient {
     Result userjoin();
 
 
+    /**
+    * @describe: 党建能力-党员相关指标上报
+    * @author wangtong
+    * @date 2020/9/2 15:47
+    * @params []
+    * @return com.elink.esua.epdc.commons.tools.utils.Result
+    */
+    @PostMapping("cloudAnalysis/indexcollect/gridpartymemberdata")
+    Result gridpartymemberdata();
+
+    /**
+    * @describe: 党建能力-网格相关指标上报
+    * @author wangtong
+    * @date 2020/9/2 15:47
+    * @params []
+    * @return com.elink.esua.epdc.commons.tools.utils.Result
+    */
+    @PostMapping("cloudAnalysis/indexcollect/gridpartyability")
+    Result gridpartyability();
+
+    /**
+    * @describe: 党建能力-街道及社区相关指标
+    * @author wangtong
+    * @date 2020/9/2 15:47
+    * @params []
+    * @return com.elink.esua.epdc.commons.tools.utils.Result
+    */
+    @PostMapping("cloudAnalysis/indexcollect/orgpartyability")
+    Result orgpartyability();
+
+    /**
+    * @describe: 服务能力-网格相关指标
+    * @author wangtong
+    * @date 2020/9/2 15:48
+    * @params []
+    * @return com.elink.esua.epdc.commons.tools.utils.Result
+    */
+    @PostMapping("cloudAnalysis/indexcollect/gridserviceability")
+    Result gridserviceability();
+
+    /**
+    * @describe: 服务能力-组织（街道|社区|全区）相关指标
+    * @author wangtong
+    * @date 2020/9/2 15:48
+    * @params []
+    * @return com.elink.esua.epdc.commons.tools.utils.Result
+    */
+    @PostMapping("cloudAnalysis/indexcollect/orgserviceability")
+    Result orgserviceability();
+
+    /**
+    * @describe: 治理能力-网格相关指标
+    * @author wangtong
+    * @date 2020/9/2 15:48
+    * @params []
+    * @return com.elink.esua.epdc.commons.tools.utils.Result
+    */
+    @PostMapping("cloudAnalysis/indexcollect/gridgovrnability")
+    Result gridgovrnability();
+
+    /**
+    * @describe: 治理能力-街道及社区相关指标
+    * @author wangtong
+    * @date 2020/9/2 15:48
+    * @params []
+    * @return com.elink.esua.epdc.commons.tools.utils.Result
+    */
+    @PostMapping("cloudAnalysis/indexcollect/orggovrnability")
+    Result orggovrnability();
+
+    /**
+    * @describe: 治理能力-部门相关指标
+    * @author wangtong
+    * @date 2020/9/2 15:50
+    * @params []
+    * @return com.elink.esua.epdc.commons.tools.utils.Result
+    */
+    @PostMapping("cloudAnalysis/indexcollect/deptgovrnability")
+    Result deptgovrnability();
 }

esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/CloudAnalysisFeignClientFallback.java

@@ -63,5 +63,45 @@ public class CloudAnalysisFeignClientFallback implements CloudAnalysisFeignClien
         return ModuleUtils.feignConError(ServiceConstant.EPDC_CLOUD_ANALYSIS_SERVER, "userjoin");
     }
 
+    @Override
+    public Result gridpartymemberdata() {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_CLOUD_ANALYSIS_SERVER, "gridpartymemberdata");
+    }
+
+    @Override
+    public Result gridpartyability() {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_CLOUD_ANALYSIS_SERVER, "gridpartyability");
+    }
+
+    @Override
+    public Result orgpartyability() {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_CLOUD_ANALYSIS_SERVER, "orgpartyability");
+    }
+
+    @Override
+    public Result gridserviceability() {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_CLOUD_ANALYSIS_SERVER, "gridserviceability");
+    }
+
+    @Override
+    public Result orgserviceability() {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_CLOUD_ANALYSIS_SERVER, "orgserviceability");
+    }
+
+    @Override
+    public Result gridgovrnability() {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_CLOUD_ANALYSIS_SERVER, "gridgovrnability");
+    }
+
+    @Override
+    public Result orggovrnability() {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_CLOUD_ANALYSIS_SERVER, "orggovrnability");
+    }
+
+    @Override
+    public Result deptgovrnability() {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_CLOUD_ANALYSIS_SERVER, "deptgovrnability");
+    }
+
 
 }

esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/PushDataEveryMonthTask.java

@@ -0,0 +1,21 @@
+package com.elink.esua.epdc.task.screen;
+
+
+/**
+* @describe: 大屏展示推送数据接口-每月推送一次
+* @author wangtong
+* @date 2020-9-2 15:38
+*/
+public interface PushDataEveryMonthTask {
+
+    /**
+    * @describe: 大屏数据推送
+    * @author wangtong
+    * @date 2020/9/2 15:38
+    * @params [param]
+    * @return void
+    */
+    void run(String param);
+
+
+}

esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/PushDataEveryMonthTaskImpl.java

@@ -0,0 +1,213 @@
+package com.elink.esua.epdc.task.screen;
+
+import com.elink.esua.epdc.feign.CloudAnalysisFeignClient;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+
+/**
+ * @program: esua-epdc
+ * @description: 大屏展示推送数据-每月
+ * @author: wangton
+ * @create: 2020-9-2 15:38
+ **/
+@Component("pushDataEveryDayTask")
+public class PushDataEveryMonthTaskImpl implements PushDataEveryMonthTask {
+
+    private Logger logger = LoggerFactory.getLogger(getClass());
+
+    //创建固定大小为100 的线程池
+    private static ExecutorService service = Executors.newFixedThreadPool(100);
+
+    @Autowired
+    private CloudAnalysisFeignClient cloudAnalysisFeignClient;
+
+    @Override
+    public void run(String param) {
+        for(int i = 0 ; i < 8 ; i++){
+            Integer integer = createThread(i);
+        }
+
+    }
+
+    /**
+     * 创建线程调用
+     * @param methodIndex
+     * @return
+     */
+    public Integer createThread(Integer methodIndex){
+        //使用Future，Callable实现发送消息后返回发送结果
+        Future<Integer> future = service.submit(new Callable<Integer>() {
+            @Override
+            public Integer call() throws Exception {
+                //调用相对比较耗时的发送消息接口
+                Thread.sleep(200);
+                if (methodIndex == 0) {
+                    // 调用-->党建能力-党员相关指标上报
+                    gridpartymemberdata();
+                } else if (methodIndex == 1){
+                    // 调用-->党建能力-网格相关指标上报
+                    gridpartyability();
+                } else if (methodIndex == 2){
+                    // 调用-->党建能力-街道及社区相关指标
+                    orgpartyability();
+                } else if (methodIndex == 3){
+                    // 调用-->服务能力-网格相关指标
+                    gridserviceability();
+                } else if (methodIndex == 4){
+                    // 调用-->服务能力-组织（街道|社区|全区）相关指标
+                    orgserviceability();
+                } else if (methodIndex == 5){
+                    // 调用-->治理能力-网格相关指标
+                    gridgovrnability();
+                } else if (methodIndex == 6){
+                    // 调用-->治理能力-街道及社区相关指标
+                    orggovrnability();
+                } else if (methodIndex == 7){
+                    // 调用-->治理能力-部门相关指标
+                    deptgovrnability();
+                }
+                return 0;
+            }
+        });
+        Integer isSuccess = 0;
+        try {
+            isSuccess = future.get();
+        }catch (Exception e){
+            e.printStackTrace();
+        }
+        return isSuccess;
+
+    }
+
+
+
+    /**
+     * @describe: 1、党建能力-党员相关指标上报
+     * @author wangtong
+     * @date 2020-9-2 15:40
+     * @params []
+     * @return void
+     */
+    public void gridpartymemberdata() {
+        //方法名
+        String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
+        logger.info("<" + methodName + "|党建能力-党员相关指标上报>定时任务开始执行");
+        cloudAnalysisFeignClient.gridpartymemberdata();
+        logger.info("<" + methodName + "|党建能力-党员相关指标上报>定时任务执行结束");
+    }
+
+    /**
+     * @describe: 2、党建能力-网格相关指标上报
+     * @author wanggongfeng
+     * @date 2020-9-2 15:40
+     * @params []
+     * @return void
+     */
+    public void gridpartyability() {
+        //方法名
+        String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
+        logger.info("<" + methodName + "|党建能力-网格相关指标上报>定时任务开始执行");
+        cloudAnalysisFeignClient.gridpartyability();
+        logger.info("<" + methodName + "|党建能力-网格相关指标上报>定时任务执行结束");
+    }
+
+    /**
+     * @describe: 3、党建能力-街道及社区相关指标
+     * @author wangtong
+     * @date 2020-9-2 15:40
+     * @params []
+     * @return void
+     */
+    public void orgpartyability() {
+        //方法名
+        String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
+        logger.info("<" + methodName + "|党建能力-街道及社区相关指标>定时任务开始执行");
+        cloudAnalysisFeignClient.orgpartyability();
+        logger.info("<" + methodName + "|党建能力-街道及社区相关指标>定时任务执行结束");
+    }
+
+    /**
+     * @describe: 4、服务能力-网格相关指标
+     * @author wanggongfeng
+     * @date 2020-9-2 15:40
+     * @params []
+     * @return void
+     */
+    public void gridserviceability() {
+        //方法名
+        String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
+        logger.info("<" + methodName + "|服务能力-网格相关指标>定时任务开始执行");
+        cloudAnalysisFeignClient.gridserviceability();
+        logger.info("<" + methodName + "|服务能力-网格相关指标>定时任务执行结束");
+    }
+
+    /**
+     * @describe: 5、服务能力-组织（街道|社区|全区）相关指标
+     * @author wanggongfeng
+     * @date 2020-9-2 15:40
+     * @params []
+     * @return void
+     */
+    public void orgserviceability() {
+        //方法名
+        String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
+        logger.info("<" + methodName + "|服务能力-组织（街道|社区|全区）相关指标>定时任务开始执行");
+        cloudAnalysisFeignClient.orgserviceability();
+        logger.info("<" + methodName + "|服务能力-组织（街道|社区|全区）相关指标>定时任务执行结束");
+    }
+
+    /**
+     * @describe: 6、治理能力-网格相关指标
+     * @author wanggongfeng
+     * @date 2020-9-2 15:40
+     * @params []
+     * @return void
+     */
+    public void gridgovrnability() {
+        //方法名
+        String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
+        logger.info("<" + methodName + "|治理能力-网格相关指标>定时任务开始执行");
+        cloudAnalysisFeignClient.gridgovrnability();
+        logger.info("<" + methodName + "|治理能力-网格相关指标>定时任务执行结束");
+    }
+
+    /**
+     * @describe: 7、治理能力-街道及社区相关指标
+     * @author wangtong
+     * @date 2020-9-2 15:40
+     * @params []
+     * @return void
+     */
+    public void orggovrnability() {
+        //方法名
+        String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
+        logger.info("<" + methodName + "|治理能力-街道及社区相关指标>定时任务开始执行");
+        cloudAnalysisFeignClient.orggovrnability();
+        logger.info("<" + methodName + "|治理能力-街道及社区相关指标>定时任务执行结束");
+    }
+
+    /**
+     * @describe: 8、治理能力-部门相关指标
+     * @author wangtong
+     * @date 2020-9-2 15:40
+     * @params []
+     * @return void
+     */
+    public void deptgovrnability() {
+        //方法名
+        String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
+        logger.info("<" + methodName + "|治理能力-部门相关指标>定时任务开始执行");
+        cloudAnalysisFeignClient.deptgovrnability();
+        logger.info("<" + methodName + "|治理能力-部门相关指标>定时任务执行结束");
+    }
+
+
+
+}