using SqlSugar;
namespace Admin.NET.Plugin.AiDOP.MaterialWarehouse;
///
/// S5 来料检验(IQC)标准事实层投影服务。
///
/// 链路:qms_qcp_inspbill(+ 报检申请/分录 + 审批流实例)→ mdp_std_iqc_inspection。
/// 目的是让 S8 Stage-3 不再直读业务表与框架表 —— 那四张表此后只由本 Writer 读。
///
/// Grain = 一张检验单(tenant_id + iqc_bill_id)。先证后建:全库 23 张单实测
/// entries ≤ 1、distinct_po ≤ 1、flow_instances ≤ 1,结构保证来自 inspbill.hid 这把
/// 指向报检分录的单值外键。
///
/// 两条正交轴分开存:质量轴取 pd(0 合格 / 1 不合格 / NULL 未判定),
/// 流程轴取审批流 Status 与 EndTime。实测存在「检验完成且 pd=1」的单,
/// 所以绝不可把流程完成当成质量合格,也绝不用 FBILLSTATUS 当质量 Authority。
///
/// 租户方向是单向的:ApprovalFlowInstance 没有 TenantId 列,
/// 因此租户只能来自 qms_qcp_inspbill.tenant_id,审批流仅按 (BizType, BizId) 反查,
/// 绝不反向驱动租户。
///
/// 刻意不做:不投 PO 行号 / 收货行号(上游 FSRCBILLID、
/// FSRCBILLENTRYSEQ 实测全空,属 SOURCE CONTRACT GAP);不做订单级完成聚合;
/// 不写任何业务源表。
///
public class IqcInspectionMdpSyncService : ITransient
{
private const string JobCode = "S5_IQC_INSPECTION_MDP_SYNC";
private const string JobName = "S5来料检验标准事实层投影";
/// 审批流业务类型,与 IqcInspBillFlowConst.BizType 一致。
private const string FlowBizType = "S5_IQC_INSPBILL";
private readonly ISqlSugarClient _db;
public IqcInspectionMdpSyncService(ISqlSugarClient db)
{
_db = db;
}
///
/// 全量投影(UPSERT)。可按租户收窄; 为 0 表示全租户。
/// 幂等:同一检验单重复运行只更新不新增,唯一键 (tenant_id, source_row_id)。
///
public async Task RunFullAsync(
long tenantId = 0,
string triggerType = "AUTO",
CancellationToken cancellationToken = default)
{
cancellationToken.ThrowIfCancellationRequested();
var now = DateTime.Now;
var batchId = $"S5_IQC_STD_{(tenantId > 0 ? tenantId + "_" : "")}{now:yyyyMMddHHmmss}";
var runLogId = await InsertRunLogAsync(batchId, now, triggerType);
var result = new IqcInspectionMdpSyncResult { BatchId = batchId, RunLogId = runLogId };
try
{
result.StdRows = await TransformStandardAsync(batchId, now, tenantId);
await CompleteRunLogAsync(runLogId, result.StdRows, now);
return result;
}
catch (Exception ex)
{
await FailRunLogAsync(runLogId, ex.Message);
throw;
}
}
///
/// 标准层投影。
///
/// 报检分录用 LEFT JOIN 且【只走 hid 这把单值外键】:hid 为空的历史单
/// 得到 NULL 的采购/收货/物料身份,而不是去申请单下"挑一条"分录 —— 宁可为空,不猜。
///
/// 审批流同样 LEFT JOIN:尚未发起流程的单落 NULL,不伪造完成时间。
///
private async Task TransformStandardAsync(string batchId, DateTime now, long tenantId)
{
// 租户收窄:>0 时只投该租户,=0 时全投。两处(COUNT 与 INSERT)共用同一谓词,防止口径漂移。
var tenantClause = tenantId > 0 ? " AND b.tenant_id=@TenantId" : "";
var countPars = new List();
if (tenantId > 0) countPars.Add(new SugarParameter("@TenantId", tenantId));
var rows = await _db.Ado.GetIntAsync(
$"""
SELECT COUNT(1) FROM qms_qcp_inspbill b
WHERE b.tenant_id > 0{tenantClause}
""", countPars);
var insertSql =
$"""
INSERT INTO mdp_std_iqc_inspection
(tenant_id, factory_id, source_system,
iqc_bill_id, iqc_bill_no, application_id, application_no, application_entry_id,
purchase_order_no, receipt_no,
material_code, material_name, lot_serial, supplier_code, supplier_name,
raw_pd, quality_result,
flow_status, flow_instance_id, completion_time,
source_row_id, source_biz_key, sync_batch_id, sync_time)
SELECT
b.tenant_id, 1, 'AIDOP',
b.id,
NULLIF(b.FBILLNO, ''),
a.id,
NULLIF(b.lydjbh, ''),
e.id,
-- 采购/收货身份只从 hid 解析出的那一条分录取,取不到就是 NULL
NULLIF(e.purchase_order_no, ''),
NULLIF(e.FSRCORDERNUM, ''),
NULLIF(e.FMATERIALCFG, ''),
NULLIF(e.wlmc, ''),
NULLIF(e.FLOTNUMBER, ''),
NULLIF(e.gysbm, ''),
NULLIF(e.gysmc, ''),
b.pd,
-- 质量结论只由 pd 派生。pd 为 NULL 时必须是 PENDING,绝不能滑成 PASS
CASE WHEN b.pd = 0 THEN 'PASS'
WHEN b.pd = 1 THEN 'FAIL'
ELSE 'PENDING' END,
i.Status,
i.Id,
-- 只有流程走到终态(Approved)才认完成时间;Running 状态下不得投影 EndTime
CASE WHEN i.Status = 2 THEN i.EndTime ELSE NULL END,
CAST(b.id AS CHAR),
NULLIF(b.FBILLNO, ''),
@BatchId, @Now
FROM qms_qcp_inspbill b
-- 申请单:租户显式对齐(Domain 不是租户边界,不可用作关联依据)
LEFT JOIN qms_qcp_inspecapplyn a
ON a.tenant_id = b.tenant_id
AND a.FBILLNO = b.lydjbh
AND IFNULL(b.lydjbh, '') <> ''
-- 报检分录:只认 hid 单值外键。不做「申请单下任取一条」的回退 —— 那会把多分录场景
-- 静默变成随机挑一个 PO,是弱关联。
LEFT JOIN qms_qcp_insappnentry e
ON e.tenant_id = b.tenant_id
AND e.id = b.hid
AND b.hid IS NOT NULL
-- 审批流实例:租户方向单向 —— 由已确定租户的检验单去查流程,绝不反向。
-- 实测每个 BizId 至多一个实例,故无需 MAX(EndTime) 之类的挑选规则。
LEFT JOIN ApprovalFlowInstance i
ON i.BizType = @FlowBizType
AND i.BizId = b.id
WHERE b.tenant_id > 0{tenantClause}
ON DUPLICATE KEY UPDATE
factory_id=VALUES(factory_id), source_system=VALUES(source_system),
iqc_bill_no=VALUES(iqc_bill_no),
application_id=VALUES(application_id), application_no=VALUES(application_no),
application_entry_id=VALUES(application_entry_id),
purchase_order_no=VALUES(purchase_order_no), receipt_no=VALUES(receipt_no),
material_code=VALUES(material_code), material_name=VALUES(material_name),
lot_serial=VALUES(lot_serial), supplier_code=VALUES(supplier_code), supplier_name=VALUES(supplier_name),
raw_pd=VALUES(raw_pd), quality_result=VALUES(quality_result),
flow_status=VALUES(flow_status), flow_instance_id=VALUES(flow_instance_id),
completion_time=VALUES(completion_time),
source_biz_key=VALUES(source_biz_key),
sync_batch_id=VALUES(sync_batch_id), sync_time=VALUES(sync_time),
update_time=CURRENT_TIMESTAMP
""";
var insPars = new List
{
new("@BatchId", batchId),
new("@Now", now),
new("@FlowBizType", FlowBizType),
};
if (tenantId > 0) insPars.Add(new SugarParameter("@TenantId", tenantId));
await _db.Ado.ExecuteCommandAsync(insertSql, insPars);
return rows;
}
private async Task InsertRunLogAsync(string batchId, DateTime startedAt, string triggerType)
{
await _db.Ado.ExecuteCommandAsync(
"""
INSERT INTO mdp_transform_run_log
(tenant_id, job_code, job_name, trigger_type, batch_id, status, start_time)
VALUES (0, @JobCode, @JobName, @TriggerType, @BatchId, 'RUNNING', @StartTime)
""",
new SugarParameter("@JobCode", JobCode),
new SugarParameter("@JobName", JobName),
new SugarParameter("@TriggerType", NormalizeTriggerType(triggerType)),
new SugarParameter("@BatchId", batchId),
new SugarParameter("@StartTime", startedAt));
return await _db.Ado.GetLongAsync(
"SELECT id FROM mdp_transform_run_log WHERE batch_id=@BatchId ORDER BY id DESC LIMIT 1",
new List { new("@BatchId", batchId) });
}
private async Task CompleteRunLogAsync(long runLogId, int stdRows, DateTime startedAt)
{
var endedAt = DateTime.Now;
await _db.Ado.ExecuteCommandAsync(
"""
UPDATE mdp_transform_run_log
SET status='SUCCESS', standard_rows=@StdRows, end_time=@EndTime,
duration_ms=@Duration, update_time=CURRENT_TIMESTAMP
WHERE id=@Id
""",
new SugarParameter("@StdRows", stdRows),
new SugarParameter("@EndTime", endedAt),
new SugarParameter("@Duration", (int)(endedAt - startedAt).TotalMilliseconds),
new SugarParameter("@Id", runLogId));
}
private async Task FailRunLogAsync(long runLogId, string message)
{
await _db.Ado.ExecuteCommandAsync(
"""
UPDATE mdp_transform_run_log
SET status='FAILED', end_time=@EndTime, error_message=@Msg, update_time=CURRENT_TIMESTAMP
WHERE id=@Id
""",
new SugarParameter("@EndTime", DateTime.Now),
new SugarParameter("@Msg", message.Length > 900 ? message[..900] : message),
new SugarParameter("@Id", runLogId));
}
private static string NormalizeTriggerType(string triggerType)
=> string.IsNullOrWhiteSpace(triggerType) ? "AUTO" : triggerType.Trim().ToUpperInvariant();
}
/// S5 IQC 标准层投影结果。
public sealed class IqcInspectionMdpSyncResult
{
public string BatchId { get; set; } = string.Empty;
public long RunLogId { get; set; }
/// 本轮投影覆盖的检验单数(去重后的 Grain 行数,非 JOIN 扇出行数)。
public int StdRows { get; set; }
}