Flask 微信公众号开发

# -*- coding:utf- -*-from flask import Flask, request, make_response
import hashlib
import xmltodict
import timeapp = Flask(__name__)WECHAT_TOKEN = "zhangbiao"@app.route('/weixin', methods=['GET', 'POST'])
def wechat():
args = request.args
print args signature = args.get('signature')
timestamp = args.get('timestamp')
nonce = args.get('nonce')
echostr = args.get('echostr') # . 将token、timestamp、nonce三个参数进行字典序排序
temp = [WECHAT_TOKEN, timestamp, nonce]
temp.sort()
# . 将三个参数字符串拼接成一个字符串进行sha1加密
temp = "".join(temp)
# sig是我们计算出来的签名结果
sig = hashlib.sha1(temp).hexdigest() # . 开发者获得加密后的字符串可与signature对比，标识该请求来源于微信
if sig == signature:
# 根据请求方式.返回不同的内容 ,如果是get方式,代表是验证服务器有效性
# 如果POST方式,代表是微服务器转发给我们的消息
if request.method == "GET":
return echostr
else:
resp_data = request.data
resp_dict = xmltodict.parse(resp_data).get('xml')
print resp_dict
# 如果是文本消息
if 'text' == resp_dict.get('MsgType'):
response = {
"ToUserName": resp_dict.get('FromUserName'),
"FromUserName": resp_dict.get('ToUserName'),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": resp_dict.get('Content'),
}
print resp_dict.get('Content')
else:
response = {
"ToUserName": resp_dict.get('FromUserName'),
"FromUserName": resp_dict.get('ToUserName'),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": u"哈哈哈哈",
}
if response:
response = {"xml": response}
response = xmltodict.unparse(response)
else:
response = ''
return make_response(response)
else:
return 'errno', if __name__ == '__main__':
app.run(host='0.0.0.0',port=)

# -*- coding:utf- -*-from flask import Flask, request, make_response
import hashlib
import xmltodict
import timeapp = Flask(__name__)WECHAT_TOKEN = "zhangbiao"@app.route('/weixin', methods=['GET', 'POST'])
def wechat():
args = request.args
print args signature = args.get('signature')
timestamp = args.get('timestamp')
nonce = args.get('nonce')
echostr = args.get('echostr') # . 将token、timestamp、nonce三个参数进行字典序排序
temp = [WECHAT_TOKEN, timestamp, nonce]
temp.sort()
# . 将三个参数字符串拼接成一个字符串进行sha1加密
temp = "".join(temp)
# sig是我们计算出来的签名结果
sig = hashlib.sha1(temp).hexdigest() # . 开发者获得加密后的字符串可与signature对比，标识该请求来源于微信
if sig == signature:
# 根据请求方式.返回不同的内容 ,如果是get方式,代表是验证服务器有效性
# 如果POST方式,代表是微服务器转发给我们的消息
if request.method == "GET":
return echostr
else:
resp_data = request.data
resp_dict = xmltodict.parse(resp_data).get('xml') if 'voice' == resp_dict.get('MsgType'):
print resp_data
res = resp_dict.get('Recognition') or u'未识别' response = {
"ToUserName": resp_dict.get('FromUserName'),
"FromUserName": resp_dict.get('ToUserName'),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": res
}
else:
response = {
"ToUserName": resp_dict.get('FromUserName'),
"FromUserName": resp_dict.get('ToUserName'),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": u"哈哈哈哈",
}
if response:
print
response = {"xml": response}
print
response = xmltodict.unparse(response)
print
else:
response = ''
return make_response(response)
else:
return 'errno', if __name__ == '__main__':
app.run(host='0.0.0.0',port=)voice.py

# -*- coding:utf- -*-from flask import Flask, request, make_response
import hashlib
import xmltodict
import timeapp = Flask(__name__)WECHAT_TOKEN = "zhangbiao"@app.route('/weixin', methods=['GET', 'POST'])
def wechat():
args = request.args
print args signature = args.get('signature')
timestamp = args.get('timestamp')
nonce = args.get('nonce')
echostr = args.get('echostr') # . 将token、timestamp、nonce三个参数进行字典序排序
temp = [WECHAT_TOKEN, timestamp, nonce]
temp.sort()
# . 将三个参数字符串拼接成一个字符串进行sha1加密
temp = "".join(temp)
# sig是我们计算出来的签名结果
sig = hashlib.sha1(temp).hexdigest() # . 开发者获得加密后的字符串可与signature对比，标识该请求来源于微信
if sig == signature:
# 根据请求方式.返回不同的内容 ,如果是get方式,代表是验证服务器有效性
# 如果POST方式,代表是微服务器转发给我们的消息
if request.method == "GET":
return echostr
else:
resp_data = request.data
resp_dict = xmltodict.parse(resp_data).get('xml')
print resp_dict.get('MsgType')
if "event" == resp_dict.get('MsgType'):
if "subscribe" == resp_dict.get("Event"):
response = {
"ToUserName": resp_dict.get("FromUserName", ""),
"FromUserName": resp_dict.get("ToUserName", ""),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": u"感谢您的关注！"
}
else:
response = None
else:
response = {
"ToUserName": resp_dict.get('FromUserName'),
"FromUserName": resp_dict.get('ToUserName'),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": u"哈哈哈哈",
}
if response:
response = {"xml": response}
response = xmltodict.unparse(response)
else:
response = ''
return make_response(response)
else:
return 'errno', if __name__ == '__main__':
app.run(host='0.0.0.0',port=)

# -*- coding:utf- -*-
import time
import urllib2
import jsonfrom flask import Flask, requestWECHAT_APPID = ""
WECHAT_APPSECRET = ""class AccessToken(object):
"""
获取accessToken
保存accessToken
判断是否过期,如果没有过期,那么直接返回一次请求的access_token
"""
access_token = {
"access_token": "",
"update_time": time.time(),
"expires_in":
} @classmethod
def get_access_token(cls):
# 判断是否有accessToken or access_token 有没有过期
# if 没有 access_tokon 或者 access_token 过期了:
if not cls.access_token.get('access_token') or (
time.time() - cls.access_token.get('update_time')) > cls.access_token.get('expires_in'):
# 去获取accessToken
url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s' % (
WECHAT_APPID, WECHAT_APPSECRET)
# 获取响应
response = urllib2.urlopen(url).read()
# 转成字典
resp_json = json.loads(response) if 'errcode' in resp_json:
raise Exception(resp_json.get('errmsg'))
else:
# 保存数据
cls.access_token['access_token'] = resp_json.get('access_token')
cls.access_token['expires_in'] = resp_json.get('expires_in')
cls.access_token['update_time'] = time.time()
return cls.access_token.get('access_token')
else:
return cls.access_token.get('access_token')if __name__ == '__main__':
print AccessToken.get_access_token()

# -*- coding:utf- -*-
import time
import urllib2
import jsonfrom flask import Flask, requestWECHAT_APPID = ""
WECHAT_APPSECRET = ""class AccessToken(object):
"""
获取accessToken
保存accessToken
判断是否过期,如果没有过期,那么直接返回一次请求的access_token
"""
access_token = {
"access_token": "",
"update_time": time.time(),
"expires_in":
} @classmethod
def get_access_token(cls):
# 判断是否有accessToken or access_token 有没有过期
# if 没有 access_tokon 或者 access_token 过期了:
if not cls.access_token.get('access_token') or (time.time() - cls.access_token.get('update_time')) > cls.access_token.get('expires_in'):
# 去获取accessToken
url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s' % (WECHAT_APPID, WECHAT_APPSECRET)
# 获取响应
response = urllib2.urlopen(url).read()
# 转成字典
resp_json = json.loads(response) if 'errcode' in resp_json:
raise Exception(resp_json.get('errmsg'))
else:
# 保存数据
cls.access_token['access_token'] = resp_json.get('access_token')
cls.access_token['expires_in'] = resp_json.get('expires_in')
cls.access_token['update_time'] = time.time()
return cls.access_token.get('access_token')
else:
return cls.access_token.get('access_token')app = Flask(__name__)# http://127.0.0.1/get_qrcode?id=1
@app.route('/get_qrcode')
def get_qrcode():
scene_id = request.args.get('id')
access_token = AccessToken.get_access_token()
url = "https://api.weixin.qq.com/cgi-bin/qrcode/create?access_token=%s" % access_token
params = {
"expire_seconds": ,
"action_name": "QR_SCENE",
"action_info": {"scene": {"scene_id": scene_id}}}
response = urllib2.urlopen(url, data=json.dumps(params)).read()
# 转成字典
resp_json = json.loads(response) ticket = resp_json.get('ticket')
if ticket:
return '<img src="https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=%s">' % ticket
else:
return resp_jsonif __name__ == '__main__':
app.run(host='0.0.0.0')

# -*- coding:utf- -*-from flask import Flask, request, make_response
import hashlib
import xmltodict
import time
import jsonapp = Flask(__name__)WECHAT_TOKEN = "zhangbiao"@app.route('/weixin', methods=['GET', 'POST'])
def wechat():
args = request.args
signature = args.get('signature')
timestamp = args.get('timestamp')
nonce = args.get('nonce')
echostr = args.get('echostr')
# . 将token、timestamp、nonce三个参数进行字典序排序
temp = [WECHAT_TOKEN, timestamp, nonce]
temp.sort()
# . 将三个参数字符串拼接成一个字符串进行sha1加密
temp = "".join(temp)
# sig是我们计算出来的签名结果
sig = hashlib.sha1(temp).hexdigest() # . 开发者获得加密后的字符串可与signature对比，标识该请求来源于微信
if sig == signature:
# 根据请求方式.返回不同的内容 ,如果是get方式,代表是验证服务器有效性
# 如果POST方式,代表是微服务器转发给我们的消息
if request.method == "GET":
return echostr
else:
resp_data = request.data
resp_dict = xmltodict.parse(resp_data).get('xml') # 如果是文本消息
if 'text' == resp_dict.get('MsgType'):
response = {
"ToUserName": resp_dict.get('FromUserName'),
"FromUserName": resp_dict.get('ToUserName'),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": resp_dict.get('Content'),
}
print resp_dict.get('Content') elif "event" == resp_dict.get('MsgType'):
if "subscribe" == resp_dict.get("Event"):
response = {
"ToUserName": resp_dict.get("FromUserName", ""),
"FromUserName": resp_dict.get("ToUserName", ""),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": u"感谢您的关注！"
}
if resp_dict.get('EventKey'):
response["Content"] += u"场景值是:"
response["Content"] += resp_dict.get('EventKey')
elif 'SCAN' == resp_dict.get('Event'):
# 当用户关注过扫描的时候,会进入到这儿
response = {
"ToUserName": resp_dict.get("FromUserName", ""),
"FromUserName": resp_dict.get("ToUserName", ""),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": resp_dict.get('EventKey')
}
print resp_dict.get('Ticket')
else:
response = None
else:
response = {
"ToUserName": resp_dict.get('FromUserName'),
"FromUserName": resp_dict.get('ToUserName'),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": u"哈哈哈哈",
} if response:
response = {"xml": response}
response = xmltodict.unparse(response)
else:
response = ''
return make_response(response)
else:
return 'errno', if __name__ == '__main__':
app.run(host='0.0.0.0',port=)

# -*- coding: utf- -*-
# filename: menu.py
import urllib
from gentate_token import AccessTokenclass Menu(object):
def __init__(self):
pass def create(self, postData, accessToken):
postUrl = "https://api.weixin.qq.com/cgi-bin/menu/create?access_token=%s" % accessToken
if isinstance(postData, unicode):
postData = postData.encode('utf-8')
urlResp = urllib.urlopen(url=postUrl, data=postData)
print urlResp.read() def query(self, accessToken):
postUrl = "https://api.weixin.qq.com/cgi-bin/menu/get?access_token=%s" % accessToken
urlResp = urllib.urlopen(url=postUrl)
print urlResp.read() def delete(self, accessToken):
postUrl = "https://api.weixin.qq.com/cgi-bin/menu/delete?access_token=%s" % accessToken
urlResp = urllib.urlopen(url=postUrl)
print urlResp.read() # 获取自定义菜单配置接口
def get_current_selfmenu_info(self, accessToken):
postUrl = "https://api.weixin.qq.com/cgi-bin/get_current_selfmenu_info?access_token=%s" % accessToken
urlResp = urllib.urlopen(url=postUrl)
print urlResp.read()if __name__ == '__main__':
myMenu = Menu()
postJson = """
{
"button":
[
{
"type": "click",
"name": "个人信息",
"key": "geren"
},
{
"type": "click",
"name": "发展历史",
"key": "fazhan"
}，
{
"type": "click",
"name": "联系我们",
"key": "contact"
}
]
}
"""
Pjson = '''
{
"button": [
{
"type": "click",
"name": "今日歌曲",
"key": "V1001_TODAY_MUSIC"
},
{
"name": "菜单",
"sub_button": [
{
"type": "view",
"name": "搜索",
"url": "http://www.soso.com/"
},
{
"type": "view",
"name": "个人博客",
"url": "http://www.cnblogs.com/crazymagic/"
}
]
}
]
}
'''
accessToken =AccessToken.get_access_token()
# myMenu.delete(accessToken)
myMenu.create(Pjson, accessToken)