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

format

feature/zhy_unlock
zhangyuan 4 years ago
parent
f1feb0f1d2
commit
3523c87ded
1 changed files with 41 additions and 41 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. 82
      epdc-cloud-job/src/main/java/com/elink/esua/epdc/service/impl/ScreenProjectDataPushDayTaskImpl.java

82
epdc-cloud-job/src/main/java/com/elink/esua/epdc/service/impl/ScreenProjectDataPushDayTaskImpl.java
View File

@ -42,43 +42,43 @@ public class ScreenProjectDataPushDayTaskImpl implements ScreenProjectDataMonthP
@Override @Override
public void run(String param) { public void run(String param) {
for(int i = 0 ; i < 11 ; i++){ for (int i = 0; i < 11; i++) {
createThread(i); createThread(i);
} }
} }
public Integer createThread(Integer methodIndex){ public Integer createThread(Integer methodIndex) {
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) {
projectGridDaily(); projectGridDaily();
} else if (methodIndex == 1){ } else if (methodIndex == 1) {
projectOrgDaily(); projectOrgDaily();
}else if (methodIndex == 2){ } else if (methodIndex == 2) {
uploadProjectInfo(); uploadProjectInfo();
} else if (methodIndex == 3){ } else if (methodIndex == 3) {
uploadProjectProcess(); uploadProjectProcess();
}else if (methodIndex == 4){ } else if (methodIndex == 4) {
//001、基层党建-党员基本情况 //001、基层党建-党员基本情况
customerCpcbasedata(); customerCpcbasedata();
}else if (methodIndex == 5){ } else if (methodIndex == 5) {
//002、党建引领-先锋模范数据 //002、党建引领-先锋模范数据
customerPioneerdata(); customerPioneerdata();
}else if (methodIndex == 6){ } else if (methodIndex == 6) {
//003、党建引领-党员联系群众数据 //003、党建引领-党员联系群众数据
customerPartylinkmassesdata(); customerPartylinkmassesdata();
}else if (methodIndex == 7){ } else if (methodIndex == 7) {
//005、党建引领|基层治理-居民（党员）积分排行榜 //005、党建引领|基层治理-居民（党员）积分排行榜
customerPartyuserrankdata(); customerPartyuserrankdata();
}else if (methodIndex == 8){ } else if (methodIndex == 8) {
//006、基层治理-难点赌点项目上报 //006、基层治理-难点赌点项目上报
customerDifficultydata(); customerDifficultydata();
}else if (methodIndex == 9){ } else if (methodIndex == 9) {
// 008、公众参与各类总数 // 008、公众参与各类总数
customerPublicpartitotaldata(); customerPublicpartitotaldata();
}else if (methodIndex == 10){ } else if (methodIndex == 10) {
// 010、中央区各类总数 // 010、中央区各类总数
// customerUsertotaldata(); // customerUsertotaldata();
} }
@ -88,39 +88,40 @@ public class ScreenProjectDataPushDayTaskImpl implements ScreenProjectDataMonthP
Integer isSuccess = 0; Integer isSuccess = 0;
try { try {
isSuccess = future.get(); isSuccess = future.get();
}catch (Exception e){ } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
return isSuccess; return isSuccess;
} }
/** /**
* @Description 项目信息上报 * @return void
* @Description 项目信息上报
* @Author songyunpeng * @Author songyunpeng
* @Date 2021/2/24 * @Date 2021/2/24
* @Param [] * @Param []
* @return void
**/ **/
private void uploadProjectInfo() { private void uploadProjectInfo() {
// 方法名 // 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|项目信息上报>定时任务开始执行"); logger.info("<" + methodName + "|项目信息上报>定时任务开始执行");
//获取上次统计时间 //获取上次统计时间
Map<String,Object> param = new HashMap<>(); Map<String, Object> param = new HashMap<>();
param.put("JOB_NAME","uploadProjectInfo"); param.put("JOB_NAME", "uploadProjectInfo");
List<ScreenRecordEntity> screenRecordEntities = screenRecordDao.selectByMap(param); List<ScreenRecordEntity> screenRecordEntities = screenRecordDao.selectByMap(param);
ScreenRecordEntity screenRecordEntity = new ScreenRecordEntity(); ScreenRecordEntity screenRecordEntity = new ScreenRecordEntity();
ScreenProjectFormDTO screenProjectFormDTO = new ScreenProjectFormDTO(); ScreenProjectFormDTO screenProjectFormDTO = new ScreenProjectFormDTO();
if(screenRecordEntities==null || screenRecordEntities.size()==0){ if (screenRecordEntities == null || screenRecordEntities.size() == 0) {
screenProjectFormDTO.setYearMonthDay("2020-01-01"); screenProjectFormDTO.setYearMonthDay("2020-01-01");
}else { } else {
screenRecordEntity = screenRecordEntities.get(0); screenRecordEntity = screenRecordEntities.get(0);
screenProjectFormDTO.setYearMonthDay(DateUtils.format(screenRecordEntity.getStatisticsTime(), DateUtils.DATE_PATTERN)); screenProjectFormDTO.setYearMonthDay(DateUtils.format(screenRecordEntity.getStatisticsTime(), DateUtils.DATE_PATTERN));
} }
//记录此次统计时间 并更新时间或者新增 //记录此次统计时间 并更新时间或者新增
screenRecordEntity.setStatisticsTime(DateUtils.addDateDays(new Date(),-1)); screenRecordEntity.setStatisticsTime(DateUtils.addDateDays(new Date(), -1));
if(StringUtils.isNotBlank(screenRecordEntity.getId())){ if (StringUtils.isNotBlank(screenRecordEntity.getId())) {
screenRecordDao.updateById(screenRecordEntity); screenRecordDao.updateById(screenRecordEntity);
}else { } else {
screenRecordEntity.setJobName("uploadProjectInfo"); screenRecordEntity.setJobName("uploadProjectInfo");
screenRecordDao.insert(screenRecordEntity); screenRecordDao.insert(screenRecordEntity);
} }
@ -129,33 +130,33 @@ public class ScreenProjectDataPushDayTaskImpl implements ScreenProjectDataMonthP
} }
/** /**
* @Description 项目处理流程信息上报 * @return void
* @Description 项目处理流程信息上报
* @Author songyunpeng * @Author songyunpeng
* @Date 2021/2/24 * @Date 2021/2/24
* @Param [] * @Param []
* @return void
**/ **/
private void uploadProjectProcess() { private void uploadProjectProcess() {
// 方法名 // 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|项目处理流程信息上报>定时任务开始执行"); logger.info("<" + methodName + "|项目处理流程信息上报>定时任务开始执行");
//获取上次统计时间 //获取上次统计时间
Map<String,Object> param = new HashMap<>(); Map<String, Object> param = new HashMap<>();
param.put("JOB_NAME","uploadProjectProcess"); param.put("JOB_NAME", "uploadProjectProcess");
List<ScreenRecordEntity> screenRecordEntities = screenRecordDao.selectByMap(param); List<ScreenRecordEntity> screenRecordEntities = screenRecordDao.selectByMap(param);
ScreenRecordEntity screenRecordEntity = new ScreenRecordEntity(); ScreenRecordEntity screenRecordEntity = new ScreenRecordEntity();
ScreenProjectFormDTO screenProjectFormDTO = new ScreenProjectFormDTO(); ScreenProjectFormDTO screenProjectFormDTO = new ScreenProjectFormDTO();
if(screenRecordEntities==null || screenRecordEntities.size()==0){ if (screenRecordEntities == null || screenRecordEntities.size() == 0) {
screenProjectFormDTO.setYearMonthDay("2020-01-01"); screenProjectFormDTO.setYearMonthDay("2020-01-01");
}else { } else {
screenRecordEntity = screenRecordEntities.get(0); screenRecordEntity = screenRecordEntities.get(0);
screenProjectFormDTO.setYearMonthDay(DateUtils.format(screenRecordEntity.getStatisticsTime(), DateUtils.DATE_PATTERN)); screenProjectFormDTO.setYearMonthDay(DateUtils.format(screenRecordEntity.getStatisticsTime(), DateUtils.DATE_PATTERN));
} }
//记录此次统计时间 并更新时间或者新增 //记录此次统计时间 并更新时间或者新增
screenRecordEntity.setStatisticsTime(DateUtils.addDateDays(new Date(),-1)); screenRecordEntity.setStatisticsTime(DateUtils.addDateDays(new Date(), -1));
if(StringUtils.isNotBlank(screenRecordEntity.getId())){ if (StringUtils.isNotBlank(screenRecordEntity.getId())) {
screenRecordDao.updateById(screenRecordEntity); screenRecordDao.updateById(screenRecordEntity);
}else { } else {
screenRecordEntity.setJobName("uploadProjectProcess"); screenRecordEntity.setJobName("uploadProjectProcess");
screenRecordDao.insert(screenRecordEntity); screenRecordDao.insert(screenRecordEntity);
} }
@ -164,12 +165,12 @@ public class ScreenProjectDataPushDayTaskImpl implements ScreenProjectDataMonthP
} }
/** /**
* @describe: 【事件/项目分析】网格内事件 * @return void
* @author wangtong * @describe: 【事件/项目分析】网格内事件
* @date 2021/2/24 13:57 * @author wangtong
* @params [] * @date 2021/2/24 13:57
* @return void * @params []
*/ */
private void projectGridDaily() { private void projectGridDaily() {
// 方法名 // 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName(); String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
@ -180,11 +181,11 @@ public class ScreenProjectDataPushDayTaskImpl implements ScreenProjectDataMonthP
} }
/** /**
* @return void
* @describe: 【事件/项目分析】组织内事件 * @describe: 【事件/项目分析】组织内事件
* @author wangtong * @author wangtong
* @date 2021/2/24 13:57 * @date 2021/2/24 13:57
* @params [] * @params []
* @return void
*/ */
private void projectOrgDaily() { private void projectOrgDaily() {
// 方法名 // 方法名
@ -225,7 +226,6 @@ public class ScreenProjectDataPushDayTaskImpl implements ScreenProjectDataMonthP
} }
/** /**
* 006、基层治理-难点赌点项目上报 * 006、基层治理-难点赌点项目上报
* *

Write Preview
Loading…
Cancel
Save