From 54843d459f3fe623e6cf2956f192141e9a99b878 Mon Sep 17 00:00:00 2001 From: 16639036659 <577530412@qq.com> Date: 星期四, 30 十一月 2023 13:03:29 +0800 Subject: [PATCH] 临时提交 --- src/main/java/com/ruoyi/project/mobile/service/ApiDangerScheduleService.java | 30 +++++++++++++++++++----------- 1 files changed, 19 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/ruoyi/project/mobile/service/ApiDangerScheduleService.java b/src/main/java/com/ruoyi/project/mobile/service/ApiDangerScheduleService.java index 8bd9bed..aab7529 100644 --- a/src/main/java/com/ruoyi/project/mobile/service/ApiDangerScheduleService.java +++ b/src/main/java/com/ruoyi/project/mobile/service/ApiDangerScheduleService.java @@ -20,12 +20,12 @@ import com.ruoyi.project.tr.hiddenDangerCheck.service.IHiddenDangerCheckService; import com.ruoyi.project.tr.hiddenDangerCheckPoint.domain.HiddenDangerCheckPoint; import com.ruoyi.project.tr.hiddenDangerCheckPoint.service.IHiddenDangerCheckPointService; +import org.apache.commons.lang3.ObjectUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; -import org.springframework.util.ObjectUtils; import java.util.ArrayList; import java.util.HashMap; @@ -209,6 +209,12 @@ } try { HiddenDangerCheckPoint hdcp = new ObjectMapper().readValue(str, HiddenDangerCheckPoint.class); + if (ObjectUtils.isEmpty(hdcp.getCheckPerson())){ + throw new RuntimeException("检查人不能为空"); + } + if (ObjectUtils.isEmpty(hdcp.getFindTime())){ + throw new RuntimeException("发现时间不能为空"); + } hdcp.setUpdateBy(header.loginName); hdcp.setUpdateTime(DateUtils.getNowDate()); hdcp.setRegisterCreateTime(DateUtils.getNowDate());//设置隐患登记上报创建时间 @@ -225,6 +231,8 @@ queryExist.setWhetherDanger(TrHiddenDangerCheckConstants.WHETHER_DANGER_YES);//是否为隐患(是隐患) queryExist.setCheckPointId(hdcp.getCheckPointId()); queryExist.setCheckId(hdcp.getCheckId()); + + hdcp.setReportStatus("0"); /** * 本次查询结果 :如果未上报过隐患,必定为空 @@ -243,15 +251,15 @@ hdcp.setCompanyId(user.getCompanyId()); i = hdcpService.insertHiddenDangerCheckPoint(hdcp); if (i< 1){ - throw new RuntimeException("添加隐患附属信息失败"); + throw new RuntimeException("添加隐患信息失败"); } //获取Id返回值 - hdcp.getId(); - int result = riskService.insertDangerInfo(hdcp.getId(), hdcp); - if (result< 1){ - throw new RuntimeException("添加隐患附属信息失败"); - } +// hdcp.getId(); +// int result = riskService.insertDangerInfo(hdcp.getId(), hdcp); +// if (result< 1){ +// throw new RuntimeException("添加隐患附属信息失败"); +// } // PreventRiskDangerCheckAndMeasure dangerCheckPointInfo = preventRiskDangerCheckAndMeasureService.getByDangerCheckPointId(hdcp.getId()); // riskService.updateCheckLog(dangerCheckPointInfo.getCheckId(), hdcp); @@ -266,10 +274,10 @@ // if (result < 1){ // throw new RuntimeException("修改失败"); // } - int result = riskService.insertDangerInfo(hdcp.getId(), hdcp); - if (result< 1){ - throw new RuntimeException("添加隐患附属信息失败"); - } +// int result = riskService.insertDangerInfo(hdcp.getId(), hdcp); +// if (result< 1){ +// throw new RuntimeException("添加隐患附属信息失败"); +// } PreventRiskDangerCheckAndMeasure dangerCheckPointInfo = preventRiskDangerCheckAndMeasureService.getByDangerCheckPointId(hdcp.getId()); riskService.updateCheckLog(dangerCheckPointInfo.getCheckId(), hdcp); -- Gitblit v1.9.2