fix

Pyspark_job/dwt/dwt_flow_asin.py

@@ -248,7 +248,7 @@ class DwtFlowAsin(Templates):
         print("6.获取环比上期整合结果")
         sql = f"""
             select asin, round(asin_ao_val, 3) as previous_asin_ao_val, asin_price as previous_asin_price,
-            sales as pervious_sales, variation_num as previous_variation_num, asin_rating as previous_asin_rating,
+            sales as previous_sales, variation_num as previous_variation_num, asin_rating as previous_asin_rating,
             bsr_orders as previous_bsr_orders, asin_total_comments as previous_asin_total_comments,
             first_category_rank as previous_first_category_rank, asin_bought_month as previous_asin_bought_month from dwt_flow_asin
             where site_name = '{self.site_name}' and date_type = '{self.date_type}' and date_info = '{self.previous_date}'
@@ -558,7 +558,7 @@ class DwtFlowAsin(Templates):
             ("variation_num", "previous_variation_num", "lastyear_variation_num", "asin_variation", "int", False),
             ("asin_ao_val", "previous_asin_ao_val", "lastyear_asin_ao_val", "asin_ao", 3, False),
             ("asin_price", "previous_asin_price", "lastyear_asin_price", "asin_price", 2, False),
-            ("sales", "pervious_sales", "lastyear_sales", "asin_sales", 2, False),
+            ("sales", "previous_sales", "lastyear_sales", "asin_sales", 2, False),
             ("asin_bought_month", "previous_asin_bought_month", "lastyear_asin_bought_month", "asin_bought", None, True),
         ]
         for current_col, prev_col, lastyear_col, suffix, rise_round, use_sentinel in columns_to_change: