西安市市政建设网站,船员专用网站开发建议,网页版游戏排行榜j,潜山网站建设更多ruoyi-nbcio功能请看演示系统
gitee源代码地址
前后端代码#xff1a; https://gitee.com/nbacheng/ruoyi-nbcio
演示地址#xff1a;RuoYi-Nbcio后台管理系统
1、上一节说到RedisReceiver #xff0c;这里有调用了NbcioRedisListener自定义业务监听#xff0c;如下…更多ruoyi-nbcio功能请看演示系统
gitee源代码地址
前后端代码 https://gitee.com/nbacheng/ruoyi-nbcio
演示地址RuoYi-Nbcio后台管理系统
1、上一节说到RedisReceiver 这里有调用了NbcioRedisListener自定义业务监听如下
package com.ruoyi.common.redis.listener;import com.ruoyi.common.base.BaseMap;/*** 自定义消息监听* author nbacheng* date 2023-09-20*/public interface NbcioRedisListener {void onMessage(BaseMap message);
}2、实现这个代码如下
package com.ruoyi.common.websocket;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import com.ruoyi.common.base.BaseMap;
import com.ruoyi.common.constant.CommonSendStatus;
import com.ruoyi.common.redis.listener.NbcioRedisListener;import cn.hutool.core.util.ObjectUtil;
import lombok.extern.slf4j.Slf4j;/*** 监听消息(采用redis发布订阅方式发送消息)*/
Slf4j
Component
public class SocketHandler implements NbcioRedisListener {Autowiredprivate WebSocketServer webSocket;Overridepublic void onMessage(BaseMap map) {log.info(【SocketHandler消息】Redis Listerer: map.toString());String userId map.get(userId);String message map.get(message);if (ObjectUtil.isNotEmpty(userId)) {webSocket.pushMessage(userId, message);//app端消息推送webSocket.pushMessage(userIdCommonSendStatus.APP_SESSION_SUFFIX, message);} else {webSocket.pushMessage(message);}} 这里进行了websocket的服务器给用户推送同时之前第一个节里公共类方法也同时往两个表增加数据以便失败后后续可以进行发送以确保能真正通知到用户。
3、接下来就是需要在用户提起流程发给审批人进行消息发送了
package com.ruoyi.flowable.listener;import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;import org.apache.commons.lang3.StringUtils;
import org.flowable.common.engine.api.delegate.event.FlowableEngineEventType;
import org.flowable.common.engine.api.delegate.event.FlowableEvent;
import org.flowable.common.engine.api.delegate.event.FlowableEventListener;
import org.flowable.common.engine.api.delegate.event.FlowableEventType;
import org.flowable.engine.HistoryService;
import org.flowable.engine.RepositoryService;
import org.flowable.engine.TaskService;
import org.flowable.engine.history.HistoricProcessInstance;
import org.flowable.task.service.impl.persistence.entity.TaskEntity;
import org.springframework.stereotype.Component;import com.ruoyi.common.core.service.CommonService;
import com.ruoyi.common.constant.Constants;
import com.ruoyi.common.core.domain.model.LoginUser;import javax.annotation.Resource;/*** 全局监听-工作流待办消息提醒** author nbacheng*/
Slf4j
Component
RequiredArgsConstructor
public class TaskCreateListener implements FlowableEventListener {private final TaskService taskService;Resourceprivate CommonService commonService;Resourceprotected RepositoryService repositoryService;Resourceprotected HistoryService historyService;Overridepublic void onEvent(FlowableEvent flowableEvent) {FlowableEventType type flowableEvent.getType();if (type FlowableEngineEventType.TASK_ASSIGNED) { if(flowableEvent instanceof org.flowable.engine.delegate.event.impl.FlowableEntityEventImpl ) {TaskEntity taskEntity (TaskEntity) ((org.flowable.engine.delegate.event.impl.FlowableEntityEventImpl) flowableEvent).getEntity();String taskId taskEntity.getId();String procInsId taskEntity.getProcessInstanceId();HistoricProcessInstance historicProcessInstance historyService.createHistoricProcessInstanceQuery().processInstanceId(procInsId).singleResult();String businessKey historicProcessInstance.getBusinessKey();String deployId historicProcessInstance.getDeploymentId();String startUserId historicProcessInstance.getStartUserId();//获取任务接收人String receiver taskEntity.getAssignee();if (StringUtils.isNotEmpty(receiver)) {//发送提醒消息String category ;if(taskService.getVariables(taskId).get(category) ! null) {category taskService.getVariables(taskId).get(category).toString();}LoginUser loginUser commonService.getLoginUser();String taskMessageUrl;if(StringUtils.isNotBlank(businessKey)) {taskMessageUrl a href commonService.getBaseUrl() ?procInsId procInsId deployId deployId taskId taskId businessKey businessKey category category finishedtrue 点击这个进行处理/a ;}else {taskMessageUrl a href commonService.getBaseUrl() ?procInsId procInsId deployId deployId taskId taskId businessKey category category finishedtrue 点击这个进行处理/a ;}String msgContent 流程待办通知 taskMessageUrl;if(!StringUtils.equals(startUserId, receiver) || !StringUtils.equals((loginUser.getUserId()).toString(),receiver)) {//发起人或登录人自己不发送log.info(流程待办通知给: receiver);commonService.sendSysNotice(loginUser.getUserId().toString(), receiver, 流程待办通知, msgContent, Constants.MSG_CATEGORY_3);//setMsgCategory3是待办}}}} }Overridepublic boolean isFailOnException() {return false;}Overridepublic boolean isFireOnTransactionLifecycleEvent() {return false;}Overridepublic String getOnTransaction() {return null;}
}
