项目详情定时任务修改

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);
+        Result result = analysisFeignClient.uploadProjectInfo(screenProjectFormDTO);
-
+
-        //记录此次统计时间 并更新时间或者新增
+        // [0:失败；1：成功] 成功后修改时间
-        screenRecordEntity.setStatisticsTime(new Date());
+        if("1".equals(result.getData())){
-        if (StringUtils.isNotBlank(screenRecordEntity.getId())) {
+            //记录此次统计时间 并更新时间或者新增
-            screenRecordDao.updateById(screenRecordEntity);
+            screenRecordEntity.setStatisticsTime(new Date());
-        } else {
+            if (StringUtils.isNotBlank(screenRecordEntity.getId())) {
-            screenRecordEntity.setJobName("uploadProjectInfo");
+                screenRecordDao.updateById(screenRecordEntity);
-            screenRecordDao.insert(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);
+        Result result = analysisFeignClient.uploadProjectProcess(screenProjectFormDTO);
-
+
-        //记录此次统计时间 并更新时间或者新增
+        // [0:失败；1：成功] 成功后修改时间
-        screenRecordEntity.setStatisticsTime(new Date());
+        if("1".equals(result.getData())){
-        if (StringUtils.isNotBlank(screenRecordEntity.getId())) {
+            //记录此次统计时间 并更新时间或者新增
-            screenRecordDao.updateById(screenRecordEntity);
+            screenRecordEntity.setStatisticsTime(new Date());
-        } else {
+            if (StringUtils.isNotBlank(screenRecordEntity.getId())) {
-            screenRecordEntity.setJobName("uploadProjectProcess");
+                screenRecordDao.updateById(screenRecordEntity);
-            screenRecordDao.insert(screenRecordEntity);
+            } else {
+                screenRecordEntity.setJobName("uploadProjectProcess");
+                screenRecordDao.insert(screenRecordEntity);
+            }
         }
 
+
         logger.info("<" + methodName + "|项目处理流程信息上报>定时任务执行结束");
     }
 }