From 1bdce029a16f396a933848b368040e78740728fa Mon Sep 17 00:00:00 2001
From: huangzhen <867127663@qq.com>
Date: Fri, 16 Sep 2022 09:39:03 +0800
Subject: [PATCH] 新增原巡检点与措施的删除、修改、查询功能
---
src/main/java/com/ruoyi/doublePrevention/service/impl/RiskServiceImpl.java | 39 +++++++++++++++++++++++++++++++++++++--
1 files changed, 37 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/ruoyi/doublePrevention/service/impl/RiskServiceImpl.java b/src/main/java/com/ruoyi/doublePrevention/service/impl/RiskServiceImpl.java
index 0321bac..54d1aa2 100644
--- a/src/main/java/com/ruoyi/doublePrevention/service/impl/RiskServiceImpl.java
+++ b/src/main/java/com/ruoyi/doublePrevention/service/impl/RiskServiceImpl.java
@@ -11,6 +11,7 @@
import com.ruoyi.doublePrevention.enums.ResultCodes;
import com.ruoyi.doublePrevention.enums.StatusEnum;
import com.ruoyi.doublePrevention.enums.SyncEnum;
+import com.ruoyi.doublePrevention.repository.param.PreventPointAndMeasureParams;
import com.ruoyi.doublePrevention.service.RiskService;
import com.ruoyi.doublePrevention.service.baseService.*;
import com.ruoyi.doublePrevention.vo.ResultVO;
@@ -19,6 +20,7 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import java.util.ArrayList;
import java.util.Date;
@@ -48,6 +50,9 @@
@Autowired
private PreventRiskControlMeasureService riskControlMeasureService;
+
+ @Autowired
+ private PreventRiskCheckUnitService preventRiskCheckUnitService;
/**
* 为设施设备清单附属表添加uuid
@@ -597,7 +602,7 @@
return resultVO;
}
resultVO.setCode(ResultCodes.OK.getCode());
- resultVO.setMsg("更新安全风险事件成功");
+ resultVO.setMsg("更新风险管控措施成功");
return resultVO;
}
@@ -640,7 +645,37 @@
ResultVO<List<PreventRiskControlMeasurePageQueryRespDTO>> resultVO = new ResultVO<>(ResultCodes.OK,pageResult);
resultVO.setCount(count);
return resultVO;
-
}
+ /**
+ * 保存原检查点与管控措施的对应关系
+ */
+ @Transactional
+ @Override
+ public int insertPointAndMeasure(PreventPointAndMeasureParams pointAndMeasureParams) {
+
+ String uuid = UUID.randomUUID().toString();
+ PreventRiskCheckUnit checkUnit = new PreventRiskCheckUnit();
+ //封装数据 todo
+
+ checkUnit.setUuid(uuid);
+ checkUnit.setRiskId(pointAndMeasureParams.getRiskId());
+ checkUnit.setBaseCheckPointId(pointAndMeasureParams.getBaseCheckPointId());
+ checkUnit.setControlMeasureId(pointAndMeasureParams.getControlMeasureId());
+ //执行插入
+ int result = preventRiskCheckUnitService.insertPointAndMeasure(checkUnit);
+ if (result < 1){
+ throw new RuntimeException("保存原检查点与管控措施的对应关系失败");
+ }
+
+ return result;
+ }
+
+ /**
+ * @description 根据原检查点查询 原检查点与管控措施对应记录
+ */
+ @Override
+ public PreventRiskCheckUnit getRiskUnitByBaseCheckPointId(Long checkPointId) {
+ return preventRiskCheckUnitService.getRiskUnitByBaseCheckPointId(checkPointId);
+ }
}
--
Gitblit v1.9.2