feat:消息模块开发

project-order/src/main/java/com/dituhui/pea/order/controller/MsgController.java

@@ -81,9 +81,9 @@ public class MsgController {
      * @date 2023/10/24
      */
     @PostMapping("/msg/read")
-    public Result<Boolean> read(@RequestHeader(name = "userId", required = true) String userId, @RequestBody @Valid MsgDTO.DeleteDto dto) {
+    public Result<Boolean> read(@RequestHeader(name = "userId", required = true) String userId, @RequestBody @Valid MsgDTO.ReadDto dto) {
         AssertUtil.isNotEmpty(userId, "用户ID不能为空");
-        msgService.readMsg(dto.getId(), userId);
+        msgService.readMsg(dto.getIds(), userId);
         return Result.success(true);
     }
 

project-order/src/main/java/com/dituhui/pea/order/dao/MsgReceiverDao.java

@@ -2,6 +2,14 @@ package com.dituhui.pea.order.dao;
 
 import com.dituhui.pea.order.entity.MsgReceiverEntity;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.util.List;
 
 public interface MsgReceiverDao extends JpaRepository<MsgReceiverEntity, Integer> {
+    @Modifying
+    @Query(value = "update zzz_msg_receiver set is_read=1 where msg_id in (:msgIds) and user_id=:userId", nativeQuery = true)
+    void read(@Param("msgIds") List<Integer> msgIds, @Param("userId") String userId);
 }

project-order/src/main/java/com/dituhui/pea/order/dto/MsgDTO.java

@@ -5,10 +5,12 @@ import org.springframework.format.annotation.DateTimeFormat;
 
 import javax.validation.constraints.Max;
 import javax.validation.constraints.Min;
+import javax.validation.constraints.NotEmpty;
 import javax.validation.constraints.NotNull;
 
 import java.time.LocalDate;
 import java.util.Date;
+import java.util.List;
 
 import static com.dituhui.pea.order.config.OrderConfig.DEFAULT_PAGE_SIZE;
 
@@ -67,6 +69,16 @@ public class MsgDTO {
         private Integer id;
     }
 
+    @lombok.Data
+    public static class ReadDto {
+
+        /**
+         * 消息Id集合
+         */
+        @NotEmpty(message = "消息Id集合不能为空")
+        private List<Integer> ids;
+    }
+
 
     @lombok.Data
     public static class addDto {

project-order/src/main/java/com/dituhui/pea/order/service/MsgService.java

@@ -5,6 +5,8 @@ import com.dituhui.pea.order.dto.MsgDTO;
 import com.dituhui.pea.order.dto.MsgGroupResp;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.List;
+
 public interface MsgService {
 
     /**
@@ -30,13 +32,13 @@ public interface MsgService {
     /**
      * 设置消息已读
      *
-     * @param msgId  味精标识
+     * @param msgIds  消息标识
      * @param userId 用户标识
      * @author RenPing
      * @date 2023/10/25
      */
     @Transactional(rollbackFor = Exception.class)
-    void readMsg(Integer msgId, String userId);
+    void readMsg(List<Integer> msgIds, String userId);
 
     /**
      * 新增消息

project-order/src/main/java/com/dituhui/pea/order/service/impl/MsgServiceImpl.java

@@ -94,12 +94,8 @@ public class MsgServiceImpl implements MsgService {
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void readMsg(Integer msgId, String userId) {
-        List<MsgReceiverEntity> list = msgReceiverDao.findAll(Example.of(new MsgReceiverEntity().setMsgId(msgId).setUserId(userId)));
-        list.forEach(msgReceiverEntity -> {
-            msgReceiverEntity.setIsRead(1).setUpdateTime(new Date());
-            msgReceiverDao.save(msgReceiverEntity);
-        });
+    public void readMsg(List<Integer> msgIds, String userId) {
+        msgReceiverDao.read(msgIds, userId);
     }
 
     @Override