diff --git a/hula-im-service/src/main/java/com/hula/core/chat/domain/vo/response/ChatMessageResp.java b/hula-im-service/src/main/java/com/hula/core/chat/domain/vo/response/ChatMessageResp.java index f15b1618..07b6003a 100644 --- a/hula-im-service/src/main/java/com/hula/core/chat/domain/vo/response/ChatMessageResp.java +++ b/hula-im-service/src/main/java/com/hula/core/chat/domain/vo/response/ChatMessageResp.java @@ -7,6 +7,7 @@ import lombok.Builder; import lombok.Data; import lombok.NoArgsConstructor; +import java.util.Date; import java.util.Map; /** @@ -38,7 +39,7 @@ public class ChatMessageResp extends BaseEntity { @Schema(description ="房间id") private String roomId; @Schema(description ="消息发送时间") - private Long sendTime; + private Date sendTime; @Schema(description ="消息类型 1正常文本 2.撤回消息") private Integer type; @Schema(description ="消息内容不同的消息类型,内容体不同") diff --git a/hula-im-service/src/main/java/com/hula/core/chat/service/adapter/MessageAdapter.java b/hula-im-service/src/main/java/com/hula/core/chat/service/adapter/MessageAdapter.java index 94461d1d..ac8d165c 100644 --- a/hula-im-service/src/main/java/com/hula/core/chat/service/adapter/MessageAdapter.java +++ b/hula-im-service/src/main/java/com/hula/core/chat/service/adapter/MessageAdapter.java @@ -58,7 +58,7 @@ public class MessageAdapter { private static ChatMessageResp.Message buildMessage(Message message, List marks, Long receiveUid) { ChatMessageResp.Message messageVO = new ChatMessageResp.Message(); BeanUtil.copyProperties(message, messageVO); - messageVO.setSendTime(message.getCreateTime().getTime()); + messageVO.setSendTime(message.getCreateTime()); AbstractMsgHandler msgHandler = MsgHandlerFactory.getStrategyNoNull(message.getType()); if (Objects.nonNull(msgHandler)) { messageVO.setBody(msgHandler.showMsg(message)); diff --git a/hula-im-service/src/main/java/com/hula/core/chat/service/impl/ChatServiceImpl.java b/hula-im-service/src/main/java/com/hula/core/chat/service/impl/ChatServiceImpl.java index ddf7a979..4af75693 100644 --- a/hula-im-service/src/main/java/com/hula/core/chat/service/impl/ChatServiceImpl.java +++ b/hula-im-service/src/main/java/com/hula/core/chat/service/impl/ChatServiceImpl.java @@ -263,29 +263,29 @@ public class ChatServiceImpl implements ChatService { LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); if(ObjectUtil.isNotNull(lastOptTime) && lastOptTime > 0) { - wrapper.ge(Message::getCreateTime, new Date(lastOptTime)).le(Message::getCreateTime, LocalDate.now()); + wrapper.ge(Message::getCreateTime, new Date(lastOptTime)).le(Message::getCreateTime, new Date()); }else { - wrapper.ge(Message::getCreateTime, LocalDate.now().minusMonths(3)); + wrapper.ge(Message::getCreateTime, LocalDate.now().minusDays(15)); } List messages = messageDao.list(wrapper); Map> groupedMessages = messages.stream() .collect(Collectors.groupingBy(Message::getRoomId)); - Map> filteredMessageMap = new HashMap<>(); +// Map> filteredMessageMap = new HashMap<>(); - groupedMessages.forEach((roomId, messageList) -> { - Long lastMsgId = lastMsgIds.get(roomId) == null ? 0L : lastMsgIds.get(roomId); - List filteredList = messageList.stream() - .filter(item -> item.getId() > lastMsgId) - .toList(); - filteredMessageMap.put(roomId, filteredList); - }); +// groupedMessages.forEach((roomId, messageList) -> { +// Long lastMsgId = lastMsgIds.get(roomId) == null ? 0L : lastMsgIds.get(roomId); +// List filteredList = messageList.stream() +// .filter(item -> item.getId() > lastMsgId) +// .toList(); +// filteredMessageMap.put(roomId, filteredList); +// }); // 4. 转换为响应对象并返回 List baseMessages = new ArrayList<>(); - for (Long roomId : filteredMessageMap.keySet()) { - baseMessages.addAll(getMsgRespBatch(roomId, filteredMessageMap.get(roomId), receiveUid)); + for (Long roomId : groupedMessages.keySet()) { + baseMessages.addAll(getMsgRespBatch(roomId, groupedMessages.get(roomId), receiveUid)); } return baseMessages; }