Skip to content

Instantly share code, notes, and snippets.

@Kingson
Last active June 16, 2020 07:42
Show Gist options
  • Save Kingson/5149802 to your computer and use it in GitHub Desktop.
Save Kingson/5149802 to your computer and use it in GitHub Desktop.
豆瓣电影查询助手V3.0 #增加给新关注的用户自动返回“欢迎关注豆瓣电影,输入电影名称即可快速查询电影讯息哦!”信息的功能 #大力丰富注释和docstring信息,以帮助后来者能快速上手。
#! /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&timestamp=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)
@shinux
Copy link

shinux commented Jul 15, 2014

有的地方代码风格不好,但是给了我很多启发,谢谢

@zhanglongqi
Copy link

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