1.0.277.sql 1.4 KB

1234567891011121314151617181920212223
  1. -- 1.0.277:S5_L1_002 物料上线满足率 中台化 —— 启用 2 个报表/明细 VIEW 的 FULL 贴源。
  2. -- 背景:S5_L1_002 原直连 t8_v5(Cj_Bg_Head_Rep 按 noid 取 min(kgdate) 开工时间 / kc_dd_list_cllist 分母行数)。
  3. -- 本批把这 2 张 VIEW 从"占位登记 sync_mode=NONE、target=NULL"启用为 FULL 贴源,指向 mdp_stg_t8_*
  4. -- (stg/std 建表 + mdp_std_t8_kc_tz_head 补 lynoid 列,由 T8BaseInboundMdpSyncService.EnsureTablesAsync 幂等处理)。
  5. -- biz_key:行级 Id(实测 count(*)==count(distinct Id):Cj_Bg_Head_Rep 5/5、kc_dd_list_cllist 29/29 唯一)。
  6. -- 注意不沿用同源 S6_REPORT 的 biz_key_expr='noid,kgdate'(实测 noid、(noid,kgdate) 均会撞行:Id=4/5 同 noid 同 kgdate)。
  7. -- 幂等:可重复执行;按 entity_code 过滤,不触碰同源的 S6_REPORT / S6_REPORT_API。
  8. UPDATE mdp_entity e
  9. JOIN mdp_source s ON s.id = e.source_id AND s.source_code = 'T8_V5_SQLSERVER'
  10. SET
  11. e.target_table_name = CASE e.entity_code
  12. WHEN 'T8_CJ_BG_HEAD_REP' THEN 'mdp_stg_t8_cj_bg_head_rep'
  13. WHEN 'T8_KC_DD_LIST_CLLIST' THEN 'mdp_stg_t8_kc_dd_list_cllist'
  14. END,
  15. e.sync_mode = 'FULL',
  16. e.incr_column = NULL,
  17. e.batch_size = 1000,
  18. e.biz_key_expr = 'Id',
  19. e.status = 1,
  20. e.remark = CONCAT(IFNULL(e.remark,''), ' | S5_L1_002-MDP: FULL 贴源启用,biz_key=Id 行级'),
  21. e.update_time = NOW()
  22. WHERE e.entity_code IN ('T8_CJ_BG_HEAD_REP','T8_KC_DD_LIST_CLLIST');