pg_durable：把持久化工作流搬进 PostgreSQL，不再依赖外部编排引擎

# 从 GitHub 克隆并编译
git clone https://github.com/microsoft/pg_durable.git
cd pg_durable

# 编译安装（需要 pg_config 在 PATH 中）
make
make install

# 在目标数据库中启用扩展
psql -d your_db -c "CREATE EXTENSION pg_durable;"

-- 注册一个持久化工作流
SELECT pg_durable.register_workflow(
  'refund_approval',
  'process_refund_step'
);

-- 定义工作流的步骤函数
-- 每次被调用时根据当前步骤执行对应逻辑
CREATE OR REPLACE FUNCTION process_refund_step(
  workflow_id  UUID,
  step_name    TEXT,
  input_data   JSONB
) RETURNS JSONB AS $$
DECLARE
  result JSONB;
BEGIN
  CASE step_name
    -- 第一步：风控自动检查
    WHEN 'risk_check' THEN
      -- 模拟风控逻辑：金额超过 5000 标记为需人工审核
      IF (input_data->>'amount')::DECIMAL > 5000 THEN
        result := jsonb_build_object(
          'status', 'need_manual_review',
          'next_step', 'manual_review'
        );
      ELSE
        result := jsonb_build_object(
          'status', 'auto_approved',
          'next_step', 'execute_refund'
        );
      END IF;

    -- 第二步：人工审批（此处仅标记等待状态，实际可对接审批系统回调）
    WHEN 'manual_review' THEN
      result := jsonb_build_object(
        'status', 'pending_approval',
        'next_step', 'execute_refund',
        'note', '等待审批人操作'
      );

    -- 第三步：执行退款
    WHEN 'execute_refund' THEN
      -- 在事务中完成退款并更新订单状态
      UPDATE orders
        SET refund_status = 'completed',
            refunded_at   = now()
        WHERE order_id = (input_data->>'order_id')::INT;
      result := jsonb_build_object(
        'status', 'done',
        'next_step', NULL  -- NULL 表示工作流结束
      );

    ELSE
      RAISE EXCEPTION '未知步骤: %', step_name;
  END CASE;

  RETURN result;
END;
$$ LANGUAGE plpgsql;

-- 发起一笔退款审批
SELECT pg_durable.start_workflow(
  'refund_approval',
  jsonb_build_object(
    'order_id', 1024,
    'amount',   3200,
    'user_id',  887
  )
);

-- 查看所有进行中的退款工作流
SELECT workflow_id, current_step, status, created_at
  FROM pg_durable.workflow_instances
  WHERE workflow_name = 'refund_approval'
    AND status != 'done'
  ORDER BY created_at;