新增me搜索词Christmas计算，引入month_aba_me分区

Pyspark_job/dim/dim_asin_amorders_info.py

@@ -37,7 +37,7 @@ class DimAsinAmordersInfo(Templates):
         # us month, month_week, 4_week, week
         # uk/de month, 4_week, week
         if self.site_name in ['us', 'uk', 'de']:
-            if self.date_type in ['month', 'month_week']:
+            if self.date_type in ['month', 'month_week', 'month_aba_me']:
                 if (self.site_name == 'us') or (self.site_name in ['uk', 'de'] and self.date_info >= '2024-05'):
                     params = f"date_type='{self.date_type}' and date_info = '{self.date_info}'"
                 else:

Pyspark_job/dim/dim_asin_detail.py

@@ -262,7 +262,7 @@ class DimAsinDetail(object):
 
     # 处理asin的变体信息
     def handle_asin_variation_attribute(self):
-        if self.date_type in ['month', 'month_week'] and self.date_info >= '2024-06':
+        if self.date_type in ['month', 'month_week', 'month_aba_me'] and self.date_info >= '2024-06':
             print("执行新版的变体信息整合")
             variat_schema = ArrayType(ArrayType(StringType()))
             self.df_asin_detail = self.df_asin_detail.withColumn("variat_list_change", F.from_json(F.col("variat_list"), variat_schema))
@@ -281,7 +281,7 @@ class DimAsinDetail(object):
             self.df_asin_detail = self.df_asin_detail.join(
                 df_asin_with_variation, on=['asin'], how='left'
             )
-        elif self.date_type in ['month', 'month_week'] and self.date_info < '2024-06':
+        elif self.date_type in ['month', 'month_week', 'month_aba_me'] and self.date_info < '2024-06':
             print("执行历史数据的变体信息整合")
             window = Window.partitionBy(self.df_asin_variat.asin).orderBy(
                 self.df_asin_variat.updated_time.desc_nulls_last())

Pyspark_job/dim/dim_asin_label.py

@@ -47,6 +47,8 @@ class DimAsinLabel(object):
                 date_sql = f" and date_type='{self.date_type}' and date_info = '{self.date_info}'"
             elif self.date_type == DateTypes.month.name and self.date_info >= '2023-10':
                 date_sql = f" and date_type='{self.date_type}' and date_info = '{self.date_info}'"
+            elif self.date_type == 'month_aba_me':
+                date_sql = f" and date_type='{self.date_type}' and date_info = '{self.date_info}'"
             else:
                 date_sql = f"and date_type='week' and date_info in {self.complete_date_info_tuple}"
         elif self.site_name in ['uk', 'de']:

Pyspark_job/dim/dim_asin_launchtime_info.py

@@ -84,7 +84,7 @@ class DimAsinLaunchtimeInfo(object):
         else:
             print("==================执行分区数据整合=================")
             # 按分区检测是否有新增的asin
-            if self.date_type in (DateTypes.week.name,DateTypes.month.name,DateTypes.month_week.name):
+            if self.date_type in (DateTypes.week.name,DateTypes.month.name,DateTypes.month_week.name, 'month_aba_me'):
                 # 取st维度的st下的asin数据
                 sql = f"""
                             select 

Pyspark_job/dim/dim_asin_stable_info.py

@@ -189,7 +189,9 @@ class DimAsinStableInfo(Templates):
 
     def read_data(self):
         if self.site_name == 'us':
-            params = f" and (date_type='week' or (date_type='month' and date_info='2023-10') or (date_type in ('month_week', 'month') and date_info>='2023-11'))"
+            # 选取最近1年的详情来计算
+            params = f" and date_type in ('month_week', 'month', 'month_aba_me') and date_info>='2025-01';"
+            # params = f" and (date_type='week' or (date_type='month' and date_info='2023-10') or (date_type in ('month_week', 'month') and date_info>='2023-11'))"
         else:
             params = f" and (date_type='week' or (date_type in ('month_week', 'month') and date_info>='2023-05'))"
 

Pyspark_job/dim/dim_cal_asin_history_detail.py

@@ -95,7 +95,7 @@ class DimCalAsinDetail(object):
                               and date_type='month' ;
                                 """
             self.date_type = 'day_all'
-        elif self.date_type in (DateTypes.week.name, DateTypes.month.name, DateTypes.month_week.name):
+        elif self.date_type in (DateTypes.week.name, DateTypes.month.name, DateTypes.month_week.name, 'month_aba_me'):
             sql = f"""select 
                               asin, 
                               asin_img_url,