修复抖音订单更新问题/修复用户注销却自动封禁的bug

admin

2023-01-03 5710fee2bd5c323096377a72d837050dd52d93b1

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
package com.yeshi.fanli.dao.user.msg;
 
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;
 
import java.util.ArrayList;
import java.util.List;
 
@Repository
public class MsgOverViewsDao extends MongodbBaseDao<MsgOverViews> {
 
 
    private Criteria[] getWheres(DaoQuery daoQuery) {
        List<Criteria> whereList = new ArrayList<>();
 
        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 List<MsgOverViews> list(DaoQuery daoQuery) {
        Query query = new Query();
        query.addCriteria(new Criteria().andOperator(getWheres(daoQuery)));
        query.skip((int) daoQuery.start);
        query.limit(daoQuery.count);
        query.with(new Sort(Sort.Direction.DESC, "updateTime"));
        return findList(query);
    }
 
    public long count(DaoQuery daoQuery) {
        Query query = new Query();
        query.addCriteria(new Criteria().andOperator(getWheres(daoQuery)));
        return count(query);
    }
 
 
    public static class DaoQuery extends BaseDaoQuery {
        public Long uid;
        public  MsgTypeEnum msgType;
        public Long identityCode;
    }
}