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-18 17:56:56 +08:00
parent 36d4702d5f
commit e6f210a11b
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
task/summary_pay.py
View File

@ -57,6 +57,7 @@ class SummaryPay(Task):
user_info = self.local_db['user'].find_one({'_game_role_id': item['_game_role_id']}, projection) user_info = self.local_db['user'].find_one({'_game_role_id': item['_game_role_id']}, projection)
for k, v in user_info.items(): for k, v in user_info.items():
item[k] = item.get(k) or user_info[k] item[k] = item.get(k) or user_info[k]
del item['_id']
model = self.Model(**item) model = self.Model(**item)
data = model.dict(by_alias=True) data = model.dict(by_alias=True)
bulk_data.append(UpdateOne({'orderid': model.orderid}, {'$set': data}, upsert=True)) bulk_data.append(UpdateOne({'orderid': model.orderid}, {'$set': data}, upsert=True))