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 index 9e0d1c2..a65bb77 100644 --- 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 @@ -1,6 +1,7 @@ package com.elink.esua.epdc.service.impl; import com.elink.esua.epdc.commons.tools.utils.DateUtils; +import com.elink.esua.epdc.commons.tools.utils.Result; import com.elink.esua.epdc.dao.ScreenRecordDao; import com.elink.esua.epdc.dto.analysis.pc.screen.form.ScreenProjectFormDTO; import com.elink.esua.epdc.entity.ScreenRecordEntity; @@ -120,15 +121,18 @@ public class ScreenProjectDataPushMinuteTaskImpl implements ScreenProjectDataMon screenProjectFormDTO.setYearMonthDay(screenRecordEntity.getStatisticsTime()); } - analysisFeignClient.uploadProjectInfo(screenProjectFormDTO); - - //记录此次统计时间 并更新时间或者新增 - screenRecordEntity.setStatisticsTime(new Date()); - if (StringUtils.isNotBlank(screenRecordEntity.getId())) { - screenRecordDao.updateById(screenRecordEntity); - } else { - screenRecordEntity.setJobName("uploadProjectInfo"); - screenRecordDao.insert(screenRecordEntity); + Result result = analysisFeignClient.uploadProjectInfo(screenProjectFormDTO); + + // [0:失败;1:成功] 成功后修改时间 + if("1".equals(result.getData())){ + //记录此次统计时间 并更新时间或者新增 + screenRecordEntity.setStatisticsTime(new Date()); + if (StringUtils.isNotBlank(screenRecordEntity.getId())) { + screenRecordDao.updateById(screenRecordEntity); + } else { + screenRecordEntity.setJobName("uploadProjectInfo"); + screenRecordDao.insert(screenRecordEntity); + } } logger.info("<" + methodName + "|项目信息上报>定时任务执行结束"); @@ -158,17 +162,21 @@ public class ScreenProjectDataPushMinuteTaskImpl implements ScreenProjectDataMon 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 + "|项目处理流程信息上报>定时任务执行结束"); } }