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

update

Browse Source
This commit is contained in:
kf_wuhao 2020-12-26 16:50:17 +08:00
parent fbf375bd45
commit 1091240d45
1 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
task/add_user_flag.py
View File

@ -75,9 +75,28 @@ class AddUserFlag(Task):
bulk_data.append( bulk_data.append(
UpdateOne({'_game_role_id': model.game_role_id}, UpdateOne({'_game_role_id': model.game_role_id},
{'$set': {'is_new_device': 1}})) {'$set': {'is_new_device': 1}}))
except Exception as e:
logger.error(f'msg:{e}')
pass
# 记录第一次登录设备id
where = {
'role_create_time': {
'$gte': ts['cursor_st'],
'$lt': ts['cursor_et'],
},
'_first_device_id': ''
}
for item in self.local_db[source_coll].find(where, projection):
try:
# 新设备
model = self.Model(**item)
bulk_data.append(
UpdateOne({'_game_role_id': model.game_role_id}, {'$set': {'_first_device_id': model.device_id}}))
except Exception as e: except Exception as e:
logger.error(f'msg:{e}') logger.error(f'msg:{e}')
# pass # pass
if bulk_data: if bulk_data:
self.local_db[self.dest_coll].bulk_write(bulk_data, ordered=False) self.local_db[self.dest_coll].bulk_write(bulk_data, ordered=False)
self.remote_db[self.dest_coll].bulk_write(bulk_data, ordered=False) self.remote_db[self.dest_coll].bulk_write(bulk_data, ordered=False)