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

feat(REQ-1507): 老的待办数据迁移

Browse Source 
背景：
  https://jira.axzo.cn/browse/REQ-1507?goToView=1

影响：
  无
This commit is contained in:
luofu 2023-11-20 12:19:22 +08:00
parent f9451ddac2
commit 72582e108b
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -63,7 +63,8 @@ public class PendingMessageDataInitServiceImpl implements PendingMessageDataInit
.eq(MessageRecord::getType, MsgTypeEnum.PENDING_MESSAGE) .eq(MessageRecord::getType, MsgTypeEnum.PENDING_MESSAGE)
.eq(MessageRecord::getIsDelete, YesNoEnum.NO.getCode()) .eq(MessageRecord::getIsDelete, YesNoEnum.NO.getCode())
.ge(MessageRecord::getCreateAt, DateFormatUtil.toDate(queryFrom)) .ge(MessageRecord::getCreateAt, DateFormatUtil.toDate(queryFrom))
.between(MessageRecord::getId, minRecordId, scrollId) .lt(MessageRecord::getId, scrollId)
.gt(MessageRecord::getId, minRecordId)
.orderByDesc(MessageRecord::getId) .orderByDesc(MessageRecord::getId)
.last("LIMIT 1000") .last("LIMIT 1000")
.list(); .list();
@ -76,11 +77,13 @@ public class PendingMessageDataInitServiceImpl implements PendingMessageDataInit
} }
scrollId = records.stream().min(Comparator.comparing(MessageRecord::getId)) scrollId = records.stream().min(Comparator.comparing(MessageRecord::getId))
.map(MessageRecord::getId).orElse(0L); .map(MessageRecord::getId).orElse(0L);
log.info("[cold_blade] scrollId:[{}]", scrollId);
records = messageRecordDao.lambdaQuery() records = messageRecordDao.lambdaQuery()
.eq(MessageRecord::getType, MsgTypeEnum.PENDING_MESSAGE) .eq(MessageRecord::getType, MsgTypeEnum.PENDING_MESSAGE)
.eq(MessageRecord::getIsDelete, YesNoEnum.NO.getCode()) .eq(MessageRecord::getIsDelete, YesNoEnum.NO.getCode())
.ge(MessageRecord::getCreateAt, DateFormatUtil.toDate(queryFrom)) .ge(MessageRecord::getCreateAt, DateFormatUtil.toDate(queryFrom))
.between(MessageRecord::getId, minRecordId, scrollId) .lt(MessageRecord::getId, scrollId)
.gt(MessageRecord::getId, minRecordId)
.orderByDesc(MessageRecord::getId) .orderByDesc(MessageRecord::getId)
.last("LIMIT 1000") .last("LIMIT 1000")
.list(); .list();