# -*- coding:utf-8 -*-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.argsprint argssignature = args.get('signature')timestamp = args.get('timestamp')nonce = args.get('nonce')echostr = args.get('echostr')# 1. 将token、timestamp、nonce三个参数进行字典序排序temp = [WECHAT_TOKEN, timestamp, nonce]temp.sort()# 2. 将三个参数字符串拼接成一个字符串进行sha1加密temp = "".join(temp)# sig是我们计算出来的签名结果sig = hashlib.sha1(temp).hexdigest()# 3. 开发者获得加密后的字符串可与signature对比，标识该请求来源于微信if sig == signature:# 根据请求方式.返回不同的内容 ,如果是get方式,代表是验证服务器有效性# 如果POST方式,代表是微服务器转发给我们的消息if request.method == "GET":return echostrelse:resp_data = request.dataresp_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', 403if __name__ == '__main__':app.run(host='0.0.0.0',port=8000)

# -*- coding:utf-8 -*-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.argsprint argssignature = args.get('signature')timestamp = args.get('timestamp')nonce = args.get('nonce')echostr = args.get('echostr')# 1. 将token、timestamp、nonce三个参数进行字典序排序temp = [WECHAT_TOKEN, timestamp, nonce]temp.sort()# 2. 将三个参数字符串拼接成一个字符串进行sha1加密temp = "".join(temp)# sig是我们计算出来的签名结果sig = hashlib.sha1(temp).hexdigest()# 3. 开发者获得加密后的字符串可与signature对比，标识该请求来源于微信if sig == signature:# 根据请求方式.返回不同的内容 ,如果是get方式,代表是验证服务器有效性# 如果POST方式,代表是微服务器转发给我们的消息if request.method == "GET":return echostrelse:resp_data = request.dataresp_dict = xmltodict.parse(resp_data).get('xml')if 'voice' == resp_dict.get('MsgType'):print resp_datares = 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 123response = {"xml": response}print 456response = xmltodict.unparse(response)print 789else:response = ''return make_response(response)else:return 'errno', 403if __name__ == '__main__':app.run(host='0.0.0.0',port=8000)voice.py

# -*- coding:utf-8 -*-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.argsprint argssignature = args.get('signature')timestamp = args.get('timestamp')nonce = args.get('nonce')echostr = args.get('echostr')# 1. 将token、timestamp、nonce三个参数进行字典序排序temp = [WECHAT_TOKEN, timestamp, nonce]temp.sort()# 2. 将三个参数字符串拼接成一个字符串进行sha1加密temp = "".join(temp)# sig是我们计算出来的签名结果sig = hashlib.sha1(temp).hexdigest()# 3. 开发者获得加密后的字符串可与signature对比，标识该请求来源于微信if sig == signature:# 根据请求方式.返回不同的内容 ,如果是get方式,代表是验证服务器有效性# 如果POST方式,代表是微服务器转发给我们的消息if request.method == "GET":return echostrelse:resp_data = request.dataresp_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 = Noneelse: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', 403if __name__ == '__main__':app.run(host='0.0.0.0',port=8000)

# -*- coding:utf-8 -*-
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": 7200}@classmethoddef 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'):# 去获取accessTokenurl = '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-8 -*-
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": 7200}@classmethoddef 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'):# 去获取accessTokenurl = '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_tokenparams = {"expire_seconds": 604800,"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">' % ticketelse:return resp_jsonif __name__ == '__main__':app.run(host='0.0.0.0')

# -*- coding:utf-8 -*-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.argssignature = args.get('signature')timestamp = args.get('timestamp')nonce = args.get('nonce')echostr = args.get('echostr')# 1. 将token、timestamp、nonce三个参数进行字典序排序temp = [WECHAT_TOKEN, timestamp, nonce]temp.sort()# 2. 将三个参数字符串拼接成一个字符串进行sha1加密temp = "".join(temp)# sig是我们计算出来的签名结果sig = hashlib.sha1(temp).hexdigest()# 3. 开发者获得加密后的字符串可与signature对比，标识该请求来源于微信if sig == signature:# 根据请求方式.返回不同的内容 ,如果是get方式,代表是验证服务器有效性# 如果POST方式,代表是微服务器转发给我们的消息if request.method == "GET":return echostrelse:resp_data = request.dataresp_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 = Noneelse: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', 403if __name__ == '__main__':app.run(host='0.0.0.0',port=8000)

# -*- coding: utf-8 -*-
# filename: menu.py
import urllib
from gentate_token import AccessTokenclass Menu(object):def __init__(self):passdef create(self, postData, accessToken):postUrl = "https://api.weixin.qq.com/cgi-bin/menu/create?access_token=%s" % accessTokenif 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" % accessTokenurlResp = urllib.urlopen(url=postUrl)print urlResp.read()def delete(self, accessToken):postUrl = "https://api.weixin.qq.com/cgi-bin/menu/delete?access_token=%s" % accessTokenurlResp = 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" % accessTokenurlResp = 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)