app,消息通知, 新增未读消息统计

safety-eval-adapter/src/main/java/org/qinan/safetyeval/adapter/web/institution/app/AppSafetyMessageController.java

@@ -53,4 +53,10 @@ public class AppSafetyMessageController {
         query.setReceiveId(AuthUserContextAdapter.getCurrentUserId());
         return safetyMessageApi.page(query);
     }
+
+    @ApiOperation("获取信息未读数量")
+    @GetMapping("/unreadCount")
+    public SingleResponse<Long> unreadCount() {
+        return safetyMessageApi.unreadCount(AuthUserContextAdapter.getCurrentUserId());
+    }
 }

safety-eval-app/src/main/java/org/qinan/safetyeval/app/executor/SafetyMessageExecutor.java

@@ -83,4 +83,12 @@ public class SafetyMessageExecutor implements SafetyMessageApi {
         );
         return SingleResponse.success(true);
     }
+
+    @Override
+    public SingleResponse<Long> unreadCount(Long currentUserId) {
+        Long unreadCount = safetyMessageMapper.selectCount(new LambdaUpdateWrapper<SafetyMessageDO>()
+                .eq(SafetyMessageDO::getReceiveId, currentUserId)
+                .eq(SafetyMessageDO::getSendState, 0));
+        return SingleResponse.success(unreadCount);
+    }
 }

safety-eval-client/src/main/java/org/qinan/safetyeval/client/api/SafetyMessageApi.java

@@ -27,4 +27,6 @@ public interface SafetyMessageApi {
     PageResponse<SafetyMessageCO> page(SafetyMessagePageQuery query);
 
     SingleResponse<Boolean> batchMarkedAsRead(List<Long> data);
+
+    SingleResponse<Long> unreadCount(Long currentUserId);
 }