AdoS0QmsSpecImportController.cs 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478
  1. using System.ComponentModel.DataAnnotations;
  2. using Admin.NET.Core;
  3. using Microsoft.AspNetCore.Http;
  4. using Admin.NET.Plugin.AiDOP.Dto.S0.Quality;
  5. using Admin.NET.Plugin.AiDOP.Entity.S0.Quality;
  6. using Admin.NET.Plugin.AiDOP.Infrastructure;
  7. using static Admin.NET.Plugin.AiDOP.Controllers.S0.Quality.AdoS0QmsControllerHelpers;
  8. namespace Admin.NET.Plugin.AiDOP.Controllers.S0.Quality;
  9. /// <summary>
  10. /// S0 质量建模 - 4 个检验规范列表(原材料 / 过程 / FQC / OQC)Excel 模板导入。
  11. /// 每个列表提供“下载导入模板”(GET import-template) 与“上传导入”(POST import) 两个端点。
  12. /// 模板为一张平铺表:主表列 + 明细列,按“文件编号”分组还原为一条主单 + 多条明细。
  13. /// 写入语义复刻各列表现有 Create(纯新增,不去重、不 upsert)。
  14. ///
  15. /// 【全或无】UAT-S0-10 拍板(2026-09-02):先做整份 preflight 校验,任一行或任一组不合格即整份拒绝、
  16. /// 0 落库;全部通过后才进入写事务。必填契约与普通 Create 入口共用 AdoS0QmsSpecAggregateGuard。
  17. /// </summary>
  18. [ApiController]
  19. [Route("api/s0/quality")]
  20. [NonUnify]
  21. public class AdoS0QmsSpecImportController : ControllerBase
  22. {
  23. private readonly SqlSugarRepository<AdoS0QmsRawInspectionSpec> _rawRep;
  24. private readonly SqlSugarRepository<AdoS0QmsRawInspectionSpecEntry> _rawEntryRep;
  25. private readonly SqlSugarRepository<AdoS0QmsProcessInspectionSpec> _processRep;
  26. private readonly SqlSugarRepository<AdoS0QmsProcessInspectionSpecEntry> _processEntryRep;
  27. // FQC 侧已切到 S7 运行链路表 qms_ccjygf / qms_ccjygfzb(见 AdoS0QmsFqcInspectionSpecsController 注释)
  28. private readonly SqlSugarRepository<AdoS0QmsFinishedInspectionSpec> _fqcRep;
  29. private readonly SqlSugarRepository<AdoS0QmsFinishedInspectionSpecEntry> _fqcEntryRep;
  30. private readonly SqlSugarRepository<AdoS0QmsOqcInspectionSpec> _oqcRep;
  31. private readonly SqlSugarRepository<AdoS0QmsOqcInspectionSpecEntry> _oqcEntryRep;
  32. private readonly FinishedWarehouse.FqcSpecMaterialMapService _specMap;
  33. public AdoS0QmsSpecImportController(
  34. SqlSugarRepository<AdoS0QmsRawInspectionSpec> rawRep,
  35. SqlSugarRepository<AdoS0QmsRawInspectionSpecEntry> rawEntryRep,
  36. SqlSugarRepository<AdoS0QmsProcessInspectionSpec> processRep,
  37. SqlSugarRepository<AdoS0QmsProcessInspectionSpecEntry> processEntryRep,
  38. SqlSugarRepository<AdoS0QmsFinishedInspectionSpec> fqcRep,
  39. SqlSugarRepository<AdoS0QmsFinishedInspectionSpecEntry> fqcEntryRep,
  40. SqlSugarRepository<AdoS0QmsOqcInspectionSpec> oqcRep,
  41. SqlSugarRepository<AdoS0QmsOqcInspectionSpecEntry> oqcEntryRep,
  42. FinishedWarehouse.FqcSpecMaterialMapService specMap)
  43. {
  44. _rawRep = rawRep;
  45. _rawEntryRep = rawEntryRep;
  46. _processRep = processRep;
  47. _processEntryRep = processEntryRep;
  48. _fqcRep = fqcRep;
  49. _fqcEntryRep = fqcEntryRep;
  50. _oqcRep = oqcRep;
  51. _oqcEntryRep = oqcEntryRep;
  52. _specMap = specMap;
  53. }
  54. // ==================== 模板下载 ====================
  55. [HttpGet("raw-inspection-specs/import-template")]
  56. public Task<IActionResult> RawTemplate()
  57. => MiniExcelUtil.ExportExcelTemplate<AdoS0QmsRawInspectionSpecImportRow>("原材料检验规范导入模板");
  58. [HttpGet("process-inspection-specs/import-template")]
  59. public Task<IActionResult> ProcessTemplate()
  60. => MiniExcelUtil.ExportExcelTemplate<AdoS0QmsProcessLikeInspectionSpecImportRow>("过程检验规范导入模板");
  61. [HttpGet("fqc-inspection-specs/import-template")]
  62. public Task<IActionResult> FqcTemplate()
  63. => MiniExcelUtil.ExportExcelTemplate<AdoS0QmsFinishedInspectionSpecImportRow>("FQC检验规范导入模板");
  64. [HttpGet("oqc-inspection-specs/import-template")]
  65. public Task<IActionResult> OqcTemplate()
  66. => MiniExcelUtil.ExportExcelTemplate<AdoS0QmsProcessLikeInspectionSpecImportRow>("OQC检验规范导入模板");
  67. // ==================== 导入 ====================
  68. [HttpPost("raw-inspection-specs/import")]
  69. public async Task<IActionResult> RawImport(IFormFile file)
  70. {
  71. if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
  72. if (file == null || file.Length == 0) return BadRequest(new { message = "请上传 Excel 文件" });
  73. var result = await RunImportAsync<AdoS0QmsRawInspectionSpecImportRow, AdoS0QmsRawInspectionSpec, AdoS0QmsRawInspectionSpecEntry>(
  74. file, r => r.FileNumber, AdoS0QmsSpecAggregateGuard.HasDetailValue, MergeRawHeader, RawRequiredHeaderFields, _rawRep, _rawEntryRep,
  75. (r, fn) => new AdoS0QmsRawInspectionSpec
  76. {
  77. FileNumber = fn,
  78. VersionNo = NullIfWhiteSpace(r.VersionNo),
  79. DrawingNo = NullIfWhiteSpace(r.DrawingNo),
  80. RawMaterialName = NullIfWhiteSpace(r.RawMaterialName),
  81. MaterialCode = NullIfWhiteSpace(r.MaterialCode),
  82. EffectiveDate = NullIfWhiteSpace(r.EffectiveDate),
  83. DrawingVersion = NullIfWhiteSpace(r.DrawingVersion),
  84. MaterialGrade = NullIfWhiteSpace(r.MaterialGrade),
  85. CavityOrMold = NullIfWhiteSpace(r.CavityOrMold),
  86. Attachment = NullIfWhiteSpace(r.Attachment),
  87. FileName = NullIfWhiteSpace(r.FileName),
  88. Title = NullIfWhiteSpace(r.Title),
  89. },
  90. m => m.Id,
  91. (r, mid) => new AdoS0QmsRawInspectionSpecEntry
  92. {
  93. MasterId = mid,
  94. Seq = r.Seq,
  95. InspectionItem = NullIfWhiteSpace(r.InspectionItem),
  96. InspectionStandard = NullIfWhiteSpace(r.InspectionStandard),
  97. InspectionMethod = NullIfWhiteSpace(r.InspectionMethod),
  98. SamplingScheme = NullIfWhiteSpace(r.SamplingScheme),
  99. UpperLimit = NullIfWhiteSpace(r.UpperLimit),
  100. LowerLimit = NullIfWhiteSpace(r.LowerLimit),
  101. },
  102. tenantId);
  103. return Ok(result);
  104. }
  105. [HttpPost("process-inspection-specs/import")]
  106. public async Task<IActionResult> ProcessImport(IFormFile file)
  107. {
  108. if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
  109. if (file == null || file.Length == 0) return BadRequest(new { message = "请上传 Excel 文件" });
  110. var result = await RunImportAsync<AdoS0QmsProcessLikeInspectionSpecImportRow, AdoS0QmsProcessInspectionSpec, AdoS0QmsProcessInspectionSpecEntry>(
  111. file, r => r.FileNumber, AdoS0QmsSpecAggregateGuard.HasDetailValue, MergeProcessLikeHeader, ProcessLikeRequiredHeaderFields, _processRep, _processEntryRep,
  112. (r, fn) => new AdoS0QmsProcessInspectionSpec
  113. {
  114. FileNumber = fn,
  115. ApplicableModel = NullIfWhiteSpace(r.ApplicableModel),
  116. VersionNo = NullIfWhiteSpace(r.VersionNo),
  117. EffectiveDate = NullIfWhiteSpace(r.EffectiveDate),
  118. MaterialCode = NullIfWhiteSpace(r.MaterialCode),
  119. Attachment = NullIfWhiteSpace(r.Attachment),
  120. Attachment2 = NullIfWhiteSpace(r.Attachment2),
  121. Version = r.Version,
  122. },
  123. m => m.Id,
  124. (r, mid) => BuildProcessLikeEntry<AdoS0QmsProcessInspectionSpecEntry>(r, mid),
  125. tenantId);
  126. return Ok(result);
  127. }
  128. [HttpPost("fqc-inspection-specs/import")]
  129. public async Task<IActionResult> FqcImport(IFormFile file)
  130. {
  131. if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
  132. if (file == null || file.Length == 0) return BadRequest(new { message = "请上传 Excel 文件" });
  133. var createdIds = new List<long>();
  134. var result = await RunImportAsync<AdoS0QmsFinishedInspectionSpecImportRow, AdoS0QmsFinishedInspectionSpec, AdoS0QmsFinishedInspectionSpecEntry>(
  135. file, r => r.FileNumber, AdoS0QmsSpecAggregateGuard.HasDetailValue, MergeFinishedHeader, FinishedRequiredHeaderFields, _fqcRep, _fqcEntryRep,
  136. (r, fn) => new AdoS0QmsFinishedInspectionSpec
  137. {
  138. FileNumber = fn,
  139. VersionNo = NullIfWhiteSpace(r.VersionNo),
  140. ProductName = NullIfWhiteSpace(r.ProductName),
  141. ProductModel = NullIfWhiteSpace(r.ProductModel),
  142. EffectiveDate = NullIfWhiteSpace(r.EffectiveDate),
  143. MaterialCode = NullIfWhiteSpace(r.MaterialCode),
  144. Attachment = NullIfWhiteSpace(r.Attachment),
  145. },
  146. m => m.Id,
  147. (r, mid) => new AdoS0QmsFinishedInspectionSpecEntry
  148. {
  149. MasterId = mid,
  150. SeqNo = NullIfWhiteSpace(r.SeqNo),
  151. InspectionItem = NullIfWhiteSpace(r.InspectionItem),
  152. ResultType = AdoS0QmsFqcInspectionSpecsController.NormalizeResultType(r.ResultType),
  153. UpperLimit = AdoS0QmsFqcInspectionSpecsController.NormalizeResultType(r.ResultType) == "NON_NUMERIC" ? null : NullIfWhiteSpace(r.UpperLimit),
  154. LowerLimit = AdoS0QmsFqcInspectionSpecsController.NormalizeResultType(r.ResultType) == "NON_NUMERIC" ? null : NullIfWhiteSpace(r.LowerLimit),
  155. TechnicalRequirement = NullIfWhiteSpace(r.TechnicalRequirement),
  156. InspectionMethod = NullIfWhiteSpace(r.InspectionMethod),
  157. Instrument = NullIfWhiteSpace(r.Instrument),
  158. TechnicalStandard = NullIfWhiteSpace(r.TechnicalStandard),
  159. SamplingPlan = NullIfWhiteSpace(r.SamplingPlan),
  160. SizeSpecifications = NullIfWhiteSpace(r.SizeSpecifications),
  161. },
  162. tenantId, createdIds);
  163. // 导入是「全或无」:Accepted=false 时未写入任何数据,无需同步。
  164. // Accepted=true 时逐条同步桥表,否则导入进来的检规对 S7 完全不可见。
  165. if (result.Accepted)
  166. {
  167. foreach (var id in createdIds) await _specMap.SyncSpecAsync(tenantId, id);
  168. }
  169. return Ok(result);
  170. }
  171. [HttpPost("oqc-inspection-specs/import")]
  172. public async Task<IActionResult> OqcImport(IFormFile file)
  173. {
  174. if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
  175. if (file == null || file.Length == 0) return BadRequest(new { message = "请上传 Excel 文件" });
  176. var result = await RunImportAsync<AdoS0QmsProcessLikeInspectionSpecImportRow, AdoS0QmsOqcInspectionSpec, AdoS0QmsOqcInspectionSpecEntry>(
  177. file, r => r.FileNumber, AdoS0QmsSpecAggregateGuard.HasDetailValue, MergeProcessLikeHeader, ProcessLikeRequiredHeaderFields, _oqcRep, _oqcEntryRep,
  178. (r, fn) => new AdoS0QmsOqcInspectionSpec
  179. {
  180. FileNumber = fn,
  181. ApplicableModel = NullIfWhiteSpace(r.ApplicableModel),
  182. VersionNo = NullIfWhiteSpace(r.VersionNo),
  183. EffectiveDate = NullIfWhiteSpace(r.EffectiveDate),
  184. MaterialCode = NullIfWhiteSpace(r.MaterialCode),
  185. Attachment = NullIfWhiteSpace(r.Attachment),
  186. Attachment2 = NullIfWhiteSpace(r.Attachment2),
  187. Version = r.Version,
  188. },
  189. m => m.Id,
  190. (r, mid) => BuildProcessLikeEntry<AdoS0QmsOqcInspectionSpecEntry>(r, mid),
  191. tenantId);
  192. return Ok(result);
  193. }
  194. // ==================== 共用逻辑 ====================
  195. /// <summary>过程/FQC/OQC 三表明细结构一致,共用一个明细构造器(各表 Entry 字段名相同)。</summary>
  196. private static TEntry BuildProcessLikeEntry<TEntry>(AdoS0QmsProcessLikeInspectionSpecImportRow r, long masterId)
  197. where TEntry : class, new()
  198. {
  199. var entry = new TEntry();
  200. switch (entry)
  201. {
  202. case AdoS0QmsProcessInspectionSpecEntry p:
  203. p.MasterId = masterId;
  204. p.OperationCode = NullIfWhiteSpace(r.OperationCode);
  205. p.OperationName = NullIfWhiteSpace(r.OperationName);
  206. p.InspectionItem = NullIfWhiteSpace(r.InspectionItem);
  207. p.InspectionMethod = NullIfWhiteSpace(r.InspectionMethod);
  208. p.InspectionSpec = NullIfWhiteSpace(r.InspectionSpec);
  209. p.InspectionFrequency = NullIfWhiteSpace(r.InspectionFrequency);
  210. p.UpperLimit = NullIfWhiteSpace(r.UpperLimit);
  211. p.LowerLimit = NullIfWhiteSpace(r.LowerLimit);
  212. break;
  213. case AdoS0QmsFqcInspectionSpecEntry f:
  214. f.MasterId = masterId;
  215. f.OperationCode = NullIfWhiteSpace(r.OperationCode);
  216. f.OperationName = NullIfWhiteSpace(r.OperationName);
  217. f.InspectionItem = NullIfWhiteSpace(r.InspectionItem);
  218. f.InspectionMethod = NullIfWhiteSpace(r.InspectionMethod);
  219. f.InspectionSpec = NullIfWhiteSpace(r.InspectionSpec);
  220. f.InspectionFrequency = NullIfWhiteSpace(r.InspectionFrequency);
  221. f.UpperLimit = NullIfWhiteSpace(r.UpperLimit);
  222. f.LowerLimit = NullIfWhiteSpace(r.LowerLimit);
  223. break;
  224. case AdoS0QmsOqcInspectionSpecEntry o:
  225. o.MasterId = masterId;
  226. o.OperationCode = NullIfWhiteSpace(r.OperationCode);
  227. o.OperationName = NullIfWhiteSpace(r.OperationName);
  228. o.InspectionItem = NullIfWhiteSpace(r.InspectionItem);
  229. o.InspectionMethod = NullIfWhiteSpace(r.InspectionMethod);
  230. o.InspectionSpec = NullIfWhiteSpace(r.InspectionSpec);
  231. o.InspectionFrequency = NullIfWhiteSpace(r.InspectionFrequency);
  232. o.UpperLimit = NullIfWhiteSpace(r.UpperLimit);
  233. o.LowerLimit = NullIfWhiteSpace(r.LowerLimit);
  234. break;
  235. }
  236. return entry;
  237. }
  238. private async Task<AdoS0QmsSpecImportResultDto> RunImportAsync<TRow, TMaster, TEntry>(
  239. IFormFile file,
  240. Func<TRow, string?> keySelector,
  241. Func<TRow, bool> detailHasValue,
  242. Func<List<TRow>, TRow> headerMerger,
  243. Func<TRow, IReadOnlyList<(string Label, string? Value)>> requiredHeaderFields,
  244. SqlSugarRepository<TMaster> masterRep,
  245. SqlSugarRepository<TEntry> entryRep,
  246. Func<TRow, string, TMaster> masterFactory,
  247. Func<TMaster, long> idOf,
  248. Func<TRow, long, TEntry> entryFactory,
  249. long tenantId,
  250. List<long>? createdMasterIds = null)
  251. where TRow : class, new()
  252. where TMaster : class, new()
  253. where TEntry : class, new()
  254. {
  255. var rows = (await MiniExcelUtil.GetImportExcelData<TRow>(file)).ToList();
  256. var result = new AdoS0QmsSpecImportResultDto();
  257. // ---------- Preflight(全或无):本段完全不碰数据库 ----------
  258. var groups = BuildGroups(rows, keySelector, result);
  259. // 归组之后再合并头字段,然后按聚合校验必填——续行允许省略除文件编号外的头字段,
  260. // 逐行校验会把合法续行误判为空值非法,故必填只在这一层判。
  261. var merged = new Dictionary<SpecGroup<TRow>, TRow>();
  262. foreach (var g in groups)
  263. {
  264. var header = headerMerger(g.Rows);
  265. merged[g] = header;
  266. var itemCount = g.Rows.Count(detailHasValue);
  267. var error = AdoS0QmsSpecAggregateGuard.ValidateCreate(requiredHeaderFields(header), itemCount);
  268. if (error != null)
  269. {
  270. result.FailedRows++;
  271. result.RowMessages.Add($"文件编号「{g.FileNumber}」(第 {g.FirstRowNo} 行起):{error}");
  272. }
  273. }
  274. if (groups.Count == 0 && result.FailedRows == 0)
  275. {
  276. // 空文件不报成功,否则用户会看到绿色的“新增 0 条规范”而误以为导入生效。
  277. result.Accepted = false;
  278. result.RowMessages.Add("未读取到任何数据行,请确认使用的是本页下载的导入模板且已填写数据。");
  279. result.Message = "导入已拒绝:文件中没有数据行,未写入任何数据。";
  280. return result;
  281. }
  282. if (result.FailedRows > 0)
  283. {
  284. result.Accepted = false;
  285. result.Message = $"导入已拒绝:共读取 {result.TotalRows} 行,发现 {result.FailedRows} 处不合格,未写入任何数据。请修正后重新导入。";
  286. return result;
  287. }
  288. // ---------- 全部通过后才进入写事务 ----------
  289. var tid = tenantId;
  290. var db = masterRep.Context;
  291. await db.Ado.BeginTranAsync();
  292. try
  293. {
  294. foreach (var g in groups)
  295. {
  296. var master = masterFactory(merged[g], g.FileNumber);
  297. typeof(TMaster).GetProperty(nameof(AdoS0QmsRawInspectionSpec.TenantId))?.SetValue(master, tid);
  298. await masterRep.AsInsertable(master).ExecuteReturnEntityAsync();
  299. var masterId = idOf(master);
  300. createdMasterIds?.Add(masterId);
  301. result.ImportedMasters++;
  302. foreach (var row in g.Rows)
  303. {
  304. if (!detailHasValue(row)) continue;
  305. var entry = entryFactory(row, masterId);
  306. typeof(TEntry).GetProperty(nameof(AdoS0QmsRawInspectionSpecEntry.TenantId))?.SetValue(entry, tid);
  307. await entryRep.AsInsertable(entry).ExecuteCommandAsync();
  308. result.ImportedItems++;
  309. }
  310. }
  311. await db.Ado.CommitTranAsync();
  312. }
  313. catch
  314. {
  315. await db.Ado.RollbackTranAsync();
  316. throw;
  317. }
  318. result.Accepted = true;
  319. result.Message = $"导入完成:新增 {result.ImportedMasters} 条规范、{result.ImportedItems} 条明细,共读取 {result.TotalRows} 行。";
  320. return result;
  321. }
  322. /// <summary>
  323. /// 按“文件编号”分组:同一文件编号的多行合并为一条主单 + 多条明细。
  324. /// 文件编号是分组键,必须逐行出现——缺失的行无法归属任何主单,记为不合格(全或无语义下将导致整份拒绝)。
  325. /// 同时逐行做特性校验([MaxLength],按实测 DB 列长),把超长值挡在 DB 之外,避免透到 INSERT 变成裸 500。
  326. /// </summary>
  327. private static List<SpecGroup<TRow>> BuildGroups<TRow>(IEnumerable<TRow> rows, Func<TRow, string?> keySelector, AdoS0QmsSpecImportResultDto result)
  328. where TRow : class
  329. {
  330. var groups = new List<SpecGroup<TRow>>();
  331. var index = new Dictionary<string, SpecGroup<TRow>>();
  332. var rowNo = 1; // 表头占第 1 行,首个数据行为第 2 行
  333. foreach (var row in rows)
  334. {
  335. rowNo++;
  336. result.TotalRows++;
  337. var validationResults = new List<ValidationResult>();
  338. if (!Validator.TryValidateObject(row, new ValidationContext(row), validationResults, validateAllProperties: true))
  339. {
  340. foreach (var v in validationResults)
  341. {
  342. result.FailedRows++;
  343. result.RowMessages.Add($"第 {rowNo} 行:{v.ErrorMessage}");
  344. }
  345. }
  346. var key = keySelector(row)?.Trim();
  347. if (string.IsNullOrWhiteSpace(key))
  348. {
  349. result.FailedRows++;
  350. result.RowMessages.Add($"第 {rowNo} 行:文件编号为空,无法归属任何规范");
  351. continue;
  352. }
  353. if (!index.TryGetValue(key, out var g))
  354. {
  355. g = new SpecGroup<TRow> { FileNumber = key, FirstRowNo = rowNo };
  356. index[key] = g;
  357. groups.Add(g);
  358. }
  359. g.Rows.Add(row);
  360. }
  361. return groups;
  362. }
  363. // ==================== 头字段合并与必填集 ====================
  364. // 合并口径:同组内每个头字段取第一个非空值。续行留空不覆盖,也不因首行留空而丢值。
  365. private static string? FirstNonBlank<TRow>(List<TRow> rows, Func<TRow, string?> selector)
  366. {
  367. foreach (var row in rows)
  368. {
  369. var v = selector(row);
  370. if (!string.IsNullOrWhiteSpace(v)) return v;
  371. }
  372. return null;
  373. }
  374. private static AdoS0QmsRawInspectionSpecImportRow MergeRawHeader(List<AdoS0QmsRawInspectionSpecImportRow> rows) => new()
  375. {
  376. FileNumber = FirstNonBlank(rows, r => r.FileNumber),
  377. VersionNo = FirstNonBlank(rows, r => r.VersionNo),
  378. DrawingNo = FirstNonBlank(rows, r => r.DrawingNo),
  379. RawMaterialName = FirstNonBlank(rows, r => r.RawMaterialName),
  380. MaterialCode = FirstNonBlank(rows, r => r.MaterialCode),
  381. EffectiveDate = FirstNonBlank(rows, r => r.EffectiveDate),
  382. DrawingVersion = FirstNonBlank(rows, r => r.DrawingVersion),
  383. MaterialGrade = FirstNonBlank(rows, r => r.MaterialGrade),
  384. CavityOrMold = FirstNonBlank(rows, r => r.CavityOrMold),
  385. Attachment = FirstNonBlank(rows, r => r.Attachment),
  386. FileName = FirstNonBlank(rows, r => r.FileName),
  387. Title = FirstNonBlank(rows, r => r.Title),
  388. };
  389. private static AdoS0QmsProcessLikeInspectionSpecImportRow MergeProcessLikeHeader(List<AdoS0QmsProcessLikeInspectionSpecImportRow> rows) => new()
  390. {
  391. ApplicableModel = FirstNonBlank(rows, r => r.ApplicableModel),
  392. FileNumber = FirstNonBlank(rows, r => r.FileNumber),
  393. VersionNo = FirstNonBlank(rows, r => r.VersionNo),
  394. EffectiveDate = FirstNonBlank(rows, r => r.EffectiveDate),
  395. MaterialCode = FirstNonBlank(rows, r => r.MaterialCode),
  396. Attachment = FirstNonBlank(rows, r => r.Attachment),
  397. Attachment2 = FirstNonBlank(rows, r => r.Attachment2),
  398. Version = rows.Select(r => r.Version).FirstOrDefault(v => v.HasValue),
  399. };
  400. /// <summary>成品检规导入头合并(续行可省略除文件编号外的头字段)。</summary>
  401. private static AdoS0QmsFinishedInspectionSpecImportRow MergeFinishedHeader(List<AdoS0QmsFinishedInspectionSpecImportRow> rows) => new()
  402. {
  403. FileNumber = FirstNonBlank(rows, r => r.FileNumber),
  404. VersionNo = FirstNonBlank(rows, r => r.VersionNo),
  405. ProductName = FirstNonBlank(rows, r => r.ProductName),
  406. ProductModel = FirstNonBlank(rows, r => r.ProductModel),
  407. EffectiveDate = FirstNonBlank(rows, r => r.EffectiveDate),
  408. MaterialCode = FirstNonBlank(rows, r => r.MaterialCode),
  409. Attachment = FirstNonBlank(rows, r => r.Attachment),
  410. };
  411. /// <summary>成品检规必填集(与 Create/Update 同口径:文件编号 / 物料编码 / 版本)。</summary>
  412. private static IReadOnlyList<(string, string?)> FinishedRequiredHeaderFields(AdoS0QmsFinishedInspectionSpecImportRow r) =>
  413. [
  414. ("文件编号", r.FileNumber),
  415. ("物料编码", r.MaterialCode),
  416. ("版本", r.VersionNo),
  417. ];
  418. /// <summary>原材料检规必填集(UAT-S0-10 拍板)。</summary>
  419. private static IReadOnlyList<(string, string?)> RawRequiredHeaderFields(AdoS0QmsRawInspectionSpecImportRow r) =>
  420. [
  421. ("文件编号", r.FileNumber),
  422. ("物料编码", r.MaterialCode),
  423. ("原材料名称", r.RawMaterialName),
  424. ("版本", r.VersionNo),
  425. ];
  426. /// <summary>过程 / FQC / OQC 检规必填集(本轮不含「适用型号」,缺业务依据,见拍板第 1 条)。</summary>
  427. private static IReadOnlyList<(string, string?)> ProcessLikeRequiredHeaderFields(AdoS0QmsProcessLikeInspectionSpecImportRow r) =>
  428. [
  429. ("文件编号", r.FileNumber),
  430. ("物料编码", r.MaterialCode),
  431. ("版本", r.VersionNo),
  432. ];
  433. private sealed class SpecGroup<TRow>
  434. {
  435. public string FileNumber { get; init; } = string.Empty;
  436. /// <summary>该分组首次出现的 Excel 行号,仅用于错误定位。</summary>
  437. public int FirstRowNo { get; init; }
  438. public List<TRow> Rows { get; } = [];
  439. }
  440. }