1.0.109.sql 3.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. -- 1.0.109.sql
  2. -- S8-DEPT-MASTER-EXPAND-AND-BACKFILL-1
  3. -- 1) 为 factory_ref_id=1(Domain='S8-DEMO-F1')新增 4 个部门:订单管理部 / 技术设计部 / 采购部 / 物料仓储部;
  4. -- 2) 把现有 16 条 ORDER_FLOW_KPI_OVERTIME_DERIVED 派生异常的责任部门按 order_flow_code 重新映射,
  5. -- 让"未归属"从 D-UNASSIGNED 重新分散到 4 个明确部门,消除 S8 部门卡全部落 D-UNASSIGNED 的演示问题。
  6. -- 执行入口:AutoVersionUpdate.UseAutoVersionUpdate(),在 csproj Version=1.0.109 主节点首次启动时触发。
  7. -- 幂等性:
  8. -- * 部门 INSERT ... ON DUPLICATE KEY UPDATE 走 (tenant_id, Domain, Department) 唯一键;
  9. -- * 异常 UPDATE 是按 CASE 重新映射,重复执行结果一致(CASE 命中相同 RecID);
  10. -- * 与 1.0.105/1.0.106 风格保持一致。
  11. -- 安全边界:不改 stage_code / order_flow_code / exception_type_code / severity / status;
  12. -- 不动 source_rule_code 非 ORDER_FLOW_KPI_OVERTIME_DERIVED 的行;不动 is_deleted=1 的软删行。
  13. -- 2026-05-16
  14. -- 1) Upsert 4 个新部门(factory_ref_id=1 / Domain='S8-DEMO-F1' / tenant_id 与现有 D-PROD 等保持一致)
  15. INSERT INTO DepartmentMaster
  16. (company_ref_id, factory_ref_id, tenant_id, Domain, Department, Descr, IsActive, CreateTime, CreateUser)
  17. SELECT 1, 1, 797403760988229, 'S8-DEMO-F1', seed.code, seed.descr, 1, NOW(), 's8-dept-master-expand-1'
  18. FROM (
  19. SELECT 'D-ORDER-MGMT' AS code, '订单管理部' AS descr
  20. UNION ALL SELECT 'D-TECH-DESIGN', '技术设计部'
  21. UNION ALL SELECT 'D-PURCHASE', '采购部'
  22. UNION ALL SELECT 'D-WAREHOUSE', '物料仓储部'
  23. ) seed
  24. ON DUPLICATE KEY UPDATE
  25. Descr = VALUES(Descr),
  26. IsActive = 1,
  27. UpdateTime = NOW(),
  28. UpdateUser = 's8-dept-master-expand-1';
  29. -- 2) 回填 16 条 ORDER_FLOW KPI 派生异常的责任/发生部门
  30. -- 映射协议:
  31. -- ORDER_REVIEW_PLAN_CALC → D-ORDER-MGMT (订单评审/排产/测算 = 订单管理部)
  32. -- PRODUCT_DESIGN → D-TECH-DESIGN (产品设计 = 技术设计部)
  33. -- MATERIAL_PURCHASE → D-PURCHASE (材料采购 = 采购部)
  34. -- BODY_PRODUCTION → D-PROD (本体生产 = 生产部,保持不变)
  35. -- FINAL_ASSEMBLY_DELIVERY → D-PROD (总装发货 = 生产部,保持不变)
  36. -- JOIN 按 factory_ref_id 对齐(DB 中 dept.tenant_id=797403760988229 与 exception.tenant_id=1 历史不一致,
  37. -- 与现有 S8MonitoringService 部门水合口径一致:只看 factory_ref_id 和 RecID)。
  38. UPDATE ado_s8_exception e
  39. JOIN DepartmentMaster d
  40. ON d.Department = CASE e.order_flow_code
  41. WHEN 'ORDER_REVIEW_PLAN_CALC' THEN 'D-ORDER-MGMT'
  42. WHEN 'PRODUCT_DESIGN' THEN 'D-TECH-DESIGN'
  43. WHEN 'MATERIAL_PURCHASE' THEN 'D-PURCHASE'
  44. WHEN 'BODY_PRODUCTION' THEN 'D-PROD'
  45. WHEN 'FINAL_ASSEMBLY_DELIVERY' THEN 'D-PROD'
  46. END
  47. AND d.factory_ref_id = e.factory_id
  48. AND d.IsActive = 1
  49. SET e.responsible_dept_id = d.RecID,
  50. e.occurrence_dept_id = d.RecID,
  51. e.updated_at = NOW(),
  52. e.updated_by = 'system:s8_dept_master_expand_backfill'
  53. WHERE e.is_deleted = 0
  54. AND e.source_rule_code = 'ORDER_FLOW_KPI_OVERTIME_DERIVED';
  55. -- 验证 SQL(注释,仅人工核对,脚本本身不依赖 SELECT 结果):
  56. -- SELECT Department, Descr, IsActive FROM DepartmentMaster
  57. -- WHERE Department IN ('D-ORDER-MGMT','D-TECH-DESIGN','D-PURCHASE','D-WAREHOUSE') AND factory_ref_id=1;
  58. -- SELECT e.order_flow_code, d.Department, COUNT(*) FROM ado_s8_exception e
  59. -- LEFT JOIN DepartmentMaster d ON d.RecID=e.responsible_dept_id
  60. -- WHERE e.is_deleted=0 AND e.source_rule_code='ORDER_FLOW_KPI_OVERTIME_DERIVED'
  61. -- GROUP BY e.order_flow_code, d.Department;