fix

Pyspark_job/doris_handle/dws_flow_asin_month_refresh.py

@@ -8,7 +8,7 @@ description: 流量选品月物化表刷新脚本——批量刷新近 3 月 sel
               1) MySQL workflow_everyday.MAX(report_date) WHERE date_type='month' AND page='流量选品' → 取最大月份
               2) 从最大月份向前推 3 月(含当月)→ 得到 3 个 date_info
               3) 站点列表(SITES)枚举 × 近 3 月,循环执行 INSERT OVERWRITE
-              4) INSERT OVERWRITE SQL 复用 dwt_flow_asin_month.build_insert_overwrite_sql
+              4) INSERT OVERWRITE SQL 复用 dwt_flow_asin_month.build_month_insert_overwrite_sql
              【无入参】
               不接收 sys.argv,所有逻辑动态推断;海豚定时调度直接执行 spark-submit 即可
 执行示例:
@@ -26,7 +26,7 @@ from utils.db_util import DBUtil
 
 from doris_handle.dwt_flow_asin_month import (
     _exec_doris_sql,
-    build_insert_overwrite_sql,
+    build_month_insert_overwrite_sql,
 )
 
 
@@ -68,7 +68,7 @@ def refresh_one_month(site_name, date_info):
     print(f"\n========== 刷新 site={site_name}, date_info={date_info}, table=selection.{selection_table} ==========")
 
     print(f"[执行] Doris INSERT OVERWRITE selection.{selection_table}")
-    _exec_doris_sql([build_insert_overwrite_sql(site_name, selection_table, date_info)])
+    _exec_doris_sql([build_month_insert_overwrite_sql(site_name, selection_table, date_info)])
 
     print(f"[完成] selection.{selection_table} 刷新成功")