forked from benx1n/wows-stats-bot
-
Notifications
You must be signed in to change notification settings - Fork 0
/
wws_bind.py
225 lines (218 loc) · 10.2 KB
/
wws_bind.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
from typing import List
import httpx
import traceback
import json
import re
from pathlib import Path
from requests import head
from .data_source import servers
from .publicAPI import get_AccountIdByName
from .utils import match_keywords
dir_path = Path(__file__).parent
cfgpath = dir_path / 'config.json'
config = json.load(open(cfgpath, 'r', encoding='utf8'))
headers = {
'Authorization': config['token']
}
async def get_BindInfo(user,info):
try:
if isinstance(info,List) and len(info) == 1:
for i in info: #是否包含me或@
if i == 'me':
url = 'https://api.wows.linxun.link/public/wows/bind/account/platform/bind/list'
params = {
"platformType": "QQ",
"platformId": user,
}
match = re.search(r"CQ:at,qq=(\d+)",i)
if match:
url = 'https://api.wows.linxun.link/public/wows/bind/account/platform/bind/list'
params = {
"platformType": "QQ",
"platformId": match.group(1),
}
break
if not url or not params:
return '参数似乎出了问题呢，请使用me或@群友'
else:
return '参数似乎出了问题呢，请使用me或@群友'
async with httpx.AsyncClient(headers=headers) as client:
resp = await client.get(url, params=params, timeout=10)
result = resp.json()
if result['code'] == 200 and result['message'] == "success":
if result['data']:
msg1 = f'当前绑定账号\n'
msg2 = f'绑定账号列表\n'
flag = 1
for bindinfo in result['data']:
msg2 += f"{flag}：{bindinfo['serverType']} {bindinfo['userName']}\n"
flag += 1
if bindinfo['defaultId']:
msg1 += f"{bindinfo['serverType']} {bindinfo['userName']}\n"
msg = msg1+msg2+"本人发送wws [切换/删除]绑定+序号 切换/删除对应账号"
return msg
else:
return '该用户似乎还没绑定窝窝屎账号'
else:
return f"{result['message']}\n这是服务器问题，请联系雨季麻麻"
except Exception:
traceback.print_exc()
return 'wuwuwu出了点问题，请联系麻麻解决'
async def set_BindInfo(user,info):
try:
param_server = None
if isinstance (info,List):
if len(info) == 2:
param_server,info = await match_keywords(info,servers)
if param_server:
param_accountid = await get_AccountIdByName(param_server,str(info[0]))
if param_accountid and param_accountid != 404:
url = 'https://api.wows.linxun.link/api/wows/bind/account/platform/bind/put'
params = {
"platformType": "QQ",
"platformId": str(user),
"accountId": param_accountid
}
elif param_accountid == 404:
return '无法查询该游戏昵称Orz，请检查昵称是否存在'
else:
return '发生了错误，有可能是网络波动，请稍后再试'
else:
return '服务器参数似乎输错了呢'
else:
return '参数似乎输错了呢，请确保后面跟随服务器+游戏昵称'
else:
return '参数似乎输错了呢，请确保后面跟随服务器+游戏昵称'
async with httpx.AsyncClient(headers=headers) as client:
resp = await client.get(url, params=params, timeout=10)
result = resp.json()
if result['code'] == 200 and result['message'] == "success":
return '绑定成功'
elif result['code'] == 500:
return f"{result['message']}\n这是服务器问题，请联系雨季麻麻"
else:
return 'wuwuwu出了点问题，请联系麻麻解决'
except Exception:
traceback.print_exc()
return 'wuwuwu出了点问题，请联系麻麻解决'
async def change_BindInfo(user,info):
try:
if isinstance(info,List) and len(info) == 1 and str(info[0]).isdigit:
url = 'https://api.wows.linxun.link/public/wows/bind/account/platform/bind/list'
params = {
"platformType": "QQ",
"platformId": user,
}
else:
return '参数似乎出了问题呢，请跟随要切换的序号'
async with httpx.AsyncClient(headers=headers) as client:
resp = await client.get(url, params=params, timeout=10)
result = resp.json()
if result['code'] == 200 and result['message'] == "success":
if result['data'] and len(result['data']) >= int(info[0]):
account_name = result['data'][int(info[0])-1]['userName']
param_server = result['data'][int(info[0])-1]['serverType']
param_accountid = result['data'][int(info[0])-1]['accountId']
url = 'https://api.wows.linxun.link/api/wows/bind/account/platform/bind/put'
params = {
"platformType": "QQ",
"platformId": str(user),
"accountId": param_accountid
}
else:
return '没有对应序号的绑定记录'
else:
return '参数似乎不正确，请确保只跟随了序号'
async with httpx.AsyncClient(headers=headers) as client:
resp = await client.get(url, params=params, timeout=10)
result = resp.json()
if result['code'] == 200 and result['message'] == "success":
return f'切换绑定成功,当前绑定账号{param_server}：{account_name}'
elif result['code'] == 403:
return f"{result['message']}\n请先绑定账号"
elif result['code'] == 404 or result['code'] == 405:
return f"{result['message']}"
elif result['code'] == 500:
return f"{result['message']}\n这是服务器问题，请联系雨季麻麻"
else:
return 'wuwuwu出了点问题，请联系麻麻解决'
except Exception:
traceback.print_exc()
return 'wuwuwu出了点问题，请联系麻麻解决'
async def set_special_BindInfo(user,info):
try:
param_server = None
if isinstance (info,List):
if len(info) == 2:
param_server,info = await match_keywords(info,servers)
if param_server:
if str(info[0]).isdigit():
url = 'https://api.wows.linxun.link/api/wows/bind/account/platform/bind/put'
params = {
"platformType": "QQ",
"platformId": str(user),
"accountId": int(info[0])
}
else:
return '特殊绑定只能使用网页查询到的AccountID哦'
else:
return '服务器参数似乎输错了呢'
else:
return '参数似乎输错了呢，请确保后面跟随服务器+网页查询到的AccountID'
else:
return '参数似乎输错了呢，请确保后面跟随服务器+游戏昵称'
async with httpx.AsyncClient(headers=headers) as client:
resp = await client.get(url, params=params, timeout=20)
result = resp.json()
if result['code'] == 200 and result['message'] == "success":
return '绑定成功'
elif result['code'] == 500:
return f"{result['message']}\n这是服务器问题，请联系雨季麻麻"
else:
return 'wuwuwu出了点问题，请联系麻麻解决'
except Exception:
return 'wuwuwu出了点问题，请联系麻麻解决'
async def delete_BindInfo(user,info):
try:
if isinstance(info,List) and len(info) == 1 and str(info[0]).isdigit:
url = 'https://api.wows.linxun.link/public/wows/bind/account/platform/bind/list'
params = {
"platformType": "QQ",
"platformId": user,
}
else:
return '参数似乎出了问题呢，请跟随要切换的序号'
async with httpx.AsyncClient(headers=headers) as client:
resp = await client.get(url, params=params, timeout=10)
result = resp.json()
if result['code'] == 200 and result['message'] == "success":
if result['data'] and len(result['data']) >= int(info[0]):
account_name = result['data'][int(info[0])-1]['userName']
param_server = result['data'][int(info[0])-1]['serverType']
param_accountid = result['data'][int(info[0])-1]['accountId']
url = 'https://api.wows.linxun.link/api/wows/bind/account/platform/bind/remove'
params = {
"platformType": "QQ",
"platformId": str(user),
"accountId": param_accountid
}
else:
return '没有对应序号的绑定记录'
else:
return '参数似乎不正确，请确保只跟随了序号'
async with httpx.AsyncClient(headers=headers) as client:
resp = await client.get(url, params=params, timeout=10)
result = resp.json()
if result['code'] == 200 and result['message'] == "success":
return f'删除绑定成功,删除的账号为{param_server}：{account_name}'
elif result['code'] == 403:
return f"{result['message']}"
elif result['code'] == 404 or result['code'] == 405:
return f"{result['message']}"
elif result['code'] == 500:
return f"{result['message']}\n这是服务器问题，请联系雨季麻麻"
else:
return 'wuwuwu出了点问题，请联系麻麻解决'
except Exception:
traceback.print_exc()
return 'wuwuwu出了点问题，请联系麻麻解决'