weixin bot demo
This commit is contained in:
urinx
@@ -1,2 +1,372 @@
|
|||||||
# WeixinBot
|
# WeixinBot [](http://github.com/Urinx/WeixinBot) [](http://github.com/Urinx/WeixinBot/fork) 
|
||||||
|
|
||||||
网页版微信API，包含终端版微信及微信机器人
|
网页版微信API，包含终端版微信及微信机器人
|
||||||
|
|
||||||
|
### Demo
|
||||||
|
为了运行 `weixin.py` 示例脚本，你需要有安装 `qrcode` 包，你可以通过 `pip install qrcode` 来安装。
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
按照操作指示在手机微信上扫描二维码然后登录，你可以选择是否开启自动回复模式。
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
开启自动回复模式后，如果接收到的是文字消息就会自动回复，包括群消息。
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
现在，名片，链接，动画表情和地址位置消息都可以正常接收。
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
**目前支持的命令**：
|
||||||
|
|
||||||
|
`->[昵称或ID]:[内容]` 给好友发送消息
|
||||||
|
|
||||||
|
`m->[昵称或ID]:[文件路径]` 给好友发送文件中的内容
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
`f->[昵称或ID]:[文件路径]` 给好友发送文件
|
||||||
|
|
||||||
|
`i->[昵称或ID]:[图片路径]` 给好友发送图片
|
||||||
|
|
||||||
|
`quit` 退出程序
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
注意，以上命令均不包含方括号。
|
||||||
|
|
||||||
|
### Web Weixin Pipeline
|
||||||
|
|
||||||
|
```
|
||||||
|
+--------------+ +---------------+ +---------------+
|
||||||
|
| | | | | |
|
||||||
|
| Get UUID | | Get Contact | | Status Notify |
|
||||||
|
| | | | | |
|
||||||
|
+-------+------+ +-------^-------+ +-------^-------+
|
||||||
|
| | |
|
||||||
|
| +-------+ +--------+
|
||||||
|
| | |
|
||||||
|
+-------v------+ +-----+--+------+ +--------------+
|
||||||
|
| | | | | |
|
||||||
|
| Get QRCode | | Weixin Init +------> Sync Check <----+
|
||||||
|
| | | | | | |
|
||||||
|
+-------+------+ +-------^-------+ +-------+------+ |
|
||||||
|
| | | |
|
||||||
|
| | +-----------+
|
||||||
|
| | |
|
||||||
|
+-------v------+ +-------+--------+ +-------v-------+
|
||||||
|
| | Confirm Login | | | |
|
||||||
|
+------> Login +---------------> New Login Page | | Weixin Sync |
|
||||||
|
| | | | | | |
|
||||||
|
| +------+-------+ +----------------+ +---------------+
|
||||||
|
| |
|
||||||
|
|QRCode Scaned|
|
||||||
|
+-------------+
|
||||||
|
```
|
||||||
|
|
||||||
|
### Web Weixin API
|
||||||
|
|
||||||
|
#### 登录
|
||||||
|
|
||||||
|
| API | 获取 UUID |
|
||||||
|
| --- | --------- |
|
||||||
|
| url | https://login.weixin.qq.com/jslogin |
|
||||||
|
| method | POST |
|
||||||
|
| data | URL Encode |
|
||||||
|
| params | **appid**: `应用ID` <br> **fun**: new `应用类型` <br> **lang**: zh\_CN `语言` <br> **_**: `时间戳` |
|
||||||
|
|
||||||
|
返回数据(String):
|
||||||
|
```
|
||||||
|
window.QRLogin.code = 200; window.QRLogin.uuid = "xxx"
|
||||||
|
```
|
||||||
|
|
||||||
|
| API | 生成二维码 |
|
||||||
|
| --- | --------- |
|
||||||
|
| url | https://login.weixin.qq.com/l/ `uuid` |
|
||||||
|
|
||||||
|
| API | 二维码扫描登录 |
|
||||||
|
| --- | --------- |
|
||||||
|
| url | https://login.weixin.qq.com/cgi-bin/mmwebwx-bin/login |
|
||||||
|
| method | GET |
|
||||||
|
| params | **tip**: 1 `未扫描` 0 `已扫描` <br> **uuid**: xxx <br> **_**: `时间戳` |
|
||||||
|
|
||||||
|
返回数据(String):
|
||||||
|
```
|
||||||
|
window.code=xxx;
|
||||||
|
|
||||||
|
xxx:
|
||||||
|
408 登陆超时
|
||||||
|
201 扫描成功
|
||||||
|
200 确认登录
|
||||||
|
|
||||||
|
当返回200时，还会有
|
||||||
|
window.redirect_uri="https://wx.qq.com/cgi-bin/mmwebwx-bin/webwxnewloginpage?ticket=xxx&uuid=xxx&lang=xxx&scan=xxx";
|
||||||
|
```
|
||||||
|
|
||||||
|
| API | webwxnewloginpage |
|
||||||
|
| --- | --------- |
|
||||||
|
| url | https://wx.qq.com/cgi-bin/mmwebwx-bin/webwxnewloginpage |
|
||||||
|
| method | GET |
|
||||||
|
| params | **ticket**: xxx <br> **uuid**: xxx <br> **lang**: zh_CN `语言` <br> **scan**: xxx <br> **fun**: new |
|
||||||
|
|
||||||
|
返回数据(XML):
|
||||||
|
```
|
||||||
|
<error>
|
||||||
|
<ret>0</ret>
|
||||||
|
<message>OK</message>
|
||||||
|
<skey>xxx</skey>
|
||||||
|
<wxsid>xxx</wxsid>
|
||||||
|
<wxuin>xxx</wxuin>
|
||||||
|
<pass_ticket>xxx</pass_ticket>
|
||||||
|
<isgrayscale>1</isgrayscale>
|
||||||
|
</error>
|
||||||
|
```
|
||||||
|
|
||||||
|
#### 微信初始化
|
||||||
|
|
||||||
|
| API | webwxinit |
|
||||||
|
| --- | --------- |
|
||||||
|
| url | https://wx.qq.com/cgi-bin/mmwebwx-bin/webwxinit?pass_ticket=xxx&skey=xxx&r=xxx |
|
||||||
|
| method | POST |
|
||||||
|
| data | JSON |
|
||||||
|
| header | ContentType: application/json; charset=UTF-8 |
|
||||||
|
| params | { <br> BaseRequest: { <br> Uin: xxx, <br> Sid: xxx, <br> Skey: xxx, <br> DeviceID: xxx, <br> } <br> } |
|
||||||
|
|
||||||
|
返回数据(JSON):
|
||||||
|
```
|
||||||
|
{
|
||||||
|
"BaseResponse": {
|
||||||
|
"Ret": 0,
|
||||||
|
"ErrMsg": ""
|
||||||
|
},
|
||||||
|
"Count": 11,
|
||||||
|
"ContactList": [...],
|
||||||
|
"SyncKey": {
|
||||||
|
"Count": 4,
|
||||||
|
"List": [
|
||||||
|
{
|
||||||
|
"Key": 1,
|
||||||
|
"Val": 635705559
|
||||||
|
},
|
||||||
|
...
|
||||||
|
]
|
||||||
|
},
|
||||||
|
"User": {
|
||||||
|
"Uin": xxx,
|
||||||
|
"UserName": xxx,
|
||||||
|
"NickName": xxx,
|
||||||
|
"HeadImgUrl": xxx,
|
||||||
|
"RemarkName": "",
|
||||||
|
"PYInitial": "",
|
||||||
|
"PYQuanPin": "",
|
||||||
|
"RemarkPYInitial": "",
|
||||||
|
"RemarkPYQuanPin": "",
|
||||||
|
"HideInputBarFlag": 0,
|
||||||
|
"StarFriend": 0,
|
||||||
|
"Sex": 1,
|
||||||
|
"Signature": "Apt-get install B",
|
||||||
|
"AppAccountFlag": 0,
|
||||||
|
"VerifyFlag": 0,
|
||||||
|
"ContactFlag": 0,
|
||||||
|
"WebWxPluginSwitch": 0,
|
||||||
|
"HeadImgFlag": 1,
|
||||||
|
"SnsFlag": 17
|
||||||
|
},
|
||||||
|
"ChatSet": xxx,
|
||||||
|
"SKey": xxx,
|
||||||
|
"ClientVersion": 369297683,
|
||||||
|
"SystemTime": 1453124908,
|
||||||
|
"GrayScale": 1,
|
||||||
|
"InviteStartCount": 40,
|
||||||
|
"MPSubscribeMsgCount": 2,
|
||||||
|
"MPSubscribeMsgList": [...],
|
||||||
|
"ClickReportInterval": 600000
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
| API | webwxstatusnotify |
|
||||||
|
| --- | --------- |
|
||||||
|
| url | https://wx.qq.com/cgi-bin/mmwebwx-bin/webwxstatusnotify?lang=zh_CN&pass_ticket=xxx |
|
||||||
|
| method | POST |
|
||||||
|
| data | JSON |
|
||||||
|
| header | ContentType: application/json; charset=UTF-8 |
|
||||||
|
| params | { <br> BaseRequest: { Uin: xxx, Sid: xxx, Skey: xxx, DeviceID: xxx }, <br> Code: 3, <br> FromUserName: `自己ID`, <br> ToUserName: `自己ID`, <br> ClientMsgId: `时间戳` <br> } |
|
||||||
|
|
||||||
|
返回数据(JSON):
|
||||||
|
```
|
||||||
|
{
|
||||||
|
"BaseResponse": {
|
||||||
|
"Ret": 0,
|
||||||
|
"ErrMsg": ""
|
||||||
|
},
|
||||||
|
...
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
#### 获取联系人信息
|
||||||
|
|
||||||
|
| API | webwxgetcontact |
|
||||||
|
| --- | --------- |
|
||||||
|
| url | https://wx.qq.com/cgi-bin/mmwebwx-bin//webwxgetcontact?pass_ticket=xxx&skey=xxx&r=xxx |
|
||||||
|
| method | POST |
|
||||||
|
| data | JSON |
|
||||||
|
| header | ContentType: application/json; charset=UTF-8 |
|
||||||
|
|
||||||
|
返回数据(JSON):
|
||||||
|
```
|
||||||
|
{
|
||||||
|
"BaseResponse": {
|
||||||
|
"Ret": 0,
|
||||||
|
"ErrMsg": ""
|
||||||
|
},
|
||||||
|
"MemberCount": 334,
|
||||||
|
"MemberList": [
|
||||||
|
{
|
||||||
|
"Uin": 0,
|
||||||
|
"UserName": xxx,
|
||||||
|
"NickName": "Urinx",
|
||||||
|
"HeadImgUrl": xxx,
|
||||||
|
"ContactFlag": 3,
|
||||||
|
"MemberCount": 0,
|
||||||
|
"MemberList": [],
|
||||||
|
"RemarkName": "",
|
||||||
|
"HideInputBarFlag": 0,
|
||||||
|
"Sex": 0,
|
||||||
|
"Signature": "你好，我们是地球三体组织。在这里，你将感受到不一样的思维模式，以及颠覆常规的世界观。而我们的目标，就是以三体人的智慧，引领人类未来科学技术500年。",
|
||||||
|
"VerifyFlag": 8,
|
||||||
|
"OwnerUin": 0,
|
||||||
|
"PYInitial": "URINX",
|
||||||
|
"PYQuanPin": "Urinx",
|
||||||
|
"RemarkPYInitial": "",
|
||||||
|
"RemarkPYQuanPin": "",
|
||||||
|
"StarFriend": 0,
|
||||||
|
"AppAccountFlag": 0,
|
||||||
|
"Statues": 0,
|
||||||
|
"AttrStatus": 0,
|
||||||
|
"Province": "",
|
||||||
|
"City": "",
|
||||||
|
"Alias": "Urinxs",
|
||||||
|
"SnsFlag": 0,
|
||||||
|
"UniFriend": 0,
|
||||||
|
"DisplayName": "",
|
||||||
|
"ChatRoomId": 0,
|
||||||
|
"KeyWord": "gh_",
|
||||||
|
"EncryChatRoomId": ""
|
||||||
|
},
|
||||||
|
...
|
||||||
|
],
|
||||||
|
"Seq": 0
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
| API | webwxbatchgetcontact |
|
||||||
|
| --- | --------- |
|
||||||
|
| url | https://wx.qq.com/cgi-bin/mmwebwx-bin/webwxbatchgetcontact?type=ex&r=xxx&pass_ticket=xxx |
|
||||||
|
| method | POST |
|
||||||
|
| data | JSON |
|
||||||
|
| header | ContentType: application/json; charset=UTF-8 |
|
||||||
|
| params | { <br> BaseRequest: { Uin: xxx, Sid: xxx, Skey: xxx, DeviceID: xxx }, <br> Count: `群数量`, <br> List: [ <br> { UserName: `群ID`, EncryChatRoomId: "" }, <br> ... <br> ], <br> } |
|
||||||
|
|
||||||
|
返回数据(JSON)同上
|
||||||
|
|
||||||
|
#### 同步刷新
|
||||||
|
|
||||||
|
| API | synccheck |
|
||||||
|
| --- | --------- |
|
||||||
|
| url | https://webpush.weixin.qq.com/cgi-bin/mmwebwx-bin/synccheck |
|
||||||
|
| method | GET |
|
||||||
|
| data | URL Encode |
|
||||||
|
| params | **r**: `时间戳` <br> **sid**: xxx <br> **uin**: xxx <br> **skey**: xxx <br> **deviceid**: xxx <br> **synckey**: xxx <br> **_**: `时间戳` |
|
||||||
|
|
||||||
|
返回数据(String):
|
||||||
|
```
|
||||||
|
window.synccheck={retcode:"xxx",selector:"xxx"}
|
||||||
|
|
||||||
|
retcode:
|
||||||
|
0 正常
|
||||||
|
1100 登出微信
|
||||||
|
selector:
|
||||||
|
0 正常
|
||||||
|
2 新的消息
|
||||||
|
7 进入/离开聊天界面
|
||||||
|
```
|
||||||
|
|
||||||
|
| API | webwxsync |
|
||||||
|
| --- | --------- |
|
||||||
|
| url | https://wx.qq.com/cgi-bin/mmwebwx-bin/webwxsync?sid=xxx&skey=xxx&pass_ticket=xxx |
|
||||||
|
| method | POST |
|
||||||
|
| data | JSON |
|
||||||
|
| header | ContentType: application/json; charset=UTF-8 |
|
||||||
|
| params | { <br> BaseRequest: { Uin: xxx, Sid: xxx, Skey: xxx, DeviceID: xxx }, <br> SyncKey: xxx, <br> rr: `时间戳取反` <br> } |
|
||||||
|
|
||||||
|
返回数据(JSON):
|
||||||
|
```
|
||||||
|
{
|
||||||
|
'BaseResponse': {'ErrMsg': '', 'Ret': 0},
|
||||||
|
'SyncKey': {
|
||||||
|
'Count': 7,
|
||||||
|
'List': [
|
||||||
|
{'Val': 636214192, 'Key': 1},
|
||||||
|
...
|
||||||
|
]
|
||||||
|
},
|
||||||
|
'ContinueFlag': 0,
|
||||||
|
'AddMsgCount': 1,
|
||||||
|
'AddMsgList': [
|
||||||
|
{
|
||||||
|
'FromUserName': '',
|
||||||
|
'PlayLength': 0,
|
||||||
|
'RecommendInfo': {...},
|
||||||
|
'Content': "",
|
||||||
|
'StatusNotifyUserName': '',
|
||||||
|
'StatusNotifyCode': 5,
|
||||||
|
'Status': 3,
|
||||||
|
'VoiceLength': 0,
|
||||||
|
'ToUserName': '',
|
||||||
|
'ForwardFlag': 0,
|
||||||
|
'AppMsgType': 0,
|
||||||
|
'AppInfo': {'Type': 0, 'AppID': ''},
|
||||||
|
'Url': '',
|
||||||
|
'ImgStatus': 1,
|
||||||
|
'MsgType': 51,
|
||||||
|
'ImgHeight': 0,
|
||||||
|
'MediaId': '',
|
||||||
|
'FileName': '',
|
||||||
|
'FileSize': '',
|
||||||
|
...
|
||||||
|
},
|
||||||
|
...
|
||||||
|
],
|
||||||
|
'ModChatRoomMemberCount': 0,
|
||||||
|
'ModContactList': [],
|
||||||
|
'DelContactList': [],
|
||||||
|
'ModChatRoomMemberList': [],
|
||||||
|
'DelContactCount': 0,
|
||||||
|
...
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
#### 消息接口
|
||||||
|
|
||||||
|
| API | webwxsendmsg |
|
||||||
|
| --- | --------- |
|
||||||
|
| url | https://wx.qq.com/cgi-bin/mmwebwx-bin/webwxsendmsg?pass_ticket=xxx |
|
||||||
|
| method | POST |
|
||||||
|
| data | JSON |
|
||||||
|
| header | ContentType: application/json; charset=UTF-8 |
|
||||||
|
| params | { <br> BaseRequest: { Uin: xxx, Sid: xxx, Skey: xxx, DeviceID: xxx }, <br> Msg: { <br> Type: 1 `文字消息`, <br> Content: `要发送的消息`, <br> FromUserName: `自己ID`, <br> ToUserName: `好友ID`, <br> LocalID: `与clientMsgId相同`, <br> ClientMsgId: `时间戳左移4位随后补上4位随机数` <br> } <br> } |
|
||||||
|
|
||||||
|
返回数据(JSON):
|
||||||
|
```
|
||||||
|
{
|
||||||
|
"BaseResponse": {
|
||||||
|
"Ret": 0,
|
||||||
|
"ErrMsg": ""
|
||||||
|
},
|
||||||
|
...
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|||||||
Binary file not shown.
|
After Width: | Height: | Size: 304 KiB |
Binary file not shown.
|
After Width: | Height: | Size: 80 KiB |
Binary file not shown.
|
After Width: | Height: | Size: 48 KiB |
Binary file not shown.
|
After Width: | Height: | Size: 46 KiB |
Binary file not shown.
|
After Width: | Height: | Size: 72 KiB |
Binary file not shown.
|
After Width: | Height: | Size: 215 KiB |
Binary file not shown.
|
After Width: | Height: | Size: 12 KiB |
@@ -0,0 +1,460 @@
|
|||||||
|
#!/usr/bin/env python
|
||||||
|
# coding: utf-8
|
||||||
|
import qrcode
|
||||||
|
import urllib, urllib2
|
||||||
|
import cookielib
|
||||||
|
import requests
|
||||||
|
import xml.dom.minidom
|
||||||
|
import json
|
||||||
|
import time, re, sys, os, random
|
||||||
|
import multiprocessing
|
||||||
|
|
||||||
|
def catchKeyboardInterrupt(fn):
|
||||||
|
def wrapper(*args):
|
||||||
|
try:
|
||||||
|
return fn(*args)
|
||||||
|
except KeyboardInterrupt:
|
||||||
|
print '\n[*] 强制退出程序'
|
||||||
|
return wrapper
|
||||||
|
|
||||||
|
class WebWeixin(object):
|
||||||
|
def __str__(self):
|
||||||
|
description = \
|
||||||
|
"=========================\n" + \
|
||||||
|
"[#] Web Weixin\n" + \
|
||||||
|
"[#] Debug Mode: " + str(self.DEBUG) + "\n" + \
|
||||||
|
"[#] Uuid: " + self.uuid + "\n" + \
|
||||||
|
"[#] Uin: " + str(self.uin) + "\n" + \
|
||||||
|
"[#] Sid: " + self.sid + "\n" + \
|
||||||
|
"[#] Skey: " + self.skey + "\n" + \
|
||||||
|
"[#] DeviceId: " + self.deviceId + "\n" + \
|
||||||
|
"[#] PassTicket: " + self.pass_ticket + "\n" + \
|
||||||
|
"========================="
|
||||||
|
return description
|
||||||
|
|
||||||
|
def __init__(self):
|
||||||
|
self.DEBUG = False
|
||||||
|
self.uuid = ''
|
||||||
|
self.base_uri = ''
|
||||||
|
self.redirect_uri= ''
|
||||||
|
self.uin = ''
|
||||||
|
self.sid = ''
|
||||||
|
self.skey = ''
|
||||||
|
self.pass_ticket = ''
|
||||||
|
self.deviceId = 'e' + repr(random.random())[2:17]
|
||||||
|
self.BaseRequest = {}
|
||||||
|
self.synckey = ''
|
||||||
|
self.SyncKey = []
|
||||||
|
self.User = []
|
||||||
|
self.MemberList = []
|
||||||
|
self.ContactList = []
|
||||||
|
self.GroupList = []
|
||||||
|
self.autoReplyMode = False
|
||||||
|
|
||||||
|
opener = urllib2.build_opener(urllib2.HTTPCookieProcessor(cookielib.CookieJar()))
|
||||||
|
urllib2.install_opener(opener)
|
||||||
|
|
||||||
|
def getUUID(self):
|
||||||
|
url = 'https://login.weixin.qq.com/jslogin'
|
||||||
|
params = {
|
||||||
|
'appid': 'wx782c26e4c19acffb',
|
||||||
|
'fun': 'new',
|
||||||
|
'lang': 'zh_CN',
|
||||||
|
'_': int(time.time()),
|
||||||
|
}
|
||||||
|
data = self._post(url, params, False)
|
||||||
|
regx = r'window.QRLogin.code = (\d+); window.QRLogin.uuid = "(\S+?)"'
|
||||||
|
pm = re.search(regx, data)
|
||||||
|
if pm:
|
||||||
|
code = pm.group(1)
|
||||||
|
self.uuid = pm.group(2)
|
||||||
|
return code == '200'
|
||||||
|
return False
|
||||||
|
|
||||||
|
def genQRCode(self):
|
||||||
|
self._str2qr('https://login.weixin.qq.com/l/' + self.uuid)
|
||||||
|
|
||||||
|
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()))
|
||||||
|
data = self._get(url)
|
||||||
|
pm = re.search(r'window.code=(\d+);', data)
|
||||||
|
code = pm.group(1)
|
||||||
|
|
||||||
|
if code == '201': return True
|
||||||
|
elif code == '200':
|
||||||
|
pm = re.search(r'window.redirect_uri="(\S+?)";', data)
|
||||||
|
r_uri = pm.group(1) + '&fun=new'
|
||||||
|
self.redirect_uri = r_uri
|
||||||
|
self.base_uri = r_uri[:r_uri.rfind('/')]
|
||||||
|
return True
|
||||||
|
elif code == '408':
|
||||||
|
self._echo('[登陆超时] ')
|
||||||
|
else:
|
||||||
|
self._echo('[登陆异常] ')
|
||||||
|
return False
|
||||||
|
|
||||||
|
def login(self):
|
||||||
|
data = self._get(self.redirect_uri)
|
||||||
|
doc = xml.dom.minidom.parseString(data)
|
||||||
|
root = doc.documentElement
|
||||||
|
|
||||||
|
for node in root.childNodes:
|
||||||
|
if node.nodeName == 'skey':
|
||||||
|
self.skey = node.childNodes[0].data
|
||||||
|
elif node.nodeName == 'wxsid':
|
||||||
|
self.sid = node.childNodes[0].data
|
||||||
|
elif node.nodeName == 'wxuin':
|
||||||
|
self.uin = node.childNodes[0].data
|
||||||
|
elif node.nodeName == 'pass_ticket':
|
||||||
|
self.pass_ticket = node.childNodes[0].data
|
||||||
|
|
||||||
|
if '' in (self.skey, self.sid, self.uin, self.pass_ticket):
|
||||||
|
return False
|
||||||
|
|
||||||
|
self.BaseRequest = {
|
||||||
|
'Uin': int(self.uin),
|
||||||
|
'Sid': self.sid,
|
||||||
|
'Skey': self.skey,
|
||||||
|
'DeviceID': self.deviceId,
|
||||||
|
}
|
||||||
|
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()))
|
||||||
|
params = {
|
||||||
|
'BaseRequest': self.BaseRequest
|
||||||
|
}
|
||||||
|
dic = self._post(url, params)
|
||||||
|
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'] ])
|
||||||
|
|
||||||
|
return dic['BaseResponse']['Ret'] == 0
|
||||||
|
|
||||||
|
def webwxstatusnotify(self):
|
||||||
|
url = self.base_uri + '/webwxstatusnotify?lang=zh_CN&pass_ticket=%s' % (self.pass_ticket)
|
||||||
|
params = {
|
||||||
|
'BaseRequest': self.BaseRequest,
|
||||||
|
"Code": 3,
|
||||||
|
"FromUserName": self.User['UserName'],
|
||||||
|
"ToUserName": self.User['UserName'],
|
||||||
|
"ClientMsgId": int(time.time())
|
||||||
|
}
|
||||||
|
dic = self._post(url, params)
|
||||||
|
|
||||||
|
return dic['BaseResponse']['Ret'] == 0
|
||||||
|
|
||||||
|
def webwxgetcontact(self):
|
||||||
|
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.MemberList = dic['MemberList']
|
||||||
|
|
||||||
|
ContactList = self.MemberList[:]
|
||||||
|
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']
|
||||||
|
for i in xrange(len(ContactList) - 1, -1, -1):
|
||||||
|
Contact = ContactList[i]
|
||||||
|
if Contact['VerifyFlag'] & 8 != 0: # 公众号/服务号
|
||||||
|
ContactList.remove(Contact)
|
||||||
|
elif Contact['UserName'] in SpecialUsers: # 特殊账号
|
||||||
|
ContactList.remove(Contact)
|
||||||
|
elif Contact['UserName'].find('@@') != -1: # 群聊
|
||||||
|
self.GroupList.append(Contact)
|
||||||
|
ContactList.remove(Contact)
|
||||||
|
elif Contact['UserName'] == self.User['UserName']: # 自己
|
||||||
|
ContactList.remove(Contact)
|
||||||
|
self.ContactList = ContactList
|
||||||
|
|
||||||
|
return True
|
||||||
|
|
||||||
|
def webwxbatchgetcontact(self):
|
||||||
|
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),
|
||||||
|
"List": [ {"UserName": g['UserName'], "EncryChatRoomId":""} for g in self.GroupList ]
|
||||||
|
}
|
||||||
|
dic = self._post(url, params)
|
||||||
|
# blabla ...
|
||||||
|
return True
|
||||||
|
|
||||||
|
def synccheck(self):
|
||||||
|
params = {
|
||||||
|
'r': int(time.time()),
|
||||||
|
'sid': self.sid,
|
||||||
|
'uin': self.uin,
|
||||||
|
'skey': self.skey,
|
||||||
|
'deviceid': self.deviceId,
|
||||||
|
'synckey': self.synckey,
|
||||||
|
'_': int(time.time()),
|
||||||
|
}
|
||||||
|
url = 'https://webpush.weixin.qq.com/cgi-bin/mmwebwx-bin/synccheck?' + urllib.urlencode(params)
|
||||||
|
data = self._get(url)
|
||||||
|
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)
|
||||||
|
params = {
|
||||||
|
'BaseRequest': self.BaseRequest,
|
||||||
|
'SyncKey': self.SyncKey,
|
||||||
|
'rr': ~int(time.time())
|
||||||
|
}
|
||||||
|
dic = self._post(url, params)
|
||||||
|
if self.DEBUG: print dic
|
||||||
|
|
||||||
|
if dic['BaseResponse']['Ret'] == 0:
|
||||||
|
self.SyncKey = dic['SyncKey']
|
||||||
|
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('.','')
|
||||||
|
params = {
|
||||||
|
'BaseRequest': self.BaseRequest,
|
||||||
|
'Msg': {
|
||||||
|
"Type": 1,
|
||||||
|
"Content": self._transcoding(word),
|
||||||
|
"FromUserName": self.User['UserName'],
|
||||||
|
"ToUserName": to,
|
||||||
|
"LocalID": clientMsgId,
|
||||||
|
"ClientMsgId": clientMsgId
|
||||||
|
}
|
||||||
|
}
|
||||||
|
headers = {'content-type': 'application/json; charset=UTF-8'}
|
||||||
|
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
|
||||||
|
|
||||||
|
def getUserRemarkName(self, id):
|
||||||
|
name = u'这个人物名字未知'
|
||||||
|
for member in self.MemberList:
|
||||||
|
if member['UserName'] == id:
|
||||||
|
name = member['RemarkName'] if member['RemarkName'] else member['NickName']
|
||||||
|
return name.encode('utf-8')
|
||||||
|
|
||||||
|
def getUSerID(self, name):
|
||||||
|
name = name.decode('utf-8')
|
||||||
|
for member in self.MemberList:
|
||||||
|
if name == member['RemarkName'] or name == member['NickName']:
|
||||||
|
return member['UserName']
|
||||||
|
return None
|
||||||
|
|
||||||
|
def handleMsg(self, r):
|
||||||
|
for msg in r['AddMsgList']:
|
||||||
|
print '[*] 你有新的消息，请注意查收'
|
||||||
|
msgType = msg['MsgType']
|
||||||
|
name = self.getUserRemarkName(msg['FromUserName'])
|
||||||
|
content = msg['Content'].encode('utf-8')
|
||||||
|
if msgType == 51:
|
||||||
|
print '[*] 成功截获微信初始化消息'
|
||||||
|
elif msgType == 1:
|
||||||
|
if msg['ToUserName'] == 'filehelper':
|
||||||
|
print name+' -> 文件传输助手: '+content.replace('<br/>','\n')
|
||||||
|
elif msg['FromUserName'] == self.User['UserName']:
|
||||||
|
pass
|
||||||
|
elif msg['ToUserName'][:2] == '@@':
|
||||||
|
[people, content] = content.split(':<br/>')
|
||||||
|
print '|'+name+'| '+people+':\n'+content.replace('<br/>','\n')
|
||||||
|
else:
|
||||||
|
print name+': '+content
|
||||||
|
if self.autoReplyMode:
|
||||||
|
ans = self._xiaodoubi(content)+'\n[微信机器人自动回复]'
|
||||||
|
if self.webwxsendmsg(ans, msg['FromUserName']):
|
||||||
|
print '自动回复: '+ans
|
||||||
|
else:
|
||||||
|
print '自动回复失败'
|
||||||
|
elif msgType == 3:
|
||||||
|
print name+' 给你发送了一张图片，请在手机上查看'
|
||||||
|
elif msgType == 34:
|
||||||
|
print name+' 给你发了一段语音，请在手机上查看'
|
||||||
|
elif msgType == 42:
|
||||||
|
print name+' 给你发送了一张名片:'
|
||||||
|
print '========================='
|
||||||
|
print '= 昵称: '+self._searchContent('nickname', content)
|
||||||
|
print '= 微信号: '+self._searchContent('alias', content)
|
||||||
|
print '= 地区: '+self._searchContent('province', content)+' '+self._searchContent('city', content)
|
||||||
|
print '= 性别: '+( '男' if self._searchContent('sex', content)=='1' else '女' )
|
||||||
|
print '========================='
|
||||||
|
elif msgType == 47:
|
||||||
|
url = self._searchContent('cdnurl', content)
|
||||||
|
print name+' 给你发了一个动画表情，点击下面链接查看:'
|
||||||
|
print url
|
||||||
|
os.system('open %s' % url)
|
||||||
|
elif msgType == 49:
|
||||||
|
content = content.replace('<','<').replace('>','>')
|
||||||
|
print name+' 给你分享了一个链接:'
|
||||||
|
print '========================='
|
||||||
|
print '= 标题: '+self._searchContent('title', content, 'xml')
|
||||||
|
print '= 描述: '+self._searchContent('des', content, 'xml')
|
||||||
|
print '= 链接: '+self._searchContent('url', content, 'xml')
|
||||||
|
print '========================='
|
||||||
|
elif msgType == 62:
|
||||||
|
print name+' 给你发了一个小视频，请在手机上查看'
|
||||||
|
elif msgType == 10002:
|
||||||
|
print name+' 撤回消息'
|
||||||
|
else:
|
||||||
|
print '[*] 该消息类型为: %d，可能是表情，图片或链接' % msg['MsgType']
|
||||||
|
print msg
|
||||||
|
|
||||||
|
def listenMsgMode(self):
|
||||||
|
print '[*] 进入消息监听模式 ... 成功'
|
||||||
|
playWeChat = 0
|
||||||
|
while True:
|
||||||
|
[retcode, selector] = self.synccheck()
|
||||||
|
if self.DEBUG: print 'retcode: %s, selector: %s' % (retcode, selector)
|
||||||
|
if retcode == '1100':
|
||||||
|
print '[*] 你在手机上登出了微信，债见'
|
||||||
|
break
|
||||||
|
elif retcode == '0':
|
||||||
|
if selector == '2':
|
||||||
|
r = self.webwxsync()
|
||||||
|
if r is not None: self.handleMsg(r)
|
||||||
|
elif selector == '7':
|
||||||
|
playWeChat += 1
|
||||||
|
print '[*] 你在手机上玩微信被我发现了 %d 次' % playWeChat
|
||||||
|
r = self.webwxsync()
|
||||||
|
elif selector == '0':
|
||||||
|
time.sleep(1)
|
||||||
|
|
||||||
|
def sendMsg(self, name, word, isfile = False):
|
||||||
|
id = self.getUSerID(name)
|
||||||
|
if id:
|
||||||
|
if isfile:
|
||||||
|
with open(word, 'r') as f:
|
||||||
|
for line in f.readlines():
|
||||||
|
line = line.replace('\n','')
|
||||||
|
self._echo('-> '+name+': '+line)
|
||||||
|
if self.webwxsendmsg(line, id):
|
||||||
|
print ' [成功]'
|
||||||
|
else:
|
||||||
|
print ' [失败]'
|
||||||
|
time.sleep(1)
|
||||||
|
else:
|
||||||
|
if self.webwxsendmsg(word, id):
|
||||||
|
print '[*] 消息发送成功'
|
||||||
|
else:
|
||||||
|
print '[*] 消息发送失败'
|
||||||
|
else:
|
||||||
|
print '[*] 此用户不存在'
|
||||||
|
|
||||||
|
@catchKeyboardInterrupt
|
||||||
|
def start(self):
|
||||||
|
print '[*] 微信网页版 ... 开动'
|
||||||
|
self._run('[*] 正在获取 uuid ... ', self.getUUID)
|
||||||
|
print '[*] 正在获取二维码 ... 成功'; self.genQRCode()
|
||||||
|
self._run('[*] 请使用微信扫描二维码以登录 ... ', self.waitForLogin)
|
||||||
|
self._run('[*] 请在手机上点击确认以登录 ... ', self.waitForLogin, 0)
|
||||||
|
self._run('[*] 正在登录 ... ', self.login)
|
||||||
|
self._run('[*] 微信初始化 ... ', self.webwxinit)
|
||||||
|
self._run('[*] 开启状态通知 ... ', self.webwxstatusnotify)
|
||||||
|
self._run('[*] 获取联系人 ... ', self.webwxgetcontact)
|
||||||
|
print '[*] 共有 %d 位联系人' % len(self.ContactList)
|
||||||
|
if self.DEBUG: print self
|
||||||
|
|
||||||
|
if raw_input('[*] 是否开启自动回复模式(y/n): ') == 'y':
|
||||||
|
self.autoReplyMode = True
|
||||||
|
print '[*] 自动回复模式 ... 开启'
|
||||||
|
else:
|
||||||
|
print '[*] 自动回复模式 ... 关闭'
|
||||||
|
|
||||||
|
listenProcess = multiprocessing.Process(target=self.listenMsgMode)
|
||||||
|
listenProcess.start()
|
||||||
|
|
||||||
|
while True:
|
||||||
|
text = raw_input('')
|
||||||
|
if text == 'quit':
|
||||||
|
listenProcess.terminate()
|
||||||
|
exit('[*] 退出微信')
|
||||||
|
elif text[:2] == '->':
|
||||||
|
[name, word] = text[2:].split(':')
|
||||||
|
self.sendMsg(name, word)
|
||||||
|
elif text[:3] == 'm->':
|
||||||
|
[name, file] = text[3:].split(':')
|
||||||
|
self.sendMsg(name, file, True)
|
||||||
|
elif text[:3] == 'f->':
|
||||||
|
print '发送文件'
|
||||||
|
elif text[:3] == 'i->':
|
||||||
|
print '发送图片'
|
||||||
|
|
||||||
|
def _run(self, str, func, *args):
|
||||||
|
self._echo(str)
|
||||||
|
if func(*args): print '成功'
|
||||||
|
else: exit('失败\n[*] 退出程序')
|
||||||
|
|
||||||
|
def _echo(self, str):
|
||||||
|
sys.stdout.write(str)
|
||||||
|
sys.stdout.flush()
|
||||||
|
|
||||||
|
def _printQR(self, mat):
|
||||||
|
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])
|
||||||
|
|
||||||
|
def _str2qr(self, str):
|
||||||
|
qr = qrcode.QRCode()
|
||||||
|
qr.border = 1
|
||||||
|
qr.add_data(str)
|
||||||
|
mat = qr.get_matrix()
|
||||||
|
self._printQR(mat) # qr.print_tty() or qr.print_ascii()
|
||||||
|
|
||||||
|
def _transcoding(self, data):
|
||||||
|
if not data: return data
|
||||||
|
result = None
|
||||||
|
if type(data) == unicode:
|
||||||
|
result = data
|
||||||
|
elif type(data) == str:
|
||||||
|
result = data.decode('utf-8')
|
||||||
|
return result
|
||||||
|
|
||||||
|
def _get(self, url):
|
||||||
|
request = urllib2.Request(url = url)
|
||||||
|
response = urllib2.urlopen(request)
|
||||||
|
data = response.read()
|
||||||
|
return data
|
||||||
|
|
||||||
|
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')
|
||||||
|
else:
|
||||||
|
request = urllib2.Request(url = url, data = urllib.urlencode(params))
|
||||||
|
response = urllib2.urlopen(request)
|
||||||
|
data = response.read()
|
||||||
|
if jsonfmt: return json.loads(data)
|
||||||
|
return data
|
||||||
|
|
||||||
|
def _xiaodoubi(self, word):
|
||||||
|
url = 'http://www.xiaodoubi.com/bot/chat.php'
|
||||||
|
try:
|
||||||
|
r = requests.post(url, data = {'chat': word})
|
||||||
|
return r.content
|
||||||
|
except:
|
||||||
|
return "让我一个人静静 T_T..."
|
||||||
|
|
||||||
|
def _simsimi(self, word):
|
||||||
|
key = ''
|
||||||
|
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 '你在说什么，风太大听不清列'
|
||||||
|
|
||||||
|
def _searchContent(self, key, content, fmat = 'attr'):
|
||||||
|
if fmat == 'attr':
|
||||||
|
pm = re.search(key+'\s?=\s?"([^"<]+)"', content)
|
||||||
|
if pm: return pm.group(1)
|
||||||
|
elif fmat == 'xml':
|
||||||
|
pm=re.search('<{0}>([^<]+)</{0}>'.format(key),content)
|
||||||
|
if pm: return pm.group(1)
|
||||||
|
return '未知'
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
webwx = WebWeixin()
|
||||||
|
webwx.start()
|
||||||
Reference in New Issue
Block a user