using Microsoft.AspNetCore.Mvc;
namespace Admin.NET.Plugin.AiDOP.Infrastructure;
///
/// S0 组织归属(company_ref_id / factory_ref_id)的服务端唯一裁决者。
///
/// 背景(S0-ORG-REFERENCE-MODEL-FIX-B1):
/// 2026-06-14 commit a18c8a6c5 在「单部署」假设下给 S0 仓储页写死了
/// DEFAULT_COMPANY_REF_ID=1329900200001 / DEFAULT_FACTORY_REF_ID=1329900200002;
/// 其后 1.0.317.sql 把这两个 SysOrg 改挂到 Demo 租户 797403760988230,
/// 前端常量却从未同步 → 任何租户新增都写入别租户的 SysOrg.Id,形成跨租户组织引用。
///
/// 铁律:
/// - 组织归属**只由服务端**在当前租户内解析,一律忽略 payload 的组织值;
/// 前端 payload 不可信(老前端 / 手工 API / 其它客户端都可能带错值)。
/// - tenantId 必须来自 (JWT claim),
/// 绝不接受前端传入的 tenantId。
/// - **绝不跨租户查找**:候选集一律先按 TenantId 收窄。
/// - **绝不新增组织**:解析不出就返回 (0,0),由调用方转 400 业务错误,不自动建公司/工厂。
///
/// 本实现自 AdoS0ProcessFlowCardsController.ResolveDefaultOrgAsync 原样抽取
/// (该实现已实测产出 8/8 SAME-TENANT),语义保持不变,避免多份重复 resolver 漂移。
///
public static class AdoS0OrgScope
{
/// 租户内优先匹配的公司编码(仅作优先条件,取不到即按机构类型/根节点在本租户内兜底)。
private const string PreferredCompanyCode = "S0-C001";
/// 租户内优先匹配的工厂编码(同上,绝不跨租户查找)。
private const string PreferredFactoryCode = "S0-F001";
/// 机构类型-公司(SysOrg.Type 数据字典值)。
private const string CompanyOrgType = "201";
///
/// 机构类型-工厂。
/// ⚠️ S0 legacy compatibility: Type=501 used as factory.
/// 平台数据字典 org_type 中 501 的官方语义是「组」(101=集团 / 201=公司 / 301=部门 / 501=组),
/// S0 自 S0OrgSeedData 起单方面把 501 复用为「工厂」。当前全库 Type=501 的组织均为 AiDOP
/// 自建工厂节点,无真实「组」,故保持兼容不重构;后续若出现真实「组」需另开批次消歧。
///
private const string FactoryOrgType = "501";
///
/// 在**当前租户内**解析 S0 默认公司/工厂组织。
///
/// 优先级——公司:
/// C1 本租户 Code=S0-C001 → C3 本租户根节点(Pid=0)且 Type=201
/// → C2 本租户任意 Type=201 → C4 本租户任意根节点(Pid=0)
/// 优先级——工厂:
/// F1 本租户 Code=S0-F001 且父级为已解析公司 → F2 本租户 Type=501 且父级为已解析公司
/// → F3 本租户任意 Type=501 → F4 回落到公司自身(兼容未建工厂节点的租户,不新增组织)。
///
/// 确定性:一次取本租户机构并按 (OrderNo, Id) 稳定排序,各级用 FirstOrDefault 在有序集合上取首个,
/// 避免多候选时结果随执行计划漂移。
///
/// 无解:返回 (0, 0),由调用方转 400 业务错误,**不抛异常**——
/// AdoS0ExceptionFilter 会把 /api/s0/* 上的未处理异常统一映射为 500 S01999,
/// 抛异常会把「租户未配置机构」这类业务态误报成系统故障。
///
/// SqlSugar 上下文(调用方一般传 _rep.Context,无需额外注入 SysOrg 仓储)。
/// AdoS0TenantScope 解析出的可信租户(JWT claim),不接受 payload 传入。
public static async Task<(long CompanyId, long FactoryId)> ResolveAsync(ISqlSugarClient db, long tenantId)
{
if (tenantId <= 0) return (0, 0);
// 单次取数 + 内存分级,避免逐级往返;排序在 SQL 侧一次确定,后续各级取首个即稳定。
var orgs = await db.Queryable()
.Where(x => x.TenantId == tenantId)
.OrderBy(x => new { x.OrderNo, x.Id })
.Select(x => new { x.Id, x.Code, x.Type, x.Pid })
.ToListAsync();
if (orgs.Count == 0) return (0, 0);
var company =
orgs.FirstOrDefault(o => o.Code == PreferredCompanyCode) // C1
?? orgs.FirstOrDefault(o => o.Pid == 0 && o.Type == CompanyOrgType) // C3
?? orgs.FirstOrDefault(o => o.Type == CompanyOrgType) // C2
?? orgs.FirstOrDefault(o => o.Pid == 0); // C4
if (company == null) return (0, 0);
var factory =
orgs.FirstOrDefault(o => o.Code == PreferredFactoryCode && o.Pid == company.Id) // F1
?? orgs.FirstOrDefault(o => o.Type == FactoryOrgType && o.Pid == company.Id) // F2
?? orgs.FirstOrDefault(o => o.Type == FactoryOrgType); // F3
return (company.Id, factory?.Id ?? company.Id); // F4
}
///
/// 解析失败时的统一业务错误(各 Controller 复用同一文案,便于前端与运维识别)。
///
public static IActionResult NotConfiguredError(string entityLabel)
=> AdoS0ApiErrors.InvalidRequest($"当前租户未配置机构,无法确定{entityLabel}的公司/工厂归属,请先在机构管理中维护");
///
/// 校验 payload 带来的组织引用未越出当前租户(B-1b:用于「页面自己驱动工厂维度」的接口,
/// 这类接口不能强制 stamp 成解析值,否则会与页面的工厂选择错位,故改为放行 + 越权拒绝)。
///
/// 判定口径——**只拒绝「确实解析到 SysOrg 且属于他租户」的值**:
/// - 0 / 负数:视为未设置,放行(由各 Controller 自身的必填校验处理);
/// - 在 SysOrg 中查不到(如 legacy 数值域 1000 / 1 等历史值):**不属于跨租户引用**,放行;
/// legacy 数值域的治理是独立批次,本校验不得把历史数据编辑一并拒绝掉。
/// - 能查到且 TenantId != 当前租户:**拒绝**——这正是要堵的越权写入。
///
/// 返回 null 表示校验通过;否则返回可直接 return 的 400 业务错误。
///
/// SqlSugar 上下文(调用方一般传 _rep.Context)。
/// AdoS0TenantScope 解析出的可信租户(JWT claim)。
/// payload 的公司引用。
/// payload 的工厂引用。
public static async Task ValidateOrgBelongsToTenantAsync(
ISqlSugarClient db, long tenantId, long companyRefId, long factoryRefId)
{
var candidates = new List();
if (companyRefId > 0) candidates.Add(companyRefId);
if (factoryRefId > 0 && factoryRefId != companyRefId) candidates.Add(factoryRefId);
if (candidates.Count == 0) return null;
// 一次取回候选组织的归属;查不到的 id 不在结果里 → 按「非 SysOrg 引用」放行。
//
// ⚠️ 必须 ClearFilter():SysOrg 继承 EntityBaseTenant,带 SqlSugar 全局租户过滤器。
// 不清过滤器时,他租户的组织**根本查不出来**,owners 恒为空 → 越权值会被误判为
// 「非 SysOrg 引用」而放行,本校验形同虚设(B-1b 首轮负控实测即因此漏过)。
// 本查询只读取 SysOrg 的 Id/TenantId 用于归属判定,不返回任何他租户业务数据。
var owners = await db.Queryable()
.ClearFilter()
.Where(x => candidates.Contains(x.Id))
.Select(x => new { x.Id, x.TenantId })
.ToListAsync();
var offending = owners.FirstOrDefault(o => o.TenantId != tenantId);
if (offending != null)
{
return AdoS0ApiErrors.InvalidRequest(
$"公司/工厂归属非法:组织 {offending.Id} 不属于当前租户,拒绝写入");
}
return null;
}
}