wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'feature/REQ-1465' of axzsource.com:universal/infrastructure/backend/msg-center-plat into dev

Browse Source
This commit is contained in:
luofu 2023-10-30 14:28:29 +08:00
commit 3f73b15583
2 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/MessageSendTwiceRecordServiceImpl.java
View File

@ -1,6 +1,5 @@
package cn.axzo.msg.center.message.service.impl; 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.dal.MessageSendTwiceRecordDao;
import cn.axzo.msg.center.domain.entity.MessageSendTwiceRecord; import cn.axzo.msg.center.domain.entity.MessageSendTwiceRecord;
import cn.axzo.msg.center.message.service.MessageSendTwiceRecordService; import cn.axzo.msg.center.message.service.MessageSendTwiceRecordService;
@ -34,10 +33,10 @@ public class MessageSendTwiceRecordServiceImpl implements MessageSendTwiceRecord
log.info("personId is null."); log.info("personId is null.");
return Collections.emptyList(); return Collections.emptyList();
} }
// TODO:[cold_blade] [P2] 此处的代码仅做一个双发兜底的策略，后期应当全走新的消息发送流程
return messageSendTwiceRecordDao.lambdaQuery() return messageSendTwiceRecordDao.lambdaQuery()
.eq(MessageSendTwiceRecord::getReceiverPersonId, personId) .eq(MessageSendTwiceRecord::getReceiverPersonId, personId)
.eq(MessageSendTwiceRecord::getIsDelete, TableIsDeleteEnum.NORMAL.value) .last("LIMIT 500")
.orderByDesc(MessageSendTwiceRecord::getId)
.select(MessageSendTwiceRecord::getOriginalMsgId) .select(MessageSendTwiceRecord::getOriginalMsgId)
.list().stream() .list().stream()
.map(MessageSendTwiceRecord::getOriginalMsgId) .map(MessageSendTwiceRecord::getOriginalMsgId)

4
msg-center-domain/src/main/java/cn/axzo/msg/center/domain/entity/MessageSendTwiceRecord.java
View File

@ -1,6 +1,6 @@
package cn.axzo.msg.center.domain.entity; 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.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Getter; import lombok.Getter;
@ -16,7 +16,7 @@ import java.io.Serializable;
@Setter @Setter
@Getter @Getter
@TableName("message_send_twice_record") @TableName("message_send_twice_record")
public class MessageSendTwiceRecord extends BaseEntity<MessageSendTwiceRecord> implements Serializable { public class MessageSendTwiceRecord extends BaseEntityExt<MessageSendTwiceRecord> implements Serializable {
private static final long serialVersionUID = 3517821492158061709L; private static final long serialVersionUID = 3517821492158061709L;