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()