Python开发微信公众平台的方法详解【基于weixin-knife】
作者:yueguanghaidao 发布时间:2023-03-09 12:05:43
本文实例讲述了Python开发微信公众平台的方法。分享给大家供大家参考,具体如下:
这两天将之前基于微信公众平台的代码重构了下,基础功能以库的方式提供,提供了demo使用的是django,看着之前为赶进度写的代码真的惨不忍睹,所以weixin-knife产生了,正如其名,提供的是必要的功能,而不是完整的应用。weixin-knife可以很方便的处理关注,取关注事件,处理文本消息,回复用户信息,jssdk处理,oauth认证,以及微信支付。
github地址:https://github.com/Skycrab/weixin-knife。
首先看看怎么用
from .weixin import handler as HD
@HD.subscribe
def subscribe(xml):
return "welcome to brain"
@HD.unsubscribe
def subscribe(xml):
print "leave"
return "leave brain"
上面处理了关注和取关事件,通过装饰器处理的还算透明。
处理文本消息,回复图文消息如下:
@HD.text
def text(xml):
content = xml.Content
if content == "111":
return {"Title":"美女", "Description":"比基尼美女", "PicUrl":"http://9smv.com/static/mm/uploads/150411/2-150411115450247.jpg", "Url":"http://9smv.com/beauty/list?category=5"}
elif content == "222":
return [
["比基尼美女", "比基尼美女", "http://9smv.com/static/mm/uploads/150411/2-150411115450247.jpg", "http://9smv.com/beauty/list?category=5"],
["长腿美女", "长腿美女", "http://9smv.com/static/mm/uploads/150506/2-150506111A9648.jpg", "http://9smv.com/beauty/list?category=8"]
]
elif content == "push":
Helper.send_text_message(xml.FromUserName, "推送消息测试")
return "push ok"
return "hello world"
如何文本是111或222,我们回复图文消息,如何使push,我们使用客服接口推送消息,其它返回“hello world"
一般我们会使用oauth网页授权获取用户的openid,如果是多个链接都需要通过oauth处理,代码会很难看,通过装饰器可以很好的处理这个问题。
def sns_userinfo_callback(callback=None):
"""网页授权获取用户信息装饰器
callback(openid, userinfo):
return user
"""
def wrap(func):
@wraps(func)
def inner(*args, **kwargs):
request = args[0] #django第一个参数request
openid = request.COOKIES.get('openid')
userinfo = None
if not openid:
code = request.GET.get("code")
if not code:
current = "http://"+ request.get_host() + request.get_full_path()
return redirect(WeixinHelper.oauth2(current))
else:
data = json.loads(WeixinHelper.getAccessTokenByCode(code))
access_token, openid, refresh_token = data["access_token"], data["openid"], data["refresh_token"]
#WeixinHelper.refreshAccessToken(refresh_token)
userinfo = json.loads(WeixinHelper.getSnsapiUserInfo(access_token, openid))
else:
ok, openid = Helper.check_cookie(openid)
if not ok:
return redirect("/")
request.openid = openid
if callable(callback):
request.user = callback(openid, userinfo)
response = func(request)
return response
return inner
return wrap
sns_userinfo = sns_userinfo_callback()
在所有需要用户openid的函数前使用sns_userinfo装饰器就可以了,callback函数接收openid,userinfo,返回用户实例,这样就可以使用request.user获取当前用户
@sns_userinfo
def oauth(request):
"""网页授权获取用户信息"""
resp = HttpResponse(request.openid)
resp.set_cookie("openid", Helper.sign_cookie(request.openid))
return resp
使用oauth需要保存cookie,不然每次用户请求都需要授权,需要走一遍完整的oauth流程,拖慢整体响应。
weixin-knife提供了微信支付支持,稍微修改我之前移植的官方PHP版本,https://github.com/Skycrab/wzhifuSDK
@sns_userinfo
def pay(request):
response = render_to_response("pay.html")
response.set_cookie("openid", Helper.sign_cookie(request.openid))
return response
@sns_userinfo
@catch
def paydetail(request):
"""获取支付信息"""
openid = request.openid
money = request.POST.get("money") or "0.01"
money = int(float(money)*100)
jsApi = JsApi_pub()
unifiedOrder = UnifiedOrder_pub()
unifiedOrder.setParameter("openid",openid) #商品描述
unifiedOrder.setParameter("body","充值测试") #商品描述
timeStamp = time.time()
out_trade_no = "{0}{1}".format(WxPayConf_pub.APPID, int(timeStamp*100))
unifiedOrder.setParameter("out_trade_no", out_trade_no) #商户订单号
unifiedOrder.setParameter("total_fee", str(money)) #总金额
unifiedOrder.setParameter("notify_url", WxPayConf_pub.NOTIFY_URL) #通知地址
unifiedOrder.setParameter("trade_type", "JSAPI") #交易类型
unifiedOrder.setParameter("attach", "6666") #附件数据,可分辨不同商家(string(127))
try:
prepay_id = unifiedOrder.getPrepayId()
jsApi.setPrepayId(prepay_id)
jsApiParameters = jsApi.getParameters()
except Exception as e:
print(e)
else:
print jsApiParameters
return HttpResponse(jsApiParameters)
FAIL, SUCCESS = "FAIL", "SUCCESS"
@catch
def payback(request):
"""支付回调"""
xml = request.raw_post_data
#使用通用通知接口
notify = Notify_pub()
notify.saveData(xml)
print xml
#验证签名,并回应微信。
#对后台通知交互时,如果微信收到商户的应答不是成功或超时,微信认为通知失败,
#微信会通过一定的策略(如30分钟共8次)定期重新发起通知,
#尽可能提高通知的成功率,但微信不保证通知最终能成功
if not notify.checkSign():
notify.setReturnParameter("return_code", FAIL) #返回状态码
notify.setReturnParameter("return_msg", "签名失败") #返回信息
else:
result = notify.getData()
if result["return_code"] == FAIL:
notify.setReturnParameter("return_code", FAIL)
notify.setReturnParameter("return_msg", "通信错误")
elif result["result_code"] == FAIL:
notify.setReturnParameter("return_code", FAIL)
notify.setReturnParameter("return_msg", result["err_code_des"])
else:
notify.setReturnParameter("return_code", SUCCESS)
out_trade_no = result["out_trade_no"] #商户系统的订单号,与请求一致。
###检查订单号是否已存在,以及业务代码
return HttpResponse(notify.returnXml())
pay.html就是使用WeixinJSBridge.invode调用
$.post("/paydetail",{
money: $momey
},function(data){
if(data){
var jsonobj = eval('('+data+')');
WeixinJSBridge.invoke('getBrandWCPayRequest', {
"appId" : jsonobj.appId, //公众号名称,由商户传入
"timeStamp" : jsonobj.timeStamp, //时间戳
"nonceStr" : jsonobj.nonceStr, //随机串
"package" : jsonobj.package,//扩展包
"signType" : "MD5", //微信签名方式:1.sha1
"paySign" : jsonobj.paySign //微信签名
});
}
}
);
由于access_token, jsapi_ticket需要缓存,而缓存方式又依赖于具体环境,所以提供了一个Helper类,使用了django 的cache缓存。
class Helper(object):
"""微信具体逻辑帮组类"""
@class_property
def access_token(cls):
key = "ACCESS_TOKEN"
token = cache.get(key)
if not token:
data = json.loads(WeixinHelper.getAccessToken())
token, expire = data["access_token"], data["expires_in"]
cache.set(key, token, expire-300)
return token
@class_property
def jsapi_ticket(cls):
key = "JSAPI_TICKET"
ticket = cache.get(key)
if not ticket:
data = json.loads(WeixinHelper.getJsapiTicket(cls.access_token))
ticket, expire = data["ticket"], data["expires_in"]
cache.set(key, ticket, expire-300)
return ticket
class_property提供了类级别的property,当然实例也是可以用的。
class class_property(object):
""" A property can decorator class or instance
class Foo(object):
@class_property
def foo(cls):
return 42
print(Foo.foo)
print(Foo().foo)
"""
def __init__(self, func, name=None, doc=None):
self.__name__ = name or func.__name__
self.__module__ = func.__module__
self.__doc__ = doc or func.__doc__
self.func = func
def __get__(self, obj, type=None):
value = self.func(type)
return value
使用weixin-knife助力公众平台开发,你完全可以稍加修改用于flask等其它web框架。
希望本文所述对大家Python程序设计有所帮助。
猜你喜欢
- asp禁止站外盗链,站外提交方法、以及asp判断星期几方法.防盗链,主要通过判断上一页面来源是否是本站来实现的,不是本站的链接就
- 本文实例为大家分享了java正则表达式工具类的具体代码,供大家参考,具体内容如下import com.google.common.base.
- 很多时候我们的redis的IP地址一般都是默认的127.0.0.1代表只能接受本机的访问,因此我们其他机器上想要访问这个redis的时候,就
- 本文实例讲述了php计算两个整数的最大公约数常用算法。分享给大家供大家参考。具体如下:<?php//计时,返回秒function&nb
- 你的SQL Server最近是否运行不正常?不,我指的不是我们肯定会遇到的通常的数据库和操作系统问题。我的意思是,你是否经历过服务器的反应迟
- 面是我下载页面down.php 的php代码 现在我发现,用迅雷,谷歌浏览器直接打开,就能输出下载文件,一点不起防盗链作用。&nb
- 前言Python 字符串是一个内置的类型序列。字符串可用于处理 Python 中的文本数据。Python 字符串是 Unicode 点的不可
- 在MySQL中有两种方法1、create table t_name select ...2、create table t_name like
- 刚才运行了一段代码,来查看Request.ServerVariables里面有多少值,看了一下,共50个!代码<%=Request.S
- ASP由于是一种古老的语言,它的一些功能对UTF-8支持非常差。比如,你想生成一个UTF-8格式的文件,使用常用的 scrīpting.Fi
- 1、实现效果2、实现步骤模块导入import os,sys,timefrom PyQt5 import QtCore,QtWidgets,Q
- --语 句 功 能--数据操作SELECT --从数据库表中检索数据行和列INSERT --向数据库表添加新数据行DELETE --从数据库
- 试了一下,xmlDoc.save()行不同,就试着用fso做了出来。整理一下,供大家discuss。由于用js操作本地xml文件之后save
- J2ME是利用HttpConnection建立HTTP连接,然后获取数据,ASP也是利用HTTP协议,因而可以利用J2ME与ASP建立连接,
- CSS Hack是在标准CSS没办法兼容各浏览器显示效果时才会用上的补救方法,在各浏览器厂商解析CSS没有达成一致前,我们只能用这样的方法来
- 一般写ASP PHP代码的朋友都估计是采用直接操作SQL的吧~ 看以下的代码 <% dim conn,rs&nbs
- l当今世界,技术发展迅猛,不论是什么行业,大多数关键数据都是放置于数据库中进行管理的,一来目前数据库技术已经相当成熟,二来其管理功能非常强大
- 虽然说标题将的是首页的访问感受,但是同样适合于网站其它页面的用户体验设计,一个好的网站设计应当尽量做到首页和次页一视同仁。第一步(视觉设计)
- 因为神奇的中文有时也是会遇到国外同学都不知道原因导致一些神奇滴问题,所以要用更神奇的英文来解决问题。Mac OS的一些:华文细黑:STHei
- sys;//系统管理员,拥有最高权限 system;//本地管理员,次高权限 scott;//普通用户,密码默认为tiger,默认未解锁 s