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

feat:feature-REQ/2129 修改状态

Browse Source
This commit is contained in:
lilong 2024-03-26 18:33:27 +08:00
parent e32bdd56c7
commit 91d2d418a7
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
im-center-server/src/main/java/cn/axzo/im/controller/MessageController.java
View File

@ -25,6 +25,7 @@ import cn.axzo.im.service.RobotMsgTemplateService;
import cn.axzo.pokonyan.exception.Aassert; import cn.axzo.pokonyan.exception.Aassert;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Sets;
import io.github.resilience4j.ratelimiter.RequestNotPermitted; import io.github.resilience4j.ratelimiter.RequestNotPermitted;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@ -113,7 +114,7 @@ public class MessageController implements MessageApi {
messageTaskService.createMessageHistory(messageTask); messageTaskService.createMessageHistory(messageTask);
List<MessageHistoryService.MessageHistoryDTO> messageHistories = messageHistoryService.list(MessageHistoryService.ListMessageHistoryParam.builder() List<MessageHistoryService.MessageHistoryDTO> messageHistories = messageHistoryService.list(MessageHistoryService.ListMessageHistoryParam.builder()
.imMessageTaskId(messageTask.getId()) .imMessageTaskId(messageTask.getId())
.status(MessageHistory.Status.PENDING.name()) .statues(Sets.newHashSet(MessageHistory.Status.PENDING.name()))
.build()); .build());
if (!CollectionUtils.isEmpty(messageHistories)) { if (!CollectionUtils.isEmpty(messageHistories)) {
messageHistoryService.sendMessage(messageHistories); messageHistoryService.sendMessage(messageHistories);

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

@ -4,6 +4,7 @@ import cn.axzo.im.entity.MessageHistory;
import cn.axzo.im.service.MessageHistoryService; import cn.axzo.im.service.MessageHistoryService;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.google.common.collect.Sets;
import com.xxl.job.core.biz.model.ReturnT; import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.IJobHandler; import com.xxl.job.core.handler.IJobHandler;
import com.xxl.job.core.handler.annotation.XxlJob; import com.xxl.job.core.handler.annotation.XxlJob;
@ -45,7 +46,7 @@ public class SendMessageJob extends IJobHandler {
while (true) { while (true) {
MessageHistoryService.PageMessageHistoryParam req = MessageHistoryService.PageMessageHistoryParam.builder() MessageHistoryService.PageMessageHistoryParam req = MessageHistoryService.PageMessageHistoryParam.builder()
.ids(sendMessageParam.getIds()) .ids(sendMessageParam.getIds())
.status(MessageHistory.Status.PENDING.name()) .statues(Sets.newHashSet(MessageHistory.Status.PENDING.name()))
.pageNumber(pageNumber++) .pageNumber(pageNumber++)
.pageSize(DEFAULT_PAGE_SIZE) .pageSize(DEFAULT_PAGE_SIZE)
.build(); .build();