114 lines
2.5 KiB
Markdown
114 lines
2.5 KiB
Markdown
# wechat-officeaccount
|
||
支持从微信服务号获取用户输入信息（含：正文，图片，视频，语音，事件），并通过zmq消息发送给订阅了config.json中woa_handler_id的代码处理，并将结果通过zmq消息发送会奔模块的等待函数
|
||
|
||
|
||
## 接收消息类型
|
||
|
||
* TextMessage
|
||
* ImageMessage
|
||
* VoiceMessage
|
||
* VideoMessage
|
||
* LocationMessage
|
||
* LinkMessage
|
||
* EventMessage
|
||
|
||
发送给消息处理程序的结构：
|
||
{
|
||
subscribe_id：消息处理程序zmq消息返回消息使用的key
|
||
received_at:消息接收时间
|
||
openid：用户的openid号
|
||
msgtype：消息类型， ['text', 'image', 'video', 'voice', 'location', 'link', 'event' ] 之一
|
||
# 以下信息为是msgtype=='text'
|
||
content: 正文
|
||
#### over
|
||
# 以下信息为是msgtype in ['video', 'voice', 'image']
|
||
media_url：媒体的url，通过此url下载相应的图片，视频，voice等
|
||
#### over
|
||
# 以下信息是msgtype=='position'
|
||
location:{ # LocationMessage位置消息
|
||
latitude:纬度
|
||
longitude:经度
|
||
label：地址标签
|
||
}
|
||
#### over
|
||
event：
|
||
# 以下信息为是msgtype == 'link'
|
||
title：标题
|
||
description：描述
|
||
url：链接
|
||
}
|
||
|
||
## 回微信的消息类型
|
||
* TextReply
|
||
消息属性
|
||
{
|
||
msgtype: 'text'
|
||
content：如果不需要回复微信的消息，content='success'
|
||
}
|
||
* ImageReply
|
||
消息属性
|
||
{
|
||
msgtype:'image'
|
||
media_file:图像文件的本地路径
|
||
}
|
||
* VoiceReply
|
||
消息属性
|
||
{
|
||
msgtype:'voice'
|
||
media_file:图像文件的本地路径
|
||
}
|
||
* VideoReply
|
||
消息属性
|
||
{
|
||
msgtype:'video'
|
||
media_file:图像文件的本地路径
|
||
}
|
||
* ArticlesReply
|
||
消息属性
|
||
{
|
||
msgtype:'video'
|
||
articles:[
|
||
{
|
||
'title':标题
|
||
‘description：描述
|
||
'image_url':图片url
|
||
'url':文章所在url
|
||
}
|
||
]
|
||
}
|
||
|
||
* MusicReply
|
||
消息属性
|
||
{
|
||
msgtype:'music'
|
||
title:标题
|
||
description：描述
|
||
music_url：公网可访问的url
|
||
hq_music_url：高质量链接
|
||
}
|
||
|
||
返回消息有以下属性
|
||
|
||
## 消息处理的例子
|
||
```
|
||
import asyncio
|
||
from appPublic.jsonConfig import getConfig
|
||
from appPublic.zmqapi import zmq_publish, zmq_subscribe
|
||
import json
|
||
|
||
async def woa_msghandle():
|
||
config = getConfig()
|
||
config.woa_handler_id
|
||
while True:
|
||
msgstr = await zmq_subscribe(config.woa_handler_id)
|
||
msgdic = json.loads(msgstr)
|
||
# 这里按照业务逻辑处理收到的msg
|
||
# 处理完成后
|
||
retmsg = {
|
||
"msgtype": "text", # 要返回的消息类型
|
||
“content": "收到" # 每个类型的消息所需要的数据
|
||
}
|
||
retstr = json.dumps(retmsg, ensure_ascii=False)
|
||
await zmq_publish(msgdic['subscribe_id'], retstr)
|
||
|