我的消息未读数

sys-api-service/src/main/java/com/xy/service/MsgUserMessageServiceImpl.java

@@ -3,6 +3,7 @@ package com.xy.service;
 import cn.hutool.core.collection.CollUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.xy.dto.MsgUserMessageDto;
 import com.xy.entity.MsgSysMonitorNotice;
@@ -61,6 +62,16 @@ public class MsgUserMessageServiceImpl extends ServiceImpl<MsgUserMessageMapper,
         return R.ok(copy(MsgUserMessageDto.Vo.class, list));
     }
 
+    @ApiOperation("我的消息-未读数量")
+    @Override
+    public R<Long> myMsgUnRead() {
+        long count = this.count(Wrappers.<MsgUserMessage>lambdaQuery()
+                .eq(MsgUserMessage::getUserId, AuthorizeUtils.getLoginId(Long.class))
+                .eq(MsgUserMessage::getReadState, MsgReadStatus.UN_READ.getCode()));
+        return R.ok(count);
+    }
+
+
     @ApiOperation("我的消息")
     @Override
     public R<PageBean<MsgUserMessageDto.PageVO>> myMsgPage(MsgUserMessageDto.Page page) {

sys-api/src/main/java/com/xy/service/MsgUserMessageService.java

@@ -22,6 +22,9 @@ public interface MsgUserMessageService {
     @PostMapping("obj")
     R<MsgUserMessageDto.Vo> obj(@RequestBody MsgUserMessageDto.Vo vo);
 
+    @PostMapping("unRead")
+    R<Long> myMsgUnRead();
+
     @PostMapping("myMsg")
     R<PageBean<MsgUserMessageDto.PageVO>> myMsgPage(@RequestBody MsgUserMessageDto.Page page);