diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/CloudAnalysisFeignClient.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/CloudAnalysisFeignClient.java index 88acf052b..6bce7d434 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/CloudAnalysisFeignClient.java +++ b/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(); } diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/CloudAnalysisFeignClientFallback.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/CloudAnalysisFeignClientFallback.java index f43d8e7f4..d1e6984dd 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/feign/fallback/CloudAnalysisFeignClientFallback.java +++ b/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"); + } + } diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/PushDataEveryMonthTask.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/PushDataEveryMonthTask.java new file mode 100644 index 000000000..cd388d6e8 --- /dev/null +++ b/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); + + +} diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/PushDataEveryMonthTaskImpl.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/screen/PushDataEveryMonthTaskImpl.java new file mode 100644 index 000000000..5ed83bead --- /dev/null +++ b/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 future = service.submit(new Callable() { + @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 + "|治理能力-部门相关指标>定时任务执行结束"); + } + + + +} \ No newline at end of file