新增标准流程消息体

distributed-print-business/src/main/java/com/qmth/distributed/print/business/activiti/custom/listener/ProcessEventListener.java

@@ -199,29 +199,19 @@ public class ProcessEventListener implements ActivitiEventListener, Serializable
                     }
                 }
                 break;
-            case TASK_ASSIGNED:
-                log.info("流程分配人员_TASK_ASSIGNED:ProcessInstanceId:{},ExecutionId:{},ProcessDefinitionId:{}", event.getProcessInstanceId(), event.getExecutionId(), event.getProcessDefinitionId());
-                taskService = SpringContextHolder.getBean(TaskService.class);
-                activitiService = SpringContextHolder.getBean(ActivitiService.class);
-                redisUtil = SpringContextHolder.getBean(RedisUtil.class);
-
-                Task taskAssigen = taskService.createTaskQuery().executionId(event.getExecutionId()).singleResult();
-                if (Objects.nonNull(taskAssigen)) {
-                    tfFlowLog = (TFFlowLog) taskService.getVariable(taskAssigen.getId(), SystemConstant.APPROVE_TF_FLOW_LOG);
-                    Optional.ofNullable(tfFlowLog).orElseThrow(() -> ExceptionResultEnum.ERROR.exception("流程审批日志为空"));
-                    log.info("tfFlowLog.getApproveOperation():{}", tfFlowLog.getApproveOperation());
-//                    if (tfFlowLog.getApproveOperation() == FlowApproveOperationEnum.EXCHANGE) {
-//                        FlowMsgDto flowMsgDto = activitiService.getFlowMsgData(tfFlowLog.getSchoolId());
-//                        if (Objects.nonNull(flowMsgDto.getOpenFlowMsgPush()) && flowMsgDto.getOpenFlowMsgPush()) {
-//                            Map<String, Object> mapVar = new HashMap<>();
-//                            mapVar.put(SystemConstant.SCHOOL_ID, tfFlowLog.getSchoolId());
-//                            mapVar.put(SystemConstant.APPROVE_OPERATION, tfFlowLog.getApproveOperation());
-//                            MqDto mqDto = new MqDto(MqTagEnum.FLOW_MQ_WORK.getCode(), tfFlowLog.getSchoolId(), String.valueOf(tfFlowLog.getFlowId()));
-//                            redisUtil.sendMessage(mqDto.getTopic(), mqDto);
-//                        }
-//                    }
-                }
-                break;
+//            case TASK_ASSIGNED:
+//                log.info("流程分配人员_TASK_ASSIGNED:ProcessInstanceId:{},ExecutionId:{},ProcessDefinitionId:{}", event.getProcessInstanceId(), event.getExecutionId(), event.getProcessDefinitionId());
+//                taskService = SpringContextHolder.getBean(TaskService.class);
+//                activitiService = SpringContextHolder.getBean(ActivitiService.class);
+//                redisUtil = SpringContextHolder.getBean(RedisUtil.class);
+//
+//                Task taskAssigen = taskService.createTaskQuery().executionId(event.getExecutionId()).singleResult();
+//                if (Objects.nonNull(taskAssigen)) {
+//                    tfFlowLog = (TFFlowLog) taskService.getVariable(taskAssigen.getId(), SystemConstant.APPROVE_TF_FLOW_LOG);
+//                    Optional.ofNullable(tfFlowLog).orElseThrow(() -> ExceptionResultEnum.ERROR.exception("流程审批日志为空"));
+//                    log.info("tfFlowLog.getApproveOperation():{}", tfFlowLog.getApproveOperation());
+//                }
+//                break;
             default:
 //                log.info("default->type:{},ProcessInstanceId:{},ExecutionId:{},ProcessDefinitionId:{}", event.getType(), event.getProcessInstanceId(), event.getExecutionId(), event.getProcessDefinitionId());
                 break;