|
@@ -606,6 +606,17 @@ def video_rank(df, now_date, now_h, rule_key, param, region, data_key, rule_rank
|
|
|
(df['score'] >= score_value) &
|
|
|
(df['platform_return_rate'] >= platform_return_rate)
|
|
|
]
|
|
|
+ try:
|
|
|
+ if "return_countv2" in param.keys() and "platform_return_ratev2" in param.keys():
|
|
|
+ return_countv2 = param["return_countv2"]
|
|
|
+ platform_return_ratev2 = param["platform_return_ratev2"]
|
|
|
+ h_recall_df = h_recall_df[
|
|
|
+ df['platform_return_rate'] >= platform_return_ratev2 |
|
|
|
+ (df['platform_return_rate'] < platform_return_ratev2 & df['lastonehour_return'] > return_countv2)
|
|
|
+ ]
|
|
|
+ except Exception as e:
|
|
|
+ log_.error("return_countv2 is wrong with{}".format(e))
|
|
|
+
|
|
|
|
|
|
# videoid重复时,保留分值高
|
|
|
h_recall_df = h_recall_df.sort_values(by=['score'], ascending=False)
|