diff --git a/adc-da-sys/src/main/java/com/adc/da/person/controller/PersonCollectEOController.java b/adc-da-sys/src/main/java/com/adc/da/person/controller/PersonCollectEOController.java
index 2e91e397..1601197f 100644
--- a/adc-da-sys/src/main/java/com/adc/da/person/controller/PersonCollectEOController.java
+++ b/adc-da-sys/src/main/java/com/adc/da/person/controller/PersonCollectEOController.java
@@ -43,10 +43,10 @@ public class PersonCollectEOController extends BaseController<TsPersonCollect> {
     **/
     @ApiOperation(value = "|PersonCollectEO|分页查询")
     @GetMapping("/page")
-    public ResponseMessage<IPage<TsPersonCollect>> page(Integer pageNo, Integer pageSize, String collectTitle, String modeType,String userId) throws Exception {
+    public ResponseMessage<IPage<TsPersonCollect>> page(Integer pageNo, Integer pageSize, String collectTitle, String modeType,String userId,Integer validFlag) throws Exception {
 
 
-        return personCollectEOService.queryCollectByWrapper(pageNo, pageSize,collectTitle,modeType,userId);
+        return personCollectEOService.queryCollectByWrapper(pageNo, pageSize,collectTitle,modeType,userId,validFlag);
 
     }
 
diff --git a/adc-da-sys/src/main/java/com/adc/da/person/service/IPersonCollectEOService.java b/adc-da-sys/src/main/java/com/adc/da/person/service/IPersonCollectEOService.java
index a68eefaf..ae505a87 100644
--- a/adc-da-sys/src/main/java/com/adc/da/person/service/IPersonCollectEOService.java
+++ b/adc-da-sys/src/main/java/com/adc/da/person/service/IPersonCollectEOService.java
@@ -28,7 +28,7 @@ public interface IPersonCollectEOService  extends IService<TsPersonCollect> {
 
     int updateByPrimaryKeySelective(TsPersonCollect tsPersonCollect) throws Exception;
 
-    public ResponseMessage<IPage<TsPersonCollect>> queryCollectByWrapper(Integer pageNo, Integer pageSize, String collectTitle,String modeType, String userId);
+    public ResponseMessage<IPage<TsPersonCollect>> queryCollectByWrapper(Integer pageNo, Integer pageSize, String collectTitle,String modeType, String userId,Integer validFlag);
 
     /**
      * 通过标准号和用户id查询是否收藏此标准
diff --git a/adc-da-sys/src/main/java/com/adc/da/person/service/impl/PersonCollectEOServiceImpl.java b/adc-da-sys/src/main/java/com/adc/da/person/service/impl/PersonCollectEOServiceImpl.java
index dd05be89..5b021183 100644
--- a/adc-da-sys/src/main/java/com/adc/da/person/service/impl/PersonCollectEOServiceImpl.java
+++ b/adc-da-sys/src/main/java/com/adc/da/person/service/impl/PersonCollectEOServiceImpl.java
@@ -133,7 +133,7 @@ public class PersonCollectEOServiceImpl extends ServiceImpl<PersonCollectEODao,
 
 
     @Override
-    public ResponseMessage<IPage<TsPersonCollect>> queryCollectByWrapper(Integer pageNo, Integer pageSize, String collectTitle, String modeType,String userId) {
+    public ResponseMessage<IPage<TsPersonCollect>> queryCollectByWrapper(Integer pageNo, Integer pageSize, String collectTitle, String modeType,String userId,Integer validFlag) {
         BasePage basePage = new BasePage();
         QueryWrapper<TsPersonCollect> wrapper = new QueryWrapper<>();
         wrapper.eq("user_id",userId);
@@ -144,6 +144,11 @@ public class PersonCollectEOServiceImpl extends ServiceImpl<PersonCollectEODao,
             List<String> ids = new ArrayList<>(Arrays.asList(modeType.split(",")));
             wrapper.in("collect_type",ids);
         }
+        if (validFlag != null && !validFlag.equals("") && validFlag == 0){
+            wrapper.eq("valid_flag",validFlag);
+        }else if (validFlag != null && !validFlag.equals("") && validFlag == 1){
+            wrapper.eq("valid_flag",validFlag);
+        }
         wrapper.orderByDesc("creation_Time");
 
         if (pageNo != null) {