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