diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenProjectDataServiceImpl.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenProjectDataServiceImpl.java index a39894b4..55cdcd4d 100644 --- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenProjectDataServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenProjectDataServiceImpl.java @@ -31,6 +31,7 @@ public class ScreenProjectDataServiceImpl extends BaseServiceImpl data = baseDao.uploadProjectInfo(screenProjectFormDTO); + String resultStr = "1"; // [0:失败;1:成功] if(data.size()!=0) { if (data.size() > 1000) { List> formList = ScreenIndexDataServiceImpl.fixedGrouping(data, NumConstant.ONE_THOUSAND); @@ -40,23 +41,24 @@ public class ScreenProjectDataServiceImpl extends BaseServiceImpl data = baseDao.uploadProjectProcess(screenProjectFormDTO); + String resultStr = "1"; // [0:失败;1:成功] if(data.size()!=0){ if (data.size() > 1000) { List> formList = ScreenIndexDataServiceImpl.fixedGrouping(data, NumConstant.ONE_THOUSAND); @@ -66,17 +68,17 @@ public class ScreenProjectDataServiceImpl extends BaseServiceImpl定时任务执行结束"); @@ -130,17 +134,21 @@ public class ScreenProjectPushTaskImpl implements ScreenIndexDataPushTask { screenProjectFormDTO.setYearMonthDay(screenRecordEntity.getStatisticsTime()); } - analysisFeignClient.uploadProjectProcess(screenProjectFormDTO); - - //记录此次统计时间 并更新时间或者新增 - screenRecordEntity.setStatisticsTime(new Date()); - if (StringUtils.isNotBlank(screenRecordEntity.getId())) { - screenRecordDao.updateById(screenRecordEntity); - } else { - screenRecordEntity.setJobName("uploadProjectProcess"); - screenRecordDao.insert(screenRecordEntity); + Result result = analysisFeignClient.uploadProjectProcess(screenProjectFormDTO); + + // [0:失败;1:成功] 成功后修改时间 + if("1".equals(result.getData())){ + //记录此次统计时间 并更新时间或者新增 + screenRecordEntity.setStatisticsTime(new Date()); + if (StringUtils.isNotBlank(screenRecordEntity.getId())) { + screenRecordDao.updateById(screenRecordEntity); + } else { + screenRecordEntity.setJobName("uploadProjectProcess"); + screenRecordDao.insert(screenRecordEntity); + } } + logger.info("<" + methodName + "|项目处理流程信息上报>定时任务执行结束"); } }