wuhao/sync_game_data
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

添加owner字段

Browse Source
This commit is contained in:
wuhao 2020-09-15 11:45:34 +08:00
parent ea74f7e678
commit 33422f034b
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
update_data/update_user.py
View File

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