diff --git a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/service/impl/ScreenProjectDataPushDayTaskImpl.java b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/service/impl/ScreenProjectDataPushDayTaskImpl.java index 27c8660..376da40 100644 --- a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/service/impl/ScreenProjectDataPushDayTaskImpl.java +++ b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/service/impl/ScreenProjectDataPushDayTaskImpl.java @@ -80,7 +80,7 @@ public class ScreenProjectDataPushDayTaskImpl implements ScreenProjectDataMonthP customerPublicpartitotaldata(); }else if (methodIndex == 10){ // 010、中央区各类总数 - customerUsertotaldata(); +// customerUsertotaldata(); } return 0; } @@ -193,22 +193,21 @@ public class ScreenProjectDataPushDayTaskImpl implements ScreenProjectDataMonthP analysisFeignClient.projectOrgDaily(); logger.info("<" + methodName + "|事件/项目分析】组织内事件>定时任务执行结束"); } - /** - * 010、中央区各类总数 - * - * @return void - * @author WK - * @since 2020/9/17 14:01 - */ - private void customerUsertotaldata() { - // 方法名 - String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); - logger.info("<" + methodName + "|中央区各类总数>定时任务开始执行"); - analysisFeignClient.usertotaldata(); - logger.info("<" + methodName + "|中央区各类总数>定时任务执行结束"); - } - +// /** +// * 010、中央区各类总数 +// * +// * @return void +// * @author WK +// * @since 2020/9/17 14:01 +// */ +// private void customerUsertotaldata() { +// // 方法名 +// String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); +// logger.info("<" + methodName + "|中央区各类总数>定时任务开始执行"); +// analysisFeignClient.usertotaldata(); +// logger.info("<" + methodName + "|中央区各类总数>定时任务执行结束"); +// } /** * 008、公众参与各类总数 diff --git a/epdc-cloud-job/src/main/java/com/elink/esua/epdc/service/impl/ScreenProjectDataPushMinuteTaskImpl.java b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/service/impl/ScreenProjectDataPushMinuteTaskImpl.java new file mode 100644 index 0000000..f1b4d1d --- /dev/null +++ b/epdc-cloud-job/src/main/java/com/elink/esua/epdc/service/impl/ScreenProjectDataPushMinuteTaskImpl.java @@ -0,0 +1,76 @@ +package com.elink.esua.epdc.service.impl; + +import com.elink.esua.epdc.dao.ScreenRecordDao; +import com.elink.esua.epdc.feign.AnalysisFeignClient; +import com.elink.esua.epdc.service.ScreenProjectDataMonthPushTask; +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: wangtong + * @create: 2021-02-24 13:48 + **/ +@Component("screenProjectDataPushMinuteTask") +public class ScreenProjectDataPushMinuteTaskImpl implements ScreenProjectDataMonthPushTask { + + private final Logger logger = LoggerFactory.getLogger(getClass()); + + private static final ExecutorService service = Executors.newFixedThreadPool(100); + + @Autowired + private AnalysisFeignClient analysisFeignClient; + + @Autowired + private ScreenRecordDao screenRecordDao; + + @Override + public void run(String param) { + for (int i = 0; i < 11; i++) { + createThread(i); + } + } + + public Integer createThread(Integer methodIndex) { + Future future = service.submit(new Callable() { + @Override + public Integer call() throws Exception { + Thread.sleep(200); + // 010、中央区各类总数 + customerUsertotaldata(); + return 0; + } + }); + Integer isSuccess = 0; + try { + isSuccess = future.get(); + } catch (Exception e) { + e.printStackTrace(); + } + return isSuccess; + } + + /** + * 010、中央区各类总数 + * + * @return void + * @author WK + * @since 2020/9/17 14:01 + */ + private void customerUsertotaldata() { + // 方法名 + String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); + logger.info("<" + methodName + "|中央区各类总数>定时任务开始执行"); + analysisFeignClient.usertotaldata(); + logger.info("<" + methodName + "|中央区各类总数>定时任务执行结束"); + } + +} \ No newline at end of file