From 9d1ab00d884b2225b60ee3efe3c00db510f91a29 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期五, 28 二月 2025 17:57:00 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into dev

---
 springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/service/impl/ComplaintServiceImpl.java |   53 +++++++++++++++++++++++++++++++++--------------------
 1 files changed, 33 insertions(+), 20 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 255181b..654ac2f 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
@@ -135,6 +135,7 @@
         complaint.setClosingTime(new Date(System.currentTimeMillis() + config.getDemandProcessingTime() * 24 * 60 * 60 * 1000));
         // 保存诉求记录
         save(complaint);
+        int count = complaintAuditRecordService.count(new LambdaQueryWrapper<ComplaintAuditRecord>().eq(ComplaintAuditRecord::getComplaintId, complaint.getId()));
         //保存记录
         ComplaintAuditRecord complaintAuditRecord = new ComplaintAuditRecord();
         complaintAuditRecord.setComplaintId(complaint.getId());
@@ -147,6 +148,7 @@
         complaintAuditRecord.setUpdateTime(new Date(System.currentTimeMillis()));
         complaintAuditRecord.setReportType(accountLevel);
         complaintAuditRecord.setSuperiorId(superiorId);
+        complaintAuditRecord.setSort(count + 1);
         complaintAuditRecordService.save(complaintAuditRecord);
     }
 
@@ -372,20 +374,21 @@
 
         // 添加审核记录
         //complaintAuditRecordService.createComplaintAuditRecord(dto.getComplaintId(), 2, dto.getComment(), loginUserInfoVO,adminUser);
-
+        int count = complaintAuditRecordService.count(new LambdaQueryWrapper<ComplaintAuditRecord>().eq(ComplaintAuditRecord::getComplaintId, complaint.getId()));
         ComplaintAuditRecord complaintAuditRecord = new ComplaintAuditRecord();
         complaintAuditRecord.setComplaintId(complaint.getId());
         complaintAuditRecord.setLatestFlag(true);
         complaintAuditRecord.setAuditType(2);
         complaintAuditRecord.setAuditStatus(0);
         complaintAuditRecord.setCreateBy(loginUserInfoVO.getUserId());
-        complaintAuditRecord.setCreateTime(new Date(System.currentTimeMillis()));
+        complaintAuditRecord.setCreateTime(new Date());
         complaintAuditRecord.setUpdateBy(loginUserInfoVO.getUserId());
-        complaintAuditRecord.setUpdateTime(new Date(System.currentTimeMillis()));
+        complaintAuditRecord.setUpdateTime(new Date());
         complaintAuditRecord.setReporter(loginUserInfoVO.getNickName());
         complaintAuditRecord.setReportType(Objects.isNull(adminUser) ? 5 : adminUser.getAccountLevel());
         complaintAuditRecord.setSuperiorId(currentId);
         complaintAuditRecord.setComment(dto.getComment());
+        complaintAuditRecord.setSort(count + 1);
         complaintAuditRecordService.save(complaintAuditRecord);
 
 
@@ -395,13 +398,14 @@
         complaintAuditRecord2.setAuditType(2);
         complaintAuditRecord2.setAuditStatus(0);
         complaintAuditRecord2.setCreateBy(loginUserInfoVO.getUserId());
-        complaintAuditRecord2.setCreateTime(new Date(System.currentTimeMillis()));
+        complaintAuditRecord2.setCreateTime(new Date());
         complaintAuditRecord2.setUpdateBy(loginUserInfoVO.getUserId());
-        complaintAuditRecord2.setUpdateTime(new Date(System.currentTimeMillis()));
+        complaintAuditRecord2.setUpdateTime(new Date());
         complaintAuditRecord2.setReporter(loginUserInfoVO.getNickName());
         complaintAuditRecord2.setReportType(reportType);
         complaintAuditRecord2.setSuperiorId(superiorId);
         complaintAuditRecord2.setComment(dto.getComment());
+        complaintAuditRecord2.setSort(count + 2);
         complaintAuditRecordService.save(complaintAuditRecord2);
     }
 
@@ -439,7 +443,7 @@
         complaintAuditRecordService.update(new LambdaUpdateWrapper<ComplaintAuditRecord>()
                 .eq(ComplaintAuditRecord::getComplaintId, dto.getComplaintId())
                 .set(ComplaintAuditRecord::getLatestFlag, false));
-
+        int count = complaintAuditRecordService.count(new LambdaQueryWrapper<ComplaintAuditRecord>().eq(ComplaintAuditRecord::getComplaintId, complaint.getId()));
         ComplaintAuditRecord record = new ComplaintAuditRecord();
         record.setComplaintId(complaint.getId());
         record.setLatestFlag(true);
@@ -452,6 +456,7 @@
         record.setReporter(loginUserInfoVO.getNickName());
         record.setReportType(accountLevel);
         record.setSuperiorId(dto.getDispatchId());
+        record.setSort(count + 1);
         complaintAuditRecordService.save(record);
     }
 
@@ -504,6 +509,7 @@
                 .set(ComplaintAuditRecord::getLatestFlag, false));
 
         if (complaintReporAuditDTO.getAuditResult().equals(1)) {
+            int count = complaintAuditRecordService.count(new LambdaQueryWrapper<ComplaintAuditRecord>().eq(ComplaintAuditRecord::getComplaintId, complaint.getId()));
             ComplaintAuditRecord record = new ComplaintAuditRecord();
             record.setComplaintId(complaint.getId());
             record.setLatestFlag(true);
@@ -511,12 +517,13 @@
             record.setAuditType(0);
             record.setAuditStatus(1);
             record.setCreateBy(loginUserInfoVO.getUserId());
-            record.setCreateTime(new Date(System.currentTimeMillis()));
+            record.setCreateTime(new Date());
             record.setUpdateBy(loginUserInfoVO.getUserId());
-            record.setUpdateTime(new Date(System.currentTimeMillis()));
+            record.setUpdateTime(new Date());
             record.setReporter(complaintAuditRecord.getReporter());
             record.setReportType(complaintAuditRecord.getReportType());
             record.setSuperiorId(superiorId);
+            record.setSort(count + 1);
             complaintAuditRecordService.save(record);
 
 
@@ -545,7 +552,7 @@
                     superiorId = complaint.getCreateBy();
                     break;
             }
-
+            int count = complaintAuditRecordService.count(new LambdaQueryWrapper<ComplaintAuditRecord>().eq(ComplaintAuditRecord::getComplaintId, complaint.getId()));
             ComplaintAuditRecord record2 = new ComplaintAuditRecord();
             record2.setComplaintId(complaint.getId());
             record2.setLatestFlag(true);
@@ -553,13 +560,14 @@
             record2.setAuditorId(loginUserInfoVO.getUserId());
             record2.setAuditStatus(2);
             record2.setCreateBy(loginUserInfoVO.getUserId());
-            record2.setCreateTime(new Date(System.currentTimeMillis()));
+            record2.setCreateTime(new Date());
             record2.setUpdateBy(loginUserInfoVO.getUserId());
-            record2.setUpdateTime(new Date(System.currentTimeMillis()));
+            record2.setUpdateTime(new Date());
             record2.setReporter(complaintAuditRecord.getReporter());
             record2.setReportType(systemUser.getAccountLevel() + 1);
             record2.setSuperiorId(superiorId);
             record2.setRejectReason(complaintReporAuditDTO.getRejectReason());
+            record2.setSort(count + 1);
             complaintAuditRecordService.save(record2);
         }
     }
@@ -588,7 +596,7 @@
             if (accountLevel == 1) {
                 throw new ServiceException("市级账号,无法上报!");
             }
-            reportType = accountLevel + 1;
+            reportType = accountLevel - 1;
 
             // 使用基本类型比较并补充默认分支
             if (accountLevel == ReportTypeEnum.COMMUNITY.getCode()) {
@@ -617,33 +625,35 @@
         complaintAuditRecordService.update(new LambdaUpdateWrapper<ComplaintAuditRecord>()
                 .eq(ComplaintAuditRecord::getComplaintId, dto.getComplaintId())
                 .set(ComplaintAuditRecord::getLatestFlag, false));
-
+        int count = complaintAuditRecordService.count(new LambdaQueryWrapper<ComplaintAuditRecord>().eq(ComplaintAuditRecord::getComplaintId, complaint.getId()));
         ComplaintAuditRecord record1 = new ComplaintAuditRecord();
         record1.setComplaintId(complaint.getId());
         record1.setLatestFlag(true);
         record1.setAuditType(2);
-        record1.setAuditStatus(2);
+        record1.setAuditStatus(0);
         record1.setCreateBy(loginUserInfoVO.getUserId());
         record1.setCreateTime(new Date(System.currentTimeMillis()));
         record1.setUpdateBy(loginUserInfoVO.getUserId());
         record1.setUpdateTime(new Date(System.currentTimeMillis()));
         record1.setReporter(loginUserInfoVO.getNickName());
-        record1.setReportType(systemUser.getAccountLevel());
+        record1.setReportType(Objects.isNull(systemUser) ? 5 : systemUser.getAccountLevel());
         record1.setSuperiorId(currentId);
+        record1.setSort(count + 1);
         complaintAuditRecordService.save(record1);
 
         ComplaintAuditRecord record2 = new ComplaintAuditRecord();
         record2.setComplaintId(complaint.getId());
         record2.setLatestFlag(true);
         record2.setAuditType(2);
-        record2.setAuditStatus(2);
+        record2.setAuditStatus(0);
         record2.setCreateBy(loginUserInfoVO.getUserId());
         record2.setCreateTime(new Date(System.currentTimeMillis()));
         record2.setUpdateBy(loginUserInfoVO.getUserId());
         record2.setUpdateTime(new Date(System.currentTimeMillis()));
         record2.setReporter(loginUserInfoVO.getNickName());
-        record2.setReportType(systemUser.getAccountLevel() - 1);
+        record2.setReportType(reportType);
         record2.setSuperiorId(superiorId);
+        record2.setSort(count + 2);
         complaintAuditRecordService.save(record2);
     }
 
@@ -694,7 +704,7 @@
         complaintAuditRecordService.update(new LambdaUpdateWrapper<ComplaintAuditRecord>()
                 .eq(ComplaintAuditRecord::getComplaintId, dto.getComplaintId())
                 .set(ComplaintAuditRecord::getLatestFlag, false));
-
+        int count = complaintAuditRecordService.count(new LambdaQueryWrapper<ComplaintAuditRecord>().eq(ComplaintAuditRecord::getComplaintId, dto.getId()));
         ComplaintAuditRecord record1 = new ComplaintAuditRecord();
         record1.setComplaintId(dto.getComplaintId());
         record1.setLatestFlag(true);
@@ -708,6 +718,7 @@
         record1.setReporter(complaintAuditRecord.getReporter());
         record1.setReportType(systemUser.getAccountLevel());
         record1.setSuperiorId(cunrrentId);
+        record1.setSort(count + 1);
         complaintAuditRecordService.save(record1);
     }
 
@@ -732,7 +743,8 @@
         // 使用基本类型比较并补充默认分支
         List<DispatchVO> dispatchVOList = new ArrayList<>();
         if (accountLevel == ReportTypeEnum.STREET.getCode()) {
-            List<ComAct> list = comActService.list();
+            String streetId = adminUser.getStreetId();
+            List<ComAct> list = comActService.list(new LambdaQueryWrapper<ComAct>().eq(ComAct::getStreetId, streetId).eq(ComAct::getState, 0));
             for (ComAct comAct : list) {
                 DispatchVO dispatchVO = new DispatchVO();
                 dispatchVO.setId(comAct.getCommunityId().toString());
@@ -740,7 +752,8 @@
                 dispatchVOList.add(dispatchVO);
             }
         } else if (accountLevel == ReportTypeEnum.DISTRICT.getCode()) {
-            List<ComStreet> list = comStreetService.list();
+            String districtsCode = adminUser.getDistrictsCode();
+            List<ComStreet> list = comStreetService.list(new LambdaQueryWrapper<ComStreet>().eq(ComStreet::getAreaCode, districtsCode));
             for (ComStreet street : list) {
                 DispatchVO dispatchVO = new DispatchVO();
                 dispatchVO.setId(street.getStreetId().toString());

--
Gitblit v1.7.1