package com.ks.daylucky.service.impl.remote;
|
|
import com.ks.daylucky.dao.UserMsgDao;
|
import com.ks.daylucky.exception.UserMsgException;
|
import com.ks.daylucky.pojo.DO.UserMsg;
|
import com.ks.daylucky.pojo.DTO.msg.LuckyMsgContent;
|
import com.ks.daylucky.query.UserMsgQuery;
|
import com.ks.daylucky.service.UserInfoExtraService;
|
import com.ks.daylucky.service.UserMsgService;
|
import org.springframework.stereotype.Service;
|
import org.springframework.validation.annotation.Validated;
|
import org.yeshi.utils.alipay.AlipayXcxUtil;
|
|
import javax.annotation.Resource;
|
import javax.validation.Valid;
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.List;
|
|
@Service
|
public class UserMsgServiceImpl implements UserMsgService {
|
@Resource
|
private UserMsgDao userMsgDao;
|
|
@Resource
|
private UserInfoExtraService userInfoExtraService;
|
|
@Validated
|
@Override
|
public void addMsg(@Valid UserMsg userMsg) throws UserMsgException {
|
if (userMsg.getCreateTime() == null) {
|
userMsg.setCreateTime(new Date());
|
}
|
userMsg.setId(UserMsg.createId(userMsg.getUid()));
|
|
userMsgDao.save(userMsg);
|
|
//添加未读提醒
|
userInfoExtraService.addMsgUnReadCount(userMsg.getUid(), 1);
|
}
|
|
@Override
|
public List<UserMsg> getUserMsgList(Long uid, int page, int pageSize) {
|
UserMsgQuery query = new UserMsgQuery();
|
query.uid = uid;
|
query.start = (page - 1) * pageSize;
|
query.count = pageSize;
|
query.sortList = Arrays.asList(new String[]{"createTime desc"});
|
|
return userMsgDao.list(query);
|
}
|
|
@Override
|
public long countUserMsg(Long uid) {
|
UserMsgQuery query = new UserMsgQuery();
|
query.uid = uid;
|
return userMsgDao.count(query);
|
}
|
|
@Override
|
public List<UserMsg> getUserMsgList(UserMsgQuery query, int page, int pageSize) {
|
query.start = (page - 1) * pageSize;
|
query.count = pageSize;
|
return userMsgDao.list(query);
|
}
|
|
@Override
|
public long countUserMsg(UserMsgQuery query) {
|
return userMsgDao.count(query);
|
}
|
|
@Override
|
public void delete(Long id) {
|
userMsgDao.delete(id);
|
}
|
}
|
