From d24555b979d9f4a08e53adad6334ba8d77f538ff Mon Sep 17 00:00:00 2001
From: wuhao <15392746632@qq.com>
Date: Tue, 20 Oct 2020 21:24:29 +0800
Subject: [PATCH] update

---
 update_data/update_pay.py  | 4 +++-
 update_data/update_user.py | 2 +-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/update_data/update_pay.py b/update_data/update_pay.py
index c9712c9..143a397 100644
--- a/update_data/update_pay.py
+++ b/update_data/update_pay.py
@@ -31,14 +31,16 @@ class LoadPayData(LoadData):
         sql = "select * from paylist where state=2 and ctime>=%s"
         await cur.execute(sql, (self.last_act_time - 3600,))
         rss = await cur.fetchall()
+        res_data = []
         for p in rss:
             if p.get('serverid') not in self.serverid_list:
                 continue
             p['data'] = p['data2']
+            res_data.append(p)
         await cur.close()
         pay_mysql.close()
         logger.info(f'{self.game_name}查询到{len(rss)}条订单')
-        return rss
+        return res_data
 
     async def update_data(self, data):
         if not data:
diff --git a/update_data/update_user.py b/update_data/update_user.py
index 5233ed6..0b5d045 100644
--- a/update_data/update_user.py
+++ b/update_data/update_user.py
@@ -50,7 +50,7 @@ class LoadUserData(LoadData):
                 db = s['db']
                 where['uid'] = {"$regex": "^" + str(sid) + "_"}
                 user_info_cursor = self.mongo_client[db]['userinfo'].find(where, projection)
-                data_list = await user_info_cursor.to_list(length=65535)
+                data_list = await user_info_cursor.to_list(length=999999)
                 for user in data_list:
                     user['lasttime'] = user['logintime']
                     user['vip'] = user.get('vip', 0)