elink-star
/
epdc-cloud-job-yushan
12
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

修改

feature/qst_copy
曲树通 5 years ago
parent
7e050db193
commit
a0dcf05f5e
1 changed files with 11 additions and 109 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 120
      epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/ScreenPublicDataPushTaskImpl.java

120
epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/ScreenPublicDataPushTaskImpl.java
View File

@ -25,6 +25,8 @@ import java.util.concurrent.Future;
@Component("screenPublicDataPushTask") @Component("screenPublicDataPushTask")
public class ScreenPublicDataPushTaskImpl implements ScreenPublicDataPushTask { public class ScreenPublicDataPushTaskImpl implements ScreenPublicDataPushTask {
private final Logger logger = LoggerFactory.getLogger(getClass()); private final Logger logger = LoggerFactory.getLogger(getClass());
private static final ExecutorService service = Executors.newFixedThreadPool(100); private static final ExecutorService service = Executors.newFixedThreadPool(100);
@ -35,37 +37,27 @@ public class ScreenPublicDataPushTaskImpl implements ScreenPublicDataPushTask {
@Override @Override
public void run(String param) { public void run(String param) {
// 参数处理 // 参数处理
ScreenJobMonthDataParamDTO paramDto = new ScreenJobMonthDataParamDTO(); ScreenJobBasicDataParamDTO paramDto = new ScreenJobBasicDataParamDTO();
if (StringUtils.isNotEmpty(param)) { if (StringUtils.isNotEmpty(param)) {
paramDto = JSONObject.parseObject(param, ScreenJobMonthDataParamDTO.class); paramDto = JSONObject.parseObject(param, ScreenJobBasicDataParamDTO.class);
} }
for(int i = 0 ; i < 5 ; i++){ for(int i = 0 ; i < 13 ; i++){
createThread(i,paramDto); createThread(i, paramDto);
} }
} }
public Integer createThread(Integer methodIndex, ScreenJobMonthDataParamDTO paramDto){ public Integer createThread(Integer methodIndex, ScreenJobBasicDataParamDTO paramDto){
Future<Integer> future = service.submit(new Callable<Integer>() { Future<Integer> future = service.submit(new Callable<Integer>() {
@Override @Override
public Integer call() throws Exception { public Integer call() throws Exception {
Thread.sleep(200); Thread.sleep(200);
if (methodIndex == 0) { if (methodIndex == 0) {
quantityGridMonthly(paramDto.getGridMonthDataMonthId()); customerAgency();
} else if (methodIndex == 1){ } else if (methodIndex == 1){
quantityOrgMonthly(paramDto.getOrgMonthDataMonthId()); customerGrid();
}else if (methodIndex == 2){ } else if (methodIndex == 2){
//004、党建引领-先进排行榜单-先进支部排行 -- customerDept();
customerOrgrankdata(paramDto.getCustomerOrgRankDataMonthId());
}else if (methodIndex == 3){
//007、基层治理-公众参与 --
customerUserjoin(paramDto.getCustomerUserJoinMonthId());
}else if (methodIndex == 4){
//009、基层治理-治理能力数据 --
customerGovernrankdata(paramDto.getCustomerGovernRankData());
} }
customerAgency();
customerGrid();
customerDept();
return 0; return 0;
} }
}); });
@ -77,7 +69,6 @@ public class ScreenPublicDataPushTaskImpl implements ScreenPublicDataPushTask {
} }
return isSuccess; return isSuccess;
} }
/** /**
* 014、组织层级 * 014、组织层级
* *
@ -92,41 +83,7 @@ public class ScreenPublicDataPushTaskImpl implements ScreenPublicDataPushTask {
analysisFeignClient.customerAgency(); analysisFeignClient.customerAgency();
logger.info("<" + methodName + "|组织层级上传>定时任务执行结束"); logger.info("<" + methodName + "|组织层级上传>定时任务执行结束");
} }
/**
* @describe: 【事件/项目分析】网格内月度数量统计
* @author wangtong
* @date 2021/2/24 13:57
* @params []
* @return void
* @param gridMonthDataMonthId
*/
private void quantityGridMonthly(String gridMonthDataMonthId) {
ScreenJobFormDTO formDto = new ScreenJobFormDTO();
formDto.setYearMonth(gridMonthDataMonthId);
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|【事件/项目分析】网格内月度数量统计>定时任务开始执行");
analysisFeignClient.quantityGridMonthly(formDto);
logger.info("<" + methodName + "|【事件/项目分析】网格内月度数量统计>定时任务执行结束");
}
/**
* @describe: 【事件/项目分析】组织内月度数量统计
* @author wangtong
* @date 2021/2/24 13:57
* @params []
* @return void
* @param orgMonthDataMonthId
*/
private void quantityOrgMonthly(String orgMonthDataMonthId) {
ScreenJobFormDTO formDto = new ScreenJobFormDTO();
formDto.setYearMonth(orgMonthDataMonthId);
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|事件/项目分析】组织内月度数量统计>定时任务开始执行");
analysisFeignClient.quantityOrgMonthly(formDto);
logger.info("<" + methodName + "|事件/项目分析】组织内月度数量统计>定时任务执行结束");
}
/** /**
* 015、网格信息上传 * 015、网格信息上传
* *
@ -156,59 +113,4 @@ public class ScreenPublicDataPushTaskImpl implements ScreenPublicDataPushTask {
analysisFeignClient.customerDept(); analysisFeignClient.customerDept();
logger.info("<" + methodName + "|部门信息上传>定时任务执行结束"); logger.info("<" + methodName + "|部门信息上传>定时任务执行结束");
} }
/**
* 004、党建引领-先进排行榜单-先进支部排行
*
* @return void
* @author WK
* @since 2020/9/17 14:01
* @param customerOrgRankDataMonthId
*/
private void customerOrgrankdata(String customerOrgRankDataMonthId) {
ScreenJobFormDTO formDto = new ScreenJobFormDTO();
formDto.setYearMonth(customerOrgRankDataMonthId);
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|党建引领-先进排行榜单-先进支部排行>定时任务开始执行");
analysisFeignClient.orgrankdata(formDto);
logger.info("<" + methodName + "|党建引领-先进排行榜单-先进支部排行>定时任务执行结束");
}
/**
* 007、基层治理-公众参与
*
* @return void
* @author WK
* @since 2020/9/17 14:01
* @param customerUserJoinMonthId
*/
private void customerUserjoin(String customerUserJoinMonthId) {
ScreenJobFormDTO formDto = new ScreenJobFormDTO();
formDto.setYearMonth(customerUserJoinMonthId);
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|基层治理-公众参与>定时任务开始执行");
analysisFeignClient.userjoin(formDto);
logger.info("<" + methodName + "|基层治理-公众参与>定时任务执行结束");
}
/**
* 009、基层治理-治理能力数据
*
* @return void
* @author WK
* @since 2020/9/17 14:01
* @param customerGovernRankData
*/
private void customerGovernrankdata(String customerGovernRankData) {
ScreenJobFormDTO formDto = new ScreenJobFormDTO();
formDto.setYearMonth(customerGovernRankData);
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|基层治理-治理能力数据>定时任务开始执行");
analysisFeignClient.governrankdata(formDto);
logger.info("<" + methodName + "|基层治理-治理能力数据>定时任务执行结束");
}
} }

Write Preview
Loading…
Cancel
Save