From ad87ece9300f6a2faa0dd2136f7b8f3df21f5eb0 Mon Sep 17 00:00:00 2001
From: buaixuexideshitongxue <2936013465@qq.com>
Date: Thu, 22 Jan 2026 10:06:59 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B6=89=E8=AE=BF=E6=B6=89=E8=AF=89+=E7=BB=BC?=
 =?UTF-8?q?=E5=90=88=E6=9F=A5=E8=AF=A2--=E6=9F=A5=E8=AF=A2=E6=9D=A1?=
 =?UTF-8?q?=E4=BB=B6=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ComplaintCollectionPageRequest.java       |  3 +++
 .../ComplaintCollectionResourceService.java   |  1 +
 .../service/NegativeQueryService.java         | 19 +++++++++++++------
 3 files changed, 17 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/biutag/supervision/pojo/request/complaintCollection/ComplaintCollectionPageRequest.java b/src/main/java/com/biutag/supervision/pojo/request/complaintCollection/ComplaintCollectionPageRequest.java
index fc3db8d..d405fec 100644
--- a/src/main/java/com/biutag/supervision/pojo/request/complaintCollection/ComplaintCollectionPageRequest.java
+++ b/src/main/java/com/biutag/supervision/pojo/request/complaintCollection/ComplaintCollectionPageRequest.java
@@ -69,6 +69,9 @@ public class ComplaintCollectionPageRequest extends BasePage implements ParamChe
     @Schema(description = "信件状态（局）")
     private String processingStatus;
 
+    @Schema(description = "状态")
+    private String status;
+
     @Override
     public void check() {
         if (CollectionUtil.isNotEmpty(discoveryTimeList)){
diff --git a/src/main/java/com/biutag/supervision/repository/complaintCollection/ComplaintCollectionResourceService.java b/src/main/java/com/biutag/supervision/repository/complaintCollection/ComplaintCollectionResourceService.java
index f8a94b6..0bea387 100644
--- a/src/main/java/com/biutag/supervision/repository/complaintCollection/ComplaintCollectionResourceService.java
+++ b/src/main/java/com/biutag/supervision/repository/complaintCollection/ComplaintCollectionResourceService.java
@@ -74,6 +74,7 @@ public class ComplaintCollectionResourceService extends BaseDAO {
         qw.eq(StrUtil.isNotBlank(param.getRepeatt()), ComplaintCollection::getRepeatt, param.getRepeatt());
         qw.eq(StrUtil.isNotBlank(param.getLeadApproval()), ComplaintCollection::getLeadApproval, param.getLeadApproval());
         qw.eq(StrUtil.isNotBlank(param.getProcessingStatus()), ComplaintCollection::getProcessingStatus, param.getProcessingStatus());
+        qw.eq(StrUtil.isNotBlank(param.getStatus()), ComplaintCollection::getStatus, param.getStatus());
         // 来件内容
         // 标签（表里如果是逗号字符串 tag="URGENT,NORMAL"）
         // 语义：命中任意一个标签即可（OR）
diff --git a/src/main/java/com/biutag/supervision/service/NegativeQueryService.java b/src/main/java/com/biutag/supervision/service/NegativeQueryService.java
index 6d08745..eeeb0bd 100644
--- a/src/main/java/com/biutag/supervision/service/NegativeQueryService.java
+++ b/src/main/java/com/biutag/supervision/service/NegativeQueryService.java
@@ -182,11 +182,18 @@ public class NegativeQueryService {
             );
         }
         if (CollectionUtil.isNotEmpty(param.getHandleResultCode())){
-            String codes = param.getHandleResultCode().stream()
-                    .map(code -> "'" + code + "'")
-                    .collect(Collectors.joining(","));
-            queryWrapper.inSql( Negative::getId,
-                    "SELECT DISTINCT negativeId FROM negative_blame WHERE handleResultCode IN (" + codes + ")"
+            String likeOr = param.getHandleResultCode().stream()
+                    .map(code ->
+                            "("
+                                    + "CONCAT(',', handleResultCode, ',') LIKE CONCAT('%,','" + code + "',',%')"
+                                    + " OR "
+                                    + "CONCAT(',', leadHandleResultCode, ',') LIKE CONCAT('%,','" + code + "',',%')"
+                                    + ")"
+                    )
+                    .collect(Collectors.joining(" OR "));
+            queryWrapper.inSql(
+                    Negative::getId,
+                    "SELECT DISTINCT negativeId FROM negative_blame WHERE " + likeOr
             );
             queryWrapper.in(Negative::getProcessingStatus,List.of("completed", "approval"));
         }
@@ -201,7 +208,7 @@ public class NegativeQueryService {
             NegativeQueryVo vo = new NegativeQueryVo();
             BeanUtils.copyProperties(item, vo);
             if (Objects.nonNull(item.getFirstDistributeTime()) && !ProcessingStatusEnum.completed.name().equals(item.getProcessingStatus())) {
-                vo.setRemainingDuration(TimeUtil.getRemainingDuration(item.getFirstDistributeTime(), item.getMaxSignDuration(), item.getMaxHandleDuration(), item.getExtensionDays(), item.getFlowKey()));
+//                vo.setRemainingDuration(TimeUtil.getRemainingDuration(item.getFirstDistributeTime(), item.getMaxSignDuration(), item.getMaxHandleDuration(), item.getExtensionDays(), item.getFlowKey()));
             }
             return vo;
         }).toList();