From 29562cfa14c5626c958e2c750400c6b06f2c3f23 Mon Sep 17 00:00:00 2001
From: luofl <1442745593@qq.com>
Date: 星期一, 14 四月 2025 15:31:25 +0800
Subject: [PATCH] 迭代:4.11版本

---
 springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/service/impl/ComplaintServiceImpl.java |   73 ++++++++++++++++++++++++++++++++++++
 1 files changed, 73 insertions(+), 0 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/service/impl/ComplaintServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/service/impl/ComplaintServiceImpl.java
index 0addaad..f118a4c 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/service/impl/ComplaintServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/service/impl/ComplaintServiceImpl.java
@@ -34,6 +34,7 @@
 import jodd.util.StringUtil;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -175,6 +176,31 @@
         complaint.setClosingTime(new Date(System.currentTimeMillis() + config.getDemandProcessingTime() * 24 * 60 * 60 * 1000));
         // 保存诉求记录
         save(complaint);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void saveAndReport(ComplaintVO complaintVO, LoginUserInfoVO loginUserInfo) {
+        Complaint complaint = new Complaint();
+        BeanUtil.copyProperties(complaintVO, complaint);
+        saveComplaint(complaint, loginUserInfo);
+        ComplaintReportDTO dto = new ComplaintReportDTO();
+        dto.setComplaintId(complaint.getId());
+        dto.setComment(complaintVO.getComment());
+        saveReport(dto, loginUserInfo);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void saveAndComplete(ComplaintSaveAndCompleteDTO complaintVO, LoginUserInfoVO loginUserInfo) {
+        Complaint complaint = new Complaint();
+        BeanUtil.copyProperties(complaintVO, complaint);
+        saveComplaint(complaint, loginUserInfo);
+
+        ComplaintCompletionDTO complaintCompletionDTO = complaintVO.getComplaintCompletionDTO();
+        complaintCompletionDTO.setComplaintId(complaint.getId());
+        complaintCompletionDTO.setId(complaint.getId());
+        saveResult(complaintCompletionDTO, loginUserInfo);
     }
 
     @Override
@@ -411,6 +437,16 @@
                 }
             }
         }
+
+        Long auditCreateBy = vo.getAuditCreateBy();
+        Long userId = loginUserInfo.getUserId();
+        if (null != auditCreateBy && auditCreateBy.compareTo(userId) == 0 && vo.getStatus() == 5) {
+            vo.setWithdrawButtonStatus(0);
+        }else {
+            vo.setWithdrawButtonStatus(1);
+        }
+
+
     }
 
 
@@ -589,6 +625,8 @@
                 .orderByAsc(ComplaintProgress::getCreateTime).list();
     }
 
+
+
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void saveReport(ComplaintReportDTO dto, LoginUserInfoVO loginUserInfoVO) {
@@ -697,6 +735,41 @@
     }
 
     @Override
+    public void reportWithdraw(ComplaintReportWithdrawDTO dto, LoginUserInfoVO loginUserInfoVO) {
+        ComplaintAuditRecord complaintAuditRecord = complaintAuditRecordService.getOne(new LambdaQueryWrapper<ComplaintAuditRecord>()
+                .eq(ComplaintAuditRecord::getComplaintId, dto.getComplaintId())
+                .eq(ComplaintAuditRecord::getAuditType, 2)
+                .eq(ComplaintAuditRecord::getLatestFlag, true));
+        if (Objects.isNull(complaintAuditRecord)) {
+            throw new ServiceException("未找到相关记录");
+        }
+        complaintAuditRecord.setAuditStatus(3);
+        complaintAuditRecord.setUpdateBy(loginUserInfoVO.getUserId());
+        complaintAuditRecord.setUpdateTime(new Date());
+        complaintAuditRecord.setLatestFlag(false);
+        complaintAuditRecordService.updateById(complaintAuditRecord);
+
+        // 获取上一条记录
+        ComplaintAuditRecord lastRecord = complaintAuditRecordService.getOne(new LambdaQueryWrapper<ComplaintAuditRecord>()
+                .ne(ComplaintAuditRecord::getId, complaintAuditRecord.getId())
+                .eq(ComplaintAuditRecord::getComplaintId, dto.getComplaintId())
+                .eq(ComplaintAuditRecord::getAuditType, 2)
+                .eq(ComplaintAuditRecord::getLatestFlag, false)
+                .orderByDesc(ComplaintAuditRecord::getSort)
+        );
+        if (Objects.nonNull(lastRecord)) {
+            // 复制上一条记录
+            ComplaintAuditRecord newRecord = new ComplaintAuditRecord();
+            BeanUtils.copyProperties(lastRecord, newRecord);
+            newRecord.setId(null);
+            newRecord.setLatestFlag(true);
+            newRecord.setUpdateBy(loginUserInfoVO.getUserId());
+            newRecord.setUpdateTime(new Date());
+            complaintAuditRecordService.save(newRecord);
+        }
+    }
+
+    @Override
     @Transactional(rollbackFor = Exception.class)
     public void saveDispatch(ComplaintDispatch dto, LoginUserInfoVO loginUserInfoVO) {
         IdentityInformation identityInformation = identityInformationService.getCurrentIdentityInformation(loginUserInfoVO);

--
Gitblit v1.7.1