XiHan.Framework.Workflow.Abstractions 5.0.0-preview.1

XiHan.Framework.Workflow.Abstractions

工作流契约与引擎（Ring 2，RFC-0021，ADR-0016 / ADR-0020 / ADR-0077）。能力 workflow.execution@1 由 Provider 提供三个存储、事务、实例锁与到期书签的轮询驱动；默认实现 Workflow.InMemory，多实例换 Workflow.Database。

引擎、定义目录、任务服务与外部任务服务在调用里被调用时加入调用方的事务（IWorkflowTransaction.IsActive）：存储写入、活动与结果处理器的写入、经发件箱发出的事件随业务提交或回滚，取得的实例锁持有到调用的服务作用域结束才释放；只读调用里的写入在执行活动之前返回 PERSISTENCE_UNEXPECTED_001（内存与数据库实现相同，ADR-0099）。在调用之外（后台任务、轮询器、定时器）被调用时自己开一次经完整管道的调用（来源协议 workflow），在那次调用的事务里执行。数据按分区隔离：平台一个分区、每个租户一个分区，调用只读写自己的分区，平台与租户互不可见，没有全局定义。

var definition = WorkflowDefinitionBuilder.Create("leave", "请假")
    .WithTimeout(TimeSpan.FromDays(7), WorkflowTimeoutAction.Terminate)
    .AddVariable("days", required: true)
    .AddStart()
    .AddUserTask("approve", "主管审批", node => node
        .WithAssigneeRule(AssigneeRuleTypes.User, "manager", "deputy")
        .WithProperty(UserTaskActivity.CompletionPolicyProperty, "All")
        .WithProperty(UserTaskActivity.ApprovalThresholdProperty, "50%")
        .WithProperty(UserTaskActivity.ReminderAfterSecondsProperty, 86400)
        .WithTimeout(TimeSpan.FromDays(3)))
    .AddHttp("notify", "https://hr.example.com/leave/{{ days }}", "POST", configure: node => node.WithProperty(HttpActivity.BodyProperty, "{\"outcome\": \"{{ outcome }}\"}").WithOutputMapping("ticket", "outputs.http.body.ticket"))
    .AddDecision("check")
    .AddEnd("approved", outcome: "approved")
    .AddEnd("rejected", outcome: "rejected")
    .AddTransition("start", "approve").AddTransition("approve", "notify").AddTransition("notify", "check")
    .AddTransition("check", "approved", "outcome == 'approved'").AddDefaultTransition("check", "rejected")
    .Build();
var created = await catalog.CreateAsync(definition, ct);
await catalog.PublishAsync(created.ValueOrThrow().Id, ct);
var instance = await engine.StartAsync(new WorkflowStartRequest { Name = "leave", Variables = new JsonObject { ["days"] = 2 }, StarterId = "alice", CorrelationId = "leave-2026-001", ReusePolicy = WorkflowReusePolicy.RejectActive }, ct);
var todo = await tasks.PendingAsync("manager", ct);
await tasks.CompleteAsync(new UserTaskCompletion(todo.ValueOrThrow()[0].Id, "manager", UserTaskOutcomes.Approved), ct);

节点以结果标签完成时（用户任务的 approved / rejected / timeout、事件网关的信号名、ContinueOnError 的 error、活动自定的标签），标签写进实例变量 outcome，当前节点与后继决策节点的出边条件都按它选边；条件都不成立时才走默认出边。

Http 活动的地址由流程定义给出，不可信：缺省的 WorkflowHttpClient 过出站地址策略（RFC-0008、ADR-0117），只能连公网地址，重定向的目标同样检查；目标被拒绝是节点故障，消息键 workflow.http.address_denied。

Http 活动的超时按引擎的 TimeProvider 计时、按令牌归因（RFC-0021，ADR-0097）：活动的超时令牌已触发即节点故障 WORKFLOW_UNEXPECTED_001（消息键 workflow.http.timed_out），不论调用方是否也已取消、客户端是抛出还是交回了响应；只有调用方取消时抛出 OperationCanceledException（操作随调用回滚）；两个都没触发时客户端抛出的取消与 TimeoutException 也按超时。WorkflowHttpClient.SendAsync(request, ct) 不另计时。

实例与节点实例的 Fault（WorkflowFault）存错误码、消息键、参数与内层原因，不存渲染好的文案（RFC-0010，ADR-0105）：展示用 Fault.Localize()（按当前消息作用域，调用链里是调用方的区域），返回给调用方用 Fault.ToError()（宿主在 Egress 翻译）；Message 是按进程默认区域渲染的文本，只供日志。引擎与内置活动的失败原因都是消息键，应用或第三方给的文本（异常消息、HTTP 原因短语、外部任务的错误、Fault 节点的消息）原样放在参数里。子流程的回调输入 childFault 是子实例故障的 JSON，父节点的故障按子实例的状态是 workflow.child.faulted / canceled / terminated、内层是子实例的故障。设计期诊断（定义校验的逐条问题、表达式诊断、DeserializeDefinition 的错误）、变量 lastError（故障的 JSON，表达式照旧读 code）、活动描述符与状态名同样是消息键（ADR-0106）：状态的展示名用 WorkflowStatusMessages。

定义不合法 → WORKFLOW_VALIDATION_001；定义未发布或在别的分区 → WORKFLOW_NOTFOUND_001（实例、书签在别的分区 → _002 / _003）；状态不允许 → WORKFLOW_CONFLICT_001 / _002；同关联已有未结束实例 → _005；操作者不是指派人 → WORKFLOW_DENIED_001；工作者没有锁 → _002；等锁超时 → WORKFLOW_TIMEOUT_001；只读调用里写入 → PERSISTENCE_UNEXPECTED_001；在调用之外被调用而应用不在服务状态 → WORKFLOW_UNAVAILABLE_001。

依赖方向

依赖 XiHan.Framework.Kernel、XiHan.Framework.Localization.Abstractions、XiHan.Framework.Messaging.Abstractions、XiHan.Framework.MultiTenancy.Abstractions（租户目录）、XiHan.Framework.Scheduling.Abstractions（cron）。被 Workflow.InMemory、Workflow.Database、Workflow.Conformance 引用。

状态

P0 + P5-11 补齐：可用（Preview）。