Merge pull request #43 from JokerQyou/master

Fix PEP8 complaints: use all spaces for indent

weixin.py

@@ -1,12 +1,17 @@
 #!/usr/bin/env python
 # coding: utf-8
 import qrcode
-import urllib, urllib2
+import urllib
+import urllib2
 import cookielib
 import requests
 import xml.dom.minidom
 import json
-import time, re, sys, os, random
+import time
+import re
+import sys
+import os
+import random
 import multiprocessing
 import platform
 import logging
@@ -15,10 +20,10 @@ from urlparse import urlparse
 from lxml import html
 
 # for media upload
-import os
 import mimetypes
 from requests_toolbelt.multipart.encoder import MultipartEncoder
 
+
 def catchKeyboardInterrupt(fn):
     def wrapper(*args):
         try:
@@ -28,6 +33,7 @@ def catchKeyboardInterrupt(fn):
             logging.debug('[*] 强制退出程序')
     return wrapper
 
+
 def _decode_list(data):
     rv = []
     for item in data:
@@ -40,6 +46,7 @@ def _decode_list(data):
         rv.append(item)
     return rv
 
+
 def _decode_dict(data):
     rv = {}
     for key, value in data.iteritems():
@@ -54,7 +61,9 @@ def _decode_dict(data):
         rv[key] = value
     return rv
 
+
 class WebWeixin(object):
+
     def __str__(self):
         description = \
             "=========================\n" + \
@@ -95,12 +104,14 @@ class WebWeixin(object):
         self.interactive = False
         self.autoOpen = False
         self.saveFolder = os.path.join(os.getcwd(), 'saved')
-		self.saveSubFolders = {'webwxgeticon': 'icons', 'webwxgetheadimg': 'headimgs', 'webwxgetmsgimg': 'msgimgs', 'webwxgetvideo': 'videos', 'webwxgetvoice': 'voices', '_showQRCodeImg': 'qrcodes'}
+        self.saveSubFolders = {'webwxgeticon': 'icons', 'webwxgetheadimg': 'headimgs', 'webwxgetmsgimg': 'msgimgs',
+                               'webwxgetvideo': 'videos', 'webwxgetvoice': 'voices', '_showQRCodeImg': 'qrcodes'}
         self.appid = 'wx782c26e4c19acffb'
         self.lang = 'zh_CN'
         self.lastCheckTs = time.time()
         self.memberCount = 0
-		self.SpecialUsers = ['newsapp', 'fmessage', 'filehelper', 'weibo', 'qqmail', 'fmessage', 'tmessage', 'qmessage', 'qqsync', 'floatbottle', 'lbsapp', 'shakeapp', 'medianote', 'qqfriend', 'readerapp', 'blogapp', 'facebookapp', 'masssendapp', 'meishiapp', 'feedsapp', 'voip', 'blogappweixin', 'weixin', 'brandsessionholder', 'weixinreminder', 'wxid_novlwrv3lqwv11', 'gh_22b87fa7cb3c', 'officialaccounts', 'notification_messages', 'wxid_novlwrv3lqwv11', 'gh_22b87fa7cb3c', 'wxitil', 'userexperience_alarm', 'notification_messages']
+        self.SpecialUsers = ['newsapp', 'fmessage', 'filehelper', 'weibo', 'qqmail', 'fmessage', 'tmessage', 'qmessage', 'qqsync', 'floatbottle', 'lbsapp', 'shakeapp', 'medianote', 'qqfriend', 'readerapp', 'blogapp', 'facebookapp', 'masssendapp', 'meishiapp', 'feedsapp',
+                             'voip', 'blogappweixin', 'weixin', 'brandsessionholder', 'weixinreminder', 'wxid_novlwrv3lqwv11', 'gh_22b87fa7cb3c', 'officialaccounts', 'notification_messages', 'wxid_novlwrv3lqwv11', 'gh_22b87fa7cb3c', 'wxitil', 'userexperience_alarm', 'notification_messages']
         self.TimeOut = 20  # 同步最短时间间隔（单位：秒）
         self.media_count = -1
 
@@ -110,11 +121,16 @@ class WebWeixin(object):
         urllib2.install_opener(opener)
 
     def loadConfig(self, config):
-		if config['DEBUG']: self.DEBUG = config['DEBUG']
-		if config['autoReplyMode']: self.autoReplyMode = config['autoReplyMode']
-		if config['user_agent']: self.user_agent = config['user_agent']
-		if config['interactive']: self.interactive = config['interactive']
-		if config['autoOpen']: self.autoOpen = config['autoOpen']
+        if config['DEBUG']:
+            self.DEBUG = config['DEBUG']
+        if config['autoReplyMode']:
+            self.autoReplyMode = config['autoReplyMode']
+        if config['user_agent']:
+            self.user_agent = config['user_agent']
+        if config['interactive']:
+            self.interactive = config['interactive']
+        if config['autoOpen']:
+            self.autoOpen = config['autoOpen']
 
     def getUUID(self):
         url = 'https://login.weixin.qq.com/jslogin'
@@ -152,12 +168,14 @@ class WebWeixin(object):
 
     def waitForLogin(self, tip=1):
         time.sleep(tip)
-		url = 'https://login.weixin.qq.com/cgi-bin/mmwebwx-bin/login?tip=%s&uuid=%s&_=%s' % (tip, self.uuid, int(time.time()))
+        url = 'https://login.weixin.qq.com/cgi-bin/mmwebwx-bin/login?tip=%s&uuid=%s&_=%s' % (
+            tip, self.uuid, int(time.time()))
         data = self._get(url)
         pm = re.search(r'window.code=(\d+);', data)
         code = pm.group(1)
 
-		if code == '201': return True
+        if code == '201':
+            return True
         elif code == '200':
             pm = re.search(r'window.redirect_uri="(\S+?)";', data)
             r_uri = pm.group(1) + '&fun=new'
@@ -197,7 +215,8 @@ class WebWeixin(object):
         return True
 
     def webwxinit(self):
-		url = self.base_uri + '/webwxinit?pass_ticket=%s&skey=%s&r=%s' % (self.pass_ticket, self.skey, int(time.time()))
+        url = self.base_uri + '/webwxinit?pass_ticket=%s&skey=%s&r=%s' % (
+            self.pass_ticket, self.skey, int(time.time()))
         params = {
             'BaseRequest': self.BaseRequest
         }
@@ -205,12 +224,14 @@ class WebWeixin(object):
         self.SyncKey = dic['SyncKey']
         self.User = dic['User']
         # synckey for synccheck
-		self.synckey = '|'.join([ str(keyVal['Key']) + '_' + str(keyVal['Val']) for keyVal in self.SyncKey['List'] ])
+        self.synckey = '|'.join(
+            [str(keyVal['Key']) + '_' + str(keyVal['Val']) for keyVal in self.SyncKey['List']])
 
         return dic['BaseResponse']['Ret'] == 0
 
     def webwxstatusnotify(self):
-		url = self.base_uri + '/webwxstatusnotify?lang=zh_CN&pass_ticket=%s' % (self.pass_ticket)
+        url = self.base_uri + \
+            '/webwxstatusnotify?lang=zh_CN&pass_ticket=%s' % (self.pass_ticket)
         params = {
             'BaseRequest': self.BaseRequest,
             "Code": 3,
@@ -225,7 +246,8 @@ class WebWeixin(object):
     def webwxgetcontact(self):
         SpecialUsers = self.SpecialUsers
         print self.base_uri
-		url = self.base_uri + '/webwxgetcontact?pass_ticket=%s&skey=%s&r=%s' % (self.pass_ticket, self.skey, int(time.time()))
+        url = self.base_uri + '/webwxgetcontact?pass_ticket=%s&skey=%s&r=%s' % (
+            self.pass_ticket, self.skey, int(time.time()))
         dic = self._post(url, {})
 
         self.MemberCount = dic['MemberCount']
@@ -253,7 +275,9 @@ class WebWeixin(object):
         return True
 
     def webwxbatchgetcontact(self):
-		url = self.base_uri + '/webwxbatchgetcontact?type=ex&r=%s&pass_ticket=%s' % (int(time.time()), self.pass_ticket)
+        url = self.base_uri + \
+            '/webwxbatchgetcontact?type=ex&r=%s&pass_ticket=%s' % (
+                int(time.time()), self.pass_ticket)
         params = {
             'BaseRequest': self.BaseRequest,
             "Count": len(self.GroupList),
@@ -274,7 +298,9 @@ class WebWeixin(object):
         return True
 
     def getNameById(self, id):
-		url = self.base_uri + '/webwxbatchgetcontact?type=ex&r=%s&pass_ticket=%s' % (int(time.time()), self.pass_ticket)
+        url = self.base_uri + \
+            '/webwxbatchgetcontact?type=ex&r=%s&pass_ticket=%s' % (
+                int(time.time()), self.pass_ticket)
         params = {
             'BaseRequest': self.BaseRequest,
             "Count": 1,
@@ -298,7 +324,8 @@ class WebWeixin(object):
         for host in SyncHost:
             self.syncHost = host
             [retcode, selector] = self.synccheck()
-			if retcode == '0': return True
+            if retcode == '0':
+                return True
         return False
 
     def synccheck(self):
@@ -311,15 +338,19 @@ 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.urlencode(params)
         data = self._get(url)
-		pm = re.search(r'window.synccheck={retcode:"(\d+)",selector:"(\d+)"}', data)
+        pm = re.search(
+            r'window.synccheck={retcode:"(\d+)",selector:"(\d+)"}', data)
         retcode = pm.group(1)
         selector = pm.group(2)
         return [retcode, selector]
 
     def webwxsync(self):
-		url = self.base_uri + '/webwxsync?sid=%s&skey=%s&pass_ticket=%s' % (self.sid, self.skey, self.pass_ticket)
+        url = self.base_uri + \
+            '/webwxsync?sid=%s&skey=%s&pass_ticket=%s' % (
+                self.sid, self.skey, self.pass_ticket)
         params = {
             'BaseRequest': self.BaseRequest,
             'SyncKey': self.SyncKey,
@@ -332,12 +363,15 @@ class WebWeixin(object):
 
         if dic['BaseResponse']['Ret'] == 0:
             self.SyncKey = dic['SyncKey']
-			self.synckey = '|'.join([ str(keyVal['Key']) + '_' + str(keyVal['Val']) for keyVal in self.SyncKey['List'] ])
+            self.synckey = '|'.join(
+                [str(keyVal['Key']) + '_' + str(keyVal['Val']) for keyVal in self.SyncKey['List']])
         return dic
 
     def webwxsendmsg(self, word, to='filehelper'):
-		url = self.base_uri + '/webwxsendmsg?pass_ticket=%s' % (self.pass_ticket)
-		clientMsgId = str(int(time.time()*1000)) + str(random.random())[:5].replace('.','')
+        url = self.base_uri + \
+            '/webwxsendmsg?pass_ticket=%s' % (self.pass_ticket)
+        clientMsgId = str(int(time.time() * 1000)) + \
+            str(random.random())[:5].replace('.', '')
         params = {
             'BaseRequest': self.BaseRequest,
             'Msg': {
@@ -374,13 +408,14 @@ class WebWeixin(object):
         # PassTicket
         pass_ticket = self.pass_ticket
         # clientMediaId
-		client_media_id = str(int(time.time()*1000)) + str(random.random())[:5].replace('.','')
+        client_media_id = str(int(time.time() * 1000)) + \
+            str(random.random())[:5].replace('.', '')
         # webwx_data_ticket
         webwx_data_ticket = ''
         for item in self.cookie:
             if item.name == 'webwx_data_ticket':
                 webwx_data_ticket = item.value
-				break;
+                break
         if (webwx_data_ticket == ''):
             return "None Fuck Cookie"
 
@@ -431,7 +466,8 @@ class WebWeixin(object):
 
     def webwxsendmsgimg(self, user_id, media_id):
         url = 'https://wx2.qq.com/cgi-bin/mmwebwx-bin/webwxsendmsgimg?fun=async&f=json&pass_ticket=%s' % self.pass_ticket
-		clientMsgId = str(int(time.time()*1000)) + str(random.random())[:5].replace('.','')
+        clientMsgId = str(int(time.time() * 1000)) + \
+            str(random.random())[:5].replace('.', '')
         data_json = {
             "BaseRequest": self.BaseRequest,
             "Msg": {
@@ -457,36 +493,43 @@ class WebWeixin(object):
                 os.makedirs(dirName)
             fn = os.path.join(dirName, filename)
             logging.debug('Saved file: %s' % fn)
-			with open(fn, 'wb') as f: f.write(data); f.close()
+            with open(fn, 'wb') as f:
+                f.write(data)
+                f.close()
         return fn
 
     def webwxgeticon(self, id):
-		url = self.base_uri + '/webwxgeticon?username=%s&skey=%s' % (id, self.skey)
+        url = self.base_uri + \
+            '/webwxgeticon?username=%s&skey=%s' % (id, self.skey)
         data = self._get(url)
         fn = 'img_' + id + '.jpg'
         return self._saveFile(fn, data, 'webwxgeticon')
 
     def webwxgetheadimg(self, id):
-		url = self.base_uri + '/webwxgetheadimg?username=%s&skey=%s' % (id, self.skey)
+        url = self.base_uri + \
+            '/webwxgetheadimg?username=%s&skey=%s' % (id, self.skey)
         data = self._get(url)
         fn = 'img_' + id + '.jpg'
         return self._saveFile(fn, data, 'webwxgetheadimg')
 
     def webwxgetmsgimg(self, msgid):
-		url = self.base_uri + '/webwxgetmsgimg?MsgID=%s&skey=%s' % (msgid, self.skey)
+        url = self.base_uri + \
+            '/webwxgetmsgimg?MsgID=%s&skey=%s' % (msgid, self.skey)
         data = self._get(url)
         fn = 'img_' + msgid + '.jpg'
         return self._saveFile(fn, data, 'webwxgetmsgimg')
 
     # Not work now for weixin haven't support this API
     def webwxgetvideo(self, msgid):
-		url = self.base_uri + '/webwxgetvideo?msgid=%s&skey=%s' % (msgid, self.skey)
+        url = self.base_uri + \
+            '/webwxgetvideo?msgid=%s&skey=%s' % (msgid, self.skey)
         data = self._get(url, api='webwxgetvideo')
         fn = 'video_' + msgid + '.mp4'
         return self._saveFile(fn, data, 'webwxgetvideo')
 
     def webwxgetvoice(self, msgid):
-		url = self.base_uri + '/webwxgetvoice?msgid=%s&skey=%s' % (msgid, self.skey)
+        url = self.base_uri + \
+            '/webwxgetvoice?msgid=%s&skey=%s' % (msgid, self.skey)
         data = self._get(url)
         fn = 'voice_' + msgid + '.mp3'
         return self._saveFile(fn, data, 'webwxgetvoice')
@@ -510,7 +553,8 @@ class WebWeixin(object):
 
     def getUserRemarkName(self, id):
         name = '未知群' if id[:2] == '@@' else '陌生人'
-		if id == self.User['UserName']: return self.User['NickName']	# 自己
+        if id == self.User['UserName']:
+            return self.User['NickName']  # 自己
 
         if id[:2] == '@@':
             # 群
@@ -519,23 +563,28 @@ class WebWeixin(object):
             # 特殊账号
             for member in self.SpecialUsersList:
                 if member['UserName'] == id:
-					name = member['RemarkName'] if member['RemarkName'] else member['NickName']
+                    name = member['RemarkName'] if member[
+                        'RemarkName'] else member['NickName']
 
             # 公众号或服务号
             for member in self.PublicUsersList:
                 if member['UserName'] == id:
-					name = member['RemarkName'] if member['RemarkName'] else member['NickName']
+                    name = member['RemarkName'] if member[
+                        'RemarkName'] else member['NickName']
 
             # 直接联系人
             for member in self.ContactList:
                 if member['UserName'] == id:
-					name = member['RemarkName'] if member['RemarkName'] else member['NickName']
+                    name = member['RemarkName'] if member[
+                        'RemarkName'] else member['NickName']
             # 群友
             for member in self.GroupMemeberList:
                 if member['UserName'] == id:
-					name = member['DisplayName'] if member['DisplayName'] else member['NickName']
+                    name = member['DisplayName'] if member[
+                        'DisplayName'] else member['NickName']
 
-		if name == '未知群' or name == '陌生人': logging.debug(id)
+        if name == '未知群' or name == '陌生人':
+            logging.debug(id)
         return name
 
     def getUSerID(self, name):
@@ -557,7 +606,8 @@ class WebWeixin(object):
         if msg['raw_msg']:
             srcName = self.getUserRemarkName(msg['raw_msg']['FromUserName'])
             dstName = self.getUserRemarkName(msg['raw_msg']['ToUserName'])
-			content = msg['raw_msg']['Content'].replace('&lt;','<').replace('&gt;','>')
+            content = msg['raw_msg']['Content'].replace(
+                '&lt;', '<').replace('&gt;', '>')
             message_id = msg['raw_msg']['MsgId']
 
             if content.find('http://weixin.qq.com/cgi-bin/redirectforward?args=') != -1:
@@ -568,9 +618,11 @@ class WebWeixin(object):
                 url = tree.xpath('//html/body/div/img')[0].attrib['src']
 
                 for item in urlparse(url).query.split('&'):
-					if item.split('=')[0] == 'center': loc = item.split('=')[-1:]
+                    if item.split('=')[0] == 'center':
+                        loc = item.split('=')[-1:]
 
-				content = '%s 发送了一个 位置消息 - 我在 [%s](%s) @ %s]' % (srcName, pos, url, loc)
+                content = '%s 发送了一个 位置消息 - 我在 [%s](%s) @ %s]' % (
+                    srcName, pos, url, loc)
 
             if msg['raw_msg']['ToUserName'] == 'filehelper':
                 # 文件传输助手
@@ -592,18 +644,21 @@ class WebWeixin(object):
                 dstName = 'GROUP'
 
             # 收到了红包
-			if content == '收到红包，请在手机上查看': msg['message'] = content
+            if content == '收到红包，请在手机上查看':
+                msg['message'] = content
 
             # 指定了消息内容
-			if 'message' in msg.keys(): content = msg['message']
-
+            if 'message' in msg.keys():
+                content = msg['message']
 
         if groupName != None:
             print '%s |%s| %s -> %s: %s' % (message_id, groupName.strip(), srcName.strip(), dstName.strip(), content.replace('<br/>', '\n'))
-			logging.info('%s |%s| %s -> %s: %s' % (message_id, groupName.strip(), srcName.strip(), dstName.strip(), content.replace('<br/>','\n')))
+            logging.info('%s |%s| %s -> %s: %s' % (message_id, groupName.strip(),
+                                                   srcName.strip(), dstName.strip(), content.replace('<br/>', '\n')))
         else:
             print '%s %s -> %s: %s' % (message_id, srcName.strip(), dstName.strip(), content.replace('<br/>', '\n'))
-			logging.info('%s %s -> %s: %s' % (message_id, srcName.strip(), dstName.strip(), content.replace('<br/>','\n')))
+            logging.info('%s %s -> %s: %s' % (message_id, srcName.strip(),
+                                              dstName.strip(), content.replace('<br/>', '\n')))
 
     def handleMsg(self, r):
         for msg in r['AddMsgList']:
@@ -612,7 +667,8 @@ class WebWeixin(object):
 
             if self.DEBUG:
                 fn = 'msg' + str(int(random.random() * 1000)) + '.json'
-				with open(fn, 'w') as f: f.write(json.dumps(msg))
+                with open(fn, 'w') as f:
+                    f.write(json.dumps(msg))
                 print '[*] 该消息已储存到文件: ' + fn
                 logging.debug('[*] 该消息已储存到文件: %s' % (fn))
 
@@ -634,12 +690,14 @@ class WebWeixin(object):
                         logging.info('自动回复失败')
             elif msgType == 3:
                 image = self.webwxgetmsgimg(msgid)
-				raw_msg = { 'raw_msg': msg, 'message': '%s 发送了一张图片: %s' % (name, image) }
+                raw_msg = {'raw_msg': msg,
+                           'message': '%s 发送了一张图片: %s' % (name, image)}
                 self._showMsg(raw_msg)
                 self._safe_open(image)
             elif msgType == 34:
                 voice = self.webwxgetvoice(msgid)
-				raw_msg = { 'raw_msg': msg, 'message': '%s 发了一段语音: %s' % (name, voice) }
+                raw_msg = {'raw_msg': msg,
+                           'message': '%s 发了一段语音: %s' % (name, voice)}
                 self._showMsg(raw_msg)
                 self._safe_open(voice)
             elif msgType == 42:
@@ -651,11 +709,13 @@ class WebWeixin(object):
                 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)) }
+                raw_msg = {'raw_msg': msg, 'message': '%s 发送了一张名片: %s' % (
+                    name.strip(), json.dumps(info))}
                 self._showMsg(raw_msg)
             elif msgType == 47:
                 url = self._searchContent('cdnurl', content)
-				raw_msg = { 'raw_msg': msg, 'message': '%s 发了一个动画表情，点击下面链接查看: %s' % (name, url) }
+                raw_msg = {'raw_msg': msg,
+                           'message': '%s 发了一个动画表情，点击下面链接查看: %s' % (name, url)}
                 self._showMsg(raw_msg)
                 self._safe_open(url)
             elif msgType == 49:
@@ -674,22 +734,26 @@ class WebWeixin(object):
                     'url': msg['Url'],
                     'appname': self._searchContent('appname', content, 'xml')
                 }
-				raw_msg = { 'raw_msg': msg, 'message': '%s 分享了一个%s: %s' % (name, appMsgType[msg['AppMsgType']], json.dumps(card)) }
+                raw_msg = {'raw_msg': msg, 'message': '%s 分享了一个%s: %s' % (
+                    name, appMsgType[msg['AppMsgType']], json.dumps(card))}
                 self._showMsg(raw_msg)
             elif msgType == 51:
                 raw_msg = {'raw_msg': msg, 'message': '[*] 成功获取联系人信息'}
                 self._showMsg(raw_msg)
             elif msgType == 62:
                 video = self.webwxgetvideo(msgid)
-				raw_msg = { 'raw_msg': msg, 'message': '%s 发了一段小视频: %s' % (name, video) }
+                raw_msg = {'raw_msg': msg,
+                           'message': '%s 发了一段小视频: %s' % (name, video)}
                 self._showMsg(raw_msg)
                 self._safe_open(video)
             elif msgType == 10002:
                 raw_msg = {'raw_msg': msg, 'message': '%s 撤回了一条消息' % name}
                 self._showMsg(raw_msg)
             else:
-				logging.debug('[*] 该消息类型为: %d，可能是表情，图片, 链接或红包: %s' % (msg['MsgType'], json.dumps(msg)))				
-				raw_msg = { 'raw_msg': msg, 'message': '[*] 该消息类型为: %d，可能是表情，图片, 链接或红包' % msg['MsgType'] }
+                logging.debug('[*] 该消息类型为: %d，可能是表情，图片, 链接或红包: %s' %
+                              (msg['MsgType'], json.dumps(msg)))
+                raw_msg = {
+                    'raw_msg': msg, 'message': '[*] 该消息类型为: %d，可能是表情，图片, 链接或红包' % msg['MsgType']}
                 self._showMsg(raw_msg)
 
     def listenMsgMode(self):
@@ -701,7 +765,8 @@ class WebWeixin(object):
         while True:
             self.lastCheckTs = time.time()
             [retcode, selector] = self.synccheck()
-			if self.DEBUG: print 'retcode: %s, selector: %s' % (retcode, selector)
+            if self.DEBUG:
+                print 'retcode: %s, selector: %s' % (retcode, selector)
             logging.debug('retcode: %s, selector: %s' % (retcode, selector))
             if retcode == '1100':
                 print '[*] 你在手机上登出了微信，债见'
@@ -714,7 +779,8 @@ class WebWeixin(object):
             elif retcode == '0':
                 if selector == '2':
                     r = self.webwxsync()
-					if r is not None: self.handleMsg(r)
+                    if r is not None:
+                        self.handleMsg(r)
                 elif selector == '6':
                     # TODO
                     redEnvelope += 1
@@ -727,7 +793,8 @@ class WebWeixin(object):
                     r = self.webwxsync()
                 elif selector == '0':
                     time.sleep(1)
-			if (time.time() - self.lastCheckTs) <= 20: time.sleep(time.time() - self.lastCheckTs)
+            if (time.time() - self.lastCheckTs) <= 20:
+                time.sleep(time.time() - self.lastCheckTs)
 
     def sendMsg(self, name, word, isfile=False):
         id = self.getUSerID(name)
@@ -755,7 +822,8 @@ class WebWeixin(object):
 
     def sendMsgToAll(self, word):
         for contact in self.ContactList:
-			name = contact['RemarkName'] if contact['RemarkName'] else contact['NickName']
+            name = contact['RemarkName'] if contact[
+                'RemarkName'] else contact['NickName']
             id = contact['UserName']
             self._echo('-> ' + name + ': ' + word)
             if self.webwxsendmsg(word, id):
@@ -774,10 +842,15 @@ class WebWeixin(object):
 
     @catchKeyboardInterrupt
     def start(self):
-		self._echo('[*] 微信网页版 ... 开动'); print; logging.debug('[*] 微信网页版 ... 开动')
+        self._echo('[*] 微信网页版 ... 开动')
+        print
+        logging.debug('[*] 微信网页版 ... 开动')
         while True:
             self._run('[*] 正在获取 uuid ... ', self.getUUID)
-			self._echo('[*] 正在获取二维码 ... 成功'); print; logging.debug('[*] 微信网页版 ... 开动'); self.genQRCode()
+            self._echo('[*] 正在获取二维码 ... 成功')
+            print
+            logging.debug('[*] 微信网页版 ... 开动')
+            self.genQRCode()
             print '[*] 请使用微信扫描二维码以登录 ... '
             if not self.waitForLogin():
                 continue
@@ -790,11 +863,16 @@ class WebWeixin(object):
         self._run('[*] 微信初始化 ... ', self.webwxinit)
         self._run('[*] 开启状态通知 ... ', self.webwxstatusnotify)
         self._run('[*] 获取联系人 ... ', self.webwxgetcontact)
-		self._echo('[*] 应有 %s 个联系人，读取到联系人 %d 个' % (self.MemberCount, len(self.MemberList))); print
-		self._echo('[*] 共有 %d 个群 | %d 个直接联系人 | %d 个特殊账号 ｜ %d 公众号或服务号' % (len(self.GroupList), len(self.ContactList), len(self.SpecialUsersList), len(self.PublicUsersList) )); print
+        self._echo('[*] 应有 %s 个联系人，读取到联系人 %d 个' %
+                   (self.MemberCount, len(self.MemberList)))
+        print
+        self._echo('[*] 共有 %d 个群 | %d 个直接联系人 | %d 个特殊账号 ｜ %d 公众号或服务号' % (len(self.GroupList),
+                                                                         len(self.ContactList), len(self.SpecialUsersList), len(self.PublicUsersList)))
+        print
         self._run('[*] 获取群 ... ', self.webwxbatchgetcontact)
         logging.debug('[*] 微信网页版 ... 开动')
-		if self.DEBUG: print self
+        if self.DEBUG:
+            print self
         logging.debug(self)
 
         if self.interactive and raw_input('[*] 是否开启自动回复模式(y/n): ') == 'y':
@@ -817,8 +895,10 @@ class WebWeixin(object):
                 exit()
             elif text[:2] == '->':
                 [name, word] = text[2:].split(':')
-				if name == 'all': self.sendMsgToAll(word)
-				else: self.sendMsg(name, word)
+                if name == 'all':
+                    self.sendMsgToAll(word)
+                else:
+                    self.sendMsg(name, word)
             elif text[:3] == 'm->':
                 [name, file] = text[3:].split(':')
                 self.sendMsg(name, file, True)
@@ -840,8 +920,14 @@ class WebWeixin(object):
 
     def _run(self, str, func, *args):
         self._echo(str)
-		if func(*args): print '成功'; logging.debug('%s... 成功' % (str))
-		else: print('失败\n[*] 退出程序'); logging.debug('%s... 失败' % (str)); logging.debug('[*] 退出程序'); exit()
+        if func(*args):
+            print '成功'
+            logging.debug('%s... 成功' % (str))
+        else:
+            print('失败\n[*] 退出程序')
+            logging.debug('%s... 失败' % (str))
+            logging.debug('[*] 退出程序')
+            exit()
 
     def _echo(self, str):
         sys.stdout.write(str)
@@ -861,7 +947,8 @@ class WebWeixin(object):
         self._printQR(mat)  # qr.print_tty() or qr.print_ascii()
 
     def _transcoding(self, data):
-		if not data: return data
+        if not data:
+            return data
         result = None
         if type(data) == unicode:
             result = data
@@ -872,8 +959,10 @@ class WebWeixin(object):
     def _get(self, url, api=None):
         request = urllib2.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-')
+        if api == 'webwxgetvoice':
+            request.add_header('Range', 'bytes=0-')
+        if api == 'webwxgetvideo':
+            request.add_header('Range', 'bytes=0-')
         response = urllib2.urlopen(request)
         data = response.read()
         logging.debug(url)
@@ -882,12 +971,14 @@ class WebWeixin(object):
     def _post(self, url, params, jsonfmt=True):
         if jsonfmt:
             request = urllib2.Request(url=url, data=json.dumps(params))
-			request.add_header('ContentType', 'application/json; charset=UTF-8')
+            request.add_header(
+                'ContentType', 'application/json; charset=UTF-8')
         else:
             request = urllib2.Request(url=url, data=urllib.urlencode(params))
         response = urllib2.urlopen(request)
         data = response.read()
-		if jsonfmt: return json.loads(data, object_hook=_decode_dict)
+        if jsonfmt:
+            return json.loads(data, object_hook=_decode_dict)
         return data
 
     def _xiaodoubi(self, word):
@@ -900,23 +991,32 @@ class WebWeixin(object):
 
     def _simsimi(self, word):
         key = ''
-		url = 'http://sandbox.api.simsimi.com/request.p?key=%s&lc=ch&ft=0.0&text=%s' % (key, word)
+        url = 'http://sandbox.api.simsimi.com/request.p?key=%s&lc=ch&ft=0.0&text=%s' % (
+            key, word)
         r = requests.get(url)
         ans = r.json()
-		if ans['result'] == '100': return ans['response']
-		else: return '你在说什么，风太大听不清列'
+        if ans['result'] == '100':
+            return ans['response']
+        else:
+            return '你在说什么，风太大听不清列'
 
     def _searchContent(self, key, content, fmat='attr'):
         if fmat == 'attr':
             pm = re.search(key + '\s?=\s?"([^"<]+)"', content)
-			if pm: return pm.group(1)
+            if pm:
+                return pm.group(1)
         elif fmat == 'xml':
             pm = re.search('<{0}>([^<]+)</{0}>'.format(key), content)
-			if not pm: pm = re.search('<{0}><\!\[CDATA\[(.*?)\]\]></{0}>'.format(key),content)
-			if pm: return pm.group(1)
+            if not pm:
+                pm = re.search(
+                    '<{0}><\!\[CDATA\[(.*?)\]\]></{0}>'.format(key), content)
+            if pm:
+                return pm.group(1)
         return '未知'
 
+
 class UnicodeStreamFilter:
+
     def __init__(self, target):
         self.target = target
         self.encoding = 'utf-8'