diff --git a/src/main/java/com/biutag/supervision/pojo/param/DataCaseVerifQueryParam.java b/src/main/java/com/biutag/supervision/pojo/param/DataCaseVerifQueryParam.java
index f53ae57..cd10269 100644
--- a/src/main/java/com/biutag/supervision/pojo/param/DataCaseVerifQueryParam.java
+++ b/src/main/java/com/biutag/supervision/pojo/param/DataCaseVerifQueryParam.java
@@ -28,7 +28,7 @@ public class DataCaseVerifQueryParam extends BasePage {
 
     private String checkStatus; // 是否属实
 
-    private String involvedIssue;
+    private List<String> involvedIssue;
 
 
     // 问题发现时间
diff --git a/src/main/java/com/biutag/supervision/pojo/param/DataPetitionComplaintQueryParam.java b/src/main/java/com/biutag/supervision/pojo/param/DataPetitionComplaintQueryParam.java
index 17c0166..d92d944 100644
--- a/src/main/java/com/biutag/supervision/pojo/param/DataPetitionComplaintQueryParam.java
+++ b/src/main/java/com/biutag/supervision/pojo/param/DataPetitionComplaintQueryParam.java
@@ -39,6 +39,6 @@ public class DataPetitionComplaintQueryParam extends BasePage {
     // 初重信访
     private String initialPetition;
 
-    private String involvedIssue;
+    private List<String> involvedIssue;
 
 }
diff --git a/src/main/java/com/biutag/supervision/pojo/param/DataThreadQueryParam.java b/src/main/java/com/biutag/supervision/pojo/param/DataThreadQueryParam.java
index 812a0c8..07d30b7 100644
--- a/src/main/java/com/biutag/supervision/pojo/param/DataThreadQueryParam.java
+++ b/src/main/java/com/biutag/supervision/pojo/param/DataThreadQueryParam.java
@@ -22,7 +22,7 @@ public class DataThreadQueryParam extends BasePage {
     //初重访
     private String initialPetition;
     //涉企涉冻
-    private String involvedIssue;
+    private List<String> involvedIssue;
     //具体内容
     private String thingDesc;
     //是否分发
diff --git a/src/main/java/com/biutag/supervision/service/DataCaseVerifService.java b/src/main/java/com/biutag/supervision/service/DataCaseVerifService.java
index 2c4e681..14ebacd 100644
--- a/src/main/java/com/biutag/supervision/service/DataCaseVerifService.java
+++ b/src/main/java/com/biutag/supervision/service/DataCaseVerifService.java
@@ -1,5 +1,6 @@
 package com.biutag.supervision.service;
 
+import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -41,7 +42,7 @@ public class DataCaseVerifService extends ServiceImpl<DataCaseVerifMapper, DataC
         queryWrapper.like(StrUtil.isNotBlank(queryParam.getOriginId()), DataCaseVerif::getOriginId, queryParam.getOriginId())
                 .like(StrUtil.isNotBlank(queryParam.getThingDesc()), DataCaseVerif::getThingDesc, queryParam.getThingDesc())
                 .eq(StrUtil.isNotBlank(queryParam.getCheckStatus()), DataCaseVerif::getIsReal, queryParam.getCheckStatus())
-                .eq(StrUtil.isNotBlank(queryParam.getInvolvedIssue()),DataCaseVerif::getInvolvedIssue,queryParam.getInvolvedIssue())
+                .in(CollectionUtil.isNotEmpty(queryParam.getInvolvedIssue()),DataCaseVerif::getInvolvedIssue,queryParam.getInvolvedIssue())
                 .eq(StrUtil.isNotBlank(queryParam.getDistributionState()), DataCaseVerif::getDistributionState, queryParam.getDistributionState())
                 .orderByDesc(DataCaseVerif::getCreateTime);
         if( !queryParam.getDiscoveryTime().isEmpty()){
diff --git a/src/main/java/com/biutag/supervision/service/DataPetitionComplaintService.java b/src/main/java/com/biutag/supervision/service/DataPetitionComplaintService.java
index a620f3a..e424dd7 100644
--- a/src/main/java/com/biutag/supervision/service/DataPetitionComplaintService.java
+++ b/src/main/java/com/biutag/supervision/service/DataPetitionComplaintService.java
@@ -1,6 +1,7 @@
 package com.biutag.supervision.service;
 
 import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -57,7 +58,7 @@ public class DataPetitionComplaintService extends ServiceImpl<DataPetitionCompla
                 .like(StrUtil.isNotBlank(queryParam.getThingDesc()), "pc.thing_desc", queryParam.getThingDesc())
                 .eq(StrUtil.isNotBlank(queryParam.getDistributionState()), "pc.distribution_state", queryParam.getDistributionState())
                 .eq(StrUtil.isNotBlank(queryParam.getInitialPetition()), "pc.initial_petition", queryParam.getInitialPetition())
-                .eq(StrUtil.isNotBlank(queryParam.getInvolvedIssue()),"pc.involved_issue",queryParam.getInvolvedIssue())
+                .in(CollectionUtil.isNotEmpty(queryParam.getInvolvedIssue()),"pc.involved_issue",queryParam.getInvolvedIssue())
                 .orderByDesc("pc.discovery_time");
         if (queryParam.getDiscoveryTime().size() == 2) {
             queryWrapper.between("pc.discovery_time", queryParam.getDiscoveryTime().get(0), queryParam.getDiscoveryTime().get(1));
diff --git a/src/main/java/com/biutag/supervision/service/DataThreadService.java b/src/main/java/com/biutag/supervision/service/DataThreadService.java
index e3537f7..ecdb3cb 100644
--- a/src/main/java/com/biutag/supervision/service/DataThreadService.java
+++ b/src/main/java/com/biutag/supervision/service/DataThreadService.java
@@ -85,10 +85,14 @@ public class DataThreadService {
                            break;
                    }
                }
+               if(CollectionUtil.isEmpty(queryParam.getInvolvedIssue())){
+                   return Result.success(new Page<>());
+               }
                return Result.success(dataMailboxService.page(Page.of(queryParam.getCurrent(), queryParam.getSize()), wrapper));
            }
            else{
                LambdaQueryWrapper<DataCaseVerif> wrapper = new LambdaQueryWrapper<DataCaseVerif>()
+                       .in(CollectionUtil.isNotEmpty(queryParam.getInvolvedIssue()),DataCaseVerif::getInvolvedIssue,queryParam.getInvolvedIssue())
                        .like(StrUtil.isNotBlank(queryParam.getOriginId()), DataCaseVerif::getOriginId, queryParam.getOriginId())
                        .like(StrUtil.isNotBlank(queryParam.getThingDesc()), DataCaseVerif::getThingDesc, queryParam.getThingDesc());
                if (queryParam.getDiscoveryTime().size() == 2) {
diff --git a/src/main/resources/mapper/DataThreadMapper.xml b/src/main/resources/mapper/DataThreadMapper.xml
index 29043d0..4a8cdee 100644
--- a/src/main/resources/mapper/DataThreadMapper.xml
+++ b/src/main/resources/mapper/DataThreadMapper.xml
@@ -34,8 +34,11 @@
                    <if test = "query.originId != null and query.originId != '' ">
                        and origin_id like concat('%',#{query.originId,jdbcType=VARCHAR},'%')
                    </if>
-                    <if test="query.involvedIssue != null and query.involvedIssue != ''">
-                        and involved_issue = #{query.involvedIssue}
+                    <if test="query.involvedIssue != null and query.involvedIssue != '' and query.involvedIssue.size() > 0">
+                        and involved_issue in
+                        <foreach collection="query.involvedIssue" item="data" open="(" close=")" separator=",">
+                            #{data}
+                        </foreach>
                     </if>
                     <if test="query.thingDesc != null and query.thingDesc != ''">
                         and thing_desc like concat('%',#{query.thingDesc,jdbcType=VARCHAR},'%')
@@ -92,8 +95,11 @@
             <if test = "query.originId != null and query.originId != '' ">
                 and origin_id like concat('%',#{query.originId,jdbcType=VARCHAR},'%')
             </if>
-            <if test="query.involvedIssue != null and query.involvedIssue != ''">
-                and involved_issue = #{query.involvedIssue}
+            <if test="query.involvedIssue != null and query.involvedIssue != '' and query.involvedIssue.size() > 0">
+                and involved_issue in
+                <foreach collection="query.involvedIssue" item="data" open="(" close=")" separator=",">
+                    #{data}
+                </foreach>
             </if>
             <if test="query.thingDesc != null and query.thingDesc != ''">
                 and thingDesc like concat('%',#{query.thingDesc,jdbcType=VARCHAR},'%')
@@ -144,8 +150,11 @@
             <if test = "query.originId != null and query.originId != '' ">
                 and originId like concat('%',#{query.originId,jdbcType=VARCHAR},'%')
             </if>
-            <if test="query.involvedIssue != null and query.involvedIssue != ''">
-                and involved_issue = #{query.involvedIssue}
+            <if test="query.involvedIssue != null and query.involvedIssue != '' and query.involvedIssue.size() > 0">
+                and involved_issue in
+                <foreach collection="query.involvedIssue" item="data" open="(" close=")" separator=",">
+                    #{data}
+                </foreach>
             </if>
             <if test="query.distributionState != null and query.distributionState != ''">
                 and distribution_state = #{query.distributionState}