wechat-officeaccount

支持从微信服务号获取用户输入信息（含：正文，图片，视频，语音，事件），并通过zmq消息发送给订阅了config.json中woa_handler_id的代码处理，并将结果通过zmq消息发送会奔模块的等待函数

接收消息类型

• TextMessage { 'ToUserName': '', 'FromUserName': '', 'CreateTime': '', 'MsgType': 'text', 'Content': 'hret', 'MsgId': '25376371128450301' }

• ImageMessage { 'ToUserName': '', 'FromUserName': '', 'CreateTime': '', 'MsgType': 'image', 'PicUrl': '可直接使用的图像url', 'MsgId': '25376358150108245', 'MediaId': 'utihMtnTma-qbcPMfc7zQlAAhT' }

• VoiceMessage 数据内容： { 'ToUserName': '微信服务号id', 'FromUserName': '用户的openid', 'CreateTime': '消息时间', 'MsgType': 'voice', 'MediaId': '媒体id，用此可以转可下载的url', 'Format': 'amr', 'MsgId': '7612907756399362048', 'Recognition': None, # 识别结果 'MediaId16K': '16K音质的mediaid' }

• VideoMessage { 'ToUserName': '', 'FromUserName': '', 'CreateTime': '', 'MsgType': 'video', 'MediaId': '', 'ThumbMediaId': '', 'MsgId': '817'}

• LocationMessage { 'ToUserName': '', 'FromUserName': '', 'CreateTime': '', 'MsgType': 'location', 'Location_X': '', 'Location_Y': '', 'Scale': '15', 'Label': '', 'MsgId': '' }

• LinkMessage

• EventMessage 1 自定义菜单 { 'ToUserName': '', 'FromUserName': '', 'CreateTime': '', 'MsgType': 'event', 'Event': 'VIEW', 'EventKey': '点击菜单对应的URL', 'MenuId': '' } 2 关注

发送给消息处理程序的结构： { 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)