From ba41b9351647a36bad13c0ab03d3fb602f5f4b27 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期一, 23 六月 2025 17:47:04 +0800
Subject: [PATCH] 2.0后台模块

---
 springcloud_k8s_panzhihuazhihuishequ/service_westcommittee/src/main/java/com/panzhihua/westcommittee/scheduled/ComplaintTasks.java |   12 ++++++------
 1 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_westcommittee/src/main/java/com/panzhihua/westcommittee/scheduled/ComplaintTasks.java b/springcloud_k8s_panzhihuazhihuishequ/service_westcommittee/src/main/java/com/panzhihua/westcommittee/scheduled/ComplaintTasks.java
index 6234d5d..a51665d 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_westcommittee/src/main/java/com/panzhihua/westcommittee/scheduled/ComplaintTasks.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_westcommittee/src/main/java/com/panzhihua/westcommittee/scheduled/ComplaintTasks.java
@@ -104,6 +104,11 @@
                 config.getCommunityHandlingTime()
               );
 
+        if(!complaintTimeoutList.isEmpty()) {
+            // 后续当前不在发送
+            complaintService.update(new LambdaUpdateWrapper<Complaint>().in(Complaint::getId, complaintTimeoutList.stream().map(ComplaintTimeout::getComplaintId).collect(Collectors.toList())).set(Complaint::getNowLevelSms, 1));
+
+        }
 
         Map<Integer, List<ComplaintTimeout>> timeOutMap = complaintTimeoutList.stream()
                 .collect(Collectors.groupingBy(ComplaintTimeout::getNowLevel));
@@ -230,8 +235,6 @@
         if (!CollectionUtils.isEmpty(communityTimeOutList)){
             List<ComplaintTimeout> collect = communityTimeOutList.stream().filter(e -> e.getAssignStatus() == 0).collect(Collectors.toList());
 
-
-
             List<SystemUser> communityUserList = systemUserService.list(new LambdaQueryWrapper<SystemUser>()
                     .eq(SystemUser::getAccountLevel, 4)
                     .in(SystemUser::getSystemRoleId,1,2)
@@ -283,10 +286,7 @@
         }
 
 
-        if(!complaintTimeoutList.isEmpty()) {
-            // 短信发送完成 当前不在发送
-            complaintService.update(new LambdaUpdateWrapper<Complaint>().in(Complaint::getId, complaintTimeoutList.stream().map(ComplaintTimeout::getComplaintId).collect(Collectors.toList())).set(Complaint::getNowLevelSms, 1));
-        }
+
     }
 
 }

--
Gitblit v1.7.1