add rank abtest: hour_score6 & score8, update cal_24h_score back_rate

cal_24h_score.py

@@ -74,7 +74,7 @@ def cal_score(data_df):
     df['share_rate_view'] = (df['share人数'] + 1) / (df['view人数'] + 1000)
 
     # back_rate = (return+1)/(share+10)
-    df['back_rate'] = (df['回流人数'] + 1) / (df['view人数'] + 10)
+    df['back_rate'] = (df['回流人数'] + 1) / (df['share人数'] + 10)
 
     df['log_back'] = (df['回流人数'] + 1).apply(math.log)
 

cal_hour_score.py

@@ -116,7 +116,10 @@ def cal_score(data_df):
     # score5 = share/view * (back_rate + back_rate_2h + back_rate_3h) * logback
     df['hour_score5'] = df['share_rate_view'] * (df['back_rate'] + df['back_rate_2h'] + df['back_rate_3h']) * df['log_back']
 
-    score_df = df[['videoid', 'hour_score1', 'hour_score2', 'hour_score3', 'hour_score4', 'hour_score5']]
+    # score6 = 回流/(view+5)*back_rate
+    df['hour_score6'] = df['lastonehour_return'] / (df['lastonehour_view'] + 5) * df['back_rate']
+
+    score_df = df[['videoid', 'hour_score1', 'hour_score2', 'hour_score3', 'hour_score4', 'hour_score5', 'hour_score6']]
     # print(score_df)
     return score_df
 

compose_score.py

@@ -33,11 +33,12 @@ def cal_compose_score(score_hour_path, score_24h_path, merge_score_path):
     # score_merge_df['score5'] = score_merge_df['24h_score1'] + score_merge_df['hour_score5']
     score_merge_df['score6'] = score_merge_df['24h_score1'] * 0.2 + score_merge_df['hour_score4'] * 0.8
     score_merge_df['score7'] = score_merge_df['24h_score2'] + score_merge_df['hour_score4']
+    score_merge_df['score8'] = score_merge_df['24h_score1'] + score_merge_df['hour_score6']
 
     # print(score_merge_df)
     log_.info(f"score_merge_df shape: {score_merge_df.shape}")
     score_merge_df.to_csv(merge_score_path, index=False)
-    score_df = score_merge_df[['videoid', 'score1', 'score4', 'score6', 'score7']]
+    score_df = score_merge_df[['videoid', 'score1', 'score4', 'score6', 'score7', 'score8']]
     log_.info(f"score_df shape: {score_merge_df.shape}")
     return score_df