From 74196bcc835d9b76cdd1bc3d85b0dfbe0191fc00 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期四, 31 十二月 2020 19:23:43 +0800 Subject: [PATCH] 活动信息缓存 --- service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserMsgServiceImpl.java | 24 +++++++++++++----------- 1 files changed, 13 insertions(+), 11 deletions(-) diff --git a/service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserMsgServiceImpl.java b/service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserMsgServiceImpl.java index 5127195..0c41943 100644 --- a/service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserMsgServiceImpl.java +++ b/service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserMsgServiceImpl.java @@ -1,11 +1,11 @@ package com.ks.daylucky.service.impl.remote; +import com.ks.daylucky.dao.UserMsgDao; 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.stereotype.Service; import org.springframework.validation.annotation.Validated; import javax.annotation.Resource; @@ -14,10 +14,10 @@ import java.util.Date; import java.util.List; -@Service(version = "1.0.0") +@Service public class UserMsgServiceImpl implements UserMsgService { @Resource - private UserMsgMapper userMsgMapper; + private UserMsgDao userMsgDao; @Validated @Override @@ -25,7 +25,9 @@ if (userMsg.getCreateTime() == null) { userMsg.setCreateTime(new Date()); } - userMsgMapper.insertSelective(userMsg); + userMsg.setId(UserMsg.createId(userMsg.getUid())); + + userMsgDao.save(userMsg); } @Override @@ -34,32 +36,32 @@ query.uid = uid; query.start = (page - 1) * pageSize; query.count = pageSize; - query.sortList = Arrays.asList(new String[]{"create_time desc"}); + query.sortList = Arrays.asList(new String[]{"createTime desc"}); - return userMsgMapper.list(query); + return userMsgDao.list(query); } @Override public long countUserMsg(Long uid) { UserMsgQuery query = new UserMsgQuery(); query.uid = uid; - return userMsgMapper.count(query); + return userMsgDao.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); + return userMsgDao.list(query); } @Override public long countUserMsg(UserMsgQuery query) { - return userMsgMapper.count(query); + return userMsgDao.count(query); } @Override public void delete(Long id) { - userMsgMapper.deleteByPrimaryKey(id); + userMsgDao.delete(id); } } -- Gitblit v1.8.0