| | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | |
|---|
| | | public static class DaoQuery extends BaseDaoQuery { |
|---|
| | | public Long uid; |
|---|
| | | public MsgTypeEnum msgType; |
|---|
| | | public Long identityCode; |
|---|
| | | } |
|---|
| | | } |
|---|
