S2MdpSyncTransformService.cs 47 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917
  1. namespace Admin.NET.Plugin.AiDOP.Production;
  2. /// <summary>
  3. /// S2 生产排程 MDP 同步、标准化、DWD 与 KPI 计算服务。
  4. /// </summary>
  5. public class S2MdpSyncTransformService : ITransient
  6. {
  7. private const string JobCode = "S2_MDP_SYNC_TRANSFORM";
  8. private readonly ISqlSugarClient _db;
  9. public S2MdpSyncTransformService(ISqlSugarClient db)
  10. {
  11. _db = db;
  12. }
  13. public async Task<S2MdpSyncTransformResult> RunFullAsync(CancellationToken cancellationToken = default, string triggerType = "AUTO")
  14. {
  15. cancellationToken.ThrowIfCancellationRequested();
  16. var now = DateTime.Now;
  17. var batchId = $"S2_MDP_FULL_{now:yyyyMMddHHmmss}";
  18. var runLogId = await InsertTransformRunLogAsync(batchId, now, triggerType);
  19. var result = new S2MdpSyncTransformResult { BatchId = batchId, RunLogId = runLogId };
  20. try
  21. {
  22. await EnsureS2RuntimeObjectsAsync();
  23. result.StageRows = await SyncStagingAsync(batchId, now, cancellationToken);
  24. result.StandardRows = await TransformStandardAsync(batchId, now, cancellationToken);
  25. result.DwdRows = await BuildDwdAsync(batchId, now, cancellationToken);
  26. result.KpiRows = await BuildS2KpiValuesAsync(batchId, now, cancellationToken);
  27. await MarkTransformRunSuccessAsync(runLogId, now, result);
  28. return result;
  29. }
  30. catch (Exception ex)
  31. {
  32. await MarkTransformRunFailedAsync(runLogId, now, ex.Message);
  33. throw;
  34. }
  35. }
  36. private async Task EnsureS2RuntimeObjectsAsync()
  37. {
  38. foreach (var sql in S2MdpDdl.SqlBlocks)
  39. {
  40. await _db.Ado.ExecuteCommandAsync(sql);
  41. }
  42. }
  43. private async Task<int> SyncStagingAsync(string batchId, DateTime now, CancellationToken cancellationToken)
  44. {
  45. var total = 0;
  46. foreach (var entity in S2MdpEntityConfig.All)
  47. {
  48. cancellationToken.ThrowIfCancellationRequested();
  49. total += await SyncOneEntityAsync(entity, batchId, now);
  50. }
  51. return total;
  52. }
  53. private async Task<int> SyncOneEntityAsync(S2MdpEntityConfig entity, string batchId, DateTime now)
  54. {
  55. var entityRow = await _db.Ado.SqlQuerySingleAsync<S2MdpEntityRow>(
  56. "SELECT id AS Id, entity_name AS EntityName FROM mdp_entity WHERE tenant_id=0 AND entity_code=@EntityCode LIMIT 1",
  57. new SugarParameter("@EntityCode", entity.EntityCode));
  58. if (entityRow == null) throw Oops.Oh($"未找到 MDP 实体配置:{entity.EntityCode}");
  59. var columns = await _db.Ado.SqlQueryAsync<S2ColumnRow>(
  60. """
  61. SELECT COLUMN_NAME AS ColumnName
  62. FROM information_schema.COLUMNS
  63. WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME=@TableName
  64. ORDER BY ORDINAL_POSITION
  65. """,
  66. new SugarParameter("@TableName", entity.SourceTable));
  67. if (columns.Count == 0) throw Oops.Oh($"未找到源表:{entity.SourceTable}");
  68. var names = columns.Select(u => u.ColumnName).ToList();
  69. var tenantExpr = names.Any(u => string.Equals(u, "tenant_id", StringComparison.OrdinalIgnoreCase))
  70. ? $"IFNULL(s.`{FindColumn(names, "tenant_id")}`,0)"
  71. : "0";
  72. var factoryExpr = names.Any(u => string.Equals(u, "factory_id", StringComparison.OrdinalIgnoreCase))
  73. ? $"s.`{FindColumn(names, "factory_id")}`"
  74. : "NULL";
  75. var domainExpr = names.Any(u => string.Equals(u, "Domain", StringComparison.OrdinalIgnoreCase))
  76. ? $"s.`{FindColumn(names, "Domain")}`"
  77. : "NULL";
  78. var sourceRowExpr = names.Any(u => string.Equals(u, entity.SourceRowIdExpression, StringComparison.OrdinalIgnoreCase))
  79. ? $"s.`{FindColumn(names, entity.SourceRowIdExpression)}`"
  80. : entity.SourceRowIdExpression;
  81. var rawDataExpr = BuildJsonObjectExpression(names);
  82. var rowsRead = await _db.Ado.GetIntAsync($"SELECT COUNT(1) FROM `{entity.SourceTable}`");
  83. var logId = await InsertSyncLogAsync(entityRow.Id, entityRow.EntityName, batchId, rowsRead);
  84. var started = DateTime.Now;
  85. try
  86. {
  87. var affected = await _db.Ado.ExecuteCommandAsync(
  88. $"""
  89. INSERT INTO `{entity.TargetTable}`
  90. (tenant_id, factory_id, source_system, source_table, source_row_id, source_biz_key, sync_batch_id, sync_time, process_status, raw_data)
  91. SELECT
  92. {tenantExpr},
  93. COALESCE({factoryExpr}, {domainExpr}),
  94. 'AIDOP',
  95. @SourceTable,
  96. CAST({sourceRowExpr} AS CHAR),
  97. CAST(COALESCE({entity.SourceBizKeyExpression}, CAST({sourceRowExpr} AS CHAR)) AS CHAR),
  98. @BatchId,
  99. @Now,
  100. 'PENDING',
  101. {rawDataExpr}
  102. FROM `{entity.SourceTable}` s
  103. ON DUPLICATE KEY UPDATE
  104. tenant_id=VALUES(tenant_id),
  105. factory_id=VALUES(factory_id),
  106. sync_batch_id=VALUES(sync_batch_id),
  107. sync_time=VALUES(sync_time),
  108. process_status=VALUES(process_status),
  109. raw_data=VALUES(raw_data),
  110. update_time=CURRENT_TIMESTAMP
  111. """,
  112. new SugarParameter("@SourceTable", entity.SourceTable),
  113. new SugarParameter("@BatchId", batchId),
  114. new SugarParameter("@Now", now));
  115. await MarkSyncLogSuccessAsync(logId, started, affected);
  116. return rowsRead;
  117. }
  118. catch (Exception ex)
  119. {
  120. await MarkSyncLogFailedAsync(logId, started, ex.Message);
  121. throw;
  122. }
  123. }
  124. private async Task<int> TransformStandardAsync(string batchId, DateTime now, CancellationToken cancellationToken)
  125. {
  126. var total = 0;
  127. foreach (var command in BuildStandardCommands(batchId, now))
  128. {
  129. cancellationToken.ThrowIfCancellationRequested();
  130. total += await _db.Ado.ExecuteCommandAsync(command.Sql, command.Parameters);
  131. }
  132. return total;
  133. }
  134. private async Task<int> BuildDwdAsync(string batchId, DateTime now, CancellationToken cancellationToken)
  135. {
  136. var total = 0;
  137. foreach (var command in BuildDwdCommands(batchId, now))
  138. {
  139. cancellationToken.ThrowIfCancellationRequested();
  140. total += await _db.Ado.ExecuteCommandAsync(command.Sql, command.Parameters);
  141. }
  142. return total;
  143. }
  144. private async Task<int> BuildS2KpiValuesAsync(string batchId, DateTime now, CancellationToken cancellationToken)
  145. {
  146. var rows = await CalculateS2KpiValuesAsync(batchId, now.Date);
  147. var affected = 0;
  148. foreach (var row in rows)
  149. {
  150. cancellationToken.ThrowIfCancellationRequested();
  151. affected += await UpsertS2KpiValueAsync(row, now.Date, now);
  152. }
  153. return affected;
  154. }
  155. private IEnumerable<S2MdpSqlCommand> BuildStandardCommands(string batchId, DateTime now)
  156. {
  157. yield return Cmd(
  158. """
  159. INSERT INTO mdp_std_work_order_schedule
  160. (tenant_id, factory_id, source_system, work_order, sales_order_no, item_code, item_name, site_code, status,
  161. priority, urgent_flag, qty_ordered, qty_completed, order_date, due_date, release_date, prod_line,
  162. source_biz_key, sync_batch_id, sync_time)
  163. SELECT tenant_id,
  164. CASE WHEN factory_id REGEXP '^[0-9]+$' THEN CAST(factory_id AS UNSIGNED) ELSE 1 END,
  165. 'AIDOP',
  166. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkOrd')),
  167. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.SalesJob')),
  168. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.ItemNum')),
  169. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.ItemName')),
  170. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.Site')),
  171. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.Status')),
  172. CASE WHEN JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.Priority')) REGEXP '^-?[0-9]+(\\.[0-9]+)?$' THEN CAST(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.Priority')) AS DECIMAL(18,6)) END,
  173. CASE WHEN JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.Urgent')) IN ('1','true','True') THEN 1 ELSE 0 END,
  174. CASE WHEN JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.QtyOrded')) REGEXP '^-?[0-9]+(\\.[0-9]+)?$' THEN CAST(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.QtyOrded')) AS DECIMAL(18,6)) ELSE 0 END,
  175. CASE WHEN JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.QtyCompleted')) REGEXP '^-?[0-9]+(\\.[0-9]+)?$' THEN CAST(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.QtyCompleted')) AS DECIMAL(18,6)) ELSE 0 END,
  176. NULLIF(NULLIF(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.OrdDate')), 'null'), ''),
  177. NULLIF(NULLIF(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.DueDate')), 'null'), ''),
  178. NULLIF(NULLIF(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.ReleaseDate')), 'null'), ''),
  179. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.ProdLine')),
  180. source_biz_key, @BatchId, @Now
  181. FROM mdp_stg_schedule
  182. WHERE source_table='WorkOrdMaster' AND IFNULL(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkOrd')), '') <> ''
  183. ON DUPLICATE KEY UPDATE
  184. sales_order_no=VALUES(sales_order_no), item_code=VALUES(item_code), item_name=VALUES(item_name),
  185. site_code=VALUES(site_code), status=VALUES(status), priority=VALUES(priority), urgent_flag=VALUES(urgent_flag),
  186. qty_ordered=VALUES(qty_ordered), qty_completed=VALUES(qty_completed), order_date=VALUES(order_date),
  187. due_date=VALUES(due_date), release_date=VALUES(release_date), prod_line=VALUES(prod_line),
  188. sync_batch_id=VALUES(sync_batch_id), sync_time=VALUES(sync_time), update_time=CURRENT_TIMESTAMP
  189. """, batchId, now);
  190. yield return Cmd(
  191. """
  192. INSERT INTO mdp_std_operation_schedule
  193. (tenant_id, factory_id, source_system, work_order, op_no, work_center, line_code, item_code,
  194. plan_date, prod_date, start_time, end_time, ord_qty, comp_qty, run_crew, employee,
  195. source_biz_key, sync_batch_id, sync_time)
  196. SELECT tenant_id,
  197. CASE WHEN factory_id REGEXP '^[0-9]+$' THEN CAST(factory_id AS UNSIGNED) ELSE 1 END,
  198. 'AIDOP',
  199. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkOrds')),
  200. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.Op')),
  201. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkCtr')),
  202. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.Line')),
  203. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.ItemNum')),
  204. NULLIF(NULLIF(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.PlanDate')), 'null'), ''),
  205. NULLIF(NULLIF(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.ProdDate')), 'null'), ''),
  206. NULLIF(NULLIF(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.StartTime')), 'null'), ''),
  207. NULLIF(NULLIF(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.EndTime')), 'null'), ''),
  208. CASE WHEN JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.OrdQty')) REGEXP '^-?[0-9]+(\\.[0-9]+)?$' THEN CAST(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.OrdQty')) AS DECIMAL(18,6)) ELSE 0 END,
  209. CASE WHEN JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.CompQty')) REGEXP '^-?[0-9]+(\\.[0-9]+)?$' THEN CAST(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.CompQty')) AS DECIMAL(18,6)) ELSE 0 END,
  210. CASE WHEN JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.RunCrew')) REGEXP '^-?[0-9]+(\\.[0-9]+)?$' THEN CAST(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.RunCrew')) AS DECIMAL(18,6)) END,
  211. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.Employee')),
  212. source_biz_key, @BatchId, @Now
  213. FROM mdp_stg_schedule
  214. WHERE source_table='PeriodSequenceDet' AND IFNULL(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkOrds')), '') <> ''
  215. ON DUPLICATE KEY UPDATE
  216. work_center=VALUES(work_center), line_code=VALUES(line_code), item_code=VALUES(item_code),
  217. plan_date=VALUES(plan_date), prod_date=VALUES(prod_date), start_time=VALUES(start_time), end_time=VALUES(end_time),
  218. ord_qty=VALUES(ord_qty), comp_qty=VALUES(comp_qty), run_crew=VALUES(run_crew), employee=VALUES(employee),
  219. sync_batch_id=VALUES(sync_batch_id), sync_time=VALUES(sync_time), update_time=CURRENT_TIMESTAMP
  220. """, batchId, now);
  221. yield return Cmd(
  222. """
  223. INSERT INTO mdp_std_operation_schedule
  224. (tenant_id, factory_id, source_system, work_order, op_no, work_center, line_code, item_code,
  225. plan_date, prod_date, start_time, end_time, ord_qty, comp_qty, run_crew, employee,
  226. source_biz_key, sync_batch_id, sync_time)
  227. SELECT tenant_id,
  228. CASE WHEN factory_id REGEXP '^[0-9]+$' THEN CAST(factory_id AS UNSIGNED) ELSE 1 END,
  229. 'AIDOP',
  230. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkOrd')),
  231. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.Op')),
  232. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkCtr')),
  233. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.Line')),
  234. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.ItemNum')),
  235. NULLIF(NULLIF(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkDate')), 'null'), ''),
  236. NULLIF(NULLIF(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkDate')), 'null'), ''),
  237. NULLIF(NULLIF(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkStartTime')), 'null'), ''),
  238. NULLIF(NULLIF(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkEndTime')), 'null'), ''),
  239. CASE WHEN JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkQty')) REGEXP '^-?[0-9]+(\\.[0-9]+)?$' THEN CAST(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkQty')) AS DECIMAL(18,6)) ELSE 0 END,
  240. CASE WHEN JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkQty')) REGEXP '^-?[0-9]+(\\.[0-9]+)?$' THEN CAST(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkQty')) AS DECIMAL(18,6)) ELSE 0 END,
  241. CASE WHEN JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.AssignedPersonnelCount')) REGEXP '^-?[0-9]+(\\.[0-9]+)?$' THEN CAST(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.AssignedPersonnelCount')) AS DECIMAL(18,6)) END,
  242. JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.AssignedEmployeeID')),
  243. source_biz_key, @BatchId, @Now
  244. FROM mdp_stg_schedule
  245. WHERE source_table='ScheduleResultOpMaster' AND IFNULL(JSON_UNQUOTE(JSON_EXTRACT(raw_data,'$.WorkOrd')), '') <> ''
  246. ON DUPLICATE KEY UPDATE
  247. work_center=VALUES(work_center), line_code=VALUES(line_code), item_code=VALUES(item_code),
  248. plan_date=VALUES(plan_date), prod_date=VALUES(prod_date), start_time=VALUES(start_time), end_time=VALUES(end_time),
  249. ord_qty=VALUES(ord_qty), comp_qty=VALUES(comp_qty), run_crew=VALUES(run_crew), employee=VALUES(employee),
  250. sync_batch_id=VALUES(sync_batch_id), sync_time=VALUES(sync_time), update_time=CURRENT_TIMESTAMP
  251. """, batchId, now);
  252. }
  253. private IEnumerable<S2MdpSqlCommand> BuildDwdCommands(string batchId, DateTime now)
  254. {
  255. yield return Cmd(
  256. """
  257. INSERT INTO dwd_order_schedule_trans
  258. (tenant_id, factory_id, stat_date, work_order, sales_order_no, item_code, item_name, site_code, prod_line,
  259. status, urgent_flag, qty_ordered, qty_completed, order_date, due_date, release_date, first_plan_date,
  260. last_plan_date, first_start_time, last_end_time, operation_count, scheduled_qty, completed_op_qty,
  261. schedule_cycle_days, schedule_satisfaction_flag, wip_qty, resource_person_count, calc_batch_id, calc_time)
  262. SELECT w.tenant_id, COALESCE(w.factory_id, 1), @StatDate,
  263. w.work_order, w.sales_order_no, w.item_code, w.item_name, w.site_code, w.prod_line,
  264. w.status, w.urgent_flag, w.qty_ordered, w.qty_completed, w.order_date, w.due_date, w.release_date,
  265. MIN(o.plan_date), MAX(o.plan_date), MIN(o.start_time), MAX(o.end_time),
  266. COUNT(o.id), SUM(IFNULL(o.ord_qty, 0)), SUM(IFNULL(o.comp_qty, 0)),
  267. CASE
  268. WHEN COALESCE(MIN(o.plan_date), MAX(o.plan_date)) IS NOT NULL
  269. AND COALESCE(w.release_date, w.order_date) IS NOT NULL
  270. THEN TIMESTAMPDIFF(HOUR, COALESCE(w.release_date, w.order_date), COALESCE(MAX(o.plan_date), MIN(o.plan_date))) / 24
  271. END,
  272. CASE
  273. WHEN w.due_date IS NOT NULL AND COALESCE(MAX(o.plan_date), MIN(o.plan_date)) IS NOT NULL
  274. AND DATE(COALESCE(MAX(o.plan_date), MIN(o.plan_date))) <= DATE(w.due_date) THEN 1
  275. ELSE 0
  276. END,
  277. GREATEST(IFNULL(w.qty_ordered, 0) - IFNULL(w.qty_completed, 0), 0),
  278. SUM(IFNULL(o.run_crew, 0)),
  279. @BatchId, @Now
  280. FROM mdp_std_work_order_schedule w
  281. LEFT JOIN mdp_std_operation_schedule o
  282. ON o.tenant_id=w.tenant_id AND IFNULL(o.work_order,'')=IFNULL(w.work_order,'')
  283. WHERE IFNULL(w.work_order, '') <> ''
  284. GROUP BY w.tenant_id, COALESCE(w.factory_id, 1), w.work_order, w.sales_order_no, w.item_code, w.item_name,
  285. w.site_code, w.prod_line, w.status, w.urgent_flag, w.qty_ordered, w.qty_completed,
  286. w.order_date, w.due_date, w.release_date
  287. ON DUPLICATE KEY UPDATE
  288. sales_order_no=VALUES(sales_order_no), item_code=VALUES(item_code), item_name=VALUES(item_name),
  289. site_code=VALUES(site_code), prod_line=VALUES(prod_line), status=VALUES(status), urgent_flag=VALUES(urgent_flag),
  290. qty_ordered=VALUES(qty_ordered), qty_completed=VALUES(qty_completed), order_date=VALUES(order_date),
  291. due_date=VALUES(due_date), release_date=VALUES(release_date), first_plan_date=VALUES(first_plan_date),
  292. last_plan_date=VALUES(last_plan_date), first_start_time=VALUES(first_start_time), last_end_time=VALUES(last_end_time),
  293. operation_count=VALUES(operation_count), scheduled_qty=VALUES(scheduled_qty), completed_op_qty=VALUES(completed_op_qty),
  294. schedule_cycle_days=VALUES(schedule_cycle_days), schedule_satisfaction_flag=VALUES(schedule_satisfaction_flag),
  295. wip_qty=VALUES(wip_qty), resource_person_count=VALUES(resource_person_count), calc_time=VALUES(calc_time),
  296. update_time=CURRENT_TIMESTAMP
  297. """, batchId, now);
  298. }
  299. private async Task<List<S2KpiCalcRow>> CalculateS2KpiValuesAsync(string batchId, DateTime statDate)
  300. {
  301. return await _db.Ado.SqlQueryAsync<S2KpiCalcRow>(
  302. """
  303. SELECT tenant_id AS TenantId, factory_id AS FactoryId, 'S2_L1_001' AS MetricCode,
  304. ROUND(AVG(schedule_cycle_days), 4) AS MetricValue
  305. FROM dwd_order_schedule_trans
  306. WHERE calc_batch_id=@BatchId AND schedule_cycle_days IS NOT NULL AND schedule_cycle_days >= 0
  307. GROUP BY tenant_id, factory_id
  308. UNION ALL
  309. SELECT tenant_id AS TenantId, factory_id AS FactoryId, 'S2_L1_002' AS MetricCode,
  310. ROUND(100 * SUM(schedule_satisfaction_flag) / NULLIF(COUNT(1), 0), 4) AS MetricValue
  311. FROM dwd_order_schedule_trans
  312. WHERE calc_batch_id=@BatchId
  313. GROUP BY tenant_id, factory_id
  314. UNION ALL
  315. SELECT tenant_id AS TenantId, factory_id AS FactoryId, 'S2_L1_003' AS MetricCode,
  316. ROUND(COUNT(1) / NULLIF(SUM(CASE WHEN IFNULL(resource_person_count, 0) > 0 THEN resource_person_count ELSE 1 END), 0), 4) AS MetricValue
  317. FROM dwd_order_schedule_trans
  318. WHERE calc_batch_id=@BatchId
  319. GROUP BY tenant_id, factory_id
  320. UNION ALL
  321. SELECT tenant_id AS TenantId, factory_id AS FactoryId, 'S2_L1_004' AS MetricCode,
  322. ROUND(SUM(wip_qty) / NULLIF(SUM(CASE WHEN qty_completed > 0 THEN qty_completed ELSE completed_op_qty END), 0) * 30, 4) AS MetricValue
  323. FROM dwd_order_schedule_trans
  324. WHERE calc_batch_id=@BatchId
  325. GROUP BY tenant_id, factory_id
  326. UNION ALL
  327. SELECT tenant_id AS TenantId, factory_id AS FactoryId, 'S2_L2_001' AS MetricCode,
  328. ROUND(AVG(schedule_cycle_days), 4) AS MetricValue
  329. FROM dwd_order_schedule_trans
  330. WHERE calc_batch_id=@BatchId AND schedule_cycle_days IS NOT NULL AND schedule_cycle_days >= 0
  331. GROUP BY tenant_id, factory_id
  332. UNION ALL
  333. SELECT tenant_id AS TenantId, factory_id AS FactoryId, 'S2_L2_002' AS MetricCode,
  334. ROUND(100 * SUM(schedule_satisfaction_flag) / NULLIF(COUNT(1), 0), 4) AS MetricValue
  335. FROM dwd_order_schedule_trans
  336. WHERE calc_batch_id=@BatchId
  337. GROUP BY tenant_id, factory_id
  338. UNION ALL
  339. SELECT tenant_id AS TenantId, factory_id AS FactoryId, 'S2_L2_003' AS MetricCode,
  340. ROUND(COUNT(1) / NULLIF(SUM(CASE WHEN IFNULL(resource_person_count, 0) > 0 THEN resource_person_count ELSE 1 END), 0), 4) AS MetricValue
  341. FROM dwd_order_schedule_trans
  342. WHERE calc_batch_id=@BatchId
  343. GROUP BY tenant_id, factory_id
  344. UNION ALL
  345. SELECT tenant_id AS TenantId, factory_id AS FactoryId, 'S2_L3_001' AS MetricCode,
  346. ROUND(AVG(
  347. CASE
  348. WHEN start_time IS NOT NULL AND end_time IS NOT NULL AND end_time >= start_time
  349. THEN TIMESTAMPDIFF(HOUR, start_time, end_time) / 24
  350. WHEN plan_date IS NOT NULL AND prod_date IS NOT NULL
  351. THEN ABS(TIMESTAMPDIFF(DAY, plan_date, prod_date))
  352. END
  353. ), 4) AS MetricValue
  354. FROM mdp_std_operation_schedule
  355. WHERE IFNULL(work_order, '') <> ''
  356. GROUP BY tenant_id, factory_id
  357. UNION ALL
  358. SELECT tenant_id AS TenantId, factory_id AS FactoryId, 'S2_L3_002' AS MetricCode,
  359. ROUND(100 * SUM(CASE WHEN plan_date IS NOT NULL AND (prod_date IS NULL OR prod_date >= plan_date) THEN 1 ELSE 0 END) / NULLIF(COUNT(1), 0), 4) AS MetricValue
  360. FROM mdp_std_operation_schedule
  361. WHERE IFNULL(work_order, '') <> ''
  362. GROUP BY tenant_id, factory_id
  363. UNION ALL
  364. SELECT tenant_id AS TenantId, factory_id AS FactoryId, 'S2_L3_003' AS MetricCode,
  365. ROUND(COUNT(1) / NULLIF(SUM(CASE WHEN IFNULL(run_crew, 0) > 0 THEN run_crew ELSE 1 END), 0), 4) AS MetricValue
  366. FROM mdp_std_operation_schedule
  367. WHERE IFNULL(work_order, '') <> ''
  368. GROUP BY tenant_id, factory_id
  369. UNION ALL
  370. SELECT tenant_id AS TenantId, factory_id AS FactoryId, 'S2_L3_004' AS MetricCode,
  371. ROUND(AVG(
  372. CASE
  373. WHEN start_time IS NOT NULL AND end_time IS NOT NULL AND end_time >= start_time
  374. THEN TIMESTAMPDIFF(HOUR, start_time, end_time) / 24
  375. WHEN plan_date IS NOT NULL AND prod_date IS NOT NULL
  376. THEN ABS(TIMESTAMPDIFF(DAY, plan_date, prod_date))
  377. END
  378. ), 4) AS MetricValue
  379. FROM mdp_std_operation_schedule
  380. WHERE IFNULL(COALESCE(NULLIF(work_center,''), NULLIF(line_code,'')), '') <> ''
  381. GROUP BY tenant_id, factory_id
  382. UNION ALL
  383. SELECT tenant_id AS TenantId, factory_id AS FactoryId, 'S2_L3_005' AS MetricCode,
  384. ROUND(100 * SUM(CASE WHEN plan_date IS NOT NULL AND (prod_date IS NULL OR prod_date >= plan_date) THEN 1 ELSE 0 END) / NULLIF(COUNT(1), 0), 4) AS MetricValue
  385. FROM mdp_std_operation_schedule
  386. WHERE IFNULL(COALESCE(NULLIF(work_center,''), NULLIF(line_code,'')), '') <> ''
  387. GROUP BY tenant_id, factory_id
  388. UNION ALL
  389. SELECT tenant_id AS TenantId, factory_id AS FactoryId, 'S2_L3_006' AS MetricCode,
  390. ROUND(COUNT(DISTINCT COALESCE(NULLIF(work_center,''), NULLIF(line_code,''), CONCAT(work_order, ':', op_no)))
  391. / NULLIF(SUM(CASE WHEN IFNULL(run_crew, 0) > 0 THEN run_crew ELSE 1 END), 0), 4) AS MetricValue
  392. FROM mdp_std_operation_schedule
  393. WHERE IFNULL(COALESCE(NULLIF(work_center,''), NULLIF(line_code,'')), '') <> ''
  394. GROUP BY tenant_id, factory_id
  395. """,
  396. new SugarParameter("@BatchId", batchId),
  397. new SugarParameter("@StatDate", statDate));
  398. }
  399. private async Task<int> UpsertS2KpiValueAsync(S2KpiCalcRow row, DateTime statDate, DateTime now)
  400. {
  401. if (row.MetricValue == null) return 0;
  402. var meta = await _db.Ado.SqlQuerySingleAsync<S2KpiMetaRow>(
  403. """
  404. SELECT MetricLevel, Direction, YellowThreshold, RedThreshold
  405. FROM ado_smart_ops_kpi_master
  406. WHERE TenantId=@TenantId AND ModuleCode='S2' AND MetricCode=@MetricCode AND IsEnabled=1
  407. LIMIT 1
  408. """,
  409. new SugarParameter("@TenantId", row.TenantId),
  410. new SugarParameter("@MetricCode", row.MetricCode));
  411. if (meta == null) return 0;
  412. var table = ResolveKpiValueTable(meta.MetricLevel);
  413. var current = await _db.Ado.SqlQuerySingleAsync<S2KpiValueRow>(
  414. $"""
  415. SELECT id AS Id, metric_value AS MetricValue, target_value AS TargetValue
  416. FROM {table}
  417. WHERE tenant_id=@TenantId AND factory_id=@FactoryId AND module_code='S2'
  418. AND metric_code=@MetricCode AND biz_date=@BizDate AND is_deleted=0
  419. ORDER BY id
  420. LIMIT 1
  421. """,
  422. new SugarParameter("@TenantId", row.TenantId),
  423. new SugarParameter("@FactoryId", row.FactoryId),
  424. new SugarParameter("@MetricCode", row.MetricCode),
  425. new SugarParameter("@BizDate", statDate));
  426. var prior = await _db.Ado.SqlQuerySingleAsync<S2KpiValueRow>(
  427. $"""
  428. SELECT id AS Id, metric_value AS MetricValue, target_value AS TargetValue
  429. FROM {table}
  430. WHERE tenant_id=@TenantId AND factory_id=@FactoryId AND module_code='S2'
  431. AND metric_code=@MetricCode AND biz_date<@BizDate AND is_deleted=0
  432. ORDER BY biz_date DESC, id DESC
  433. LIMIT 1
  434. """,
  435. new SugarParameter("@TenantId", row.TenantId),
  436. new SugarParameter("@FactoryId", row.FactoryId),
  437. new SugarParameter("@MetricCode", row.MetricCode),
  438. new SugarParameter("@BizDate", statDate));
  439. var actual = Math.Round(row.MetricValue.Value, 4);
  440. var target = current?.TargetValue ?? prior?.TargetValue ?? DefaultS2Target(row.MetricCode);
  441. var status = ResolveKpiStatus(actual, target, meta.Direction, meta.YellowThreshold, meta.RedThreshold);
  442. var trend = ResolveTrendFlag(actual, prior?.MetricValue);
  443. if (current != null)
  444. {
  445. return await _db.Ado.ExecuteCommandAsync(
  446. $"""
  447. UPDATE {table}
  448. SET metric_value=@MetricValue, target_value=@TargetValue, status_color=@StatusColor, trend_flag=@TrendFlag,
  449. is_active=1, status='ACTIVE', calc_time=@CalcTime, update_time=@CalcTime
  450. WHERE tenant_id=@TenantId AND factory_id=@FactoryId AND module_code='S2'
  451. AND metric_code=@MetricCode AND biz_date=@BizDate AND is_deleted=0
  452. """,
  453. new SugarParameter("@MetricValue", actual),
  454. new SugarParameter("@TargetValue", target),
  455. new SugarParameter("@StatusColor", status),
  456. new SugarParameter("@TrendFlag", trend),
  457. new SugarParameter("@CalcTime", now),
  458. new SugarParameter("@TenantId", row.TenantId),
  459. new SugarParameter("@FactoryId", row.FactoryId),
  460. new SugarParameter("@MetricCode", row.MetricCode),
  461. new SugarParameter("@BizDate", statDate));
  462. }
  463. var nextId = await _db.Ado.GetLongAsync($"SELECT COALESCE(MAX(id), 0) + 1 FROM {table}");
  464. return await _db.Ado.ExecuteCommandAsync(
  465. $"""
  466. INSERT INTO {table}
  467. (id, tenant_id, factory_id, status, biz_date, create_time, update_time, is_deleted, is_active,
  468. module_code, metric_code, metric_value, target_value, status_color, trend_flag, calc_time)
  469. VALUES
  470. (@Id, @TenantId, @FactoryId, 'ACTIVE', @BizDate, @CalcTime, @CalcTime, 0, 1,
  471. 'S2', @MetricCode, @MetricValue, @TargetValue, @StatusColor, @TrendFlag, @CalcTime)
  472. """,
  473. new SugarParameter("@Id", nextId),
  474. new SugarParameter("@TenantId", row.TenantId),
  475. new SugarParameter("@FactoryId", row.FactoryId),
  476. new SugarParameter("@BizDate", statDate),
  477. new SugarParameter("@CalcTime", now),
  478. new SugarParameter("@MetricCode", row.MetricCode),
  479. new SugarParameter("@MetricValue", actual),
  480. new SugarParameter("@TargetValue", target),
  481. new SugarParameter("@StatusColor", status),
  482. new SugarParameter("@TrendFlag", trend));
  483. }
  484. private async Task<long> InsertSyncLogAsync(long entityId, string entityName, string batchId, int rowsRead)
  485. {
  486. await _db.Ado.ExecuteCommandAsync(
  487. """
  488. INSERT INTO mdp_sync_log
  489. (tenant_id, entity_id, source_code, entity_name, sync_batch_id, sync_type, trigger_type, sync_start, rows_read, status)
  490. VALUES (0, @EntityId, 'AIDOPDEV_MYSQL', @EntityName, @BatchId, 'FULL', 'AUTO', NOW(), @RowsRead, 'RUNNING')
  491. """,
  492. new SugarParameter("@EntityId", entityId),
  493. new SugarParameter("@EntityName", entityName),
  494. new SugarParameter("@BatchId", batchId),
  495. new SugarParameter("@RowsRead", rowsRead));
  496. return await _db.Ado.GetLongAsync(
  497. "SELECT id FROM mdp_sync_log WHERE sync_batch_id=@BatchId AND entity_id=@EntityId ORDER BY id DESC LIMIT 1",
  498. new List<SugarParameter> { new("@BatchId", batchId), new("@EntityId", entityId) });
  499. }
  500. private async Task MarkSyncLogSuccessAsync(long logId, DateTime started, int affected)
  501. {
  502. await _db.Ado.ExecuteCommandAsync(
  503. """
  504. UPDATE mdp_sync_log
  505. SET sync_end=NOW(), duration_ms=@DurationMs, rows_insert=@RowsInsert, rows_update=0, rows_skip=0, rows_error=0, status='SUCCESS'
  506. WHERE id=@Id
  507. """,
  508. new SugarParameter("@DurationMs", (int)(DateTime.Now - started).TotalMilliseconds),
  509. new SugarParameter("@RowsInsert", affected),
  510. new SugarParameter("@Id", logId));
  511. }
  512. private async Task MarkSyncLogFailedAsync(long logId, DateTime started, string message)
  513. {
  514. try
  515. {
  516. await _db.Ado.ExecuteCommandAsync(
  517. """
  518. UPDATE mdp_sync_log
  519. SET sync_end=NOW(), duration_ms=@DurationMs, rows_error=1, status='FAILED', error_msg=@ErrorMsg
  520. WHERE id=@Id
  521. """,
  522. new SugarParameter("@DurationMs", (int)(DateTime.Now - started).TotalMilliseconds),
  523. new SugarParameter("@ErrorMsg", Truncate(message, 1000)),
  524. new SugarParameter("@Id", logId));
  525. }
  526. catch (Exception ex)
  527. {
  528. Console.Error.WriteLine($"[S2MdpSyncTransform] MarkSyncLogFailed write failed (syncLogId={logId}): {ex.Message}");
  529. }
  530. }
  531. private async Task<long> InsertTransformRunLogAsync(string batchId, DateTime startedAt, string triggerType)
  532. {
  533. await _db.Ado.ExecuteCommandAsync(
  534. """
  535. INSERT INTO mdp_transform_run_log
  536. (tenant_id, job_code, job_name, trigger_type, batch_id, status, start_time)
  537. VALUES (0, 'S2_MDP_SYNC_TRANSFORM', 'S2 MDP同步与KPI计算', @TriggerType, @BatchId, 'RUNNING', @StartTime)
  538. """,
  539. new SugarParameter("@TriggerType", NormalizeTriggerType(triggerType)),
  540. new SugarParameter("@BatchId", batchId),
  541. new SugarParameter("@StartTime", startedAt));
  542. return await _db.Ado.GetLongAsync(
  543. "SELECT id FROM mdp_transform_run_log WHERE batch_id=@BatchId ORDER BY id DESC LIMIT 1",
  544. new List<SugarParameter> { new("@BatchId", batchId) });
  545. }
  546. private async Task MarkTransformRunSuccessAsync(long runLogId, DateTime startedAt, S2MdpSyncTransformResult result)
  547. {
  548. var finishedAt = DateTime.Now;
  549. await _db.Ado.ExecuteCommandAsync(
  550. """
  551. UPDATE mdp_transform_run_log
  552. SET status='SUCCESS', end_time=@EndTime, duration_ms=@DurationMs,
  553. stage_rows=@StageRows, standard_rows=@StandardRows, dwd_rows=@DwdRows,
  554. summary_json=@SummaryJson, update_time=CURRENT_TIMESTAMP
  555. WHERE id=@Id
  556. """,
  557. new SugarParameter("@EndTime", finishedAt),
  558. new SugarParameter("@DurationMs", (int)(finishedAt - startedAt).TotalMilliseconds),
  559. new SugarParameter("@StageRows", result.StageRows),
  560. new SugarParameter("@StandardRows", result.StandardRows),
  561. new SugarParameter("@DwdRows", result.DwdRows),
  562. new SugarParameter("@SummaryJson", BuildRunSummaryJson(result)),
  563. new SugarParameter("@Id", runLogId));
  564. }
  565. private async Task MarkTransformRunFailedAsync(long runLogId, DateTime startedAt, string message)
  566. {
  567. try
  568. {
  569. var finishedAt = DateTime.Now;
  570. await _db.Ado.ExecuteCommandAsync(
  571. """
  572. UPDATE mdp_transform_run_log
  573. SET status='FAILED', end_time=@EndTime, duration_ms=@DurationMs,
  574. error_message=@ErrorMessage, update_time=CURRENT_TIMESTAMP
  575. WHERE id=@Id
  576. """,
  577. new SugarParameter("@EndTime", finishedAt),
  578. new SugarParameter("@DurationMs", (int)(finishedAt - startedAt).TotalMilliseconds),
  579. new SugarParameter("@ErrorMessage", Truncate(message, 2000)),
  580. new SugarParameter("@Id", runLogId));
  581. }
  582. catch (Exception ex)
  583. {
  584. Console.Error.WriteLine($"[S2MdpSyncTransform] MarkTransformRunFailed write failed (runLogId={runLogId}): {ex.Message}");
  585. }
  586. }
  587. private static S2MdpSqlCommand Cmd(string sql, string batchId, DateTime now)
  588. {
  589. return new S2MdpSqlCommand(sql, new[]
  590. {
  591. new SugarParameter("@BatchId", batchId),
  592. new SugarParameter("@Now", now),
  593. new SugarParameter("@StatDate", now.Date)
  594. });
  595. }
  596. private static string BuildJsonObjectExpression(IEnumerable<string> columns)
  597. {
  598. var parts = columns.SelectMany(c => new[] { $"'{c.Replace("'", "''")}'", $"s.`{c}`" });
  599. return $"JSON_OBJECT({string.Join(",", parts)})";
  600. }
  601. private static string FindColumn(IEnumerable<string> columns, string expected)
  602. {
  603. return columns.First(u => string.Equals(u, expected, StringComparison.OrdinalIgnoreCase));
  604. }
  605. private static string NormalizeTriggerType(string? triggerType)
  606. {
  607. return string.IsNullOrWhiteSpace(triggerType) ? "AUTO" : triggerType.Trim().ToUpperInvariant();
  608. }
  609. private static string BuildRunSummaryJson(S2MdpSyncTransformResult result)
  610. {
  611. return $$"""{"batchId":"{{result.BatchId}}","stageRows":{{result.StageRows}},"standardRows":{{result.StandardRows}},"dwdRows":{{result.DwdRows}},"kpiRows":{{result.KpiRows}}}""";
  612. }
  613. private static string ResolveKpiValueTable(int metricLevel)
  614. {
  615. return metricLevel switch
  616. {
  617. 1 => "ado_s9_kpi_value_l1_day",
  618. 2 => "ado_s9_kpi_value_l2_day",
  619. 3 => "ado_s9_kpi_value_l3_day",
  620. 4 => "ado_s9_kpi_value_l4_day",
  621. _ => "ado_s9_kpi_value_l2_day"
  622. };
  623. }
  624. private static decimal DefaultS2Target(string metricCode)
  625. {
  626. return metricCode switch
  627. {
  628. "S2_L1_001" => 20m,
  629. "S2_L1_002" => 99m,
  630. "S2_L1_003" => 20m,
  631. "S2_L1_004" => 18m,
  632. "S2_L2_001" => 1.2m,
  633. "S2_L2_002" => 95m,
  634. "S2_L2_003" => 20m,
  635. "S2_L3_001" => 3m,
  636. "S2_L3_002" => 95m,
  637. "S2_L3_003" => 60m,
  638. "S2_L3_004" => 3m,
  639. "S2_L3_005" => 95m,
  640. "S2_L3_006" => 60m,
  641. _ => 0m
  642. };
  643. }
  644. private static string ResolveKpiStatus(decimal actual, decimal target, string? direction, decimal? yellowThreshold, decimal? redThreshold)
  645. {
  646. if (target <= 0) return "gray";
  647. var ratio = actual / target * 100m;
  648. if (string.Equals(direction, "lower_is_better", StringComparison.OrdinalIgnoreCase))
  649. {
  650. if (actual <= target) return "green";
  651. if (ratio <= (yellowThreshold ?? 110m)) return "yellow";
  652. return ratio >= (redThreshold ?? 120m) ? "red" : "yellow";
  653. }
  654. if (actual >= target) return "green";
  655. if (ratio >= (yellowThreshold ?? 95m)) return "yellow";
  656. return ratio <= (redThreshold ?? 80m) ? "red" : "yellow";
  657. }
  658. private static string ResolveTrendFlag(decimal actual, decimal? previous)
  659. {
  660. if (previous == null) return "flat";
  661. if (actual > previous.Value) return "up";
  662. if (actual < previous.Value) return "down";
  663. return "flat";
  664. }
  665. private static string Truncate(string? raw, int maxLength)
  666. {
  667. if (string.IsNullOrEmpty(raw)) return string.Empty;
  668. return raw.Length <= maxLength ? raw : raw[..maxLength];
  669. }
  670. private sealed class S2ColumnRow
  671. {
  672. public string ColumnName { get; set; } = string.Empty;
  673. }
  674. private sealed class S2MdpEntityRow
  675. {
  676. public long Id { get; set; }
  677. public string EntityName { get; set; } = string.Empty;
  678. }
  679. private sealed class S2KpiCalcRow
  680. {
  681. public long TenantId { get; set; }
  682. public long FactoryId { get; set; }
  683. public string MetricCode { get; set; } = string.Empty;
  684. public decimal? MetricValue { get; set; }
  685. }
  686. private sealed class S2KpiMetaRow
  687. {
  688. public int MetricLevel { get; set; }
  689. public string Direction { get; set; } = "higher_is_better";
  690. public decimal? YellowThreshold { get; set; }
  691. public decimal? RedThreshold { get; set; }
  692. }
  693. private sealed class S2KpiValueRow
  694. {
  695. public long Id { get; set; }
  696. public decimal? MetricValue { get; set; }
  697. public decimal? TargetValue { get; set; }
  698. }
  699. }
  700. public sealed class S2MdpSyncTransformResult
  701. {
  702. public long RunLogId { get; set; }
  703. public string BatchId { get; set; } = string.Empty;
  704. public int StageRows { get; set; }
  705. public int StandardRows { get; set; }
  706. public int DwdRows { get; set; }
  707. public int KpiRows { get; set; }
  708. }
  709. internal sealed record S2MdpSqlCommand(string Sql, SugarParameter[] Parameters);
  710. internal sealed record S2MdpEntityConfig(
  711. string EntityCode,
  712. string SourceTable,
  713. string TargetTable,
  714. string SourceRowIdExpression,
  715. string SourceBizKeyExpression)
  716. {
  717. public static readonly IReadOnlyList<S2MdpEntityConfig> All = new List<S2MdpEntityConfig>
  718. {
  719. new("S2_WORK_ORDER_MASTER", "WorkOrdMaster", "mdp_stg_schedule", "RecID", "CONCAT(IFNULL(s.`Domain`,''), ':', IFNULL(s.`WorkOrd`,''))"),
  720. new("S2_WORK_ORDER_ROUTING", "WorkOrdRouting", "mdp_stg_schedule", "RecID", "CONCAT(IFNULL(s.`Domain`,''), ':', IFNULL(s.`WorkOrd`,''), ':', IFNULL(s.`OP`,''))"),
  721. new("S2_WORK_ORDER_DETAIL", "WorkOrdDetail", "mdp_stg_schedule", "RecID", "CONCAT(IFNULL(s.`Domain`,''), ':', IFNULL(s.`WorkOrd`,''), ':', IFNULL(s.`Op`,''), ':', IFNULL(s.`ItemNum`,''))"),
  722. new("S2_PERIOD_SEQUENCE_DET", "PeriodSequenceDet", "mdp_stg_schedule", "RecID", "CONCAT(IFNULL(s.`Domain`,''), ':', IFNULL(s.`WorkOrds`,''), ':', IFNULL(s.`Op`,''), ':', IFNULL(s.`Sequence`,''))"),
  723. new("S2_SCHEDULE_RESULT_OP", "ScheduleResultOpMaster", "mdp_stg_schedule", "RecID", "CONCAT(IFNULL(s.`Domain`,''), ':', IFNULL(s.`WorkOrd`,''), ':', IFNULL(s.`Op`,''), ':', IFNULL(s.`WorkDate`,''))")
  724. };
  725. }
  726. internal static class S2MdpDdl
  727. {
  728. public static readonly IReadOnlyList<string> SqlBlocks = new[]
  729. {
  730. """
  731. CREATE TABLE IF NOT EXISTS mdp_stg_schedule (
  732. id BIGINT AUTO_INCREMENT PRIMARY KEY,
  733. tenant_id BIGINT NOT NULL DEFAULT 0,
  734. factory_id VARCHAR(64) NULL,
  735. source_system VARCHAR(50) NOT NULL DEFAULT 'AIDOP',
  736. source_table VARCHAR(100) NOT NULL,
  737. source_row_id VARCHAR(100) NOT NULL,
  738. source_biz_key VARCHAR(200) NULL,
  739. sync_batch_id VARCHAR(100) NOT NULL,
  740. sync_time DATETIME NOT NULL,
  741. process_status VARCHAR(20) NOT NULL DEFAULT 'PENDING',
  742. raw_data JSON NOT NULL,
  743. update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  744. UNIQUE KEY uk_mdp_stg_schedule (tenant_id, source_table, source_row_id),
  745. KEY idx_mdp_stg_schedule_batch (sync_batch_id),
  746. KEY idx_mdp_stg_schedule_biz (source_biz_key)
  747. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S2生产排程贴源层';
  748. """,
  749. """
  750. CREATE TABLE IF NOT EXISTS mdp_std_work_order_schedule (
  751. id BIGINT AUTO_INCREMENT PRIMARY KEY,
  752. tenant_id BIGINT NOT NULL DEFAULT 0,
  753. factory_id BIGINT NULL,
  754. source_system VARCHAR(50) NOT NULL DEFAULT 'AIDOP',
  755. work_order VARCHAR(100) NOT NULL,
  756. sales_order_no VARCHAR(100) NULL,
  757. item_code VARCHAR(100) NULL,
  758. item_name VARCHAR(200) NULL,
  759. site_code VARCHAR(50) NULL,
  760. status VARCHAR(50) NULL,
  761. priority DECIMAL(18,6) NULL,
  762. urgent_flag TINYINT NOT NULL DEFAULT 0,
  763. qty_ordered DECIMAL(18,6) NULL,
  764. qty_completed DECIMAL(18,6) NULL,
  765. order_date DATETIME NULL,
  766. due_date DATETIME NULL,
  767. release_date DATETIME NULL,
  768. prod_line VARCHAR(100) NULL,
  769. source_biz_key VARCHAR(200) NULL,
  770. sync_batch_id VARCHAR(100) NOT NULL,
  771. sync_time DATETIME NOT NULL,
  772. update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  773. UNIQUE KEY uk_std_work_order_schedule (tenant_id, work_order),
  774. KEY idx_std_work_order_schedule_batch (sync_batch_id),
  775. KEY idx_std_work_order_schedule_due (tenant_id, due_date)
  776. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S2标准工单排程';
  777. """,
  778. """
  779. CREATE TABLE IF NOT EXISTS mdp_std_operation_schedule (
  780. id BIGINT AUTO_INCREMENT PRIMARY KEY,
  781. tenant_id BIGINT NOT NULL DEFAULT 0,
  782. factory_id BIGINT NULL,
  783. source_system VARCHAR(50) NOT NULL DEFAULT 'AIDOP',
  784. work_order VARCHAR(100) NOT NULL,
  785. op_no VARCHAR(50) NULL,
  786. work_center VARCHAR(100) NULL,
  787. line_code VARCHAR(100) NULL,
  788. item_code VARCHAR(100) NULL,
  789. plan_date DATETIME NULL,
  790. prod_date DATETIME NULL,
  791. start_time DATETIME NULL,
  792. end_time DATETIME NULL,
  793. ord_qty DECIMAL(18,6) NULL,
  794. comp_qty DECIMAL(18,6) NULL,
  795. run_crew DECIMAL(18,6) NULL,
  796. employee VARCHAR(200) NULL,
  797. source_biz_key VARCHAR(200) NULL,
  798. sync_batch_id VARCHAR(100) NOT NULL,
  799. sync_time DATETIME NOT NULL,
  800. update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  801. UNIQUE KEY uk_std_operation_schedule (tenant_id, source_biz_key),
  802. KEY idx_std_operation_schedule_work_order (tenant_id, work_order),
  803. KEY idx_std_operation_schedule_batch (sync_batch_id)
  804. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S2标准工序排程';
  805. """,
  806. """
  807. CREATE TABLE IF NOT EXISTS dwd_order_schedule_trans (
  808. id BIGINT AUTO_INCREMENT PRIMARY KEY,
  809. tenant_id BIGINT NOT NULL DEFAULT 0,
  810. factory_id BIGINT NOT NULL DEFAULT 1,
  811. stat_date DATE NOT NULL,
  812. work_order VARCHAR(100) NOT NULL,
  813. sales_order_no VARCHAR(100) NULL,
  814. item_code VARCHAR(100) NULL,
  815. item_name VARCHAR(200) NULL,
  816. site_code VARCHAR(50) NULL,
  817. prod_line VARCHAR(100) NULL,
  818. status VARCHAR(50) NULL,
  819. urgent_flag TINYINT NOT NULL DEFAULT 0,
  820. qty_ordered DECIMAL(18,6) NULL,
  821. qty_completed DECIMAL(18,6) NULL,
  822. order_date DATETIME NULL,
  823. due_date DATETIME NULL,
  824. release_date DATETIME NULL,
  825. first_plan_date DATETIME NULL,
  826. last_plan_date DATETIME NULL,
  827. first_start_time DATETIME NULL,
  828. last_end_time DATETIME NULL,
  829. operation_count INT NOT NULL DEFAULT 0,
  830. scheduled_qty DECIMAL(18,6) NULL,
  831. completed_op_qty DECIMAL(18,6) NULL,
  832. schedule_cycle_days DECIMAL(18,6) NULL,
  833. schedule_satisfaction_flag TINYINT NOT NULL DEFAULT 0,
  834. wip_qty DECIMAL(18,6) NULL,
  835. resource_person_count DECIMAL(18,6) NULL,
  836. calc_batch_id VARCHAR(100) NOT NULL,
  837. calc_time DATETIME NOT NULL,
  838. update_time DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  839. UNIQUE KEY uk_dwd_order_schedule_trans (tenant_id, work_order, calc_batch_id),
  840. KEY idx_dwd_order_schedule_trans_batch (calc_batch_id),
  841. KEY idx_dwd_order_schedule_trans_stat (tenant_id, stat_date),
  842. KEY idx_dwd_order_schedule_trans_order (tenant_id, sales_order_no)
  843. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='S2订单工单排程DWD';
  844. """,
  845. """
  846. INSERT INTO mdp_entity
  847. (tenant_id, source_id, entity_code, entity_name, entity_type, source_table_name, target_table_name, sync_mode, batch_size, status, remark)
  848. SELECT 0, s.id, v.entity_code, v.entity_name, 'TABLE', v.source_table_name, 'mdp_stg_schedule', 'FULL', 5000, 1, v.remark
  849. FROM mdp_source s
  850. JOIN (
  851. SELECT 'S2_WORK_ORDER_MASTER' AS entity_code, 'S2工单主数据' AS entity_name, 'WorkOrdMaster' AS source_table_name, '工单主数据进入 S2 贴源层' AS remark
  852. UNION ALL SELECT 'S2_WORK_ORDER_ROUTING', 'S2工单工艺路线', 'WorkOrdRouting', '工单工艺路线进入 S2 贴源层'
  853. UNION ALL SELECT 'S2_WORK_ORDER_DETAIL', 'S2工单物料明细', 'WorkOrdDetail', '工单物料需求进入 S2 贴源层'
  854. UNION ALL SELECT 'S2_PERIOD_SEQUENCE_DET', 'S2工序排程计划', 'PeriodSequenceDet', '工序间衔接与排程计划进入 S2 贴源层'
  855. UNION ALL SELECT 'S2_SCHEDULE_RESULT_OP', 'S2工序排产结果', 'ScheduleResultOpMaster', '工序排产结果进入 S2 贴源层'
  856. ) v
  857. WHERE s.tenant_id=0 AND s.source_code='AIDOPDEV_MYSQL'
  858. ON DUPLICATE KEY UPDATE
  859. source_id=VALUES(source_id), entity_name=VALUES(entity_name), entity_type=VALUES(entity_type),
  860. source_table_name=VALUES(source_table_name), target_table_name=VALUES(target_table_name),
  861. sync_mode=VALUES(sync_mode), batch_size=VALUES(batch_size), status=VALUES(status),
  862. remark=VALUES(remark), update_time=CURRENT_TIMESTAMP;
  863. """
  864. };
  865. }