feat(backfill): 7 张 ods 表 init SQL（单源全表扫）

manual/backfill/20260507_{cgi/abu/auci/tmi/pcbi/pcvc/cbi}_inc_d_init.sql × 7：
单源 raw 全表扫 + DATE(update_time) 归位 + (id, ods_dt) dedupe + 动态分区。
顶部 SET max.dynamic.partitions=2000 / pernode=200（各表跨多年 dt 撞默认 1000）。
跑完后由 jobs/ods/<域>/<表>_inc_d.sql 接管日常增量。
DS 工作流批量创建脚本另落 workspace/20260507/（不入仓）。

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

manual/backfill/20260507_ods_prd_checklist_base_info_inc_d_init.sql

@@ -0,0 +1,64 @@
+-- 作者：tianyu.chu
+-- 日期：2026-05-07
+-- 工单：(无)
+-- 目的：ods_prd_checklist_base_info ods 初始化一次性灌入：raw 单表全部历史 dt → DATE(update_time) 归位 → ods 各 dt 分区
+-- 状态：[待执行]
+-- 备注：跑一次后由 jobs/ods/prd/ods_prd_checklist_base_info_inc_d.sql 接管日常增量；
+--       update_time 为空的行落入 __HIVE_DEFAULT_PARTITION__（非阻塞，下游自行处理）
+
+-- 动态分区上限：本表跨多年 dt 撞 hive 默认 1000/100。
+-- pernode 指 Spark task 节点（spark.sql.shuffle.partitions=200）不是物理 worker。
+-- 仅 init 场景需要，日常调度写 1 个 dt 不撞，故只在本 SQL 内 SET 不入 conf 默认。
+set hive.exec.max.dynamic.partitions=2000;
+set hive.exec.max.dynamic.partitions.pernode=200;
+
+INSERT OVERWRITE TABLE ods.ods_prd_checklist_base_info_inc_d PARTITION (dt)
+SELECT
+    CAST(id                AS BIGINT)    AS id,
+    code                                 AS code,
+    year                                 AS year,
+    sport                                AS sport,
+    manufacturer                         AS manufacturer,
+    sets                                 AS sets,
+    display_name                         AS display_name,
+    type                                 AS type,
+    CAST(num               AS BIGINT)    AS num,
+    CAST(use_num           AS BIGINT)    AS use_num,
+    CAST(status            AS BIGINT)    AS status,
+    remark                               AS remark,
+    CAST(create_time       AS TIMESTAMP) AS create_time,
+    create_by                            AS create_by,
+    CAST(update_time       AS TIMESTAMP) AS update_time,
+    update_by                            AS update_by,
+    CAST(lot               AS BIGINT)    AS lot,
+    CAST(del_flg           AS BIGINT)    AS del_flg,
+    act_point_type                       AS act_point_type,
+    CAST(parent_id         AS BIGINT)    AS parent_id,
+    sets_version                         AS sets_version,
+    CAST(merchant_id       AS BIGINT)    AS merchant_id,
+    merchant_name                        AS merchant_name,
+    CAST(share             AS BIGINT)    AS share,
+    share_to_merchant                    AS share_to_merchant,
+    CAST(custom            AS BIGINT)    AS custom,
+    CAST(panini_config_id  AS BIGINT)    AS panini_config_id,
+    import_failure_cause                 AS import_failure_cause,
+    check_failure_cause                  AS check_failure_cause,
+    CAST(import_status     AS BIGINT)    AS import_status,
+    review_msg                           AS review_msg,
+    sub_type                             AS sub_type,
+    title                                AS title,
+    data_version                         AS data_version,
+    CAST(sport_blend       AS BIGINT)    AS sport_blend,
+    display_name_translations            AS display_name_translations,
+    CASE WHEN del_flg = '1' THEN TRUE ELSE FALSE END AS is_deleted,
+    ods_dt                               AS dt
+FROM (
+    SELECT *,
+        DATE_FORMAT(update_time, 'yyyyMMdd') AS ods_dt,
+        ROW_NUMBER() OVER (
+            PARTITION BY id, DATE_FORMAT(update_time, 'yyyyMMdd')
+            ORDER BY update_time DESC
+        ) AS rn
+    FROM raw.raw_prd_checklist_base_info_inc_d
+) t
+WHERE t.rn = 1;

manual/backfill/20260507_ods_prd_panini_checklist_base_info_inc_d_init.sql

@@ -0,0 +1,61 @@
+-- 作者：tianyu.chu
+-- 日期：2026-05-07
+-- 工单：(无)
+-- 目的：ods_prd_panini_checklist_base_info ods 初始化一次性灌入：raw 单表全部历史 dt → DATE(update_time) 归位 → ods 各 dt 分区
+-- 状态：[待执行]
+-- 备注：跑一次后由 jobs/ods/prd/ods_prd_panini_checklist_base_info_inc_d.sql 接管日常增量；
+--       update_time 为空的行落入 __HIVE_DEFAULT_PARTITION__（非阻塞，下游自行处理）
+
+-- 动态分区上限：本表跨多年 dt 撞 hive 默认 1000/100。
+-- pernode 指 Spark task 节点（spark.sql.shuffle.partitions=200）不是物理 worker。
+-- 仅 init 场景需要，日常调度写 1 个 dt 不撞，故只在本 SQL 内 SET 不入 conf 默认。
+set hive.exec.max.dynamic.partitions=2000;
+set hive.exec.max.dynamic.partitions.pernode=200;
+
+INSERT OVERWRITE TABLE ods.ods_prd_panini_checklist_base_info_inc_d PARTITION (dt)
+SELECT
+    CAST(id                 AS BIGINT)        AS id,
+    code                                      AS code,
+    year                                      AS year,
+    sport                                     AS sport,
+    manufacturer                              AS manufacturer,
+    sets                                      AS sets,
+    sets_version                              AS sets_version,
+    display_name                              AS display_name,
+    type                                      AS type,
+    CAST(num                AS BIGINT)        AS num,
+    CAST(use_num            AS BIGINT)        AS use_num,
+    CAST(status             AS BIGINT)        AS status,
+    remark                                    AS remark,
+    CAST(lot                AS BIGINT)        AS lot,
+    CAST(del_flg            AS BIGINT)        AS del_flg,
+    carmichael_img_type                       AS carmichael_img_type,
+    CAST(create_time        AS TIMESTAMP)     AS create_time,
+    create_by                                 AS create_by,
+    CAST(update_time        AS TIMESTAMP)     AS update_time,
+    update_by                                 AS update_by,
+    import_type                               AS import_type,
+    CAST(report_flag        AS BIGINT)        AS report_flag,
+    base_config                               AS base_config,
+    CAST(base_price         AS DECIMAL(20,4)) AS base_price,
+    CAST(min_reference_price AS DECIMAL(20,4)) AS min_reference_price,
+    CAST(max_reference_price AS DECIMAL(20,4)) AS max_reference_price,
+    prop1                                     AS prop1,
+    prop2                                     AS prop2,
+    prop3                                     AS prop3,
+    prop4                                     AS prop4,
+    data_version                              AS data_version,
+    first_sport                               AS first_sport,
+    sets_display_name                         AS sets_display_name,
+    CASE WHEN del_flg = '1' THEN TRUE ELSE FALSE END AS is_deleted,
+    ods_dt                                    AS dt
+FROM (
+    SELECT *,
+        DATE_FORMAT(update_time, 'yyyyMMdd') AS ods_dt,
+        ROW_NUMBER() OVER (
+            PARTITION BY id, DATE_FORMAT(update_time, 'yyyyMMdd')
+            ORDER BY update_time DESC
+        ) AS rn
+    FROM raw.raw_prd_panini_checklist_base_info_inc_d
+) t
+WHERE t.rn = 1;

manual/backfill/20260507_ods_prd_panini_checklist_version_config_inc_d_init.sql

@@ -0,0 +1,61 @@
+-- 作者：tianyu.chu
+-- 日期：2026-05-07
+-- 工单：(无)
+-- 目的：ods_prd_panini_checklist_version_config ods 初始化一次性灌入：raw 单表全部历史 dt → DATE(update_time) 归位 → ods 各 dt 分区
+-- 状态：[待执行]
+-- 备注：跑一次后由 jobs/ods/prd/ods_prd_panini_checklist_version_config_inc_d.sql 接管日常增量；
+--       update_time 为空的行落入 __HIVE_DEFAULT_PARTITION__（非阻塞，下游自行处理）
+
+-- 动态分区上限：本表跨多年 dt 撞 hive 默认 1000/100。
+-- pernode 指 Spark task 节点（spark.sql.shuffle.partitions=200）不是物理 worker。
+-- 仅 init 场景需要，日常调度写 1 个 dt 不撞，故只在本 SQL 内 SET 不入 conf 默认。
+set hive.exec.max.dynamic.partitions=2000;
+set hive.exec.max.dynamic.partitions.pernode=200;
+
+INSERT OVERWRITE TABLE ods.ods_prd_panini_checklist_version_config_inc_d PARTITION (dt)
+SELECT
+    CAST(id                  AS BIGINT)        AS id,
+    CAST(panini_list_id      AS BIGINT)        AS panini_list_id,
+    set_version                                AS set_version,
+    carmichael_img_type                        AS carmichael_img_type,
+    import_type                                AS import_type,
+    CAST(report_flag         AS BIGINT)        AS report_flag,
+    base_config                                AS base_config,
+    CAST(base_price          AS DECIMAL(20,4)) AS base_price,
+    CAST(min_reference_price AS DECIMAL(20,4)) AS min_reference_price,
+    CAST(max_reference_price AS DECIMAL(20,4)) AS max_reference_price,
+    CAST(num                 AS BIGINT)        AS num,
+    CAST(use_num             AS BIGINT)        AS use_num,
+    CAST(status              AS BIGINT)        AS status,
+    remark                                     AS remark,
+    CAST(del_flg             AS BIGINT)        AS del_flg,
+    CAST(create_time         AS TIMESTAMP)     AS create_time,
+    create_by                                  AS create_by,
+    CAST(update_time         AS TIMESTAMP)     AS update_time,
+    update_by                                  AS update_by,
+    prop1                                      AS prop1,
+    prop2                                      AS prop2,
+    prop3                                      AS prop3,
+    prop4                                      AS prop4,
+    tag                                        AS tag,
+    display_name                               AS display_name,
+    CAST(presale_time        AS TIMESTAMP)     AS presale_time,
+    CAST(max_box             AS BIGINT)        AS max_box,
+    league                                     AS league,
+    CAST(issuing_time        AS TIMESTAMP)     AS issuing_time,
+    CAST(issuing_price       AS DECIMAL(20,4)) AS issuing_price,
+    display_name_translations                  AS display_name_translations,
+    CAST(sale_time           AS TIMESTAMP)     AS sale_time,
+    CAST(open_time           AS BIGINT)        AS open_time,
+    CASE WHEN del_flg = '1' THEN TRUE ELSE FALSE END AS is_deleted,
+    ods_dt                                     AS dt
+FROM (
+    SELECT *,
+        DATE_FORMAT(update_time, 'yyyyMMdd') AS ods_dt,
+        ROW_NUMBER() OVER (
+            PARTITION BY id, DATE_FORMAT(update_time, 'yyyyMMdd')
+            ORDER BY update_time DESC
+        ) AS rn
+    FROM raw.raw_prd_panini_checklist_version_config_inc_d
+) t
+WHERE t.rn = 1;

manual/backfill/20260507_ods_shp_tzy_merchant_info_inc_d_init.sql

@@ -0,0 +1,78 @@
+-- 作者：tianyu.chu
+-- 日期：2026-05-07
+-- 工单：(无)
+-- 目的：ods_shp_tzy_merchant_info ods 初始化一次性灌入：raw 单表全部历史 dt → DATE(update_time) 归位 → ods 各 dt 分区
+-- 状态：[待执行]
+-- 备注：跑一次后由 jobs/ods/shp/ods_shp_tzy_merchant_info_inc_d.sql 接管日常增量；
+--       update_time 为空的行落入 __HIVE_DEFAULT_PARTITION__（非阻塞，下游自行处理）
+
+-- 动态分区上限：本表跨多年 dt 撞 hive 默认 1000/100。
+-- pernode 指 Spark task 节点（spark.sql.shuffle.partitions=200）不是物理 worker。
+-- 仅 init 场景需要，日常调度写 1 个 dt 不撞，故只在本 SQL 内 SET 不入 conf 默认。
+set hive.exec.max.dynamic.partitions=2000;
+set hive.exec.max.dynamic.partitions.pernode=200;
+
+INSERT OVERWRITE TABLE ods.ods_shp_tzy_merchant_info_inc_d PARTITION (dt)
+SELECT
+    CAST(id                  AS BIGINT)    AS id,
+    appid                                  AS appid,
+    CAST(user_id             AS BIGINT)    AS user_id,
+    username                               AS username,
+    name                                   AS name,
+    CAST(status              AS BIGINT)    AS status,
+    remark                                 AS remark,
+    create_by                              AS create_by,
+    CAST(create_time         AS TIMESTAMP) AS create_time,
+    update_by                              AS update_by,
+    CAST(update_time         AS TIMESTAMP) AS update_time,
+    code                                   AS code,
+    CAST(fans                AS BIGINT)    AS fans,
+    CAST(sale_num            AS BIGINT)    AS sale_num,
+    CAST(applet_auth         AS BOOLEAN)   AS applet_auth,
+    CAST(applet_lives_auth   AS BOOLEAN)   AS applet_lives_auth,
+    applet_lives_role                      AS applet_lives_role,
+    commission_rate                        AS commission_rate,
+    prop_json                              AS prop_json,
+    CAST(sort_rate           AS BIGINT)    AS sort_rate,
+    CAST(check_status        AS BIGINT)    AS check_status,
+    live_type                              AS live_type,
+    living_auth_config                     AS living_auth_config,
+    CAST(goods_sold_num      AS BIGINT)    AS goods_sold_num,
+    hot_config                             AS hot_config,
+    tag_config                             AS tag_config,
+    CAST(mall_role           AS BIGINT)    AS mall_role,
+    living_time                            AS living_time,
+    express_level                          AS express_level,
+    CAST(del_flg             AS BIGINT)    AS del_flg,
+    group_show_name                        AS group_show_name,
+    main_business                          AS main_business,
+    CAST(min_card_num        AS BIGINT)    AS min_card_num,
+    dy_name                                AS dy_name,
+    CAST(current_month_score AS DOUBLE)    AS current_month_score,
+    CAST(member_level        AS BIGINT)    AS member_level,
+    member_name                            AS member_name,
+    member_medal                           AS member_medal,
+    CAST(prefer_valid_time   AS TIMESTAMP) AS prefer_valid_time,
+    tag_id                                 AS tag_id,
+    CAST(show_status         AS BIGINT)    AS show_status,
+    point_type                             AS point_type,
+    CAST(refund_limit_day    AS BIGINT)    AS refund_limit_day,
+    CAST(open_act_discount   AS BIGINT)    AS open_act_discount,
+    CAST(reputation_score    AS BIGINT)    AS reputation_score,
+    CAST(hide_stock          AS BIGINT)    AS hide_stock,
+    CAST(version             AS BIGINT)    AS version,
+    CAST(total_sold_num      AS BIGINT)    AS total_sold_num,
+    shipping_cost_config                   AS shipping_cost_config,
+    CAST(merchant_group_id   AS BIGINT)    AS merchant_group_id,
+    CASE WHEN del_flg = '1' THEN TRUE ELSE FALSE END AS is_deleted,
+    ods_dt                                 AS dt
+FROM (
+    SELECT *,
+        DATE_FORMAT(update_time, 'yyyyMMdd') AS ods_dt,
+        ROW_NUMBER() OVER (
+            PARTITION BY id, DATE_FORMAT(update_time, 'yyyyMMdd')
+            ORDER BY update_time DESC
+        ) AS rn
+    FROM raw.raw_shp_tzy_merchant_info_inc_d
+) t
+WHERE t.rn = 1;

manual/backfill/20260507_ods_trd_card_group_info_inc_d_init.sql

@@ -0,0 +1,143 @@
+-- 作者：tianyu.chu
+-- 日期：2026-05-07
+-- 工单：(无)
+-- 目的：ods_trd_card_group_info ods 初始化一次性灌入：raw 单表全部历史 dt → DATE(update_time) 归位 → ods 各 dt 分区
+-- 状态：[待执行]
+-- 备注：跑一次后由 jobs/ods/trd/ods_trd_card_group_info_inc_d.sql 接管日常增量；
+--       update_time 为空的行落入 __HIVE_DEFAULT_PARTITION__（非阻塞，下游自行处理）
+
+-- 动态分区上限：本表跨多年 dt 撞 hive 默认 1000/100。
+-- pernode 指 Spark task 节点（spark.sql.shuffle.partitions=200）不是物理 worker。
+-- 仅 init 场景需要，日常调度写 1 个 dt 不撞，故只在本 SQL 内 SET 不入 conf 默认。
+set hive.exec.max.dynamic.partitions=2000;
+set hive.exec.max.dynamic.partitions.pernode=200;
+
+INSERT OVERWRITE TABLE ods.ods_trd_card_group_info_inc_d PARTITION (dt)
+SELECT
+    CAST(id                           AS BIGINT)        AS id,
+    CAST(merchant_id                  AS BIGINT)        AS merchant_id,
+    appid                                               AS appid,
+    name                                                AS name,
+    code                                                AS code,
+    CAST(status                       AS BIGINT)        AS status,
+    specs                                               AS specs,
+    type                                                AS type,
+    random_type                                         AS random_type,
+    CAST(total_price                  AS DECIMAL(20,4)) AS total_price,
+    CAST(copies                       AS BIGINT)        AS copies,
+    CAST(unit_price                   AS DECIMAL(20,4)) AS unit_price,
+    CAST(sold_copies                  AS BIGINT)        AS sold_copies,
+    release_time                                        AS release_time,
+    cycle                                               AS cycle,
+    show_applet                                         AS show_applet,
+    title                                               AS title,
+    msg                                                 AS msg,
+    remark                                              AS remark,
+    CAST(create_time                  AS TIMESTAMP)     AS create_time,
+    update_by                                           AS update_by,
+    CAST(update_time                  AS TIMESTAMP)     AS update_time,
+    CAST(order_quota_min              AS BIGINT)        AS order_quota_min,
+    CAST(order_quota_max              AS BIGINT)        AS order_quota_max,
+    CAST(user_quota_max               AS BIGINT)        AS user_quota_max,
+    CAST(start_time                   AS TIMESTAMP)     AS start_time,
+    marketing_info                                      AS marketing_info,
+    reviewmsg                                           AS reviewmsg,
+    CAST(`lock`                       AS BOOLEAN)       AS `lock`,
+    commission_rate                                     AS commission_rate,
+    year                                                AS year,
+    sport                                               AS sport,
+    manufacturer                                        AS manufacturer,
+    sets                                                AS sets,
+    act                                                 AS act,
+    config                                              AS config,
+    info_config                                         AS info_config,
+    CAST(total_num                    AS BIGINT)        AS total_num,
+    CAST(banner_end_time              AS TIMESTAMP)     AS banner_end_time,
+    add_banner                                          AS add_banner,
+    CAST(finished_time                AS TIMESTAMP)     AS finished_time,
+    display_name                                        AS display_name,
+    CAST(group_sets_no                AS BIGINT)        AS group_sets_no,
+    CAST(close_payment_time           AS TIMESTAMP)     AS close_payment_time,
+    CAST(confirm_send_time            AS TIMESTAMP)     AS confirm_send_time,
+    CAST(close_payment_status         AS BIGINT)        AS close_payment_status,
+    CAST(open_card                    AS BIGINT)        AS open_card,
+    close_payment_record                                AS close_payment_record,
+    CAST(group_full_time              AS TIMESTAMP)     AS group_full_time,
+    CAST(live_create_time             AS TIMESTAMP)     AS live_create_time,
+    CAST(live_start_time              AS TIMESTAMP)     AS live_start_time,
+    CAST(live_end_time                AS TIMESTAMP)     AS live_end_time,
+    CAST(report_start_time            AS TIMESTAMP)     AS report_start_time,
+    CAST(report_end_time              AS TIMESTAMP)     AS report_end_time,
+    CAST(report_review_num            AS BIGINT)        AS report_review_num,
+    CAST(report_review_first_time     AS TIMESTAMP)     AS report_review_first_time,
+    CAST(report_review_end_time       AS TIMESTAMP)     AS report_review_end_time,
+    CAST(review_hold_time             AS TIMESTAMP)     AS review_hold_time,
+    CAST(review_approval_time         AS TIMESTAMP)     AS review_approval_time,
+    CAST(review_num                   AS BIGINT)        AS review_num,
+    config_json                                         AS config_json,
+    CAST(free_flag                    AS BIGINT)        AS free_flag,
+    mer_name                                            AS mer_name,
+    change_type                                         AS change_type,
+    CAST(act_price                    AS DECIMAL(20,4)) AS act_price,
+    act_config_json                                     AS act_config_json,
+    CAST(real_sold_num                AS BIGINT)        AS real_sold_num,
+    CAST(weight                       AS BIGINT)        AS weight,
+    hot_type                                            AS hot_type,
+    CAST(team_first                   AS BIGINT)        AS team_first,
+    prop1                                               AS prop1,
+    prop2                                               AS prop2,
+    prop3                                               AS prop3,
+    CAST(point_rate                   AS BIGINT)        AS point_rate,
+    CAST(point_max                    AS BIGINT)        AS point_max,
+    CAST(point_min                    AS BIGINT)        AS point_min,
+    CAST(list_id                      AS BIGINT)        AS list_id,
+    list_code                                           AS list_code,
+    CAST(mix_copies                   AS BIGINT)        AS mix_copies,
+    sub_type                                            AS sub_type,
+    act_point_type                                      AS act_point_type,
+    CAST(payment_method               AS BIGINT)        AS payment_method,
+    CAST(payment_total_price          AS DECIMAL(20,4)) AS payment_total_price,
+    CAST(payment_commission           AS DECIMAL(20,4)) AS payment_commission,
+    CAST(payment_finished_price       AS DECIMAL(20,4)) AS payment_finished_price,
+    CAST(payment_remain_price         AS DECIMAL(20,4)) AS payment_remain_price,
+    CAST(payment_online_price         AS DECIMAL(20,4)) AS payment_online_price,
+    CAST(exclusive                    AS BIGINT)        AS exclusive,
+    CAST(has_bg                       AS BIGINT)        AS has_bg,
+    CAST(merchant_sort                AS BIGINT)        AS merchant_sort,
+    CAST(del_flg                      AS BIGINT)        AS del_flg,
+    CAST(del_time                     AS TIMESTAMP)     AS del_time,
+    review_account                                      AS review_account,
+    CAST(act_id                       AS BIGINT)        AS act_id,
+    CAST(sold_end_time                AS TIMESTAMP)     AS sold_end_time,
+    CAST(panini_list_id               AS BIGINT)        AS panini_list_id,
+    hot_type_config                                     AS hot_type_config,
+    CAST(goods_type                   AS BIGINT)        AS goods_type,
+    CAST(report_flag                  AS BIGINT)        AS report_flag,
+    CAST(use_coupon                   AS BIGINT)        AS use_coupon,
+    CAST(user_level                   AS BIGINT)        AS user_level,
+    CAST(custom                       AS BIGINT)        AS custom,
+    CAST(gift_card_id                 AS BIGINT)        AS gift_card_id,
+    group_show_name                                     AS group_show_name,
+    CAST(min_card_num                 AS BIGINT)        AS min_card_num,
+    act_type                                            AS act_type,
+    waring_type                                         AS waring_type,
+    CAST(compensation_status          AS BIGINT)        AS compensation_status,
+    point_type                                          AS point_type,
+    first_act_config                                    AS first_act_config,
+    gift_config                                         AS gift_config,
+    CAST(version                      AS BIGINT)        AS version,
+    extra_prop                                          AS extra_prop,
+    CAST(use_member_discount          AS BIGINT)        AS use_member_discount,
+    CAST(merchant_open                AS BIGINT)        AS merchant_open,
+    CASE WHEN del_flg = '1' THEN TRUE ELSE FALSE END    AS is_deleted,
+    ods_dt                                              AS dt
+FROM (
+    SELECT *,
+        DATE_FORMAT(update_time, 'yyyyMMdd') AS ods_dt,
+        ROW_NUMBER() OVER (
+            PARTITION BY id, DATE_FORMAT(update_time, 'yyyyMMdd')
+            ORDER BY update_time DESC
+        ) AS rn
+    FROM raw.raw_trd_card_group_info_inc_d
+) t
+WHERE t.rn = 1;

manual/backfill/20260507_ods_usr_app_base_user_inc_d_init.sql

@@ -0,0 +1,80 @@
+-- 作者：tianyu.chu
+-- 日期：2026-05-07
+-- 工单：(无)
+-- 目的：ods_usr_app_base_user ods 初始化一次性灌入：raw 单表全部历史 dt → DATE(update_time) 归位 → ods 各 dt 分区
+-- 状态：[待执行]
+-- 备注：跑一次后由 jobs/ods/usr/ods_usr_app_base_user_inc_d.sql 接管日常增量；
+--       update_time 为空的行落入 __HIVE_DEFAULT_PARTITION__（非阻塞，下游自行处理）
+
+-- 动态分区上限：本表跨多年 dt 撞 hive 默认 1000/100。
+-- pernode 指 Spark task 节点（spark.sql.shuffle.partitions=200）不是物理 worker。
+-- 仅 init 场景需要，日常调度写 1 个 dt 不撞，故只在本 SQL 内 SET 不入 conf 默认。
+set hive.exec.max.dynamic.partitions=2000;
+set hive.exec.max.dynamic.partitions.pernode=200;
+
+INSERT OVERWRITE TABLE ods.ods_usr_app_base_user_inc_d PARTITION (dt)
+SELECT
+    CAST(id                       AS BIGINT)        AS id,
+    appid                                           AS appid,
+    CAST(point                    AS BIGINT)        AS point,
+    CAST(level                    AS BIGINT)        AS level,
+    register_channel                                AS register_channel,
+    CAST(status                   AS BIGINT)        AS status,
+    CAST(del_flg                  AS BIGINT)        AS del_flg,
+    remark                                          AS remark,
+    create_by                                       AS create_by,
+    CAST(create_time              AS TIMESTAMP)     AS create_time,
+    update_by                                       AS update_by,
+    CAST(update_time              AS TIMESTAMP)     AS update_time,
+    username                                        AS username,
+    CAST(growth_num               AS BIGINT)        AS growth_num,
+    code                                            AS code,
+    CAST(notify_flag              AS BIGINT)        AS notify_flag,
+    CAST(user_id                  AS BIGINT)        AS user_id,
+    notify_type                                     AS notify_type,
+    CAST(face_verify              AS BIGINT)        AS face_verify,
+    CAST(open_psd                 AS BIGINT)        AS open_psd,
+    CAST(refuse_pick_up           AS BIGINT)        AS refuse_pick_up,
+    prop1                                           AS prop1,
+    prop2                                           AS prop2,
+    prop3                                           AS prop3,
+    prop4                                           AS prop4,
+    CAST(window_open              AS BIGINT)        AS window_open,
+    CAST(open_invoice             AS BIGINT)        AS open_invoice,
+    CAST(blacklist                AS BIGINT)        AS blacklist,
+    id_card                                         AS id_card,
+    CAST(member_level             AS BIGINT)        AS member_level,
+    member_name                                     AS member_name,
+    CAST(current_month_growth     AS BIGINT)        AS current_month_growth,
+    CAST(member_init_flag         AS BIGINT)        AS member_init_flag,
+    CAST(member_keep_growth       AS BIGINT)        AS member_keep_growth,
+    register_ip_addr                                AS register_ip_addr,
+    register_addr                                   AS register_addr,
+    login_ip_addr                                   AS login_ip_addr,
+    login_addr                                      AS login_addr,
+    CAST(notify_top_show          AS BIGINT)        AS notify_top_show,
+    CAST(voice_reminder           AS BIGINT)        AS voice_reminder,
+    CAST(vibrate_reminder         AS BIGINT)        AS vibrate_reminder,
+    CAST(consume_amount           AS DECIMAL(20,4)) AS consume_amount,
+    CAST(order_total_num          AS BIGINT)        AS order_total_num,
+    CAST(open_card_show           AS BIGINT)        AS open_card_show,
+    effects_type                                    AS effects_type,
+    live_config_json                                AS live_config_json,
+    CAST(cancel_verify_num        AS BIGINT)        AS cancel_verify_num,
+    CAST(version                  AS BIGINT)        AS version,
+    CAST(daily_limit              AS BIGINT)        AS daily_limit,
+    CAST(weekly_limit             AS BIGINT)        AS weekly_limit,
+    CAST(monthly_limit            AS BIGINT)        AS monthly_limit,
+    CAST(live_anonymous           AS BIGINT)        AS live_anonymous,
+    CASE WHEN del_flg = '1' THEN TRUE ELSE FALSE END AS is_deleted,
+    ods_dt                                          AS dt
+FROM (
+    SELECT *,
+        DATE_FORMAT(update_time, 'yyyyMMdd') AS ods_dt,
+        ROW_NUMBER() OVER (
+            PARTITION BY id, DATE_FORMAT(update_time, 'yyyyMMdd')
+            ORDER BY update_time DESC
+        ) AS rn
+    FROM raw.raw_usr_app_base_user_inc_d
+) t
+WHERE t.rn = 1;

manual/backfill/20260507_ods_usr_app_user_cert_info_inc_d_init.sql

@@ -0,0 +1,39 @@
+-- 作者：tianyu.chu
+-- 日期：2026-05-07
+-- 工单：(无)
+-- 目的：ods_usr_app_user_cert_info ods 初始化一次性灌入：raw 单表全部历史 dt → DATE(update_time) 归位 → ods 各 dt 分区
+-- 状态：[待执行]
+-- 备注：跑一次后由 jobs/ods/usr/ods_usr_app_user_cert_info_inc_d.sql 接管日常增量；
+--       update_time 为空的行落入 __HIVE_DEFAULT_PARTITION__（非阻塞，下游自行处理）
+
+-- 动态分区上限：本表跨多年 dt 撞 hive 默认 1000/100。
+-- pernode 指 Spark task 节点（spark.sql.shuffle.partitions=200）不是物理 worker。
+-- 仅 init 场景需要，日常调度写 1 个 dt 不撞，故只在本 SQL 内 SET 不入 conf 默认。
+set hive.exec.max.dynamic.partitions=2000;
+set hive.exec.max.dynamic.partitions.pernode=200;
+
+INSERT OVERWRITE TABLE ods.ods_usr_app_user_cert_info_inc_d PARTITION (dt)
+SELECT
+    CAST(id            AS BIGINT)    AS id,
+    CAST(user_id       AS BIGINT)    AS user_id,
+    CAST(cert_birthday AS TIMESTAMP) AS cert_birthday,
+    CAST(cert_sex      AS BIGINT)    AS cert_sex,
+    cert_province                    AS cert_province,
+    cert_city                        AS cert_city,
+    CAST(version       AS BIGINT)    AS version,
+    CAST(status        AS BIGINT)    AS status,
+    CAST(del_flag      AS BIGINT)    AS del_flag,
+    CAST(create_time   AS TIMESTAMP) AS create_time,
+    CAST(update_time   AS TIMESTAMP) AS update_time,
+    CASE WHEN del_flag = '1' THEN TRUE ELSE FALSE END AS is_deleted,
+    ods_dt                           AS dt
+FROM (
+    SELECT *,
+        DATE_FORMAT(update_time, 'yyyyMMdd') AS ods_dt,
+        ROW_NUMBER() OVER (
+            PARTITION BY id, DATE_FORMAT(update_time, 'yyyyMMdd')
+            ORDER BY update_time DESC
+        ) AS rn
+    FROM raw.raw_usr_app_user_cert_info_inc_d
+) t
+WHERE t.rn = 1;