package com.yeshi.makemoney.app.service.impl.msg;
|
|
import java.lang.Exception;
|
import javax.annotation.Resource;
|
|
import com.yeshi.makemoney.app.entity.user.UserExtraInfo;
|
import com.yeshi.makemoney.app.service.inter.user.UserExtraInfoService;
|
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.makemoney.app.dao.msg.UserMsgDao;
|
import com.yeshi.makemoney.app.entity.msg.UserMsg;
|
import com.yeshi.makemoney.app.service.inter.msg.UserMsgService;
|
import com.yeshi.makemoney.app.service.query.msg.UserMsgQuery;
|
import com.yeshi.makemoney.app.dao.msg.UserMsgDao.DaoQuery;
|
|
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Query;
|
|
@Service
|
public class UserMsgServiceImpl implements UserMsgService {
|
|
@Resource
|
private UserMsgDao userMsgDao;
|
|
@Resource
|
private UserExtraInfoService userExtraInfoService;
|
|
@Override
|
public List<UserMsg> list(UserMsgQuery userMsgQuery, int page, int pageSize) {
|
DaoQuery daoQuery = new DaoQuery();
|
daoQuery.uid = userMsgQuery.getUid();
|
daoQuery.type = userMsgQuery.getType();
|
daoQuery.minCreateTime = userMsgQuery.toStartTime();
|
daoQuery.maxCreateTime = userMsgQuery.toEndTime();
|
daoQuery.sortList = Arrays.asList(new Sort.Order[]{Sort.Order.desc("createTime")});
|
daoQuery.start = (page - 1) * pageSize;
|
daoQuery.count = pageSize;
|
return userMsgDao.list(daoQuery);
|
}
|
|
@Override
|
public long count(UserMsgQuery userMsgQuery) {
|
DaoQuery daoQuery = new DaoQuery();
|
daoQuery.uid = userMsgQuery.getUid();
|
daoQuery.type = userMsgQuery.getType();
|
daoQuery.minCreateTime = userMsgQuery.toStartTime();
|
daoQuery.maxCreateTime = userMsgQuery.toEndTime();
|
return userMsgDao.count(daoQuery);
|
}
|
|
@Override
|
public UserMsg get(String id) {
|
Query query = new Query();
|
query.addCriteria(Criteria.where("_id").is(id));
|
return userMsgDao.findOne(query);
|
}
|
|
@Override
|
public void add(UserMsg userMsg) throws Exception {
|
|
if (userMsg.getCreateTime() == null) {
|
userMsg.setCreateTime(new Date());
|
}
|
|
if (userMsg.getId() == null) {
|
userMsg.setId(userMsg.toId());
|
}
|
|
//查询主键ID是否存在
|
if (userMsgDao.get(userMsg.getId()) != null) {
|
throw new Exception("已存在");
|
}
|
|
//保存
|
userMsgDao.save(userMsg);
|
|
//添加消息数量
|
userExtraInfoService.addUnReadMsgCount(userMsg.getUid(), 1);
|
}
|
|
@Override
|
public void update(UserMsg userMsg) {
|
if (userMsg.getUpdateTime() == null) {
|
userMsg.setUpdateTime(new Date());
|
}
|
//更新
|
userMsgDao.updateSelective(userMsg);
|
}
|
|
@Override
|
public void delete(List<String> idList) {
|
for (String id : idList) {
|
userMsgDao.delete(id);
|
}
|
}
|
|
@Override
|
public void readAllMsg(Long uid) {
|
userExtraInfoService.setMsgRead(uid);
|
}
|
|
|
}
|
