-- =============================================================================
|
-- 文件：bpm_audit_flow_02_deploy_proc.sql
|
-- 用途：BPM 审核流程「流程定义部署」段（第 2 个执行，需先执行 01 修复/分类文件）
|
-- 目标库：ruoyi-vue-pro
|
-- 要求：
|
-- * MySQL 8.0+，账号需具备 CREATE PROCEDURE 权限
|
-- * 以 mysql CLI 执行（含 DELIMITER）：
|
-- mysql -u<账号> -p ruoyi-vue-pro < bpm_audit_flow_02_deploy_proc.sql
|
-- * 模板：默认从 ruoyi-vue-pro 内已有规范流程「erp-finance-payment-audit」复制，
|
-- 其 BPMN 为“发起人节点 + 提交即通过”(candidateStrategy=36) 的最简结构，
|
-- 适合所有对接单据先跑通；后续如需多级审批可在「流程模型」界面调整。
|
-- 健壮性设计：
|
-- * 幂等：目标 key 若已存在（无论激活/挂起）→ 整段跳过，不重复部署、不产生新版本。
|
-- * 事务：单流程 5 张表写入包在一个事务内，任一步失败自动回滚，不留半成品。
|
-- * 自检：procdef ID = key:1:<32位uuid>，超 64 字符直接报错中断。
|
-- * 空值规避：ENGINE_VERSION_ 不写入空串(保持 NULL)，避免 Flowable 提交审批报错；
|
-- META_INFO_ 写入最小合法 JSON(含 sort/type=10)，避免模型页/列表 NPE。
|
-- * 重复执行文件安全：DROP PROCEDURE IF EXISTS 保证可重复运行。
|
-- =============================================================================
|
|
SET NAMES utf8mb4;
|
|
-- 部署前自检：模板存在性（应返回 1 行）
|
SELECT KEY_, NAME_, SUSPENSION_STATE_ FROM ACT_RE_PROCDEF WHERE KEY_ = 'erp-finance-payment-audit';
|
|
DROP PROCEDURE IF EXISTS bpm_deploy_flow_from_template;
|
|
DELIMITER $$
|
|
-- 从一个“模板流程”复制部署一个新审核流程（BPMN 结构一致，仅替换 key/名称）
|
CREATE PROCEDURE bpm_deploy_flow_from_template(
|
IN p_key VARCHAR(64), -- 新流程 key（需与代码侧监听器匹配）
|
IN p_name VARCHAR(128), -- 新流程显示名
|
IN p_category VARCHAR(64), -- 归属流程分类 code
|
IN p_template VARCHAR(64) -- 复制来源模板流程 key
|
)
|
label_deploy: BEGIN
|
DECLARE v_exist INT DEFAULT 0;
|
DECLARE v_tpl_key VARCHAR(64) DEFAULT 'erp-finance-payment-audit';
|
DECLARE v_tpl_dep VARCHAR(64) DEFAULT NULL;
|
DECLARE v_tpl_name VARCHAR(255) DEFAULT NULL;
|
DECLARE v_dep VARCHAR(64);
|
DECLARE v_model_id VARCHAR(64);
|
DECLARE v_byte_id VARCHAR(64);
|
DECLARE v_procdef_id VARCHAR(64);
|
DECLARE v_meta TEXT;
|
DECLARE v_sort BIGINT;
|
DECLARE v_now DATETIME;
|
|
-- 任何异常 → 回滚并重新抛出
|
DECLARE EXIT HANDLER FOR SQLEXCEPTION
|
BEGIN
|
ROLLBACK;
|
RESIGNAL;
|
END;
|
|
-- 幂等：key 已存在直接跳过
|
SELECT COUNT(*) INTO v_exist FROM ACT_RE_PROCDEF WHERE KEY_ = p_key;
|
IF v_exist > 0 THEN
|
SELECT CONCAT('[SKIP] 流程已存在，跳过：', p_key) AS deploy_result;
|
LEAVE label_deploy;
|
END IF;
|
|
-- 模板定位
|
IF p_template IS NOT NULL AND p_template <> '' THEN
|
SET v_tpl_key = p_template;
|
END IF;
|
SELECT DEPLOYMENT_ID_ INTO v_tpl_dep FROM ACT_RE_PROCDEF
|
WHERE KEY_ = v_tpl_key ORDER BY VERSION_ DESC LIMIT 1;
|
SELECT NAME_ INTO v_tpl_name FROM ACT_RE_PROCDEF
|
WHERE KEY_ = v_tpl_key ORDER BY VERSION_ DESC LIMIT 1;
|
IF v_tpl_dep IS NULL THEN
|
SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = CONCAT('模板流程不存在，无法复制：', v_tpl_key);
|
END IF;
|
|
SET v_now = NOW(3);
|
SET v_sort = UNIX_TIMESTAMP(v_now) * 1000;
|
SET v_dep = REPLACE(UUID(), '-', '');
|
SET v_model_id = REPLACE(UUID(), '-', '');
|
SET v_byte_id = REPLACE(UUID(), '-', '');
|
SET v_procdef_id = CONCAT(p_key, ':1:', v_dep);
|
-- procdef ID 列 VARCHAR(64) 长度守卫
|
IF CHAR_LENGTH(v_procdef_id) > 64 THEN
|
SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = CONCAT('流程 key 过长，procdef ID 将超 64 字符：', p_key);
|
END IF;
|
|
START TRANSACTION;
|
|
-- 1) 部署记录（ACT_RE_DEPLOYMENT 无 REV_ 列）
|
INSERT INTO ACT_RE_DEPLOYMENT
|
(ID_, NAME_, CATEGORY_, KEY_, TENANT_ID_, DEPLOY_TIME_, ENGINE_VERSION_)
|
VALUES
|
(v_dep, p_name, p_category, p_key, '', v_now, NULL);
|
|
-- 2) BPMN 字节（复制模板字节并替换 key 与显示名）
|
INSERT INTO ACT_GE_BYTEARRAY
|
(ID_, NAME_, DEPLOYMENT_ID_, BYTES_, GENERATED_)
|
SELECT
|
v_byte_id,
|
CONCAT(p_key, '.bpmn'),
|
v_dep,
|
CONVERT(
|
REPLACE(
|
REPLACE(CONVERT(BYTES_ USING utf8mb4), v_tpl_key, p_key),
|
v_tpl_name, p_name)
|
USING utf8mb4),
|
0
|
FROM ACT_GE_BYTEARRAY
|
WHERE DEPLOYMENT_ID_ = v_tpl_dep
|
AND NAME_ = CONCAT(v_tpl_key, '.bpmn');
|
|
-- 3) 流程定义（激活态 SUSPENSION_STATE_=1；ENGINE_VERSION_ 留 NULL）
|
INSERT INTO ACT_RE_PROCDEF
|
(ID_, REV_, CATEGORY_, NAME_, KEY_, VERSION_, DEPLOYMENT_ID_, RESOURCE_NAME_,
|
DGRM_RESOURCE_NAME_, DESCRIPTION_, HAS_START_FORM_KEY_, HAS_GRAPHICAL_NOTATION_,
|
SUSPENSION_STATE_, TENANT_ID_, ENGINE_VERSION_, DERIVED_VERSION_)
|
VALUES
|
(v_procdef_id, 1, p_category, p_name, p_key, 1, v_dep, CONCAT(p_key, '.bpmn'),
|
NULL, NULL, 0, 1,
|
1, '', NULL, 0);
|
|
-- 4) 流程模型（含最小合法 META_INFO_，避免模型列表 NPE）
|
SET v_meta = CONCAT(
|
'{"type":10,"formType":10,"sort":', v_sort,
|
',"visible":true,"allowCancelRunningProcess":true,"allowWithdrawTask":false',
|
',"autoApprovalType":0,"description":"","formCustomCreatePath":"","formCustomViewPath":"",',
|
'"formId":null,"managerUserIds":[],"startUserIds":[],"startDeptIds":[],"icon":null,',
|
'"processBeforeTriggerSetting":null,"processAfterTriggerSetting":null,',
|
'"taskBeforeTriggerSetting":null,"taskAfterTriggerSetting":null,',
|
'"printTemplateSetting":null,"summarySetting":null,"titleSetting":null,"processIdRule":null}');
|
INSERT INTO ACT_RE_MODEL
|
(ID_, NAME_, KEY_, CATEGORY_, CREATE_TIME_, LAST_UPDATE_TIME_, VERSION_, META_INFO_, DEPLOYMENT_ID_, TENANT_ID_)
|
VALUES
|
(v_model_id, p_name, p_key, p_category, v_now, v_now, 1, v_meta, v_dep, '');
|
|
-- 5) 流程定义扩展信息（model_type=10）
|
INSERT INTO bpm_process_definition_info
|
(process_definition_id, model_id, model_type, category, form_type, visible, sort,
|
allow_cancel_running_process, allow_withdraw_task,
|
creator, create_time, updater, update_time, deleted)
|
VALUES
|
(v_procdef_id, v_model_id, 10, p_category, 10, 1, v_sort,
|
1, 1,
|
'1', v_now, '1', v_now, 0);
|
|
COMMIT;
|
|
SELECT CONCAT('[OK] 已部署新审核流程：', p_key, ' (procdef=', v_procdef_id, ')') AS deploy_result;
|
END$$
|
|
DELIMITER ;
|
|
-- =============================================================================
|
-- ④ 按单据逐个部署缺失流程（重复执行会自动跳过已存在项）
|
-- 参数：(key, 名称, 分类code, 模板key)
|
-- =============================================================================
|
|
-- ERP 销售订单审批（代码监听 key：sale_order_approve）
|
CALL bpm_deploy_flow_from_template('sale_order_approve', '销售订单审批', 'sale_order_approve', 'erp-finance-payment-audit');
|
-- ERP 采购订单审批（代码监听 key：purchase_order_approve）
|
CALL bpm_deploy_flow_from_template('purchase_order_approve', '采购订单审批', 'purchase_order_approve', 'erp-finance-payment-audit');
|
|
-- CRM 合同审批（代码监听 key：crm-contract-audit，挂既有 contract_approve 分类）
|
CALL bpm_deploy_flow_from_template('crm-contract-audit', '合同审批', 'contract_approve', 'erp-finance-payment-audit');
|
|
-- HRM 请假审批（代码监听 key：hrm_leave）
|
CALL bpm_deploy_flow_from_template('hrm_leave', '请假审批', 'hrm_leave_approve', 'erp-finance-payment-audit');
|
-- HRM 加班审批（代码监听 key：hrm_overtime）
|
CALL bpm_deploy_flow_from_template('hrm_overtime', '加班审批', 'overtime_approve', 'erp-finance-payment-audit');
|
-- HRM 离职审批（代码监听 key：hrm_resignation）
|
CALL bpm_deploy_flow_from_template('hrm_resignation', '离职审批', 'hrm_resignation_approve', 'erp-finance-payment-audit');
|
-- HRM 调动审批（代码监听 key：hrm_transfer）
|
CALL bpm_deploy_flow_from_template('hrm_transfer', '调动审批', 'hrm_transfer_approve', 'erp-finance-payment-audit');
|
-- HRM 考勤异常审批（全量监听不挑 key，挂既有 hrm_attendance_approve 分类）
|
CALL bpm_deploy_flow_from_template('hrm_attendance_approve', '考勤异常审批', 'hrm_attendance_approve', 'erp-finance-payment-audit');
|
|
-- SRM 供应商准入审批（代码监听 key：supplier_apply_approve）
|
CALL bpm_deploy_flow_from_template('supplier_apply_approve', '供应商准入审批', 'supplier_apply_approve', 'erp-finance-payment-audit');
|
|
-- MES 仓库入库 / 出库 / 调拨审批（代码监听 key 固定，挂既有 wms_approve 分类）
|
CALL bpm_deploy_flow_from_template('wms_inbound_approve', '仓库入库审批', 'wms_approve', 'erp-finance-payment-audit');
|
CALL bpm_deploy_flow_from_template('wms_outbound_approve', '仓库出库审批', 'wms_approve', 'erp-finance-payment-audit');
|
CALL bpm_deploy_flow_from_template('wms_transfer_approve', '仓库调拨审批', 'wms_approve', 'erp-finance-payment-audit');
|
-- MES 采购收货（入库单）审批（全量监听，挂既有 item_receipt_approve 分类）
|
CALL bpm_deploy_flow_from_template('item_receipt_approve', '采购入库审批', 'item_receipt_approve', 'erp-finance-payment-audit');
|
-- MES 报工/生产工单审批（代码监听 key：mes-pro-feedback-audit）
|
CALL bpm_deploy_flow_from_template('mes-pro-feedback-audit', '报工审批', 'mes_pro_feedback_audit', 'erp-finance-payment-audit');
|
|
-- =============================================================================
|
-- ⑤ 部署结果校验（应看到 14 条新流程且 SUSPENSION_STATE_=1、model_type=10）
|
-- =============================================================================
|
SELECT p.KEY_, p.NAME_, p.VERSION_, p.SUSPENSION_STATE_ AS active_flag,
|
LENGTH(p.ID_) AS procdef_id_len,
|
i.model_type, i.category
|
FROM ACT_RE_PROCDEF p
|
LEFT JOIN bpm_process_definition_info i ON i.process_definition_id = p.ID_
|
WHERE p.KEY_ IN ('sale_order_approve','purchase_order_approve','crm-contract-audit',
|
'hrm_leave','hrm_overtime','hrm_resignation','hrm_transfer',
|
'hrm_attendance_approve','supplier_apply_approve',
|
'wms_inbound_approve','wms_outbound_approve','wms_transfer_approve',
|
'item_receipt_approve','mes-pro-feedback-audit')
|
ORDER BY p.KEY_;
|
