update

task/recommend_strategy_d.py

@@ -89,7 +89,7 @@ device_df.show(1, False)
 sql_res = device_df.collect()
 print("-----------------------------------------------------------------------------")
 for res in sql_res:
-    print(res)
+    # print(res)
     day_id = res.day_id
     device_os_type = res.device_os_type
     active_type = res.active_type
@@ -104,6 +104,8 @@ for res in sql_res:
 
     recommend_welfare_card = res.recommend_welfare_card
     recommend_content_card = res.recommend_content_card
+    if not recommend_content_card:
+        recommend_content_card = 0
     recommend_special_card = res.recommend_special_card
     transfer_card = res.transfer_card
     video_consultation = res.video_consultation