1 概述

RocketMQ消息应用于第三方平台整合工作流进行消息推送等场景。

2 配置说明

系统管理员登录系统,配置入口[系统维护>RocketMQ消息],分为基础配置和详细配置。

1、基础配置
在基础配置中,对提供RocketMQ消息的服务地址进行配置,支持本地服务和云服务,如下图所示。

2、详细配置
对消息域进行配置,如下图所示。

3 工作任务RocketMQ消息二开整合相关

1、标准消息结构
StandardWorkflowEventModel

{
    "tenantId": "",
    "instanceId": "",
    "taskId": "",
    "businessKey": "",                    // 业务单据
    "procType": "",                              // 流程类型key
    "procName": "",                           // 流程类型名称
    "instanceTitle": "",                  // 流程标题
    "taskName": "",                           // 任务名称
    "op": "",                                          // 操作
    "instanceStartTime": "",             // 流程发起时间 时间戳
    "instanceEndTime": "",               // 流程结束时间 时间戳
    "taskStartTime": "",                    // 任务发起时间 时间戳
    "taskEndTime": "",                      // 任务处理时间 时间戳
    "starter": "",                                // 发起人
    "taskAssigns": [""],                    // 任务分配用户列表
    "taskUrl": ""                                    // 审批表单地址
}
  • 流程审批相关op枚举值
    • start, // 流程发起
    • assign, // 任务分配处理人
    • agree, // 任务处理-同意
    • disagree, // 任务处理-不同意
    • abort, // 任务处理_终止
    • reject, // 任务处理_退回
    • end, // 流程结束
    • claim, // 签收
    • unclaim, // 反签收
    • cancel_back, // 撤回
    • //加签相关
      ■ delegate_start // 加签开始,等同于删除原始任务
      ■ delegate_addsign // 加签-用户分配
      ■ delegate_delsign // 减签
      ■ delegate_finish // 加签结束,等同于新建原始任务

2、自定义转换类
需实现接口IWorkflowMQConverter

/**
 * 自定义消息内容格式转化
 */
public interface IWorkflowMQConverter {
    /**
     *
     * @param standardJson 标准流程事件模型StandardWorkflowEventModel转化的json
     * @return 转化后的json结构
     */
    String convert(StandardWorkflowEventModel standardJson);
}

3、消息发送时机说明
RocketMQ消息支持的发送时机如下:

  • 发起流程
  • 处理流程
    • 同意
    • 不同意
    • 终止
    • 退回
    • 签收、反签收
    • 加减签
    • 撤回
  • 流程结束
  • 待办分配
作者:Eric  创建时间:2023-06-25 16:27
最后编辑:Eric  更新时间:2025-04-24 11:27