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