功能完善

admin

2021-11-27 4f015b8c624484e0c3b2d88b944163ce43a48d1f

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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
package com.yeshi.location.app.service.impl.location;
 
import java.lang.Exception;
import javax.annotation.Resource;
 
import org.springframework.data.domain.Sort;
import org.springframework.stereotype.Service;
 
import java.util.Arrays;
import java.util.Date;
 
import org.yeshi.utils.bean.BeanUtil;
 
import java.util.List;
 
import com.yeshi.location.app.dao.location.LocationUsersDao;
import com.yeshi.location.app.entity.location.LocationUsers;
import com.yeshi.location.app.service.inter.location.LocationUsersService;
import com.yeshi.location.app.service.query.location.LocationUsersQuery;
import com.yeshi.location.app.dao.location.LocationUsersDao.DaoQuery;
 
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
 
@Service
public class LocationUsersServiceImpl implements LocationUsersService {
 
    @Resource
    private LocationUsersDao locationUsersDao;
 
    @Override
    public List<LocationUsers> list(LocationUsersQuery locationUsersQuery, int page, int pageSize) {
        DaoQuery daoQuery = new DaoQuery();
        try {
            BeanUtil.copyProperties(locationUsersQuery, daoQuery);
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        }
        daoQuery.start = (page - 1) * pageSize;
        daoQuery.count = pageSize;
        daoQuery.sortList = Arrays.asList(new Sort.Order[]{Sort.Order.desc("createTime")});
        return locationUsersDao.list(daoQuery);
    }
 
    @Override
    public long count(LocationUsersQuery locationUsersQuery) {
        DaoQuery daoQuery = new DaoQuery();
        try {
            BeanUtil.copyProperties(locationUsersQuery, daoQuery);
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        }
        return locationUsersDao.count(daoQuery);
    }
 
    @Override
    public LocationUsers get(String id) {
        Query query = new Query();
        query.addCriteria(Criteria.where("_id").is(id));
        return locationUsersDao.findOne(query);
    }
 
    @Override
    public void add(LocationUsers locationUsers) throws Exception {
 
        if (locationUsers.getId() == null) {
            locationUsers.setId(LocationUsers.createId(locationUsers.getUid(), locationUsers.getTargetUid()));
        }
 
        if (locationUsers.getUid().equals(locationUsers.getTargetUid())) {
            throw new Exception("不能添加自己");
        }
 
        //查询主键ID是否存在
        if (locationUsersDao.get(locationUsers.getId()) != null) {
            throw new Exception("已存在");
        }
 
        if (locationUsers.getStatus() == null) {
            locationUsers.setStatus(LocationUsers.LocationInviteStatus.sentInvite);
        }
 
        if (locationUsers.getSentCount() == null) {
            locationUsers.setSentCount(0);
        }
        if (locationUsers.getCreateTime() == null) {
            locationUsers.setCreateTime(new Date());
        }
        //保存
        locationUsersDao.save(locationUsers);
    }
 
    @Override
    public void update(LocationUsers locationUsers) {
        if (locationUsers.getUpdateTime() == null) {
            locationUsers.setUpdateTime(new Date());
        }
        //更新
        locationUsersDao.updateSelective(locationUsers);
    }
 
    @Override
    public void delete(List<String> idList) {
        for (String id : idList) {
            locationUsersDao.delete(id);
        }
    }
 
    @Override
    public List<LocationUsers> listMyLocationUser(Long uid,Long targetUid, LocationUsers.LocationInviteStatus status, int page, int pageSize) {
        DaoQuery daoQuery = new DaoQuery();
        daoQuery.start = (page - 1) * pageSize;
        daoQuery.count = pageSize;
        daoQuery.status = status;
        daoQuery.uid = uid;
        daoQuery.targetUid = targetUid;
        return locationUsersDao.list(daoQuery);
    }
 
    @Override
    public long countMyLocationUser(Long uid, LocationUsers.LocationInviteStatus status) {
        DaoQuery daoQuery = new DaoQuery();
        daoQuery.uid = uid;
        daoQuery.status = status;
        return locationUsersDao.count(daoQuery);
    }
 
    @Override
    public LocationUsers selectByUidAndTargetUid(Long uid, Long targetUid) {
        DaoQuery daoQuery = new DaoQuery();
        daoQuery.uid = uid;
        daoQuery.targetUid = targetUid;
        daoQuery.count = 1;
        List<LocationUsers> list = locationUsersDao.list(daoQuery);
        return list != null && list.size() > 0 ? list.get(0) : null;
    }
 
 
}