asin榜单数据修复

Pyspark_job/doris_handle/dwt_flow_asin_month.py

@@ -381,8 +381,7 @@ LEFT JOIN `selection`.`user_mask_category` umc ON f.category_id = umc.category_i
 LEFT JOIN (
     SELECT asin, asin_cate_flag, bsr_latest_date, bsr_30day_count, nsr_latest_date, nsr_30day_count
     FROM `dwd`.`dwd_asin_source_flag`
-    WHERE date_info = (SELECT MAX(date_info) FROM `dwd`.`dwd_asin_source_flag` WHERE site_name = '{site_name}')
-      AND site_name = '{site_name}'
+    WHERE site_name = '{site_name}' AND date_type = 'month' AND date_info = '{date_info}'
 ) cf ON f.asin = cf.asin
 LEFT JOIN `dwd`.`dwd_asin_auction` aa ON f.asin = aa.asin
 WHERE f.date_info = '{date_info}'