From 1752e67b285e9109e3982748c4c70128d450eeac Mon Sep 17 00:00:00 2001
From: easonzhu <easonzhu@upchina.com>
Date: Fri, 14 Feb 2025 15:24:17 +0800
Subject: [PATCH] =?UTF-8?q?=E9=98=85=E8=AF=BB=E6=95=B0=E7=BB=9F=E8=AE=A1?=
 =?UTF-8?q?=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../upchina/group/service/common/GroupCommonService.java   | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/src/main/java/com/upchina/group/service/common/GroupCommonService.java b/src/main/java/com/upchina/group/service/common/GroupCommonService.java
index b53b55e..13ef045 100644
--- a/src/main/java/com/upchina/group/service/common/GroupCommonService.java
+++ b/src/main/java/com/upchina/group/service/common/GroupCommonService.java
@@ -67,6 +67,9 @@ public class GroupCommonService {
                         map.computeIfAbsent(m, k -> new HashSet<>()).add(read.getUserId()));
             }
         }
+
+        LocalDateTime now = LocalDateTime.now();
+
         List<GroupMessageRead> list = map.entrySet().stream()
                 .map(entry -> {
                     Integer messageId = entry.getKey();
@@ -82,6 +85,7 @@ public class GroupCommonService {
                         read.setMessageId(messageId);
                         read.setUserId(userId);
                         read.setGroupId(message.getGroupId());
+                        read.setCreateTime(now);
                         return read;
                     }).collect(Collectors.toList());
                 }).filter(Objects::nonNull).flatMap(List::stream).collect(Collectors.toList());
@@ -172,6 +176,8 @@ public class GroupCommonService {
         List<GroupMessage> messageCollect = groupMessageMapper.collectMessage(startTime, endTime);
         Map<Integer, List<GroupMessage>> groupMessageMap = messageCollect.stream().collect(Collectors.groupingBy(GroupMessage::getGroupId));
 
+        LocalDateTime now = LocalDateTime.now();
+
         List<GroupCollect> collectList = groupIds.stream().map(groupId -> {
             GroupCollect collect = new GroupCollect();
             collect.setGroupId(groupId);
@@ -219,6 +225,7 @@ public class GroupCommonService {
                     }
                 }
             }
+            collect.setCreateTime(now);
             return collect;
         }).collect(Collectors.toList());
         if (CollUtil.isNotEmpty(collectList)) {