配置第一条审批工作流：重大案件合伙人联签实战

using BitzOrcas.Application.Abstractions.Tenancy;
using BitzOrcas.Application.Security;
using BitzOrcas.Domain.Results;
using BitzOrcas.Modules.Legal.Domain;
using BitzOrcas.Workflow.Abstractions.Services;
using Mediator;

namespace BitzOrcas.Modules.Legal.Application.Commands.SubmitMatterForApproval;

public sealed record SubmitMatterForApprovalCommand(
    string MatterId,
    decimal ClaimAmount,
    bool HasPotentialConflict) : ICommand<Result<string>>;

public sealed class SubmitMatterForApprovalCommandHandler(
    IWorkflowTransitionFlow workflowTransition,
    ICurrentTenant currentTenant,
    ICurrentUser currentUser) : ICommandHandler<SubmitMatterForApprovalCommand, Result<string>>
{
    public async ValueTask<Result<string>> Handle(
        SubmitMatterForApprovalCommand request,
        CancellationToken cancellationToken)
    {
        var tenantId = currentTenant.Tenant.EffectiveTenantId;
        var starterId = currentUser.UserId;

        // 组装工作流路由变量：用于 DAG 网关评估条件分支
        var workflowVariables = new Dictionary<string, object?>
        {
            ["MatterId"] = request.MatterId,
            ["ClaimAmount"] = request.ClaimAmount,
            ["HasPotentialConflict"] = request.HasPotentialConflict,
            ["IsMajorMatter"] = request.ClaimAmount >= 50_000_000.00m
        };

        // 委托 IWorkflowTransitionFlow 发起流程实例
        var startResult = await workflowTransition.StartAsync(
            definitionKey: "WF_LEGAL_MATTER_APPROVAL",
            businessKey: request.MatterId,
            businessType: "LegalMatterIntake",
            starterId: starterId,
            tenantId: tenantId,
            officeId: null,
            variables: workflowVariables,
            cancellationToken: cancellationToken);

        if (startResult.IsFailure)
        {
            return Result<string>.Failure(startResult.Error);
        }

        var instance = startResult.GetValueOrThrow();
        return Result<string>.Success(instance.Id);
    }
}

using BitzOrcas.Application.Security;
using BitzOrcas.Domain.Results;
using BitzOrcas.Workflow.Abstractions.Services;
using Mediator;

namespace BitzOrcas.Modules.Legal.Application.Commands.ApproveMatterTask;

public sealed record ApproveMatterTaskCommand(
    string TaskId,
    string ApprovalComment) : ICommand<Result>;

public sealed class ApproveMatterTaskCommandHandler(
    IWorkflowTransitionFlow workflowTransition,
    ICurrentUser currentUser) : ICommandHandler<ApproveMatterTaskCommand, Result>
{
    public async ValueTask<Result> Handle(
        ApproveMatterTaskCommand request,
        CancellationToken cancellationToken)
    {
        var userId = currentUser.UserId;

        // 调用流转端口完成任务；引擎将原子校验会签进度，并在全部联签完成后自动流转至下游节点
        var transitionResult = await workflowTransition.CompleteTaskAsync(
            taskId: request.TaskId,
            userId: userId,
            comment: request.ApprovalComment,
            variables: null,
            cancellationToken: cancellationToken);

        return transitionResult;
    }
}

// 驳回至主办律师，指定驳回原因
var rejectResult = await workflowTransition.RejectTaskAsync(
    taskId: request.TaskId,
    userId: currentUser.UserId,
    comment: "检测到相对方为本所常年法律顾问客户，存在法定利益冲突，请先办理豁免手续。",
    targetNodeId: null, // null 表示根据节点配置的 RollbackRule 原路回退至发起人
    cancellationToken: cancellationToken);

using BitzOrcas.Modules.Legal.Application.Commands.SubmitMatterForApproval;
using BitzOrcas.Workflow.Abstractions.Engine;
using Shouldly;
using Xunit;

public sealed class MatterWorkflowIntegrationTests : IClassFixture<CustomWebApplicationFactory>
{
    private readonly IWorkflowEngine _engine;

    public MatterWorkflowIntegrationTests(CustomWebApplicationFactory factory)
    {
        _engine = factory.GetRequiredService<IWorkflowEngine>();
    }

    [Fact]
    public async Task MajorMatter_Over50Million_ShouldRequirePartnerCountersign()
    {
        // 1. 模拟提交涉案标的额 6000 万的重大民商事诉讼
        var transition = _engine.RuntimeTransition;
        var variables = new Dictionary<string, object?>
        {
            ["ClaimAmount"] = 60_000_000.00m,
            ["HasPotentialConflict"] = false
        };

        var startResult = await transition.StartAsync(
            definitionKey: "WF_LEGAL_MATTER_APPROVAL",
            businessKey: "MAT-20260923-9999",
            businessType: "LegalMatterIntake",
            starterId: "lawyer_001",
            tenantId: "1000001",
            officeId: null,
            variables: variables,
            cancellationToken: CancellationToken.None);

        startResult.IsSuccess.ShouldBeTrue();
        var instanceId = startResult.GetValueOrThrow().Id;

        // 2. 机器断言：网关正确分流至重大案件联签节点
        var tasksResult = await _engine.Tasks.GetActiveTasksByInstanceIdAsync(instanceId, CancellationToken.None);
        tasksResult.IsSuccess.ShouldBeTrue();

        var activeTasks = tasksResult.GetValueOrThrow();
        activeTasks.Count.ShouldBe(2); // 主任合伙人任务 + 首席风控官联签任务
        activeTasks.ShouldContain(t => t.TaskName == "主任合伙人审批");
        activeTasks.ShouldContain(t => t.TaskName == "首席风控官联签");
    }
}