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

feat:feature-REQ/2129 修改page=1，因为查询后会更改数据状态，导致page错误

Browse Source
This commit is contained in:
lilong 2024-04-03 18:07:40 +08:00
parent b149c22c67
commit 57d8a5ae23
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
im-center-server/src/main/java/cn/axzo/im/job/CreateMessageHistoryJob.java
View File

@ -49,7 +49,7 @@ public class CreateMessageHistoryJob extends IJobHandler {
.ids(createMessageHistoryParam.getIds()) .ids(createMessageHistoryParam.getIds())
.planStartTimeLE(now) .planStartTimeLE(now)
.status(MessageTask.Status.PENDING) .status(MessageTask.Status.PENDING)
.page(pageNumber++) .page(pageNumber)
.pageSize(DEFAULT_PAGE_SIZE) .pageSize(DEFAULT_PAGE_SIZE)
.build(); .build();

2
im-center-server/src/main/java/cn/axzo/im/job/SendMessageJob.java
View File

@ -47,7 +47,7 @@ public class SendMessageJob extends IJobHandler {
MessageHistoryService.PageMessageHistoryParam req = MessageHistoryService.PageMessageHistoryParam.builder() MessageHistoryService.PageMessageHistoryParam req = MessageHistoryService.PageMessageHistoryParam.builder()
.ids(sendMessageParam.getIds()) .ids(sendMessageParam.getIds())
.statues(Sets.newHashSet(MessageHistory.Status.PENDING.name())) .statues(Sets.newHashSet(MessageHistory.Status.PENDING.name()))
.page(pageNumber++) .page(pageNumber)
.pageSize(DEFAULT_PAGE_SIZE) .pageSize(DEFAULT_PAGE_SIZE)
.build(); .build();