From 8902a36fe282c27794dc05a1efba14b7abe95dfb Mon Sep 17 00:00:00 2001 From: luofu Date: Mon, 30 Oct 2023 14:27:50 +0800 Subject: [PATCH] =?UTF-8?q?feat(REQ-1465):=20=E5=AD=90=E6=A0=87=E9=A2=98?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E8=BF=87=E6=BB=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 背景： https://jira.axzo.cn/browse/REQ-1465?goToView=1 修改： 1、子标题数据过滤 影响： 无 --- .../service/impl/MessageSendTwiceRecordServiceImpl.java | 5 ++--- .../msg/center/domain/entity/MessageSendTwiceRecord.java | 4 ++-- 2 files changed, 4 insertions(+), 5 deletions(-) diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/MessageSendTwiceRecordServiceImpl.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/MessageSendTwiceRecordServiceImpl.java index 093dccdc..05c66a8a 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/MessageSendTwiceRecordServiceImpl.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/MessageSendTwiceRecordServiceImpl.java @@ -1,6 +1,5 @@ package cn.axzo.msg.center.message.service.impl; -import cn.axzo.msg.center.common.enums.TableIsDeleteEnum; import cn.axzo.msg.center.dal.MessageSendTwiceRecordDao; import cn.axzo.msg.center.domain.entity.MessageSendTwiceRecord; import cn.axzo.msg.center.message.service.MessageSendTwiceRecordService; @@ -34,10 +33,10 @@ public class MessageSendTwiceRecordServiceImpl implements MessageSendTwiceRecord log.info("personId is null."); return Collections.emptyList(); } - // TODO:[cold_blade] [P2] 此处的代码仅做一个双发兜底的策略，后期应当全走新的消息发送流程 return messageSendTwiceRecordDao.lambdaQuery() .eq(MessageSendTwiceRecord::getReceiverPersonId, personId) - .eq(MessageSendTwiceRecord::getIsDelete, TableIsDeleteEnum.NORMAL.value) + .last("LIMIT 500") + .orderByDesc(MessageSendTwiceRecord::getId) .select(MessageSendTwiceRecord::getOriginalMsgId) .list().stream() .map(MessageSendTwiceRecord::getOriginalMsgId) diff --git a/msg-center-domain/src/main/java/cn/axzo/msg/center/domain/entity/MessageSendTwiceRecord.java b/msg-center-domain/src/main/java/cn/axzo/msg/center/domain/entity/MessageSendTwiceRecord.java index 1fe2184c..1f2457f7 100644 --- a/msg-center-domain/src/main/java/cn/axzo/msg/center/domain/entity/MessageSendTwiceRecord.java +++ b/msg-center-domain/src/main/java/cn/axzo/msg/center/domain/entity/MessageSendTwiceRecord.java @@ -1,6 +1,6 @@ package cn.axzo.msg.center.domain.entity; -import cn.axzo.msg.center.domain.persistence.BaseEntity; +import cn.axzo.msg.center.domain.persistence.BaseEntityExt; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.annotation.TableName; import lombok.Getter; @@ -16,7 +16,7 @@ import java.io.Serializable; @Setter @Getter @TableName("message_send_twice_record") -public class MessageSendTwiceRecord extends BaseEntity implements Serializable { +public class MessageSendTwiceRecord extends BaseEntityExt implements Serializable { private static final long serialVersionUID = 3517821492158061709L;