微信大眾開發使用訊息接的方法
- 高洛峰原創
- 2017-03-23 13:15:521425瀏覽
承啟
因為之前設計了要實現一個微信機器人，以向用戶響應響應的文章，這個app十分地簡單，並不需要特別深入的設計，而且我的想法是：拿來主義， 反正github上面那麼多的用python寫的博客系統，我只需要實現微信響應的部分，也就是從數據庫中獲取文章的數據，然後將文章的標題，url，圖片等信息打包成xml格式返回微信伺服器，伺服器再返回給用戶。而且我發現，有菜單的會好很多，就像一個完整的app，可以直接點擊察看某篇文章，而不是硬邦邦的回應。我是用別人寫的一個博客系統進行改造——saepy-log.而這個博客系統又是基於tornado框架的，本來不打算染指tornado的，但是不得不硬著頭皮鑽研。其中遇到了許多困難，在sql語句的like寫法，察看文件方面有了比較大的收穫。
部署與開發
事先說明，由於我是各種折騰，所以可能照這篇文章做是做不成的。下載了saepy-log的源碼後，按照這裡的操作進行上傳後，就可以將博客系統安裝在sae平台上了，然後用svn把代碼同步下來到本地工作目錄，一切準備就緒。
我們要修改的是blog.py是部落格的核心功能所在，還有modle.py是資料模型的關鍵所在，我們將要擴充資料模型功能，使之完成我們的微信功能。
在blog.py裡面加入我們的微信功能類別weixin.py(由於是用tornado框架，所以方法與在django裡面略有不同):
導入需要用到的包
# weixin used package
import xml.etree.ElementTree as ET
import urllib,urllib2,time,hashlib
import tornado.wsgi
import tornado.escape主要是xml的解析和一些處理字串的包，接下來我們定義weixin類別的主體：
# 添加微信推送帐号
class WeiXinPoster(BaseHandler):
#-----------------------------------------------------------------------
# 处理get方法 对应check_signature
def get(self):
global TOKEN
signature = self.get_argument("signature")
timestamp = self.get_argument("timestamp")
nonce = self.get_argument("nonce")
echoStr = self.get_argument("echostr")
token = TOKEN
tmpList = [token,timestamp,nonce]
tmpList.sort()
tmpstr = "%s%s%s" % tuple(tmpList)
tmpstr = hashlib.sha1(tmpstr).hexdigest()
if tmpstr == signature:
self.write(echoStr)
#return echoStr
else:
self.write(None);
#return None
# 处理post方法,对应response_msg
def post(self):
global SORRY
# 从request中获取请求文本
rawStr = self.request.body
# 将文本进行解析,得到请求的数据
msg = self.parse_request_xml(ET.fromstring(rawStr))
# 根据请求消息来处理内容返回
query_str = msg.get("Content")
query_str = tornado.escape.utf8(query_str)
# TODO 用户发来的数据类型可能多样，所以需要判别
response_msg = ""
return_data = ""
# 使用简单的处理逻辑，有待扩展
if query_str[0] == "h": # send help menu to user
response_msg = self.get_help_menu() # 返回消息
# 包括post_msg，和对应的 response_msg
if response_msg:
return_data = self.pack_text_xml(msg, response_msg)
else:
response_msg = SORRY
return_data = self.pack_text_xml(msg, response_msg)
self.write(return_data)
# 分类
elif query_str[0] =="c":
category = query_str[1:]
response_msg = self.get_category_articles(category)
if response_msg:
return_data = self.pack_news_xml(msg, response_msg)
else:
response_msg = SORRY
return_data = self.pack_text_xml(msg, response_msg)
self.write(return_data)
# 列出文章列表
elif query_str[0] =="l":
response_msg = self.get_article_list()
if response_msg:
return_data = self.pack_text_xml(msg, response_msg)
else:
response_msg = SORRY
return_data = self.pack_text_xml(msg, response_msg)
self.write(return_data)
# 直接获取某篇文章
elif query_str[0] == "a":
# 直接获取文章的id，然后在数据库中查询
article_id = int(query_str[1:])
# 进行操作
response_msg = self.get_response_article_by_id(article_id)
if response_msg:
return_data = self.pack_news_xml(msg, response_msg)
else:
response_msg = SORRY
return_data = self.pack_text_xml(msg, response_msg)
self.write(return_data)
# 还要考虑其他
elif query_str[0] == "s":
keyword = str(query_str[1:])
# 搜索关键词，返回相关文章
response_msg = self.get_response_article(keyword)
# 返回图文信息
if response_msg:
return_data = self.pack_news_xml(msg, response_msg)
else:
response_msg = SORRY
return_data = self.pack_text_xml(msg, response_msg)
self.write(return_data)
elif query_str[0] == "n":
response_msg = self.get_latest_articles()
# 返回图文信息
if response_msg:
return_data = self.pack_news_xml(msg, response_msg)
else:
response_msg = SORRY
return_data = self.pack_text_xml(msg, response_msg)
self.write(return_data)
# 如果找不到，返回帮助信息
else:
response_msg = get_help_menu()
if response_msg:
return_data = response_msg
else:
return_data = SORRY
self.write(return_data)
# n for 获取最新的文章
def get_latest_articles(self):
global MAX_ARTICLE
global PIC_URL
article_list = Article.get_articles_by_latest()
article_list_length = len(article_list)
count = (article_list_length < MAX_ARTICLE) and article_list_length or MAX_ARTICLE
if article_list:
# 构造图文消息
articles_msg = {'articles':[]}
for i in range(0,count):
article = {
'title': article_list[i].slug,
'description':article_list[i].description,
'picUrl':PIC_URL,
'url':article_list[i].absolute_url
}
# 插入文章
articles_msg['articles'].append(article)
article = {}
# 返回文章
return articles_msg
#-----------------------------------------------------------------------
# 解析请求,拆解到一个字典里
def parse_request_xml(self,root_elem):
msg = {}
if root_elem.tag == 'xml':
for child in root_elem:
msg[child.tag] = child.text # 获得内容
return msg
#-----------------------------------------------------------------------
def get_help_menu(self):
menu_msg = '''欢迎关注南苑随笔，在这里你能获得关于校园的资讯和故事。回复如下按键则可以完成得到相应的回应
h ：帮助(help)
l ：文章列表(article list)
f : 获得分类列表
n : 获取最新文章
a + 数字 ：察看某篇文章 a2 察看第2篇文章
s + 关键字 : 搜索相关文章 s科研 察看科研相关
c + 分类名 ： 获取分类文章 c校园生活 察看校园生活分类
其他 ： 功能有待丰富'''
return menu_msg
#-----------------------------------------------------------------------
# 获取文章列表
def get_article_list(self):
# 查询数据库获取文章列表
article_list = Article.get_all_article_list()
article_list_str = "最新文章列表供您点阅，回复a+数字即可阅读: \n"
for i in range(len(article_list)):
art_id = str(article_list[i].id)
art_id = tornado.escape.native_str(art_id)
art_title = article_list[i].title
art_title = tornado.escape.native_str(art_title)
art_category = article_list[i].category
art_category = tornado.escape.native_str(art_category)
article_list_str += art_id + ' ' + art_title + ' ' + art_category + '\n'
return article_list_str
# 按照分类查找
def get_category_articles(self, category):
global MAX_ARTICLE
global PIC_URL
article_list = Article.get_articles_by_category(category)
article_list_length = len(article_list)
count = (article_list_length < MAX_ARTICLE) and article_list_length or MAX_ARTICLE
if article_list:
# 构造图文消息
articles_msg = {'articles':[]}
for i in range(0,count):
article = {
'title': article_list[i].slug,
'description':article_list[i].description,
'picUrl':PIC_URL,
'url':article_list[i].absolute_url
}
# 插入文章
articles_msg['articles'].append(article)
article = {}
# 返回文章
return articles_msg
#-----------------------------------------------------------------------
# 获取用于返回的msg
def get_response_article(self, keyword):
global PIC_URL
keyword = str(keyword)
# 从数据库查询得到若干文章
article = Article.get_article_by_keyword(keyword)
# 这里先用测试数据
if article:
title = article.slug
description = article.description
picUrl = PIC_URL
url = article.absolute_url
count = 1
# 也有可能是若干篇
# 这里实现相关逻辑，从数据库中获取内容
# 构造图文消息
articles_msg = {'articles':[]}
for i in range(0,count):
article = {
'title':title,
'description':description,
'picUrl':picUrl,
'url':url
}
# 插入文章
articles_msg['articles'].append(article)
article = {}
# 返回文章
return articles_msg
else:
return
def get_response_article_by_id(self, post_id):
global PIC_URL
# 从数据库查询得到若干文章
article = Article.get_article_by_id_detail(post_id)
# postId为文章id
if article:
title = article.slug
description = article.description
picUrl = PIC_URL
url = article.absolute_url
count = 1
# 这里实现相关逻辑，从数据库中获取内容
# 构造图文消息
articles_msg = {'articles':[]}
for i in range(0,count):
article = {
'title':title,
'description':description,
'picUrl':picUrl,
'url':url
}
# 插入文章
articles_msg['articles'].append(article)
article = {}
# 返回文章
return articles_msg
else:
return可見app的難度並不大，還是上次使用微信API裡面的和接近，需要用到的幾個全域變量，需要自己定義，如token，如PIC_URL等。程式原理其實就是解析使用者請求，h開頭，則提供幫助選單，a開頭加數字的，就提供某篇文章，等等，然後提供相應的函數進行處理，這裡面說明起來比較複雜，就以獲取分類文章來講：
需要用到分析使用者請求字串：
# 分类
elif query_str[0] =="c":
category = query_str[1:]
response_msg = self.get_category_articles(category)
if response_msg:
return_data = self.pack_news_xml(msg, response_msg)
else:
response_msg = SORRY
return_data = self.pack_text_xml(msg, response_msg)
self.write(return_data)這裡要提供get_category_articles(category)的功能，所以需要在weixin類別裡面實作一個這樣的函數：
# 按照分类查找
def get_category_articles(self, category):
global MAX_ARTICLE
global PIC_URL
article_list = Article.get_articles_by_category(category)
article_list_length = len(article_list)
count = (article_list_length < MAX_ARTICLE) and article_list_length or MAX_ARTICLE
if article_list:
# 构造图文消息
articles_msg = {'articles':[]}
for i in range(0,count):
article = {
'title': article_list[i].slug,
'description':article_list[i].description,
'picUrl':PIC_URL,
'url':article_list[i].absolute_url
}
# 插入文章
articles_msg['articles'].append(article)
article = {}
# 返回文章
return articles_msg很顯然，這裡需要和資料庫模型Article打交道，看看Article是否實現了該功能，很遺憾沒有，那麼我們只好捲起袖子自己幹——擴展Article,所以我們轉戰到modle.py文件裡面了，寫下瞭如下的程式碼：
# 返回一个包含若干篇文章的数组 limit 5
def get_articles_by_category(self, category):
sdb._ensure_connected()
article_list = sdb.query('SELECT * FROM `sp_posts` WHERE `category` = %s LIMIT 5', str(category))
for i in range(len(article_list)):
article_list[i] = post_detail_formate(article_list[i])
return article_list這裡進行了資料庫查詢，將category參數傳遞進去，選擇category為參數的5篇文章，打包返回。 post_detail_formate是部落格系統已經寫好的，我們只要拿來用就好了。在python裡面，寫sql語句要很小心，遇到要傳入參數的，最好是用逗號分割開，而不是用%來填入參數。特別是使用like的時候，我們往往需要寫這樣的sql語句：
SELECT * FROM `sp_posts` WHERE `category` LIKE '%study%'
但是python裡面又是用%s做參數佔位符的，故而會造成很多不必要的錯誤，例如這裡。總之要安全使用，最好是作為參數傳遞，python會為他們與原字串裡的%等分開。
以上是微信大眾開發使用訊息接的方法的詳細內容。更多資訊請關注PHP中文網其他相關文章！
陳述：
本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn