From c0e125d71c1663af641ffdd8f53b8761217e3025 Mon Sep 17 00:00:00 2001
From: sol <bgasolyang@gmail.com>
Date: Wed, 18 Mar 2026 13:20:54 +0800
Subject: [PATCH] refactor(message): update message envelope controller and
 service methods

---
 .../common/message/service/MessageEnvelopeService.java       | 5 +++--
 .../system/message/controller/MessageEnvelopeController.java | 5 +++--
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/cloud/common/common-base-web/src/main/java/com/bgasol/common/message/service/MessageEnvelopeService.java b/cloud/common/common-base-web/src/main/java/com/bgasol/common/message/service/MessageEnvelopeService.java
index 46df525..d1c08d2 100644
--- a/cloud/common/common-base-web/src/main/java/com/bgasol/common/message/service/MessageEnvelopeService.java
+++ b/cloud/common/common-base-web/src/main/java/com/bgasol/common/message/service/MessageEnvelopeService.java
@@ -10,7 +10,6 @@ import com.bgasol.model.system.message.entity.MessageEnvelopeEntity;
 import com.bgasol.model.system.message.entity.MessageEnvelopeStatusEnum;
 import com.bgasol.model.system.user.api.UserApi;
 import com.bgasol.model.system.user.entity.UserEntity;
-import jakarta.validation.Valid;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.ObjectUtils;
@@ -41,6 +40,7 @@ public class MessageEnvelopeService extends BaseService<MessageEnvelopeEntity<?>
     }
 
     @Override
+    @Transactional(readOnly = true)
     public void findOtherTable(List<MessageEnvelopeEntity<?>> list) {
         Set<String> userIds = list.stream()
                 .map(MessageEnvelopeEntity::getUserId)
@@ -82,7 +82,8 @@ public class MessageEnvelopeService extends BaseService<MessageEnvelopeEntity<?>
         }
     }
 
-    public void read(@Valid List<String> ids) {
+    @Transactional
+    public void toReadById(List<String> ids) {
         Set<String> idSet = new HashSet<>(ids);
         MessageEnvelopeEntity<?> messageEnvelopeEntity = new MessageEnvelopeEntity<>();
         messageEnvelopeEntity.setStatus(MessageEnvelopeStatusEnum.READ);
diff --git a/cloud/web/web-system-8081/src/main/java/com/bgasol/web/system/message/controller/MessageEnvelopeController.java b/cloud/web/web-system-8081/src/main/java/com/bgasol/web/system/message/controller/MessageEnvelopeController.java
index 0e42059..4b7fd6e 100644
--- a/cloud/web/web-system-8081/src/main/java/com/bgasol/web/system/message/controller/MessageEnvelopeController.java
+++ b/cloud/web/web-system-8081/src/main/java/com/bgasol/web/system/message/controller/MessageEnvelopeController.java
@@ -13,6 +13,7 @@ import com.bgasol.model.system.message.entity.MessageEnvelopeEntity;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.validation.Valid;
+import jakarta.validation.constraints.NotEmpty;
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.*;
 
@@ -62,8 +63,8 @@ public class MessageEnvelopeController extends BaseController<
     @PostMapping("/read")
     @Operation(summary = "批量已读消息", operationId = "readMessageEnvelope")
     @SaCheckPermission(value = "messageEnvelope:read", orRole = "admin")
-    public BaseVo<Void> read(@RequestBody @Valid List<String> ids) {
-        messageEnvelopeService.read(ids);
+    public BaseVo<Void> read(@RequestBody @Valid @NotEmpty(message = "ids列表不能为空") List<String> ids) {
+        messageEnvelopeService.toReadById(ids);
         return BaseVo.success();
     }