Last active
June 16, 2020 07:42
-
-
Save Kingson/5149802 to your computer and use it in GitHub Desktop.
豆瓣电影查询助手V3.0 #增加给新关注的用户自动返回“欢迎关注豆瓣电影,输入电影名称即可快速查询电影讯息哦!”信息的功能 #大力丰富注释和docstring信息,以帮助后来者能快速上手。
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#! /usr/bin/env python | |
# coding=utf-8 | |
__author__ = 'jszhou' | |
from bottle import * | |
import hashlib | |
import xml.etree.ElementTree as ET | |
import urllib2 | |
# import requests | |
import json | |
""" | |
Change Log: | |
# 03-04--03-08 完成微信API+Python自动回复代码雏形,可以通过电影ID查询电影信息,以Text形式返回给用户电影 | |
Title和电影summary | |
# 03-11 完成通过电影名称查询并返回图文格式的数据 | |
# 03-13 1.增加给新关注的用户自动返回“欢迎关注豆瓣电影,输入电影名称即可快速查询电影讯息哦!”信息的功能 | |
2.完善注释信息 | |
# 03-28 根据微信公众平台公告,更改获取新关注用户方式,从text改为event。 | |
关于本地调试问题: | |
微信没有提供本地调试功能,给用户造成不小的麻烦。 | |
打开Bottle的Debug功能,在本地运行自己的代码(启动Server),使用Chrome或Firefox上的Advanced Rest Client插件来模拟微信服务器向自己的应用发送请求, | |
这样就可以看到详细的报错信息,方便开发者定位修复问题,其相当于,自己的应用是SAE,而Advanced Rest Client模拟的是新微信客户端和微信服务器。 | |
也有同学自己写脚本,模拟微信服务器发送数据,这也是同样的道理。 | |
遗留问题: | |
1.从豆瓣拿到的海报图片都是竖向的,而微信中显示的是横向的,所以在微信看图片就被裁了一节,不过还好能看, | |
如何能完整显示海报图片,有待进一步research; | |
2.现在的通过电影名称返回的结果,实际上是拿的豆瓣返回的第一条数据,这样就有可能不准确,如何精确匹配用户的 | |
查询条件,也还需要进一步研究。 | |
""" | |
@get("/") | |
def checkSignature(): | |
""" | |
这里是用来做接口验证的,从微信Server请求的URL中拿到“signature”,“timestamp”,"nonce"和“echostr”, | |
然后再将token, timestamp, nonce三个排序并进行Sha1计算,并将计算结果和拿到的signature进行比较, | |
如果相等,就说明验证通过。 | |
话说微信的这个验证做的很渣,因为只要把echostr返回去,就能通过验证,这也就造成我看到一个Blog中, | |
验证那儿只返回了一个echostr,而纳闷了半天。 | |
附微信Server请求的Url示例:http://yoursaeappid.sinaapp.com/?signature=730e3111ed7303fef52513c8733b431a0f933c7c | |
&echostr=5853059253416844429×tamp=1362713741&nonce=1362771581 | |
""" | |
token = "xiaomayi" # 你在微信公众平台上设置的TOKEN | |
signature = request.GET.get('signature', None) # 拼写不对害死人那,把signature写成singnature,直接导致怎么也认证不成功 | |
timestamp = request.GET.get('timestamp', None) | |
nonce = request.GET.get('nonce', None) | |
echostr = request.GET.get('echostr', None) | |
tmpList = [token, timestamp, nonce] | |
tmpList.sort() | |
tmpstr = "%s%s%s" % tuple(tmpList) | |
hashstr = hashlib.sha1(tmpstr).hexdigest() | |
if hashstr == signature: | |
return echostr | |
else: | |
return None | |
def parse_msg(): | |
""" | |
这里是用来解析微信Server Post过来的XML数据的,取出各字段对应的值,以备后面的代码调用,也可用lxml等模块。 | |
""" | |
recvmsg = request.body.read() # 严重卡壳的地方,最后还是在Stack OverFlow上找到了答案 | |
root = ET.fromstring(recvmsg) | |
msg = {} | |
for child in root: | |
msg[child.tag] = child.text | |
return msg | |
def query_movie_info(): | |
""" | |
这里使用豆瓣的电影search API,通过关键字查询电影信息,这里的关键点是,一是关键字取XML中的Content值, | |
二是如果Content中存在汉字,就需要先转码,才能进行请求 | |
""" | |
movieurlbase = "http://api.douban.com/v2/movie/search" | |
DOUBAN_APIKEY = "0ec7076653f7fffb2c551632fbe7fff1" # 这里需要填写你自己在豆瓣上申请的应用的APIKEY | |
movieinfo = parse_msg() | |
searchkeys = urllib2.quote(movieinfo["Content"].encode("utf-8")) # 如果Content中存在汉字,就需要先转码,才能进行请求 | |
url = '%s?q=%s&apikey=%s' % (movieurlbase, searchkeys, DOUBAN_APIKEY) | |
# return "<p>{'url': %s}</p>" % url | |
# url = '%s%s?apikey=%s' % (movieurlbase, id["Content"], DOUBAN_APIKEY) | |
# resp = requests.get(url=url, headers=header) | |
resp = urllib2.urlopen(url) | |
movie = json.loads(resp.read()) | |
# return "<p>{'movie': %s}</p>" % movie | |
# info = movie["subjects"][0]["title"] + movie["subjects"][0]["alt"] | |
# info = movie['title'] + ': ' + ''.join(movie['summary']) | |
return movie | |
# return info | |
def query_movie_details(): | |
""" | |
这里使用豆瓣的电影subject API,通过在query_movie_info()中拿到的电影ID,来获取电影的summary。 | |
""" | |
movieurlbase = "http://api.douban.com/v2/movie/subject/" | |
DOUBAN_APIKEY = "0ec7076653f7fffb2c551632fbe7fff1" # 这里需要填写你自己在豆瓣上申请的应用的APIKEY | |
id = query_movie_info() | |
url = '%s%s?apikey=%s' % (movieurlbase, id["subjects"][0]["id"], DOUBAN_APIKEY) | |
resp = urllib2.urlopen(url) | |
description = json.loads(resp.read()) | |
description = ''.join(description['summary']) | |
return description | |
@post("/") | |
def response_msg(): | |
""" | |
这里是响应微信Server的请求,并返回数据的主函数,判断Content内容,如果是一条“subscribe”的事件,就 | |
表明是一个新注册用户,调用纯文本格式返回,如果是其他的内容就组织数据以图文格式返回。 | |
基本思路: | |
# 拿到Post过来的数据 | |
# 分析数据(拿到FromUserName、ToUserName、CreateTime、MsgType和content) | |
# 构造回复信息(将你组织好的content返回给用户) | |
""" | |
# 拿到并解析数据 | |
msg = parse_msg() | |
# 设置返回数据模板 | |
# 纯文本格式 | |
textTpl = """<xml> | |
<ToUserName><![CDATA[%s]]></ToUserName> | |
<FromUserName><![CDATA[%s]]></FromUserName> | |
<CreateTime>%s</CreateTime> | |
<MsgType><![CDATA[text]]></MsgType> | |
<Content><![CDATA[%s]]></Content> | |
<FuncFlag>0</FuncFlag> | |
</xml>""" | |
# 图文格式 | |
pictextTpl = """<xml> | |
<ToUserName><![CDATA[%s]]></ToUserName> | |
<FromUserName><![CDATA[%s]]></FromUserName> | |
<CreateTime>%s</CreateTime> | |
<MsgType><![CDATA[news]]></MsgType> | |
<ArticleCount>1</ArticleCount> | |
<Articles> | |
<item> | |
<Title><![CDATA[%s]]></Title> | |
<Description><![CDATA[%s]]></Description> | |
<PicUrl><![CDATA[%s]]></PicUrl> | |
<Url><![CDATA[%s]]></Url> | |
</item> | |
</Articles> | |
<FuncFlag>1</FuncFlag> | |
</xml> """ | |
# 判断MsgType内容,如果是一条“subscribe”的event,表明是一个新关注用户,如果不是,就返回电影标题,电影简介 | |
# 和电影海报组成的图文信息 | |
if msg["MsgType"] == "event": | |
echostr = textTpl % ( | |
msg['FromUserName'], msg['ToUserName'], str(int(time.time())), | |
u"欢迎关注豆瓣电影,输入电影名称即可快速查询电影讯息哦!") | |
return echostr | |
else: | |
Content = query_movie_info() | |
description = query_movie_details() | |
echostr = pictextTpl % (msg['FromUserName'], msg['ToUserName'], str(int(time.time())), | |
Content["subjects"][0]["title"], description, | |
Content["subjects"][0]["images"]["large"], Content["subjects"][0]["alt"]) | |
return echostr | |
if __name__ == "__main__": | |
# Interactive mode | |
debug(True) | |
run(host='127.0.0.1', port=8888, reloader=True) | |
else: | |
# Mod WSGI launch | |
import sae | |
debug(True) | |
os.chdir(os.path.dirname(__file__)) | |
app = default_app() | |
application = sae.create_wsgi_app(app) |
谢谢,我就是看你的v1版本开始入门的
多谢,希望能和你切磋切磋!
有的地方代码风格不好,但是给了我很多启发,谢谢
hashstr = hashlib.sha1(tmpstr).hexdigest()
这一行报错了,应该更新一下了
tmp_str = ''.join(args_list)
hashcode = hashlib.sha1(tmp_str.encode('utf-8')).hexdigest()
这个可以代替
注释很不错
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
多谢多谢!