|
@@ -145,7 +145,8 @@ if __name__ == '__main__':
|
|
|
start_date = datetime.datetime.now().date() + datetime.timedelta(days=-config['activeMaterialFilterRule']['days'])
|
|
|
sql = f"select signature from kuaishou_material_video_report_daily_dw where project_id = {project_id} " \
|
|
|
f"and stat_date >= {start_date.year * 10000 + start_date.month * 100 + start_date.day} group by signature " \
|
|
|
- f"having sum(activation) >= {config['activeMaterialFilterRule']['activation']}"
|
|
|
+ f"having sum(activation) >= {config['activeMaterialFilterRule']['activation']} " \
|
|
|
+ f"and sum(event_pay_first_day) / sum(activation) >= {config['activeMaterialFilterRule']['event_pay_first_day_pct']}"
|
|
|
df = pd.read_sql(sql, application_product_db)
|
|
|
active_signatures = list(df[~df.signature.isnull()].signature.values)
|
|
|
active_signatures = active_signatures * 2 if len(active_signatures) == 1 else active_signatures
|