From ed38a454a8609792a7dd7f72673e10470af9508c Mon Sep 17 00:00:00 2001 From: ajaxfan <909938737@qq.com> Date: Thu, 18 Mar 2021 15:57:17 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E5=A2=9E=E5=8A=A0=E7=94=A8?= =?UTF-8?q?=E6=88=B7=E5=8F=AF=E8=A7=81=E6=80=A7=E6=8E=A7=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../bizmessage/dao/BizMessageMapper.java | 5 +++++ .../dao/mapper/BizMessageMapper.xml | 21 +++++++++++++++++++ .../impl/BizMessageConsumerServiceImpl.java | 12 +++++------ 3 files changed, 32 insertions(+), 6 deletions(-) create mode 100644 src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java index 0ce7fdd..b504edb 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java @@ -1,8 +1,13 @@ package com.chinaunicom.mall.ebtp.extend.bizmessage.dao; +import org.apache.ibatis.annotations.Param; + import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessage; public interface BizMessageMapper extends BaseMapper { + IPage findMessage(@Param("param") IPage page, @Param("userId") String userId); + } diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml new file mode 100644 index 0000000..1d6cdc6 --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml @@ -0,0 +1,21 @@ + + + + + + + \ No newline at end of file diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageConsumerServiceImpl.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageConsumerServiceImpl.java index 3e63b54..07fb7ec 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageConsumerServiceImpl.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageConsumerServiceImpl.java @@ -7,9 +7,9 @@ import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.chinaunicom.mall.ebtp.common.base.service.IBaseCacheUserService; import com.chinaunicom.mall.ebtp.extend.bizmessage.dao.BizMessageMapper; import com.chinaunicom.mall.ebtp.extend.bizmessage.dto.PageDTO; import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessage; @@ -27,6 +27,7 @@ import com.chinaunicom.mall.ebtp.extend.bizmessage.vo.DescribeSiteMsgVO; public class BizMessageConsumerServiceImpl implements BizMessageConsumerService { private @Autowired BizMessageMapper mapper; + private @Autowired IBaseCacheUserService service; /** * 消息概要列表 @@ -36,11 +37,10 @@ public class BizMessageConsumerServiceImpl implements BizMessageConsumerService @Override public IBizMessagePage listOutline(PageDTO page) { page = createPageCondition(page); - - IPage pageEntity = mapper.selectPage(new Page<>(page.getPageNo(), page.getPageSize()), - new QueryWrapper().select("id", "title", "category", "createtime") - .orderByDesc("createtime")); - + + IPage pageEntity = mapper.findMessage(new Page(page.getPageNo(), page.getPageSize()), + service.getCacheUser().getUserId()); + // DAT -> VO 转换 IBizMessagePage result = new BizMessagePage<>(); BeanUtils.copyProperties(pageEntity, result, "records");