From 7e92012fe9bc9172dd6265871ade82216fd50555 Mon Sep 17 00:00:00 2001
From: zhanglei <xx@cenxi.online>
Date: Wed, 5 Aug 2026 19:31:29 +0800
Subject: [PATCH] =?UTF-8?q?app,=E6=B6=88=E6=81=AF=E9=80=9A=E7=9F=A5,=20?=
 =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=9C=AA=E8=AF=BB=E6=B6=88=E6=81=AF=E7=BB=9F?=
 =?UTF-8?q?=E8=AE=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../web/institution/app/AppSafetyMessageController.java   | 6 ++++++
 .../safetyeval/app/executor/SafetyMessageExecutor.java    | 8 ++++++++
 .../org/qinan/safetyeval/client/api/SafetyMessageApi.java | 2 ++
 3 files changed, 16 insertions(+)

diff --git a/safety-eval-adapter/src/main/java/org/qinan/safetyeval/adapter/web/institution/app/AppSafetyMessageController.java b/safety-eval-adapter/src/main/java/org/qinan/safetyeval/adapter/web/institution/app/AppSafetyMessageController.java
index 6e47454..9661555 100644
--- a/safety-eval-adapter/src/main/java/org/qinan/safetyeval/adapter/web/institution/app/AppSafetyMessageController.java
+++ b/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());
+    }
 }
diff --git a/safety-eval-app/src/main/java/org/qinan/safetyeval/app/executor/SafetyMessageExecutor.java b/safety-eval-app/src/main/java/org/qinan/safetyeval/app/executor/SafetyMessageExecutor.java
index 4ef7f1c..761739d 100644
--- a/safety-eval-app/src/main/java/org/qinan/safetyeval/app/executor/SafetyMessageExecutor.java
+++ b/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);
+    }
 }
diff --git a/safety-eval-client/src/main/java/org/qinan/safetyeval/client/api/SafetyMessageApi.java b/safety-eval-client/src/main/java/org/qinan/safetyeval/client/api/SafetyMessageApi.java
index 010b5af..d60de66 100644
--- a/safety-eval-client/src/main/java/org/qinan/safetyeval/client/api/SafetyMessageApi.java
+++ b/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);
 }