xinyin025/RuoYi-Vue-Plus
1
0
Fork 0
mirror of https://github.com/dromara/RuoYi-Vue-Plus.git synced 2025-09-30 23:26:41 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

update 调整消息发送

Browse Source
This commit is contained in:
gssong 2023-11-02 21:45:13 +08:00
parent 66f749a09b
commit 015a204efe
1 changed files with 13 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -367,15 +367,19 @@ public class WorkflowUtils {
} }
if (CollUtil.isNotEmpty(userIds)) { if (CollUtil.isNotEmpty(userIds)) {
List<SysUserVo> sysUserVoList = I_WORKFLOW_USER_SERVICE.getUserListByIds(new ArrayList<>(userIds)); List<SysUserVo> sysUserVoList = I_WORKFLOW_USER_SERVICE.getUserListByIds(new ArrayList<>(userIds));
if (messageType.contains(MessageTypeEnum.SYSTEM_MESSAGE.getCode())) { for (String code : messageType) {
WebSocketMessageDto dto = new WebSocketMessageDto(); if (code.equals(MessageTypeEnum.SYSTEM_MESSAGE.getCode())) {
dto.setSessionKeys(new ArrayList<>(userIds)); WebSocketMessageDto dto = new WebSocketMessageDto();
dto.setMessage(message); dto.setSessionKeys(new ArrayList<>(userIds));
WebSocketUtils.publishMessage(dto); dto.setMessage(message);
} else if (messageType.contains(MessageTypeEnum.EMAIL_MESSAGE.getCode())) { WebSocketUtils.publishMessage(dto);
MailUtils.sendText(StreamUtils.join(sysUserVoList, SysUserVo::getEmail), "单据审批提醒", message); }
} else if (messageType.contains(MessageTypeEnum.SMS_MESSAGE.getCode())) { if (code.equals(MessageTypeEnum.EMAIL_MESSAGE.getCode())) {
//todo 短信发送 MailUtils.sendText(StreamUtils.join(sysUserVoList, SysUserVo::getEmail), "单据审批提醒", message);
}
if (code.equals(MessageTypeEnum.SMS_MESSAGE.getCode())) {
//todo 短信发送
}
} }
} }
} }