diff --git a/task/summary_pay.py b/task/summary_pay.py index 6cf6783..0b1d58a 100644 --- a/task/summary_pay.py +++ b/task/summary_pay.py @@ -57,6 +57,7 @@ class SummaryPay(Task): user_info = self.local_db['user'].find_one({'_game_role_id': item['_game_role_id']}, projection) for k, v in user_info.items(): item[k] = item.get(k) or user_info[k] + del item['_id'] model = self.Model(**item) data = model.dict(by_alias=True) bulk_data.append(UpdateOne({'orderid': model.orderid}, {'$set': data}, upsert=True))