更新

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
+ * 【通用线上监听器】为即将到来的任务创建内部“我的消息”记录。  知无涯
  * <p>
  * 该监听器被设计为在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("<span id='flow-identifier' data-proc-inst-id='%s' data-activity-id='%s' style='display:none;'></span>",
                 execution.getProcessInstanceId(),

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 = "您提交的学生违纪处分申请已有最终处理结果，<a href='http://zhxg.gxsdxy.cn/web/#/pages/Approval/index'>请点击前往处理</a>。";
+        String internalMessageText = "您有一条新的【" + nextTaskName + "】待办任务需要处理。";
+        String hiddenIdentifier = String.format("<span id='flow-identifier' data-proc-inst-id='%s' data-activity-id='%s' style='display:none;'></span>",
+                execution.getProcessInstanceId(),
+                ((SequenceFlow) execution.getCurrentFlowElement()).getTargetRef());
+        String internalMessageContent = internalMessageText + "<a href='http://zhxg.gxsdxy.cn/web/#/pages/Approval/index'>请点击前往处理</a>。" + 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 "结果接收";
+    }
+}

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;
+
+/**
+ * 【多实例专用线上监听器】为即将到来的多实例任务创建内部消息。
+ * <p>
+ * 它只从流程变量 `userList` 中读取接收人列表。
+ * </p>
+ */
+@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<Long> receiverIdList = (List<Long>) 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 = "<a href='http://zhxg.gxsdxy.cn/web/#/pages/Approval/index'>请点击前往处理</a>。";
+        String hiddenIdentifier = String.format("<span id='flow-identifier' data-proc-inst-id='%s' data-activity-id='%s' style='display:none;'></span>",
+                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;
+        }
+    }
+}

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<Long> userIdList = disciplinaryMapper.getApprovalByRoleKey(TARGET_ROLE_KEY);
 
         // 3. 检查是否找到了成员。
         if (userIdList == null || userIdList.isEmpty()) {
-            log.error("根据角色Key '{}' 未找到任何用户，无法发送通知。", TARGET_ROLE_KEY);
+            log.error("根据角色Key '{}' 未找到任何用户，无法发送通知和设置变量。", TARGET_ROLE_KEY);
-            return; // 中止执行，不抛出异常以免中断流程
+            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<Long> userIdList, DisciplinaryMapper disciplinaryMapper, String roleKey) {
         try {
-            // 批量查询userName (即使只有一个ID，这个方法也能正常工作)
             List<String> userNameList = disciplinaryMapper.getUserNamesByUserIdList(userIdList);
 
-            if (!userNameList.isEmpty()) {
+            if (userNameList != null && !userNameList.isEmpty()) {
-                // 将列表拼接成 "username1|username2|..." 的格式
                 String toUser = String.join("|", userNameList);
 
                 WeChatUtil weChatUtil = SpringUtils.getBean(WeChatUtil.class);
                 String content = "您有一条新的学生违纪审批任务待处理，<a href='http://zhxg.gxsdxy.cn/web/#/pages/Approval/index'>请点击前往处理</a>。";
 
                 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);
         }
     }
 }

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());
+        log.info("流程实例 [{}]: 触发 XYWJCLWYHListener，为'委员会'节点准备数据...", execution.getProcessInstanceId());
-
-        // 步骤 1: 单一数据库查询，获取所有需要的审批人信息 (ID和企微账号)
-        // List<DisciplinaryMapper.UserInfo> userInfos = disciplinaryMapper.getUserInfoByRoleKey("xywjclwyh");
-        // 注意：如果您不方便修改Mapper，这里可以保持原来的两次查询，逻辑依然正确。
-        // 我们先用原始的两次查询来演示，更具普适性。
 
         List<Long> userIdList = disciplinaryMapper.getApprovalByRoleKey("xywjclwyh");
-
+        if (CollectionUtils.isEmpty(userIdList)) {
-        if (userIdList == null || userIdList.isEmpty()) {
             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<Long> userIdList, String processInstanceId) {
         try {
             List<String> userNameList = disciplinaryMapper.getUserNamesByUserIdList(userIdList);
-            if (userNameList == null || userNameList.isEmpty()) {
+            if (CollectionUtils.isEmpty(userNameList)) {
-                log.warn("流程实例 [{}]: 角色'xywjclwyh'存在审批人ID，但无人配置企微账号，未发送通知。", processInstanceId);
+                log.warn("流程实例 [{}]: 角色'xywjclwyh'存在审批人ID，但无人配置企微账号。", processInstanceId);
                 return;
             }
-
             String toUser = String.join("|", userNameList);
             String content = "您有一条新的学生违纪审批任务待处理，<a href='http://zhxg.gxsdxy.cn/web/#/pages/Approval/index'>请点击前往处理</a>。";
-
             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;
+    }
 }

srs-routine/src/main/java/com/srs/routine/service/impl/RtStuDisciplinaryApplicationServiceImpl.java

@@ -265,7 +265,7 @@ public class RtStuDisciplinaryApplicationServiceImpl extends ServiceImpl<RtStuDi
 
         // todo 企业微信推送消息
 
-        AjaxResult ajaxResult = flowDefinitionService.startProcessInstanceById("flow_n27gxm4k:22:720004", variables);
+        AjaxResult ajaxResult = flowDefinitionService.startProcessInstanceById("flow_n27gxm4k:27:795072", variables);
         String code = ajaxResult.get("code").toString();
         if (code.equals("200")) {
 

srs-routine/src/main/java/com/srs/routine/service/impl/RtStuDisciplinaryRelieveServiceImpl.java

@@ -194,7 +194,7 @@ public class RtStuDisciplinaryRelieveServiceImpl extends ServiceImpl<RtStuDiscip
         variables.put("penaltyType", rtStuDisciplinaryRelieve.getPenaltyType());
         variables.put("stuUserId", SecurityUtils.getUserId());
 
-        AjaxResult ajaxResult = flowDefinitionService.startProcessInstanceById("flow_d46199lc:7:260004", variables);
+        AjaxResult ajaxResult = flowDefinitionService.startProcessInstanceById("flow_d46199lc:12:765004", variables);
         String code = ajaxResult.get("code").toString();
         if (code.equals("200")) {