admin/AdvisorServer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

阅读数统计逻辑

Browse Source
This commit is contained in:
easonzhu 2025-02-14 15:24:17 +08:00
parent 42d7a81343
commit 1752e67b28
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/com/upchina/group/service/common/GroupCommonService.java
View File

@ -67,6 +67,9 @@ public class GroupCommonService {
map.computeIfAbsent(m, k -> new HashSet<>()).add(read.getUserId())); map.computeIfAbsent(m, k -> new HashSet<>()).add(read.getUserId()));
} }
} }
LocalDateTime now = LocalDateTime.now();
List<GroupMessageRead> list = map.entrySet().stream() List<GroupMessageRead> list = map.entrySet().stream()
.map(entry -> { .map(entry -> {
Integer messageId = entry.getKey(); Integer messageId = entry.getKey();
@ -82,6 +85,7 @@ public class GroupCommonService {
read.setMessageId(messageId); read.setMessageId(messageId);
read.setUserId(userId); read.setUserId(userId);
read.setGroupId(message.getGroupId()); read.setGroupId(message.getGroupId());
read.setCreateTime(now);
return read; return read;
}).collect(Collectors.toList()); }).collect(Collectors.toList());
}).filter(Objects::nonNull).flatMap(List::stream).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); List<GroupMessage> messageCollect = groupMessageMapper.collectMessage(startTime, endTime);
Map<Integer, List<GroupMessage>> groupMessageMap = messageCollect.stream().collect(Collectors.groupingBy(GroupMessage::getGroupId)); Map<Integer, List<GroupMessage>> groupMessageMap = messageCollect.stream().collect(Collectors.groupingBy(GroupMessage::getGroupId));
LocalDateTime now = LocalDateTime.now();
List<GroupCollect> collectList = groupIds.stream().map(groupId -> { List<GroupCollect> collectList = groupIds.stream().map(groupId -> {
GroupCollect collect = new GroupCollect(); GroupCollect collect = new GroupCollect();
collect.setGroupId(groupId); collect.setGroupId(groupId);
@ -219,6 +225,7 @@ public class GroupCommonService {
} }
} }
} }
collect.setCreateTime(now);
return collect; return collect;
}).collect(Collectors.toList()); }).collect(Collectors.toList());
if (CollUtil.isNotEmpty(collectList)) { if (CollUtil.isNotEmpty(collectList)) {