abu/wzj-boot
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update 优化 将工作流消息推送改为sse

Browse Source
This commit is contained in:
疯狂的狮子Li 2024-12-14 23:39:21 +08:00
parent 67c9c5f910
commit 0bc46c849f
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ruoyi-modules/ruoyi-workflow/pom.xml
View File

@ -20,7 +20,7 @@
<dependency> <dependency>
<groupId>org.dromara</groupId> <groupId>org.dromara</groupId>
<artifactId>ruoyi-common-websocket</artifactId> <artifactId>ruoyi-common-sse</artifactId>
</dependency> </dependency>
<dependency> <dependency>

10
ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/utils/WorkflowUtils.java
View File

@ -9,8 +9,8 @@ import org.dromara.common.core.utils.SpringUtils;
import org.dromara.common.core.utils.StreamUtils; import org.dromara.common.core.utils.StreamUtils;
import org.dromara.common.core.utils.StringUtils; import org.dromara.common.core.utils.StringUtils;
import org.dromara.common.mail.utils.MailUtils; import org.dromara.common.mail.utils.MailUtils;
import org.dromara.common.websocket.dto.WebSocketMessageDto; import org.dromara.common.sse.dto.SseMessageDto;
import org.dromara.common.websocket.utils.WebSocketUtils; import org.dromara.common.sse.utils.SseMessageUtils;
import org.dromara.warm.flow.core.entity.Task; import org.dromara.warm.flow.core.entity.Task;
import org.dromara.warm.flow.core.entity.User; import org.dromara.warm.flow.core.entity.User;
import org.dromara.warm.flow.orm.entity.FlowTask; import org.dromara.warm.flow.orm.entity.FlowTask;
@ -105,10 +105,10 @@ public class WorkflowUtils {
if (ObjectUtil.isNotEmpty(messageTypeEnum)) { if (ObjectUtil.isNotEmpty(messageTypeEnum)) {
switch (messageTypeEnum) { switch (messageTypeEnum) {
case SYSTEM_MESSAGE: case SYSTEM_MESSAGE:
WebSocketMessageDto dto = new WebSocketMessageDto(); SseMessageDto dto = new SseMessageDto();
dto.setSessionKeys(new ArrayList<>(StreamUtils.toList(userList, UserDTO::getUserId))); dto.setUserIds(StreamUtils.toList(userList, UserDTO::getUserId));
dto.setMessage(message); dto.setMessage(message);
WebSocketUtils.publishMessage(dto); SseMessageUtils.publishMessage(dto);
break; break;
case EMAIL_MESSAGE: case EMAIL_MESSAGE:
MailUtils.sendText(StreamUtils.join(userList, UserDTO::getEmail), "单据审批提醒", message); MailUtils.sendText(StreamUtils.join(userList, UserDTO::getEmail), "单据审批提醒", message);