caojiahao/dev_caojiahao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!12 会员消息问题整改

Browse Source 
Merge pull request !12 from chopper711/qiuqiu
This commit is contained in:
chopper711 2021-06-29 01:05:15 +00:00 committed by Gitee
commit 707c4dbec2
4 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
buyer-api/src/main/java/cn/lili/controller/member/MemberMessageBuyerController.java
View File

@ -1,6 +1,7 @@
package cn.lili.controller.member; package cn.lili.controller.member;
import cn.lili.common.enums.ResultUtil; import cn.lili.common.enums.ResultUtil;
import cn.lili.common.security.context.UserContext;
import cn.lili.common.vo.PageVO; import cn.lili.common.vo.PageVO;
import cn.lili.common.vo.ResultMessage; import cn.lili.common.vo.ResultMessage;
import cn.lili.modules.message.entity.enums.MessageStatusEnum; import cn.lili.modules.message.entity.enums.MessageStatusEnum;
@ -34,21 +35,23 @@ public class MemberMessageBuyerController {
@ApiOperation(value = "分页获取会员站内消息") @ApiOperation(value = "分页获取会员站内消息")
@GetMapping @GetMapping
public ResultMessage<IPage<MemberMessage>> page(MemberMessageQueryVO memberMessageQueryVO, PageVO page) { public ResultMessage<IPage<MemberMessage>> page(MemberMessageQueryVO memberMessageQueryVO, PageVO page) {
memberMessageQueryVO.setMemberId(UserContext.getCurrentUser().getId());
return ResultUtil.data(memberMessageService.getPage(memberMessageQueryVO, page)); return ResultUtil.data(memberMessageService.getPage(memberMessageQueryVO, page));
} }
@ApiOperation(value = "消息已读") @ApiOperation(value = "消息已读")
@ApiImplicitParam(name = "messageId", value = "会员消息id", required = true, paramType = "path") @ApiImplicitParam(name = "messageId", value = "会员消息id", required = true, paramType = "path")
@PutMapping @PutMapping("/{message_id}")
public ResultMessage<Boolean> read(@PathVariable String messageId) { public ResultMessage<Boolean> read(@PathVariable("message_id") String messageId) {
return ResultUtil.data(memberMessageService.editStatus(MessageStatusEnum.ALREADY_READY.name(), messageId)); return ResultUtil.data(memberMessageService.editStatus(MessageStatusEnum.ALREADY_READY.name(), messageId));
} }
@ApiOperation(value = "消息删除") @ApiOperation(value = "消息放入回收站")
@ApiImplicitParam(name = "messageId", value = "会员消息id", required = true, paramType = "path") @ApiImplicitParam(name = "messageId", value = "会员消息id", required = true, paramType = "path")
@DeleteMapping @DeleteMapping("/{message_id}")
public ResultMessage<Boolean> deleteMessage(@PathVariable String messageId) { public ResultMessage<Boolean> deleteMessage(@PathVariable("message_id") String messageId) {
return ResultUtil.data(memberMessageService.deleteMessage(messageId)); return ResultUtil.data(memberMessageService.editStatus(MessageStatusEnum.ALREADY_REMOVE.name(), messageId));
} }

2
consumer/src/main/java/cn/lili/listener/NoticeSendMessageListener.java
View File

@ -148,7 +148,7 @@ public class NoticeSendMessageListener implements RocketMQListener<MessageExt> {
Integer memberNum = memberService.getMemberNum(memberSearchVO); Integer memberNum = memberService.getMemberNum(memberSearchVO);
//构建分页查询参数 //构建分页查询参数
//100条查一次 //100条查一次
Integer pageSize = 200; Integer pageSize = 100;
Integer pageCount = 0; Integer pageCount = 0;
pageCount = memberNum / pageSize; pageCount = memberNum / pageSize;
pageCount = memberNum % pageSize > 0 ? pageCount + 1 : pageCount; pageCount = memberNum % pageSize > 0 ? pageCount + 1 : pageCount;

2
framework/src/main/java/cn/lili/modules/message/entity/dos/MemberMessage.java
View File

@ -43,7 +43,7 @@ public class MemberMessage extends BaseEntity {
/** /**
* @see MessageStatusEnum * @see MessageStatusEnum
*/ */
@ApiModelProperty(value = "状态 0默认未读 1已读 2回收站") @ApiModelProperty(value = "状态")
private String status = MessageStatusEnum.UN_READY.name(); private String status = MessageStatusEnum.UN_READY.name();
} }

8
framework/src/main/java/cn/lili/modules/message/serviceimpl/MemberMessageServiceImpl.java
View File

@ -31,13 +31,15 @@ public class MemberMessageServiceImpl extends ServiceImpl<MemberMessageMapper, M
public IPage<MemberMessage> getPage(MemberMessageQueryVO memberMessageQueryVO, PageVO pageVO) { public IPage<MemberMessage> getPage(MemberMessageQueryVO memberMessageQueryVO, PageVO pageVO) {
QueryWrapper<MemberMessage> queryWrapper = new QueryWrapper<>(); QueryWrapper<MemberMessage> queryWrapper = new QueryWrapper<>();
//消息id //消息id
queryWrapper.like(StringUtils.isNotEmpty(memberMessageQueryVO.getMessageId()), "message_id", memberMessageQueryVO.getMessageId()); queryWrapper.eq(StringUtils.isNotEmpty(memberMessageQueryVO.getMessageId()), "message_id", memberMessageQueryVO.getMessageId());
//消息标题 //消息标题
queryWrapper.like(StringUtils.isNotEmpty(memberMessageQueryVO.getTitle()), "title", memberMessageQueryVO.getTitle()); queryWrapper.like(StringUtils.isNotEmpty(memberMessageQueryVO.getTitle()), "title", memberMessageQueryVO.getTitle());
//会员id //会员id
queryWrapper.like(StringUtils.isNotEmpty(memberMessageQueryVO.getMemberId()), "member_id", memberMessageQueryVO.getMemberId()); queryWrapper.eq(StringUtils.isNotEmpty(memberMessageQueryVO.getMemberId()), "member_id", memberMessageQueryVO.getMemberId());
//消息状态 //消息状态
queryWrapper.like(StringUtils.isNotEmpty(memberMessageQueryVO.getStatus()), "status", memberMessageQueryVO.getStatus()); queryWrapper.eq(StringUtils.isNotEmpty(memberMessageQueryVO.getStatus()), "status", memberMessageQueryVO.getStatus());
//倒序
queryWrapper.orderByDesc("create_time");
//构建查询 //构建查询
return this.page(PageUtil.initPage(pageVO), queryWrapper); return this.page(PageUtil.initPage(pageVO), queryWrapper);
} }