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/PreventCJReportRiskEventServiceImpl.java | 163 +++++++++++++++++++++++++++++------------------------
1 files changed, 89 insertions(+), 74 deletions(-)
diff --git a/src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/PreventCJReportRiskEventServiceImpl.java b/src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/PreventCJReportRiskEventServiceImpl.java
index 07dd7fc..98034d3 100644
--- a/src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/PreventCJReportRiskEventServiceImpl.java
+++ b/src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/PreventCJReportRiskEventServiceImpl.java
@@ -1,74 +1,89 @@
-package com.ruoyi.doublePrevention.service.baseService.impl;
-
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportRiskEvent;
-import com.ruoyi.doublePrevention.enums.E;
-import com.ruoyi.doublePrevention.exception.AusinessException;
-import com.ruoyi.doublePrevention.repository.PreventCJReportRiskEventRepository;
-import com.ruoyi.doublePrevention.repository.param.HandlerCJReportParam;
-import com.ruoyi.doublePrevention.repository.param.HandlerReportParam;
-import com.ruoyi.doublePrevention.service.baseService.PreventCJReportRiskEventService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
-import java.util.List;
-
-@Service("PreventCJReportRiskEventService")
-public class PreventCJReportRiskEventServiceImpl
- extends ServiceImpl<PreventCJReportRiskEventRepository, PreventCJReportRiskEvent> implements PreventCJReportRiskEventService {
-
- @Autowired
- private PreventCJReportRiskEventRepository preventCJReportRiskEventRepository;
-
-
-// /**
-// * 分页查询
-// * */
-// @Override
-// public IPage<PreventCJReportRiskEvent> getReportRiskEventPage(Page<Object> objectPage, PreReportRiskEventQueryReqDTO queryReqDTO) {
-// return preventCJReportRiskEventRepository.getReportRiskEventPage(objectPage, queryReqDTO);
-// }
-
- /**
- * 插入
- * */
- @Override
- public int insertEventLists(PreventCJReportRiskEvent event) {
- int result = preventCJReportRiskEventRepository.insertEventLists(event);
- if (result < 1){
- throw new AusinessException(E.ADD_FAIL.getCode(), "保存CJ风险单元失败");
- }
- return result;
- }
-
- /**
- * 上报数据-查询待上报数据
- * */
- @Override
- public List<PreventCJReportRiskEvent> listReportEventDate() {
- return preventCJReportRiskEventRepository.listReportEventDate();
- }
-
- /**
- * 修改上报状态
- * */
- @Override
- public int updateEventReportStatus(HandlerReportParam handlerReportParam) {
- int result = preventCJReportRiskEventRepository.updateEventReportStatus(handlerReportParam);
- if (result < 1){
- throw new AusinessException(E.ADD_FAIL.getCode(), "修改上报-事件状态失败");
- }
- return result;
- }
-
- /**
- * 修改上报状态-通过id
- * */
- @Override
- public void updateCJReportStatusById(HandlerCJReportParam handlerCJReportParam) {
- int result = preventCJReportRiskEventRepository.updateCJReportStatusById(handlerCJReportParam);
- if (result < 1){
- throw new AusinessException(E.ADD_FAIL.getCode(), "修改上报-事件状态失败");
- }
- }
-}
+package com.ruoyi.doublePrevention.service.baseService.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportRiskEvent;
+import com.ruoyi.doublePrevention.entity.ZDReport.HandlerZDReportParam;
+import com.ruoyi.doublePrevention.enums.E;
+import com.ruoyi.doublePrevention.exception.AusinessException;
+import com.ruoyi.doublePrevention.repository.PreventCJReportRiskEventRepository;
+import com.ruoyi.doublePrevention.repository.param.HandlerCJReportParam;
+import com.ruoyi.doublePrevention.repository.param.HandlerReportParam;
+import com.ruoyi.doublePrevention.service.baseService.PreventCJReportRiskEventService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service("PreventCJReportRiskEventService")
+public class PreventCJReportRiskEventServiceImpl
+ extends ServiceImpl<PreventCJReportRiskEventRepository, PreventCJReportRiskEvent> implements PreventCJReportRiskEventService {
+
+ @Autowired
+ private PreventCJReportRiskEventRepository preventCJReportRiskEventRepository;
+
+
+// /**
+// * 分页查询
+// * */
+// @Override
+// public IPage<PreventCJReportRiskEvent> getReportRiskEventPage(Page<Object> objectPage, PreReportRiskEventQueryReqDTO queryReqDTO) {
+// return preventCJReportRiskEventRepository.getReportRiskEventPage(objectPage, queryReqDTO);
+// }
+
+ /**
+ * 插入
+ * */
+ @Override
+ public int insertEventLists(PreventCJReportRiskEvent event) {
+ int result = preventCJReportRiskEventRepository.insertEventLists(event);
+ if (result < 1){
+ throw new AusinessException(E.ADD_FAIL.getCode(), "保存CJ风险单元失败");
+ }
+ return result;
+ }
+
+ /**
+ * 上报数据-查询待上报数据
+ * */
+ @Override
+ public List<PreventCJReportRiskEvent> listReportEventDate() {
+ return preventCJReportRiskEventRepository.listReportEventDate();
+ }
+
+ @Override
+ public List<PreventCJReportRiskEvent> listReportEventDateHuaiDong() {
+ return preventCJReportRiskEventRepository.listReportEventDateHuaiDong();
+ }
+
+ @Override
+ public int updateEventReportStatusHuaiDong(HandlerZDReportParam handlerReportParam) {
+ int result = preventCJReportRiskEventRepository.updateEventReportStatusHuaiDong(handlerReportParam);
+ if (result < 1){
+ throw new AusinessException(E.ADD_FAIL.getCode(), "修改上报-事件状态失败");
+ }
+ return result;
+ }
+
+ /**
+ * 修改上报状态
+ * */
+ @Override
+ public int updateEventReportStatus(HandlerReportParam handlerReportParam) {
+ int result = preventCJReportRiskEventRepository.updateEventReportStatus(handlerReportParam);
+ if (result < 1){
+ throw new AusinessException(E.ADD_FAIL.getCode(), "修改上报-事件状态失败");
+ }
+ return result;
+ }
+
+ /**
+ * 修改上报状态-通过id
+ * */
+ @Override
+ public void updateCJReportStatusById(HandlerCJReportParam handlerCJReportParam) {
+ int result = preventCJReportRiskEventRepository.updateCJReportStatusById(handlerCJReportParam);
+ if (result < 1){
+ throw new AusinessException(E.ADD_FAIL.getCode(), "修改上报-事件状态失败");
+ }
+ }
+}
--
Gitblit v1.9.2