信息库、周期性、季节性增加用户自定义修改功能

Pyspark_job/doris_handle/dwt_flow_asin_month.py

@@ -975,20 +975,20 @@ SELECT
     f.title_matching_degree,
     bb.brand_badge_reason,
     ARRAY_JOIN(ARRAY_SLICE(SPLIT_BY_STRING(stem_en(f.title), ' '), 1, 15), ' ') AS title_stem_15,
-    ai.ai_package_quantity,
-    ai.ai_package_quantity_arr,
-    ai.ai_material,
-    ai.ai_color,
-    ai.ai_appearance,
-    ai.ai_size,
-    ai.ai_shape,
-    ai.ai_function,
-    ai.ai_scene_title,
-    ai.ai_scene_comment,
-    ai.ai_uses,
-    ai.ai_theme,
-    ai.ai_crowd,
-    ai.ai_short_desc,
+    COALESCE(uma.ai_package_quantity, ai.ai_package_quantity) AS ai_package_quantity,
+    COALESCE(uma.ai_package_quantity_arr, ai.ai_package_quantity_arr) AS ai_package_quantity_arr,
+    COALESCE(uma.ai_material, ai.ai_material) AS ai_material,
+    COALESCE(uma.ai_color, ai.ai_color) AS ai_color,
+    COALESCE(uma.ai_appearance, ai.ai_appearance) AS ai_appearance,
+    COALESCE(uma.ai_size, ai.ai_size) AS ai_size,
+    COALESCE(uma.ai_shape, ai.ai_shape) AS ai_shape,
+    COALESCE(uma.ai_function, ai.ai_function) AS ai_function,
+    COALESCE(uma.ai_scene_title, ai.ai_scene_title) AS ai_scene_title,
+    COALESCE(uma.ai_scene_comment, ai.ai_scene_comment) AS ai_scene_comment,
+    COALESCE(uma.ai_uses, ai.ai_uses) AS ai_uses,
+    COALESCE(uma.ai_theme, ai.ai_theme) AS ai_theme,
+    COALESCE(uma.ai_crowd, ai.ai_crowd) AS ai_crowd,
+    COALESCE(uma.ai_short_desc, ai.ai_short_desc) AS ai_short_desc,
     addr.seller_province,
     addr.seller_city
 FROM `dwt`.`{site_name}_flow_asin_month` f
@@ -1398,20 +1398,20 @@ SELECT
     f.title_matching_degree,
     bb.brand_badge_reason,
     ARRAY_JOIN(ARRAY_SLICE(SPLIT_BY_STRING(stem_en(f.title), ' '), 1, 15), ' ') AS title_stem_15,
-    ai.ai_package_quantity,
-    ai.ai_package_quantity_arr,
-    ai.ai_material,
-    ai.ai_color,
-    ai.ai_appearance,
-    ai.ai_size,
-    ai.ai_shape,
-    ai.ai_function,
-    ai.ai_scene_title,
-    ai.ai_scene_comment,
-    ai.ai_uses,
-    ai.ai_theme,
-    ai.ai_crowd,
-    ai.ai_short_desc,
+    COALESCE(uma.ai_package_quantity, ai.ai_package_quantity) AS ai_package_quantity,
+    COALESCE(uma.ai_package_quantity_arr, ai.ai_package_quantity_arr) AS ai_package_quantity_arr,
+    COALESCE(uma.ai_material, ai.ai_material) AS ai_material,
+    COALESCE(uma.ai_color, ai.ai_color) AS ai_color,
+    COALESCE(uma.ai_appearance, ai.ai_appearance) AS ai_appearance,
+    COALESCE(uma.ai_size, ai.ai_size) AS ai_size,
+    COALESCE(uma.ai_shape, ai.ai_shape) AS ai_shape,
+    COALESCE(uma.ai_function, ai.ai_function) AS ai_function,
+    COALESCE(uma.ai_scene_title, ai.ai_scene_title) AS ai_scene_title,
+    COALESCE(uma.ai_scene_comment, ai.ai_scene_comment) AS ai_scene_comment,
+    COALESCE(uma.ai_uses, ai.ai_uses) AS ai_uses,
+    COALESCE(uma.ai_theme, ai.ai_theme) AS ai_theme,
+    COALESCE(uma.ai_crowd, ai.ai_crowd) AS ai_crowd,
+    COALESCE(uma.ai_short_desc, ai.ai_short_desc) AS ai_short_desc,
     addr.seller_province,
     addr.seller_city,
     -- ===== 年度聚合（dwt/dwt_flow_asin_year.py 在 Hive 预计算，经 sync_extra_table 同步到 Doris）=====
@@ -1426,8 +1426,8 @@ SELECT
     COALESCE(agg.nsr_seen_count_total, 0) AS nsr_seen_count_total,
     agg.bought_month_peak,
     agg.peak_month_arr,
-    COALESCE(agg.is_periodic_flag, 0) AS is_periodic_flag,
-    COALESCE(agg.is_seasonal_flag, 0) AS is_seasonal_flag
+    COALESCE(uma.is_periodic_flag, agg.is_periodic_flag, 0) AS is_periodic_flag,
+    COALESCE(uma.is_seasonal_flag, agg.is_seasonal_flag, 0) AS is_seasonal_flag
 FROM `dwt`.`{site_name}_flow_asin_365day` f
 LEFT JOIN `dwt`.`{site_name}_flow_asin_365day_extra` agg ON f.asin = agg.asin
 -- ===== 利润率 =====