src/main/java/com/ruoyi/doublePrevention/repository/PreventCJReportRiskAnaUnitRepository.java
@@ -3,6 +3,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportRiskAnaUnit; import com.ruoyi.doublePrevention.repository.param.HandlerCJReportParam; import com.ruoyi.doublePrevention.repository.param.HandlerReportParam; import org.springframework.stereotype.Repository; import java.util.List; @@ -21,7 +22,7 @@ /** * 上报数据-修改待上报 */ int updateReportStatus(HandlerCJReportParam handlerReportParam); int updateReportStatus(HandlerReportParam handlerReportParam); /** * 上报数据-修改待上报-通过id */ src/main/java/com/ruoyi/doublePrevention/repository/PreventCJReportRiskEventRepository.java
@@ -29,7 +29,7 @@ /** * 修改上报状态 * */ int updateEventReportStatus(HandlerCJReportParam handlerReportParam); int updateEventReportStatus(HandlerReportParam handlerReportParam); /** * 修改上报状态-通过id * */ src/main/java/com/ruoyi/doublePrevention/scheduls/ExecCJReportDateSchedule.java
@@ -213,7 +213,7 @@ handlerReportParam.setId(riskAnaUnit.getId()); handlerReportParam.setReportStatus(SyncEnum.SYNC_EXEC_SUCCESS.getCode()); handlerReportParam.setReportTime(date); CJRiskAnaUnitService.updateReportStatus(handlerReportParam); CJRiskAnaUnitService.updateCJReportStatusById(handlerReportParam); idTextBuffer.append(riskAnaUnit.getId() + ";"); } }else { @@ -291,7 +291,7 @@ handlerReportParam.setId(cjEvent.getId()); handlerReportParam.setReportStatus(SyncEnum.SYNC_EXEC_SUCCESS.getCode()); handlerReportParam.setReportTime(date); CJEventService.updateEventReportStatus(handlerReportParam); CJEventService.updateCJReportStatusById(handlerReportParam); } logger.info("【2】安全风险事件-数据处理完成"); }else { @@ -369,7 +369,7 @@ handlerReportParam.setId(cjMeasure.getId()); handlerReportParam.setReportStatus(SyncEnum.SYNC_EXEC_SUCCESS.getCode()); handlerReportParam.setReportTime(date); CJMeasureService.updateMeasureReportStatus(handlerReportParam); CJMeasureService.updateCJReportStatusById(handlerReportParam); } logger.info("【3】风险管控措施-数据处理完成"); }else { @@ -448,7 +448,7 @@ handlerReportParam.setId(cjTaskFromWork.getId()); handlerReportParam.setReportStatus(SyncEnum.SYNC_EXEC_SUCCESS.getCode()); handlerReportParam.setReportTime(date); CJTaskFromWorkService.updateWorkReportStatus(handlerReportParam); CJTaskFromWorkService.updateCJReportStatusById(handlerReportParam); } logger.info("【4】任务-数据处理完成"); @@ -529,7 +529,7 @@ handlerReportParam.setId(cjRecordFromTask.getId()); handlerReportParam.setReportStatus(SyncEnum.SYNC_EXEC_SUCCESS.getCode()); handlerReportParam.setReportTime(date); CJTaskRecordService.updateTaskReportStatus(handlerReportParam); CJTaskRecordService.updateCJReportStatusById(handlerReportParam); } logger.info("【5】任务记录-数据处理完成"); }else { @@ -613,7 +613,7 @@ handlerReportParam.setId(cjDangerInfo.getId()); handlerReportParam.setReportStatus(SyncEnum.SYNC_EXEC_SUCCESS.getCode()); handlerReportParam.setReportTime(date); CJDangerInfoService.updateDangerInfoReportStatus(handlerReportParam); CJDangerInfoService.updateCJReportStatusById(handlerReportParam); } logger.info("【6】隐患信息-数据处理完成"); }else { src/main/java/com/ruoyi/doublePrevention/service/baseService/PreventCJReportRiskAnaUnitService.java
@@ -24,7 +24,7 @@ /** * 上报数据-修改待上报 */ void updateReportStatus(HandlerCJReportParam handlerReportParam); void updateReportStatus(HandlerReportParam handlerReportParam); /** * 上报数据-修改待上报-通过id */ src/main/java/com/ruoyi/doublePrevention/service/baseService/PreventCJReportRiskEventService.java
@@ -24,7 +24,7 @@ /** * 修改上报状态 * */ int updateEventReportStatus(HandlerCJReportParam handlerReportParam); int updateEventReportStatus(HandlerReportParam handlerReportParam); /** * 修改上报状态-通过id * */ src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/PreventCJReportRiskAnaUnitServiceImpl.java
@@ -52,7 +52,7 @@ * 上报数据-修改待上报 */ @Override public void updateReportStatus(HandlerCJReportParam handlerReportParam) { public void updateReportStatus(HandlerReportParam handlerReportParam) { int result = preventCJReportRiskAnaUnitRepository.updateReportStatus(handlerReportParam); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "CJ保存风险单元失败"); src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/PreventCJReportRiskEventServiceImpl.java
@@ -53,7 +53,7 @@ * 修改上报状态 * */ @Override public int updateEventReportStatus(HandlerCJReportParam handlerReportParam) { public int updateEventReportStatus(HandlerReportParam handlerReportParam) { int result = preventCJReportRiskEventRepository.updateEventReportStatus(handlerReportParam); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "修改上报-事件状态失败");
