package com.ks.daylucky.service.impl.remote;
|
|
import com.ks.daylucky.exception.UserMsgException;
|
import com.ks.daylucky.mapper.UserMsgMapper;
|
import com.ks.daylucky.pojo.DO.UserMsg;
|
import com.ks.daylucky.query.UserMsgQuery;
|
import com.ks.daylucky.service.UserMsgService;
|
import org.apache.dubbo.config.annotation.Service;
|
import org.springframework.validation.annotation.Validated;
|
|
import javax.annotation.Resource;
|
import javax.validation.Valid;
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.List;
|
|
@Service(version = "1.0.0")
|
public class UserMsgServiceImpl implements UserMsgService {
|
@Resource
|
private UserMsgMapper userMsgMapper;
|
|
@Validated
|
@Override
|
public void addMsg(@Valid UserMsg userMsg) throws UserMsgException {
|
if (userMsg.getCreateTime() == null) {
|
userMsg.setCreateTime(new Date());
|
}
|
userMsgMapper.insertSelective(userMsg);
|
}
|
|
@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[]{"create_time desc"});
|
|
return userMsgMapper.list(query);
|
}
|
|
@Override
|
public long countUserMsg(Long uid) {
|
UserMsgQuery query = new UserMsgQuery();
|
query.uid = uid;
|
return userMsgMapper.count(query);
|
}
|
|
@Override
|
public List<UserMsg> getUserMsgList(UserMsgQuery query, int page, int pageSize) {
|
query.start = (page - 1) * pageSize;
|
query.count = pageSize;
|
return userMsgMapper.list(query);
|
}
|
|
@Override
|
public long countUserMsg(UserMsgQuery query) {
|
return userMsgMapper.count(query);
|
}
|
|
@Override
|
public void delete(Long id) {
|
userMsgMapper.deleteByPrimaryKey(id);
|
}
|
}
|