From 317ec348c68c176eada17c509adb45526772fe1b Mon Sep 17 00:00:00 2001
From: heheng <475597332@qq.com>
Date: 星期一, 20 十月 2025 13:19:10 +0800
Subject: [PATCH] 新增数据上传准东
---
src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/PreventCJReportRiskAnaUnitServiceImpl.java | 158 ++++++++++++++++++++++++++++------------------------
1 files changed, 86 insertions(+), 72 deletions(-)
diff --git a/src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/PreventCJReportRiskAnaUnitServiceImpl.java b/src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/PreventCJReportRiskAnaUnitServiceImpl.java
index 8c9c955..357ac9c 100644
--- a/src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/PreventCJReportRiskAnaUnitServiceImpl.java
+++ b/src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/PreventCJReportRiskAnaUnitServiceImpl.java
@@ -1,72 +1,86 @@
-package com.ruoyi.doublePrevention.service.baseService.impl;
-
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportRiskAnaUnit;
-import com.ruoyi.doublePrevention.enums.E;
-import com.ruoyi.doublePrevention.exception.AusinessException;
-import com.ruoyi.doublePrevention.repository.PreventCJReportRiskAnaUnitRepository;
-import com.ruoyi.doublePrevention.repository.param.HandlerCJReportParam;
-import com.ruoyi.doublePrevention.repository.param.HandlerReportParam;
-import com.ruoyi.doublePrevention.service.baseService.PreventCJReportRiskAnaUnitService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
-import java.util.List;
-
-@Service("PreventCJReportRiskAnaUnitService")
-public class PreventCJReportRiskAnaUnitServiceImpl
- extends ServiceImpl<PreventCJReportRiskAnaUnitRepository, PreventCJReportRiskAnaUnit> implements PreventCJReportRiskAnaUnitService {
-
- @Autowired
- private PreventCJReportRiskAnaUnitRepository preventCJReportRiskAnaUnitRepository;
-
-// /**
-// * 上报数据-风险分析单元-分页查询
-// */
-// @Override
-// public IPage<PreventCJReportRiskAnaUnit> getReportRiskUnitPage(Page<Object> page, PreReportRiskUnitQueryReqDTO queryReqDTO) {
-// return preventCJReportRiskAnaUnitRepository.getReportRiskUnitPage(page, queryReqDTO);
-// }
-
- /**
- * 上报数据-插入
- */
- @Override
- public int insertUnitList(PreventCJReportRiskAnaUnit unit) {
- int result = preventCJReportRiskAnaUnitRepository.insertUnitList(unit);
- if (result < 1){
- throw new AusinessException(E.ADD_FAIL.getCode(), "保存CJ风险单元失败");
- }
- return result;
- }
-
- /**
- * 上报数据-查询待上报数据
- */
- @Override
- public List<PreventCJReportRiskAnaUnit> listReportUnitDate() {
- return preventCJReportRiskAnaUnitRepository.listReportUnitDate();
- }
-
- /**
- * 上报数据-修改待上报
- */
- @Override
- public void updateReportStatus(HandlerReportParam handlerReportParam) {
- int result = preventCJReportRiskAnaUnitRepository.updateReportStatus();
- if (result < 1){
- throw new AusinessException(E.ADD_FAIL.getCode(), "CJ保存风险单元失败");
- }
- }
-
- /**
- * 上报数据-修改待上报-通过id
- */
- @Override
- public void updateCJReportStatusById(HandlerCJReportParam handlerCJReportParam) {
- int result = preventCJReportRiskAnaUnitRepository.updateCJReportStatusById(handlerCJReportParam);
- if (result < 1){
- throw new AusinessException(E.ADD_FAIL.getCode(), "CJ保存风险单元失败");
- }
- }
-}
+package com.ruoyi.doublePrevention.service.baseService.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportRiskAnaUnit;
+import com.ruoyi.doublePrevention.entity.ZDReport.HandlerZDReportParam;
+import com.ruoyi.doublePrevention.enums.E;
+import com.ruoyi.doublePrevention.exception.AusinessException;
+import com.ruoyi.doublePrevention.repository.PreventCJReportRiskAnaUnitRepository;
+import com.ruoyi.doublePrevention.repository.param.HandlerCJReportParam;
+import com.ruoyi.doublePrevention.repository.param.HandlerReportParam;
+import com.ruoyi.doublePrevention.service.baseService.PreventCJReportRiskAnaUnitService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service("PreventCJReportRiskAnaUnitService")
+public class PreventCJReportRiskAnaUnitServiceImpl
+ extends ServiceImpl<PreventCJReportRiskAnaUnitRepository, PreventCJReportRiskAnaUnit> implements PreventCJReportRiskAnaUnitService {
+
+ @Autowired
+ private PreventCJReportRiskAnaUnitRepository preventCJReportRiskAnaUnitRepository;
+
+// /**
+// * 上报数据-风险分析单元-分页查询
+// */
+// @Override
+// public IPage<PreventCJReportRiskAnaUnit> getReportRiskUnitPage(Page<Object> page, PreReportRiskUnitQueryReqDTO queryReqDTO) {
+// return preventCJReportRiskAnaUnitRepository.getReportRiskUnitPage(page, queryReqDTO);
+// }
+
+ /**
+ * 上报数据-插入
+ */
+ @Override
+ public int insertUnitList(PreventCJReportRiskAnaUnit unit) {
+ int result = preventCJReportRiskAnaUnitRepository.insertUnitList(unit);
+ if (result < 1){
+ throw new AusinessException(E.ADD_FAIL.getCode(), "保存CJ风险单元失败");
+ }
+ return result;
+ }
+
+ /**
+ * 上报数据-查询待上报数据
+ */
+ @Override
+ public List<PreventCJReportRiskAnaUnit> listReportUnitDate() {
+ return preventCJReportRiskAnaUnitRepository.listReportUnitDate();
+ }
+
+ /**
+ * 上报数据-修改待上报
+ */
+ @Override
+ public void updateReportStatus(HandlerReportParam handlerReportParam) {
+ int result = preventCJReportRiskAnaUnitRepository.updateReportStatus();
+ if (result < 1){
+ throw new AusinessException(E.ADD_FAIL.getCode(), "CJ保存风险单元失败");
+ }
+ }
+
+ /**
+ * 上报数据-修改待上报-通过id
+ */
+ @Override
+ public void updateCJReportStatusById(HandlerCJReportParam handlerCJReportParam) {
+ int result = preventCJReportRiskAnaUnitRepository.updateCJReportStatusById(handlerCJReportParam);
+ if (result < 1){
+ throw new AusinessException(E.ADD_FAIL.getCode(), "CJ保存风险单元失败");
+ }
+ }
+
+ @Override
+ public void updateHDReportStatusById(HandlerZDReportParam handlerZDReportParam) {
+ int result = preventCJReportRiskAnaUnitRepository.updateHDReportStatusById(handlerZDReportParam);
+ if (result < 1){
+ throw new AusinessException(E.ADD_FAIL.getCode(), "CJ保存风险单元失败");
+ }
+ }
+
+ @Override
+ public List<PreventCJReportRiskAnaUnit> listReportUnitDateHuaiDong() {
+ return preventCJReportRiskAnaUnitRepository.listReportUnitDateHuaiDong();
+ }
+}
--
Gitblit v1.9.2