update

task/recommend_strategy_fix.py

@@ -795,15 +795,6 @@ for t in range(5, 6):
     device_df.show(1, False)
     sql_res = device_df.collect()
 
-    data_dict = {}
-    has_click_pv_sql = 'select pid,card_click from recommend_strategy_d where partition_day = "%s"' % today_str
-    all_data_res = con_sql(has_click_pv_sql)
-    for data in all_data_res:
-        # print(data)
-        data_dict[data[0]] = data[1]
-    if not data_dict:
-        continue
-    print(data_dict)
     print("-----------------------------------------------------------------------------")
     for res in sql_res:
         # print(res)
@@ -836,16 +827,7 @@ for t in range(5, 6):
         second_jump_ctr = res.second_jump_ctr
         click_ctr = res.click_ctr
         pid = hashlib.md5((day_id + device_os_type + active_type + card_content_type + recommend_type).encode("utf8")).hexdigest()
-        try:
-            if data_dict.get(pid):
-                card_click_diff = data_dict.get(pid) - card_click
-            if card_click_diff and card_click_diff >= 0:
-                print("card_click_diff",card_click_diff)
-                card_click += card_click_diff
-                card_exposure += card_click_diff
-                click_ctr = round(card_click/card_exposure,5)
-        except:
-            print("add error")
+
         instert_sql = """replace into recommend_strategy_d_fix(
         day_id,device_os_type,active_type,card_content_type,recommend_type,card_click,card_exposure,avg_page_stay,navbar_search,
         highlight_word,self_welfare_card,recommend_welfare_card,recommend_content_card,recommend_special_card,transfer_card,video_consultation,