From 33422f034b7035f0b4327799c9ae23321b64c151 Mon Sep 17 00:00:00 2001 From: wuhao <15392746632@qq.com> Date: Tue, 15 Sep 2020 11:45:34 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0owner=E5=AD=97=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- update_data/update_user.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/update_data/update_user.py b/update_data/update_user.py index b5ca998..30760fa 100644 --- a/update_data/update_user.py +++ b/update_data/update_user.py @@ -53,7 +53,7 @@ class LoadUserData(LoadData): for user in data_list: user['lasttime'] = user['logintime'] user['vip'] = user.get('vip', 0) - self.channel_set.add((self.game_name, user.get('ext_channel', 'unkonwn'))) + self.channel_set.add((self.game_name, user.get('ext_channel', 'unkonwn'), user.get('ext_owner', 'unkonwn'))) user_info_data.extend(data_list) logger.info(f'db:{db}') logger.info(f'区服id:{sid}') @@ -130,10 +130,11 @@ class LoadUserData(LoadData): await conn.commit() # 记录渠道 - update_channel_sql = """insert into `gm_game_channel_list` (game,channel) values (%s,%s) + update_channel_sql = """insert into `gm_game_channel_list` (game,channel,owner) values (%s,%s,%s) on duplicate key update game=values(game), - channel=values(channel) + channel=values(channel), + owner=values(owner) """ await cur.executemany(update_channel_sql, self.channel_set) await conn.commit()