流量选品30天，价格-1置空

Pyspark_job/my_kafka/kafka_flow_asin_detail_to_doris.py

@@ -247,6 +247,7 @@ class KafkaFlowAsinDetail(Templates):
 
     # 3. 处理bsr销量、价格类型字段以及BSR销售额信息
     def handle_asin_bsr_orders(self, df):
+        df = df.withColumn("price", F.when(F.col("price") < 0, F.lit(None)).otherwise(F.col("price")))
         df = df.join(self.df_bs_report, on=['asin_bs_cate_1_id', 'asin_bs_cate_1_rank'], how='left')
         df = df.withColumn("price_type", F.expr("""
         CASE WHEN price IS NOT NULL AND price > 0 AND price < 10 THEN 1 WHEN price >= 10 AND price < 15 THEN 2