diff --git a/saved/qrcodes/qrcode.jpg b/saved/qrcodes/qrcode.jpg
new file mode 100644
index 0000000..862fd9d
Binary files /dev/null and b/saved/qrcodes/qrcode.jpg differ
diff --git a/weixin.py b/weixin.py
index 0271547..2ed25d9 100755
--- a/weixin.py
+++ b/weixin.py
@@ -1,9 +1,9 @@
#!/usr/bin/env python
# coding: utf-8
import qrcode
-import urllib
-import urllib2
-import cookielib
+import urllib.request, urllib.parse, urllib.error
+import urllib.request, urllib.error, urllib.parse
+import http.cookiejar
import requests
import xml.dom.minidom
import json
@@ -16,9 +16,9 @@ import random
import multiprocessing
import platform
import logging
-import httplib
+import http.client
from collections import defaultdict
-from urlparse import urlparse
+from urllib.parse import urlparse
from lxml import html
#import pdb
@@ -32,7 +32,7 @@ def catchKeyboardInterrupt(fn):
try:
return fn(*args)
except KeyboardInterrupt:
- print '\n[*] 强制退出程序'
+ print('\n[*] 强制退出程序')
logging.debug('[*] 强制退出程序')
return wrapper
@@ -40,7 +40,7 @@ def catchKeyboardInterrupt(fn):
def _decode_list(data):
rv = []
for item in data:
- if isinstance(item, unicode):
+ if isinstance(item, str):
item = item.encode('utf-8')
elif isinstance(item, list):
item = _decode_list(item)
@@ -52,10 +52,10 @@ def _decode_list(data):
def _decode_dict(data):
rv = {}
- for key, value in data.iteritems():
- if isinstance(key, unicode):
+ for key, value in data.items():
+ if isinstance(key, str):
key = key.encode('utf-8')
- if isinstance(value, unicode):
+ if isinstance(value, str):
value = value.encode('utf-8')
elif isinstance(value, list):
value = _decode_list(value)
@@ -118,10 +118,10 @@ class WebWeixin(object):
self.TimeOut = 20 # 同步最短时间间隔（单位：秒）
self.media_count = -1
- self.cookie = cookielib.CookieJar()
- opener = urllib2.build_opener(urllib2.HTTPCookieProcessor(self.cookie))
+ self.cookie = http.cookiejar.CookieJar()
+ opener = urllib.request.build_opener(urllib.request.HTTPCookieProcessor(self.cookie))
opener.addheaders = [('User-agent', self.user_agent)]
- urllib2.install_opener(opener)
+ urllib.request.install_opener(opener)
def loadConfig(self, config):
if config['DEBUG']:
@@ -143,7 +143,10 @@ class WebWeixin(object):
'lang': self.lang,
'_': int(time.time()),
}
- data = self._post(url, params, False)
+ #r = requests.get(url=url, params=params)
+ #r.encoding = 'utf-8'
+ #data = r.text
+ data = self._post(url, params, False).decode("utf-8")
if data == '':
return False
regx = r'window.QRLogin.code = (\d+); window.QRLogin.uuid = "(\S+?)"'
@@ -163,7 +166,7 @@ class WebWeixin(object):
else:
self._str2qr('https://login.weixin.qq.com/l/' + self.uuid)
- def _showQRCodeImg(self, os):
+ def _showQRCodeImg(self, str):
url = 'https://login.weixin.qq.com/qrcode/' + self.uuid
params = {
't': 'webwx',
@@ -174,9 +177,9 @@ class WebWeixin(object):
if data == '':
return
QRCODE_PATH = self._saveFile('qrcode.jpg', data, '_showQRCodeImg')
- if os == 'win':
+ if str == 'win':
os.startfile(QRCODE_PATH)
- elif os == 'macos':
+ elif str == 'macos':
subprocess.call(["open", QRCODE_PATH])
else:
return
@@ -188,7 +191,7 @@ class WebWeixin(object):
data = self._get(url)
if data == '':
return False
- pm = re.search(r'window.code=(\d+);', data)
+ pm = re.search(r"window.code=(\d+);", data)
code = pm.group(1)
if code == '201':
@@ -242,13 +245,13 @@ class WebWeixin(object):
dic = self._post(url, params)
if dic == '':
return False
- self.SyncKey = dic['SyncKey']
- self.User = dic['User']
+ self.SyncKey = dic[b'SyncKey']
+ self.User = dic[b'User']
# synckey for synccheck
self.synckey = '|'.join(
- [str(keyVal['Key']) + '_' + str(keyVal['Val']) for keyVal in self.SyncKey['List']])
+ [str(keyVal[b'Key']) + '_' + str(keyVal[b'Val']) for keyVal in self.SyncKey[b'List']])
- return dic['BaseResponse']['Ret'] == 0
+ return dic[b'BaseResponse'][b'Ret'] == 0
def webwxstatusnotify(self):
url = self.base_uri + \
@@ -256,15 +259,15 @@ class WebWeixin(object):
params = {
'BaseRequest': self.BaseRequest,
"Code": 3,
- "FromUserName": self.User['UserName'],
- "ToUserName": self.User['UserName'],
+ "FromUserName": self.User[b'UserName'].decode(),
+ "ToUserName": self.User[b'UserName'].decode(),
"ClientMsgId": int(time.time())
}
dic = self._post(url, params)
if dic == '':
return False
- return dic['BaseResponse']['Ret'] == 0
+ return dic[b'BaseResponse'][b'Ret'] == 0
def webwxgetcontact(self):
SpecialUsers = self.SpecialUsers
@@ -274,25 +277,25 @@ class WebWeixin(object):
if dic == '':
return False
- self.MemberCount = dic['MemberCount']
- self.MemberList = dic['MemberList']
+ self.MemberCount = dic[b'MemberCount']
+ self.MemberList = dic[b'MemberList']
ContactList = self.MemberList[:]
GroupList = self.GroupList[:]
PublicUsersList = self.PublicUsersList[:]
SpecialUsersList = self.SpecialUsersList[:]
- for i in xrange(len(ContactList) - 1, -1, -1):
+ for i in range(len(ContactList) - 1, -1, -1):
Contact = ContactList[i]
- if Contact['VerifyFlag'] & 8 != 0: # 公众号/服务号
+ if Contact[b'VerifyFlag'] & 8 != 0: # 公众号/服务号
ContactList.remove(Contact)
self.PublicUsersList.append(Contact)
- elif Contact['UserName'] in SpecialUsers: # 特殊账号
+ elif Contact[b'UserName'].decode() in SpecialUsers: # 特殊账号
ContactList.remove(Contact)
self.SpecialUsersList.append(Contact)
- elif '@@' in Contact['UserName']: # 群聊
+ elif '@@' in Contact[b'UserName'].decode(): # 群聊
ContactList.remove(Contact)
self.GroupList.append(Contact)
- elif Contact['UserName'] == self.User['UserName']: # 自己
+ elif Contact[b'UserName'] == self.User[b'UserName']: # 自己
ContactList.remove(Contact)
self.ContactList = ContactList
@@ -302,23 +305,28 @@ class WebWeixin(object):
url = self.base_uri + \
'/webwxbatchgetcontact?type=ex&r=%s&pass_ticket=%s' % (
int(time.time()), self.pass_ticket)
+ List=[{"UserName": g[b'UserName'], "EncryChatRoomId":""} for g in self.GroupList]
+ for x in List:
+ x['UserName']=x['UserName'].decode()
+
+ print(1)
params = {
'BaseRequest': self.BaseRequest,
"Count": len(self.GroupList),
- "List": [{"UserName": g['UserName'], "EncryChatRoomId":""} for g in self.GroupList]
+ "List": List
}
dic = self._post(url, params)
if dic == '':
return False
# blabla ...
- ContactList = dic['ContactList']
- ContactCount = dic['Count']
+ ContactList = dic[b'ContactList']
+ ContactCount = dic[b'Count']
self.GroupList = ContactList
- for i in xrange(len(ContactList) - 1, -1, -1):
+ for i in range(len(ContactList) - 1, -1, -1):
Contact = ContactList[i]
- MemberList = Contact['MemberList']
+ MemberList = Contact[b'MemberList']
for member in MemberList:
self.GroupMemeberList.append(member)
return True
@@ -337,18 +345,18 @@ class WebWeixin(object):
return None
# blabla ...
- return dic['ContactList']
+ return dic[b'ContactList'].decode()
def testsynccheck(self):
SyncHost = [
'webpush.weixin.qq.com',
- #'webpush2.weixin.qq.com',
+ 'webpush2.weixin.qq.com',
'webpush.wechat.com',
'webpush1.wechat.com',
'webpush2.wechat.com',
'webpush.wx.qq.com',
'webpush2.wx.qq.com'
- # 'webpush.wechatapp.com'
+ 'webpush.wechatapp.com'
]
for host in SyncHost:
self.syncHost = host
@@ -367,11 +375,11 @@ class WebWeixin(object):
'synckey': self.synckey,
'_': int(time.time()),
}
- url = 'https://' + self.syncHost + \
- '/cgi-bin/mmwebwx-bin/synccheck?' + urllib.urlencode(params)
+ url = 'https://' + self.syncHost + '/cgi-bin/mmwebwx-bin/synccheck?' + urllib.parse.urlencode(params)
data = self._get(url)
if data == '':
return [-1,-1]
+
pm = re.search(
r'window.synccheck={retcode:"(\d+)",selector:"(\d+)"}', data)
retcode = pm.group(1)
@@ -391,11 +399,11 @@ class WebWeixin(object):
if dic == '':
return None
if self.DEBUG:
- print json.dumps(dic, indent=4)
+ print(json.dumps(dic, indent=4))
(json.dumps(dic, indent=4))
- if dic['BaseResponse']['Ret'] == 0:
- self.SyncKey = dic['SyncKey']
+ if dic[b'BaseResponse'][b'Ret'] == 0:
+ self.SyncKey = dic[b'SyncKey'].decode()
self.synckey = '|'.join(
[str(keyVal['Key']) + '_' + str(keyVal['Val']) for keyVal in self.SyncKey['List']])
return dic
@@ -420,7 +428,7 @@ class WebWeixin(object):
data = json.dumps(params, ensure_ascii=False).encode('utf8')
r = requests.post(url, data=data, headers=headers)
dic = r.json()
- return dic['BaseResponse']['Ret'] == 0
+ return dic[b'BaseResponse'][b'Ret'] == 0
def webwxuploadmedia(self, image_name):
url = 'https://file2.wx.qq.com/cgi-bin/mmwebwx-bin/webwxuploadmedia?f=json'
@@ -516,7 +524,7 @@ class WebWeixin(object):
data = json.dumps(data_json, ensure_ascii=False).encode('utf8')
r = requests.post(url, data=data, headers=headers)
dic = r.json()
- return dic['BaseResponse']['Ret'] == 0
+ return dic[b'BaseResponse'][b'Ret'] == 0
def webwxsendmsgemotion(self, user_id, media_id):
url = 'https://wx2.qq.com/cgi-bin/mmwebwx-bin/webwxsendemoticon?fun=sys&f=json&pass_ticket=%s' % self.pass_ticket
@@ -539,9 +547,9 @@ class WebWeixin(object):
r = requests.post(url, data=data, headers=headers)
dic = r.json()
if self.DEBUG:
- print json.dumps(dic, indent=4)
+ print(json.dumps(dic, indent=4))
logging.debug(json.dumps(dic, indent=4))
- return dic['BaseResponse']['Ret'] == 0
+ return dic[b'BaseResponse'][b'Ret'] == 0
def _saveFile(self, filename, data, api=None):
fn = filename
@@ -642,14 +650,14 @@ class WebWeixin(object):
# 直接联系人
for member in self.ContactList:
- if member['UserName'] == id:
- name = member['RemarkName'] if member[
- 'RemarkName'] else member['NickName']
+ if member[b'UserName'].decode() == id:
+ name = member[b'RemarkName'].decode() if member[
+ b'RemarkName'].decode() else member[b'NickName'].decode()
# 群友
for member in self.GroupMemeberList:
- if member['UserName'] == id:
- name = member['DisplayName'] if member[
- 'DisplayName'] else member['NickName']
+ if member[b'UserName'].decode() == id:
+ name = member[b'DisplayName'] if member[
+ b'DisplayName'].decode() else member[b'NickName'].decode()
if name == '未知群' or name == '陌生人':
logging.debug(id)
@@ -657,8 +665,8 @@ class WebWeixin(object):
def getUSerID(self, name):
for member in self.MemberList:
- if name == member['RemarkName'] or name == member['NickName']:
- return member['UserName']
+ if name == member[b'RemarkName'].decode() or name == member[b'NickName'].decode():
+ return member[b'UserName'].decode()
return None
def _showMsg(self, message):
@@ -722,28 +730,28 @@ class WebWeixin(object):
msg['message'] = content
# 指定了消息内容
- if 'message' in msg.keys():
+ if 'message' in list(msg.keys()):
content = msg['message']
if groupName != None:
- print '%s |%s| %s -> %s: %s' % (message_id, groupName.strip(), srcName.strip(), dstName.strip(), content.replace('
', '\n'))
+ print('%s |%s| %s -> %s: %s' % (message_id, groupName.strip(), srcName.strip(), dstName.strip(), content.replace('
', '\n')))
logging.info('%s |%s| %s -> %s: %s' % (message_id, groupName.strip(),
srcName.strip(), dstName.strip(), content.replace('
', '\n')))
else:
- print '%s %s -> %s: %s' % (message_id, srcName.strip(), dstName.strip(), content.replace('
', '\n'))
+ print('%s %s -> %s: %s' % (message_id, srcName.strip(), dstName.strip(), content.replace('
', '\n')))
logging.info('%s %s -> %s: %s' % (message_id, srcName.strip(),
dstName.strip(), content.replace('
', '\n')))
def handleMsg(self, r):
for msg in r['AddMsgList']:
- print '[*] 你有新的消息，请注意查收'
+ print('[*] 你有新的消息，请注意查收')
logging.debug('[*] 你有新的消息，请注意查收')
if self.DEBUG:
fn = 'msg' + str(int(random.random() * 1000)) + '.json'
with open(fn, 'w') as f:
f.write(json.dumps(msg))
- print '[*] 该消息已储存到文件: ' + fn
+ print('[*] 该消息已储存到文件: ' + fn)
logging.debug('[*] 该消息已储存到文件: %s' % (fn))
msgType = msg['MsgType']
@@ -754,13 +762,17 @@ class WebWeixin(object):
if msgType == 1:
raw_msg = {'raw_msg': msg}
self._showMsg(raw_msg)
+#自己加的代码-------------------------------------------#
+ #if self.autoReplyRevokeMode:
+ # store
+#自己加的代码-------------------------------------------#
if self.autoReplyMode:
ans = self._xiaodoubi(content) + '\n[微信机器人自动回复]'
if self.webwxsendmsg(ans, msg['FromUserName']):
- print '自动回复: ' + ans
+ print('自动回复: ' + ans)
logging.info('自动回复: ' + ans)
else:
- print '自动回复失败'
+ print('自动回复失败')
logging.info('自动回复失败')
elif msgType == 3:
image = self.webwxgetmsgimg(msgid)
@@ -776,13 +788,13 @@ class WebWeixin(object):
self._safe_open(voice)
elif msgType == 42:
info = msg['RecommendInfo']
- print '%s 发送了一张名片:' % name
- print '========================='
- print '= 昵称: %s' % info['NickName']
- print '= 微信号: %s' % info['Alias']
- print '= 地区: %s %s' % (info['Province'], info['City'])
- print '= 性别: %s' % ['未知', '男', '女'][info['Sex']]
- print '========================='
+ print('%s 发送了一张名片:' % name)
+ print('=========================')
+ print('= 昵称: %s' % info['NickName'])
+ print('= 微信号: %s' % info['Alias'])
+ print('= 地区: %s %s' % (info['Province'], info['City']))
+ print('= 性别: %s' % ['未知', '男', '女'][info['Sex']])
+ print('=========================')
raw_msg = {'raw_msg': msg, 'message': '%s 发送了一张名片: %s' % (
name.strip(), json.dumps(info))}
self._showMsg(raw_msg)
@@ -795,13 +807,13 @@ class WebWeixin(object):
elif msgType == 49:
appMsgType = defaultdict(lambda: "")
appMsgType.update({5: '链接', 3: '音乐', 7: '微博'})
- print '%s 分享了一个%s:' % (name, appMsgType[msg['AppMsgType']])
- print '========================='
- print '= 标题: %s' % msg['FileName']
- print '= 描述: %s' % self._searchContent('des', content, 'xml')
- print '= 链接: %s' % msg['Url']
- print '= 来自: %s' % self._searchContent('appname', content, 'xml')
- print '========================='
+ print('%s 分享了一个%s:' % (name, appMsgType[msg['AppMsgType']]))
+ print('=========================')
+ print('= 标题: %s' % msg['FileName'])
+ print('= 描述: %s' % self._searchContent('des', content, 'xml'))
+ print('= 链接: %s' % msg['Url'])
+ print('= 来自: %s' % self._searchContent('appname', content, 'xml'))
+ print('=========================')
card = {
'title': msg['FileName'],
'description': self._searchContent('des', content, 'xml'),
@@ -831,7 +843,7 @@ class WebWeixin(object):
self._showMsg(raw_msg)
def listenMsgMode(self):
- print '[*] 进入消息监听模式 ... 成功'
+ print('[*] 进入消息监听模式 ... 成功')
logging.debug('[*] 进入消息监听模式 ... 成功')
self._run('[*] 进行同步线路测试 ... ', self.testsynccheck)
playWeChat = 0
@@ -840,14 +852,14 @@ class WebWeixin(object):
self.lastCheckTs = time.time()
[retcode, selector] = self.synccheck()
if self.DEBUG:
- print 'retcode: %s, selector: %s' % (retcode, selector)
+ print('retcode: %s, selector: %s' % (retcode, selector))
logging.debug('retcode: %s, selector: %s' % (retcode, selector))
if retcode == '1100':
- print '[*] 你在手机上登出了微信，债见'
+ print('[*] 你在手机上登出了微信，债见')
logging.debug('[*] 你在手机上登出了微信，债见')
break
if retcode == '1101':
- print '[*] 你在其他地方登录了 WEB 版微信，债见'
+ print('[*] 你在其他地方登录了 WEB 版微信，债见')
logging.debug('[*] 你在其他地方登录了 WEB 版微信，债见')
break
elif retcode == '0':
@@ -858,11 +870,11 @@ class WebWeixin(object):
elif selector == '6':
# TODO
redEnvelope += 1
- print '[*] 收到疑似红包消息 %d 次' % redEnvelope
+ print('[*] 收到疑似红包消息 %d 次' % redEnvelope)
logging.debug('[*] 收到疑似红包消息 %d 次' % redEnvelope)
elif selector == '7':
playWeChat += 1
- print '[*] 你在手机上玩微信被我发现了 %d 次' % playWeChat
+ print('[*] 你在手机上玩微信被我发现了 %d 次' % playWeChat)
logging.debug('[*] 你在手机上玩微信被我发现了 %d 次' % playWeChat)
r = self.webwxsync()
elif selector == '0':
@@ -879,31 +891,31 @@ class WebWeixin(object):
line = line.replace('\n', '')
self._echo('-> ' + name + ': ' + line)
if self.webwxsendmsg(line, id):
- print ' [成功]'
+ print(' [成功]')
else:
- print ' [失败]'
+ print(' [失败]')
time.sleep(1)
else:
if self.webwxsendmsg(word, id):
- print '[*] 消息发送成功'
+ print('[*] 消息发送成功')
logging.debug('[*] 消息发送成功')
else:
- print '[*] 消息发送失败'
+ print('[*] 消息发送失败')
logging.debug('[*] 消息发送失败')
else:
- print '[*] 此用户不存在'
+ print('[*] 此用户不存在')
logging.debug('[*] 此用户不存在')
def sendMsgToAll(self, word):
for contact in self.ContactList:
- name = contact['RemarkName'] if contact[
- 'RemarkName'] else contact['NickName']
- id = contact['UserName']
+ name = contact[b'RemarkName'].decode() if contact[
+ b'RemarkName'].decode() else contact[b'NickName'].decode()
+ id = contact[b'UserName'].decode()
self._echo('-> ' + name + ': ' + word)
if self.webwxsendmsg(word, id):
- print ' [成功]'
+ print(' [成功]')
else:
- print ' [失败]'
+ print(' [失败]')
time.sleep(1)
def sendImg(self, name, file_name):
@@ -925,18 +937,18 @@ class WebWeixin(object):
@catchKeyboardInterrupt
def start(self):
self._echo('[*] 微信网页版 ... 开动')
- print
+ print()
logging.debug('[*] 微信网页版 ... 开动')
while True:
self._run('[*] 正在获取 uuid ... ', self.getUUID)
self._echo('[*] 正在获取二维码 ... 成功')
- print
+ print()
logging.debug('[*] 微信网页版 ... 开动')
self.genQRCode()
- print '[*] 请使用微信扫描二维码以登录 ... '
+ print('[*] 请使用微信扫描二维码以登录 ... ')
if not self.waitForLogin():
continue
- print '[*] 请在手机上点击确认以登录 ... '
+ print('[*] 请在手机上点击确认以登录 ... ')
if not self.waitForLogin(0):
continue
break
@@ -947,33 +959,33 @@ class WebWeixin(object):
self._run('[*] 获取联系人 ... ', self.webwxgetcontact)
self._echo('[*] 应有 %s 个联系人，读取到联系人 %d 个' %
(self.MemberCount, len(self.MemberList)))
- print
+ print()
self._echo('[*] 共有 %d 个群 | %d 个直接联系人 | %d 个特殊账号 ｜ %d 公众号或服务号' % (len(self.GroupList),
len(self.ContactList), len(self.SpecialUsersList), len(self.PublicUsersList)))
- print
+ print()
self._run('[*] 获取群 ... ', self.webwxbatchgetcontact)
logging.debug('[*] 微信网页版 ... 开动')
if self.DEBUG:
- print self
+ print(self)
logging.debug(self)
- if self.interactive and raw_input('[*] 是否开启自动回复模式(y/n): ') == 'y':
+ if self.interactive and input('[*] 是否开启自动回复模式(y/n): ') == 'y':
self.autoReplyMode = True
- print '[*] 自动回复模式 ... 开启'
+ print('[*] 自动回复模式 ... 开启')
logging.debug('[*] 自动回复模式 ... 开启')
else:
- print '[*] 自动回复模式 ... 关闭'
+ print('[*] 自动回复模式 ... 关闭')
logging.debug('[*] 自动回复模式 ... 关闭')
if sys.platform.startswith('win'):
- import thread
- thread.start_new_thread(self.listenMsgMode())
+ import _thread
+ _thread.start_new_thread(self.listenMsgMode())
else:
listenProcess = multiprocessing.Process(target=self.listenMsgMode)
listenProcess.start()
while True:
- text = raw_input('')
+ text = input('')
if text == 'quit':
listenProcess.terminate()
print('[*] 退出微信')
@@ -989,15 +1001,15 @@ class WebWeixin(object):
[name, file] = text[3:].split(':')
self.sendMsg(name, file, True)
elif text[:3] == 'f->':
- print '发送文件'
+ print('发送文件')
logging.debug('发送文件')
elif text[:3] == 'i->':
- print '发送图片'
+ print('发送图片')
[name, file_name] = text[3:].split(':')
self.sendImg(name, file_name)
logging.debug('发送图片')
elif text[:3] == 'e->':
- print '发送表情'
+ print('发送表情')
[name, file_name] = text[3:].split(':')
self.sendEmotion(name, file_name)
logging.debug('发送表情')
@@ -1012,7 +1024,7 @@ class WebWeixin(object):
def _run(self, str, func, *args):
self._echo(str)
if func(*args):
- print '成功'
+ print('成功')
logging.debug('%s... 成功' % (str))
else:
print('失败\n[*] 退出程序')
@@ -1028,7 +1040,7 @@ class WebWeixin(object):
for i in mat:
BLACK = '\033[40m \033[0m'
WHITE = '\033[47m \033[0m'
- print ''.join([BLACK if j else WHITE for j in i])
+ print(''.join([BLACK if j else WHITE for j in i]))
def _str2qr(self, str):
print(str)
@@ -1046,55 +1058,57 @@ class WebWeixin(object):
if not data:
return data
result = None
- if type(data) == unicode:
+ if type(data) == str:
result = data
elif type(data) == str:
result = data.decode('utf-8')
return result
- def _get(self, url, api=None):
- request = urllib2.Request(url=url)
+ def _get(self, url: object, api: object = None) -> object:
+ request = urllib.request.Request(url=url)
request.add_header('Referer', 'https://wx.qq.com/')
if api == 'webwxgetvoice':
request.add_header('Range', 'bytes=0-')
if api == 'webwxgetvideo':
request.add_header('Range', 'bytes=0-')
try:
- response = urllib2.urlopen(request)
- data = response.read()
+ response = urllib.request.urlopen(request)
+ data = response.read().decode('utf-8')
logging.debug(url)
return data
- except urllib2.HTTPError, e:
+ except urllib.error.HTTPError as e:
logging.error('HTTPError = ' + str(e.code))
- except urllib2.URLError, e:
+ except urllib.error.URLError as e:
logging.error('URLError = ' + str(e.reason))
- except httplib.HTTPException, e:
+ except http.client.HTTPException as e:
logging.error('HTTPException')
except Exception:
import traceback
logging.error('generic exception: ' + traceback.format_exc())
return ''
- def _post(self, url, params, jsonfmt=True):
+ def _post(self, url: object, params: object, jsonfmt: object = True) -> object:
if jsonfmt:
- request = urllib2.Request(url=url, data=json.dumps(params))
+ data = json.dumps(params)
+ data=data.encode()
+ request = urllib.request.Request(url=url, data=data)
request.add_header(
'ContentType', 'application/json; charset=UTF-8')
else:
- request = urllib2.Request(url=url, data=urllib.urlencode(params))
+ request = urllib.request.Request(url=url, data=urllib.parse.urlencode(params).encode(encoding='utf-8'))
try:
- response = urllib2.urlopen(request)
+ response = urllib.request.urlopen(request)
data = response.read()
if jsonfmt:
- return json.loads(data, object_hook=_decode_dict)
+ return json.loads(data.decode('utf-8'), object_hook=_decode_dict)
return data
- except urllib2.HTTPError, e:
+ except urllib.error.HTTPError as e:
logging.error('HTTPError = ' + str(e.code))
- except urllib2.URLError, e:
+ except urllib.error.URLError as e:
logging.error('URLError = ' + str(e.reason))
- except httplib.HTTPException, e:
+ except http.client.HTTPException as e:
logging.error('HTTPException')
except Exception:
import traceback