task/summary_pay.py

@@ -58,6 +58,7 @@ class SummaryPay(Task):
                             item[k] = item.get(k) or user_info[k]
                         model = self.Model(**item)
                         data = model.dict(by_alias=True)
+                        _game_role_id = data.pop('_game_role_id')
                         data.pop('_id')
                         bulk_data.append(UpdateOne({'orderid': model.orderid}, {'$set': data}, upsert=True))
                     except Exception as e:

task/sync_user.py

@@ -1,4 +1,6 @@
+import pymongo
 from pymongo import UpdateOne
+from pydantic import BaseModel, Field
 
 from .task import Task
 from utils import *