From 9166f92b86dd8a145596f810a749603bb69c5634 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=9F=A5=E6=97=A0=E6=B6=AF?= <2637171921@qq.com> Date: Tue, 26 Aug 2025 17:44:01 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../disciplinary/GenericMessageListener.java | 4 +- .../InitiatorNotificationListener.java | 121 ++++++++++++++++++ .../MultiInstanceMessageListener.java | 95 ++++++++++++++ .../disciplinary/XSJYGLKListener.java | 45 ++++--- .../disciplinary/XYWJCLWYHListener.java | 53 ++++---- ...StuDisciplinaryApplicationServiceImpl.java | 2 +- .../RtStuDisciplinaryRelieveServiceImpl.java | 2 +- 7 files changed, 278 insertions(+), 44 deletions(-) create mode 100644 srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/InitiatorNotificationListener.java create mode 100644 srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/MultiInstanceMessageListener.java diff --git a/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/GenericMessageListener.java b/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/GenericMessageListener.java index 50c1305..88ad185 100644 --- a/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/GenericMessageListener.java +++ b/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/GenericMessageListener.java @@ -13,7 +13,7 @@ import java.util.Collections; import java.util.List; /** - * 【通用线上监听器】为即将到来的任务创建内部“我的消息”记录。 知无涯1 + * 【通用线上监听器】为即将到来的任务创建内部“我的消息”记录。 知无涯 *

* 该监听器被设计为在SequenceFlow的'take'事件上触发。 * 它会智能地从流程变量中读取单个接收人(变量名: approval)或多个接收人(变量名: userList)， @@ -44,7 +44,7 @@ public class GenericMessageListener implements ExecutionListener { String taskName = execution.getCurrentFlowElement() != null ? execution.getCurrentFlowElement().getName() : "新"; // --- 关键改动：构建带有隐藏标识的消息内容 --- - String messageText = "您有一条新的【" + taskName + "】待办任务需要处理，"; + String messageText = "您有一条新的【" + taskName + "】待办任务需要处理"; // 我们嵌入一个隐藏的span，它包含了流程实例ID和活动ID作为唯一标识 String hiddenIdentifier = String.format("", execution.getProcessInstanceId(), diff --git a/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/InitiatorNotificationListener.java b/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/InitiatorNotificationListener.java new file mode 100644 index 0000000..c3e8ff7 --- /dev/null +++ b/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/InitiatorNotificationListener.java @@ -0,0 +1,121 @@ +package com.srs.flowable.listener.disciplinary; +import com.srs.common.utils.SecurityUtils; +import com.srs.common.utils.WeChatUtil; +import com.srs.comprehensive.domain.CphMsg; +import com.srs.comprehensive.service.ICphMsgService; +import com.srs.flowable.mapper.DisciplinaryMapper; +import lombok.extern.slf4j.Slf4j; +import org.flowable.bpmn.model.FlowElement; +import org.flowable.bpmn.model.SequenceFlow; +import org.flowable.engine.delegate.DelegateExecution; +import org.flowable.engine.delegate.ExecutionListener; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * 【线上专用监听器】在流程结果返回给发起人时， + * 负责发送企业微信和内部消息两种通知。 + */ +@Component("initiatorNotificationListener") // 使用一个全新的、明确的Bean名称 +@Slf4j +public class InitiatorNotificationListener implements ExecutionListener { + + @Autowired + private DisciplinaryMapper disciplinaryMapper; + + @Autowired + private ICphMsgService cphMsgService; + + @Autowired(required = false) // 允许WeChatUtil为null，增加灵活性 + private WeChatUtil weChatUtil; + + @Override + public void notify(DelegateExecution execution) { + log.info("流程实例 [{}]: 触发 InitiatorNotificationListener，准备向发起人发送整合通知...", execution.getProcessInstanceId()); + + // --- 1. 获取核心数据：发起人ID --- + Object initiatorObj = execution.getVariable("INITIATOR"); + if (initiatorObj == null) { + log.error("在流程实例 [{}] 中未找到发起人(INITIATOR)变量，无法发送任何通知。", execution.getProcessInstanceId()); + return; + } + + Long initiatorUserId; + try { + initiatorUserId = Long.parseLong(initiatorObj.toString()); + } catch (NumberFormatException e) { + log.error("发起人(INITIATOR)变量 '{}' 无法转换为Long类型。", initiatorObj, e); + return; + } + + // --- 2. 准备通知内容 (解决taskName为空的问题) --- + String nextTaskName = getNextTaskName(execution); + String weChatMessage = "您提交的学生违纪处分申请已有最终处理结果，请点击前往处理。"; + String internalMessageText = "您有一条新的【" + nextTaskName + "】待办任务需要处理。"; + String hiddenIdentifier = String.format("", + execution.getProcessInstanceId(), + ((SequenceFlow) execution.getCurrentFlowElement()).getTargetRef()); + String internalMessageContent = internalMessageText + "请点击前往处理。" + hiddenIdentifier; + + // --- 3. 发送企业微信通知 --- + sendWeChatNotification(initiatorUserId, weChatMessage); + + // --- 4. 创建内部消息 --- + createInternalMessage(initiatorUserId, internalMessageContent, execution); + } + + /** + * 发送企业微信通知 + */ + private void sendWeChatNotification(Long userId, String content) { + if (weChatUtil == null) { // 防御性编程 + log.warn("WeChatUtil未配置，跳过发送企业微信。"); + return; + } + try { + String userName = disciplinaryMapper.getUserNameByUserId(userId); + if (userName != null && !userName.isEmpty()) { + weChatUtil.sendTextMessage(userName, content); + log.info("已成功向流程发起人 (userId:{}) 发送企业微信通知。", userId); + } else { + log.warn("找到了发起人(userId:{})，但其企微账号为空，未发送企微通知。", userId); + } + } catch (Exception e) { + log.error("向流程发起人发送企业微信通知时异常: {}", e.getMessage(), e); + } + } + + /** + * 创建内部消息 + */ + private void createInternalMessage(Long receiverId, String content, DelegateExecution execution) { + try { + CphMsg cphMsg = new CphMsg(); + cphMsg.setReceiver(receiverId); + cphMsg.setContent(content); + // 安全地获取发送人，提供默认值 + cphMsg.setSender(SecurityUtils.getUserId() != null ? SecurityUtils.getUserId() : 1L); + + cphMsgService.insertCphMsg(cphMsg); + log.info("已成功为流程发起人 (userId:{}) 创建内部消息。", receiverId); + } catch (Exception e) { + log.error("为流程发起人创建内部消息时异常: {}", e.getMessage(), e); + } + } + + /** + * 安全地获取线上监听器下一个目标节点的名称 + */ + private String getNextTaskName(DelegateExecution execution) { + try { + SequenceFlow sequenceFlow = (SequenceFlow) execution.getCurrentFlowElement(); + FlowElement targetElement = sequenceFlow.getTargetFlowElement(); + if (targetElement != null) { + return targetElement.getName(); + } + } catch (Exception e) { + log.warn("获取下一个任务名称时出错: {}", e.getMessage()); + } + return "结果接收"; + } +} \ No newline at end of file diff --git a/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/MultiInstanceMessageListener.java b/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/MultiInstanceMessageListener.java new file mode 100644 index 0000000..475da2b --- /dev/null +++ b/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/MultiInstanceMessageListener.java @@ -0,0 +1,95 @@ +package com.srs.flowable.listener.disciplinary; + +import com.srs.common.utils.SecurityUtils; +import com.srs.comprehensive.domain.CphMsg; +import com.srs.comprehensive.service.ICphMsgService; +import lombok.extern.slf4j.Slf4j; +import org.flowable.bpmn.model.FlowElement; +import org.flowable.bpmn.model.SequenceFlow; +import org.flowable.engine.delegate.DelegateExecution; +import org.flowable.engine.delegate.ExecutionListener; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.util.List; + +/** + * 【多实例专用线上监听器】为即将到来的多实例任务创建内部消息。 + *

+ * 它只从流程变量 `userList` 中读取接收人列表。 + *

+ */ +@Component("multiInstanceMessageListener") // 定义一个全新的Bean名称 +@Slf4j +public class MultiInstanceMessageListener implements ExecutionListener { + + @Autowired + private ICphMsgService cphMsgService; + + @Override + public void notify(DelegateExecution execution) { + log.info("流程实例 [{}]: 触发多实例专用消息监听器 (MultiInstanceMessageListener)...", execution.getProcessInstanceId()); + + // --- 步骤 1: 只从 'userList' 变量获取接收人 --- + Object userListObj = execution.getVariable("userList"); + if (!(userListObj instanceof List) || ((List) userListObj).isEmpty()) { + log.warn("流程实例 [{}]: 未能从 'userList' 变量中找到有效的接收人列表，跳过消息创建。", execution.getProcessInstanceId()); + return; + } + + @SuppressWarnings("unchecked") + List receiverIdList = (List) userListObj; + + // --- 步骤 2: (已修正) 精确获取下一个目标节点的名称和ID --- + FlowElement nextElement = getNextFlowElement(execution); + String taskName = (nextElement != null && nextElement.getName() != null) ? nextElement.getName() : "新的待办"; + String activityId = (nextElement != null) ? nextElement.getId() : "unknownActivity"; + + // --- 步骤 3: 准备消息内容 --- + String messageText = "您有一条新的【" + taskName + "】待办任务需要处理。"; + String link = "请点击前往处理。"; + String hiddenIdentifier = String.format("", + execution.getProcessInstanceId(), + activityId); + String finalContent = messageText + link + hiddenIdentifier; + + Long senderId = getSenderId(); + + // --- 步骤 4: 批量创建消息 --- + for (Long receiverId : receiverIdList) { + try { + CphMsg cphMsg = new CphMsg(); + cphMsg.setReceiver(receiverId); + cphMsg.setSender(senderId); + cphMsg.setContent(finalContent); + cphMsgService.insertCphMsg(cphMsg); + log.info("已成功为用户 [{}] 创建多实例任务的内部消息 (关联 Activity ID: {})。", receiverId, activityId); + } catch (Exception e) { + log.error("为用户 [{}] 创建多实例任务内部消息时发生异常: {}", receiverId, e.getMessage(), e); + } + } + } + + /** + * 安全地获取线上监听器的下一个目标节点 + */ + private FlowElement getNextFlowElement(DelegateExecution execution) { + if (execution.getCurrentFlowElement() instanceof SequenceFlow) { + return ((SequenceFlow) execution.getCurrentFlowElement()).getTargetFlowElement(); + } + return null; + } + + /** + * 安全地获取当前操作的发送人ID。 + */ + private Long getSenderId() { + try { + Long userId = SecurityUtils.getUserId(); + return userId != null ? userId : 1L; + } catch (Exception e) { + log.warn("在监听器中获取发送人ID时发生异常，使用默认系统管理员ID(1L)。"); + return 1L; + } + } +} \ No newline at end of file diff --git a/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/XSJYGLKListener.java b/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/XSJYGLKListener.java index 16faf40..adc1f54 100644 --- a/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/XSJYGLKListener.java +++ b/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/XSJYGLKListener.java @@ -10,10 +10,11 @@ import org.springframework.stereotype.Component; import java.util.List; /** - * 学生教育管理科审核节点的执行监听器。 知无涯 - * 向“学生教育管理科”角色发送企业微信通知。 + * 【线上监听器-升级版】为“学生教育管理科审核”节点做准备。 + * 1. 向该候选组的所有成员发送企业微信通知。 + * 2. 将该组的所有成员ID列表存入 'userList' 流程变量，供下游监听器(GenericMessageListener)使用。 */ -@Component +@Component("xsjyglkListener") @Slf4j public class XSJYGLKListener implements ExecutionListener { @@ -21,39 +22,51 @@ public class XSJYGLKListener implements ExecutionListener { public void notify(DelegateExecution delegateExecution) { DisciplinaryMapper disciplinaryMapper = SpringUtils.getBean(DisciplinaryMapper.class); - // 1. 【核心】定义“学生教育管理科”xsjyglksh + // 1. 【核心】定义“学生教育管理科”角色Key final String TARGET_ROLE_KEY = "xsjyglksh"; - log.info("流程实例 [{}]: 准备向角色 '{}' 发送通知。", delegateExecution.getProcessInstanceId(), TARGET_ROLE_KEY); + log.info("流程实例 [{}]: 触发XSJYGLKListener, 准备向角色 '{}' 发送通知并设置流程变量。", delegateExecution.getProcessInstanceId(), TARGET_ROLE_KEY); - // 2. 根据这个固定的角色Key，查询该角色的所有成员ID（即使只有一个）。 + // 2. 根据角色Key，查询该角色的所有成员ID。 + // 这个查询结果既用于发送企微，也用于设置流程变量。 List userIdList = disciplinaryMapper.getApprovalByRoleKey(TARGET_ROLE_KEY); // 3. 检查是否找到了成员。 if (userIdList == null || userIdList.isEmpty()) { - log.error("根据角色Key '{}' 未找到任何用户，无法发送通知。", TARGET_ROLE_KEY); - return; // 中止执行，不抛出异常以免中断流程 + log.error("根据角色Key '{}' 未找到任何用户，无法发送通知和设置变量。", TARGET_ROLE_KEY); + return; // 中止执行 } - // 4. 发送企业微信通知。 - // (我们的批量发送逻辑即使只有一个用户也能完美处理) + // --- 关键新增逻辑：开始 --- + // 4. 将查询到的用户ID列表存入流程变量 'userList'。 + // 这是为下游的 GenericMessageListener 准备的标准“产品”。 + delegateExecution.setVariable("userList", userIdList); + log.info("已将角色 '{}' 的 {} 位成员ID存入 'userList' 流程变量，供下游监听器使用。", TARGET_ROLE_KEY, userIdList.size()); + // --- 关键新增逻辑：结束 --- + + // 5. (原有逻辑) 发送企业微信通知。 + sendWeChatNotification(userIdList, disciplinaryMapper, TARGET_ROLE_KEY); + } + + /** + * 封装的发送企业微信的私有方法，保持主方法 notify 的整洁。 + */ + private void sendWeChatNotification(List userIdList, DisciplinaryMapper disciplinaryMapper, String roleKey) { try { - // 批量查询userName (即使只有一个ID，这个方法也能正常工作) List userNameList = disciplinaryMapper.getUserNamesByUserIdList(userIdList); - if (!userNameList.isEmpty()) { - // 将列表拼接成 "username1|username2|..." 的格式 + if (userNameList != null && !userNameList.isEmpty()) { String toUser = String.join("|", userNameList); WeChatUtil weChatUtil = SpringUtils.getBean(WeChatUtil.class); String content = "您有一条新的学生违纪审批任务待处理，请点击前往处理。"; weChatUtil.sendTextMessage(toUser, content); - log.info("已成功向角色 '{}' 的成员发送通知。接收人: {}", TARGET_ROLE_KEY, toUser); + log.info("已成功向角色 '{}' 的成员发送企业微信通知。接收人: {}", roleKey, toUser); } else { - log.warn("角色 '{}' 中找到了 {} 个用户，但无人配置企业微信账号，未发送任何通知。", TARGET_ROLE_KEY, userIdList.size()); + log.warn("角色 '{}' 中找到了 {} 个用户，但无人配置企业微信账号，未发送任何通知。", roleKey, userIdList.size()); } } catch (Exception e) { - log.error("向角色 '{}' 发送企业微信通知时出现异常。流程将继续。错误详情: {}", TARGET_ROLE_KEY, e.getMessage(), e); + log.error("向角色 '{}' 发送企业微信通知时出现异常。流程将继续。错误详情: {}", roleKey, e.getMessage(), e); } } } \ No newline at end of file diff --git a/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/XYWJCLWYHListener.java b/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/XYWJCLWYHListener.java index a318bed..4de3ea2 100644 --- a/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/XYWJCLWYHListener.java +++ b/srs-flowable/src/main/java/com/srs/flowable/listener/disciplinary/XYWJCLWYHListener.java @@ -3,24 +3,26 @@ package com.srs.flowable.listener.disciplinary; import com.srs.common.utils.WeChatUtil; import com.srs.flowable.mapper.DisciplinaryMapper; import lombok.extern.slf4j.Slf4j; +import org.flowable.bpmn.model.FlowElement; +import org.flowable.bpmn.model.SequenceFlow; import org.flowable.engine.delegate.DelegateExecution; import org.flowable.engine.delegate.ExecutionListener; -import org.mybatis.spring.annotation.MapperScan; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; +import org.springframework.util.CollectionUtils; import java.util.List; -import java.util.stream.Collectors; /** - * 【线上监听器】为“学院违纪处理委员会”多实例任务准备数据并发送通知 知无涯 + * 【生产者线上监听器】为“学院违纪处理委员会”多实例任务准备数据。 + * 1. 设置 'userList' 变量供多实例节点本身消费。 + * 2. 设置 'nextTaskNameForMessage' 变量供下游消息监听器消费。 + * 3. 发送企业微信通知。 */ -@MapperScan("com.srs.flowable.mapper") @Component("xywjclwyhListener") @Slf4j public class XYWJCLWYHListener implements ExecutionListener { - // 推荐：使用依赖注入，而不是SpringUtils @Autowired private DisciplinaryMapper disciplinaryMapper; @@ -29,46 +31,49 @@ public class XYWJCLWYHListener implements ExecutionListener { @Override public void notify(DelegateExecution execution) { - log.info("流程实例 [{}]: 在进入'学院违纪处理委员会'节点前，开始准备审批数据...", execution.getProcessInstanceId()); - - // 步骤 1: 单一数据库查询，获取所有需要的审批人信息 (ID和企微账号) - // List userInfos = disciplinaryMapper.getUserInfoByRoleKey("xywjclwyh"); - // 注意：如果您不方便修改Mapper，这里可以保持原来的两次查询，逻辑依然正确。 - // 我们先用原始的两次查询来演示，更具普适性。 + log.info("流程实例 [{}]: 触发 XYWJCLWYHListener，为'委员会'节点准备数据...", execution.getProcessInstanceId()); List userIdList = disciplinaryMapper.getApprovalByRoleKey("xywjclwyh"); - - if (userIdList == null || userIdList.isEmpty()) { + if (CollectionUtils.isEmpty(userIdList)) { log.error("角色 'xywjclwyh' 未配置或未找到任何有效用户，流程无法继续。"); throw new RuntimeException("学院违纪处理委员会审批人员未设置"); } - // 步骤 2: 设置多实例任务需要的流程变量 (这是“线上”为“节点”准备的核心数据) + // 步骤 1: 设置 'userList' 变量，供多实例UserTask节点消费 execution.setVariable("userList", userIdList); - log.info("流程实例 [{}]: 已成功设置'userList'变量，包含 {} 个审批人。", execution.getProcessInstanceId(), userIdList.size()); + log.info("已将'委员会'的 {} 位成员ID存入 'userList' 流程变量。", userIdList.size()); + + // 步骤 2: 主动获取并设置下一个节点的名称，供 GenericMessageListener 消费 + FlowElement nextElement = getNextFlowElement(execution); + if (nextElement != null) { + execution.setVariable("nextTaskNameForMessage", nextElement.getName()); + log.info("已将下一个任务的名称 '{}' 存入流程变量 'nextTaskNameForMessage'。", nextElement.getName()); + } // 步骤 3: 发送企业微信通知 sendWeChatNotification(userIdList, execution.getProcessInstanceId()); } - /** - * 封装并执行企业微信通知逻辑 - */ private void sendWeChatNotification(List userIdList, String processInstanceId) { try { List userNameList = disciplinaryMapper.getUserNamesByUserIdList(userIdList); - if (userNameList == null || userNameList.isEmpty()) { - log.warn("流程实例 [{}]: 角色'xywjclwyh'存在审批人ID，但无人配置企微账号，未发送通知。", processInstanceId); + if (CollectionUtils.isEmpty(userNameList)) { + log.warn("流程实例 [{}]: 角色'xywjclwyh'存在审批人ID，但无人配置企微账号。", processInstanceId); return; } - String toUser = String.join("|", userNameList); String content = "您有一条新的学生违纪审批任务待处理，请点击前往处理。"; - weChatUtil.sendTextMessage(toUser, content); - log.info("流程实例 [{}]: 已成功向学院违纪处理委员会发送通知。接收人: {}", processInstanceId, toUser); + log.info("流程实例 [{}]: 已成功向'委员会'发送企微通知。", processInstanceId); } catch (Exception e) { - log.error("流程实例 [{}]: 发送企微通知时出现异常，但不影响主流程。错误: {}", processInstanceId, e.getMessage(), e); + log.error("流程实例 [{}]: 发送企微通知时出现异常: {}", processInstanceId, e.getMessage(), e); } } + + private FlowElement getNextFlowElement(DelegateExecution execution) { + if (execution.getCurrentFlowElement() instanceof SequenceFlow) { + return ((SequenceFlow) execution.getCurrentFlowElement()).getTargetFlowElement(); + } + return null; + } } \ No newline at end of file diff --git a/srs-routine/src/main/java/com/srs/routine/service/impl/RtStuDisciplinaryApplicationServiceImpl.java b/srs-routine/src/main/java/com/srs/routine/service/impl/RtStuDisciplinaryApplicationServiceImpl.java index 95679a7..3a2053e 100644 --- a/srs-routine/src/main/java/com/srs/routine/service/impl/RtStuDisciplinaryApplicationServiceImpl.java +++ b/srs-routine/src/main/java/com/srs/routine/service/impl/RtStuDisciplinaryApplicationServiceImpl.java @@ -265,7 +265,7 @@ public class RtStuDisciplinaryApplicationServiceImpl extends ServiceImpl