脚本如何实现审批流程节点流转

wen 实用脚本 2026-06-24 29

从零到一的实战指南

目录导读

审批流程节点流转的核心逻辑是什么？
脚本在审批流程中扮演什么角色？
如何用脚本驱动节点自动流转？（附代码示例）
常见问题与解决方案（FAQ）
总结与最佳实践建议

审批流程节点流转的核心逻辑是什么？

在理解脚本如何实现审批流程节点流转之前,首先要明确“节点流转”的本质，一个审批流程通常由多个“节点”组成，每个节点代表一个审批步骤（如“发起申请”→“部门经理审批”→“财务审核”→“结束”），节点流转，就是指系统根据预设规则，自动将审批任务从一个节点传递到下一个节点的过程。

脚本如何实现审批流程节点流转

关键要素包括：

节点状态：待审批、已通过、已驳回、已转交等。
流转条件：当所有审批人同意时流转”“当任一审批人驳回时终止”。
触发时机：审批人提交决策后、超时自动流转、或满足特定业务条件时。

传统的审批系统往往依赖硬编码或配置表,而脚本化实现则提供了更高的灵活性和可定制性。

脚本在审批流程中扮演什么角色？

脚本（如Python、JavaScript、Groovy或平台自带的DSL脚本）充当了“流程引擎的大脑”，它负责：

读取当前节点状态：从数据库或API获取当前节点ID、审批人、审批结果。
执行流转规则：判断是否需要流转到下一节点，以及选择哪个分支（如“同意”走A路径，“驳回”走B路径）。
更新节点数据：将新节点信息写入数据表，并通知下一审批人。
处理异常情况：如审批人缺失、超时自动跳过、条件分支错误等。

典型应用场景举例：

在CRM系统中,当销售订单金额超过10万元时，脚本自动增加“总经理审批”节点。
在OA系统中,若部门经理48小时内未处理，脚本自动将任务转交至总监。

如何用脚本驱动节点自动流转？

以下以Python脚本为例,结合伪代码和真实逻辑演示。

1 基础数据结构设计

# 审批节点定义（简化版）
node = {
    "id": "node_002",          # 当前节点ID
    "name": "部门经理审批",
    "status": "pending",       # pending/approved/rejected/transferred
    "assignee": "user_123",    # 当前审批人
    "result": None,            # None/approved/rejected
    "next_node_rules": {       # 流转规则
        "on_approved": "node_003",  # 同意后到财务审核
        "on_rejected": "node_004",  # 驳回后到驳回处理节点
        "on_transfer": "auto_route" # 转交时走自动路由
    }
}

2 核心流转脚本

def process_approval_node(current_node, decision):
    """
    current_node: 当前节点字典
    decision: 审批决策，如"approved"或"rejected"
    """
    # 1. 记录决策
    current_node["result"] = decision
    current_node["status"] = decision  # 根据决策更新状态
    # 2. 根据决策找到下一节点
    if decision == "approved":
        next_node_id = current_node["next_node_rules"]["on_approved"]
    elif decision == "rejected":
        next_node_id = current_node["next_node_rules"]["on_rejected"]
    else:
        raise ValueError(f"Unknown decision: {decision}")
    # 3. 如果是结束节点（如"end"），流程结束
    if next_node_id == "end":
        update_process_status("completed")
        send_notification("流程已结束")
        return
    # 4. 否则创建下一节点实例
    next_node = create_node_instance(next_node_id)
    save_to_database(next_node)
    # 5. 通知下一审批人
    notify_assignee(next_node["assignee"], f"您有一个新的审批任务：{next_node['name']}")
    # 6. 清理当前节点的待办
    remove_todo(current_node["id"])
# 实际调用（当部门经理点击"同意"时）
process_approval_node(node, "approved")

3 处理更复杂的条件分支

当节点流转依赖于多个条件时,脚本可以动态计算。

def calculate_next_node(current_node, decision, extra_data):
    # 如果金额>10万，且决策为同意，走总经理审批
    if extra_data.get("amount", 0) > 100000 and decision == "approved":
        return "node_general_manager"
    # 如果金额<=10万，直接到财务
    elif decision == "approved":
        return "node_finance"
    # 驳回时走驳回处理
    elif decision == "rejected":
        return "node_rework"
    else:
        return "unknown"

然后将此函数嵌入到流转主逻辑中,代替静态的next_node_rules。

4 超时自动流转脚本

# 定时任务（如Celery Beat）每5分钟执行一次
def auto_transfer_overdue_nodes():
    overdue_nodes = get_nodes_older_than(hours=48, status="pending")
    for node in overdue_nodes:
        # 将任务自动转交到上级，或自动跳过
        new_assignee = find_superior(node["assignee"])
        node["assignee"] = new_assignee
        node["status"] = "transferred"
        save_node(node)
        notify_assignee(new_assignee, f"您收到转交的审批：{node['name']}")