wuhao/data_cleaning
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

update

Browse Source
This commit is contained in:
kf_wuhao 2021-01-08 17:59:24 +08:00
parent 52376471c4
commit b5a5ebc52c
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
task/summary3.py
View File

@ -343,15 +343,15 @@ class Summary3(Task):
@HandlerWrapper @HandlerWrapper
def handler_now(self, role_data, device_data, account_data, df, group, cdate): def handler_now(self, role_data, device_data, account_data, df, group, cdate):
if df.get('_game_role_id'):
role_data['new_role_list'] = list(df['_game_role_id'].unique()) role_data['new_role_list'] = list(df['_game_role_id'].unique())
role_data['new_role'] = len(role_data['new_role_list']) role_data['new_role'] = len(role_data['new_role_list'])
if df.get('is_new_device'):
device_data['new_device_list'] = list(df[df['is_new_device'] == 1]['_device_id'].unique()) device_data['new_device_list'] = list(df[df['is_new_device'] == 1]['_device_id'].unique())
device_data['new_device'] = len(device_data['new_device_list']) device_data['new_device'] = len(device_data['new_device_list'])
if df.get('is_new_channel_uid'):
account_data['new_account_list'] = list(df[df['is_new_channel_uid'] == 1]['_channel_uid'].unique()) account_data['new_account_list'] = list(df[df['is_new_channel_uid'] == 1]['_channel_uid'].unique())
account_data['new_account'] = len(account_data['new_account_list']) account_data['new_account'] = len(account_data['new_account_list'])
@HandlerWrapper @HandlerWrapper
def handler_pay(self, role_data, device_data, account_data, df, group, cdate): def handler_pay(self, role_data, device_data, account_data, df, group, cdate):