From 81da61b828e29b7745e1382dfbbaeb685dc083ef Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 23 一月 2024 17:17:55 +0800
Subject: [PATCH] 抖音转链修改

---
 fanli/src/main/java/com/yeshi/fanli/dao/user/msg/MsgOverViewsDao.java |   12 ++++++++++++
 1 files changed, 12 insertions(+), 0 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/dao/user/msg/MsgOverViewsDao.java b/fanli/src/main/java/com/yeshi/fanli/dao/user/msg/MsgOverViewsDao.java
index ac5b6b4..c8bf4b2 100644
--- a/fanli/src/main/java/com/yeshi/fanli/dao/user/msg/MsgOverViewsDao.java
+++ b/fanli/src/main/java/com/yeshi/fanli/dao/user/msg/MsgOverViewsDao.java
@@ -3,7 +3,9 @@
 import com.ks.lijin.query.BaseDaoQuery;
 import com.yeshi.common.MongodbBaseDao;
 import com.yeshi.fanli.entity.bus.msg.MsgOverViews;
+import com.yeshi.fanli.entity.bus.msg.MsgTypeEnum;
 import org.springframework.data.domain.Sort;
+import org.springframework.data.mongodb.core.mapping.Field;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Repository;
@@ -21,6 +23,14 @@
         if (daoQuery.uid != null) {
             whereList.add(Criteria.where("uid").is(daoQuery.uid));
         }
+        if (daoQuery.identityCode != null) {
+            whereList.add(Criteria.where("identityCode").is(daoQuery.identityCode));
+        }
+        if (daoQuery.msgType != null) {
+            whereList.add(Criteria.where("msgType").is(daoQuery.msgType));
+        }
+
+
         Criteria[] wheres = new Criteria[whereList.size()];
         whereList.toArray(wheres);
         return wheres;
@@ -44,5 +54,7 @@
 
     public static class DaoQuery extends BaseDaoQuery {
         public Long uid;
+        public  MsgTypeEnum msgType;
+        public Long identityCode;
     }
 }

--
Gitblit v1.8.0