diff --git a/woa/init.py b/woa/init.py index 8d224c2..31f785e 100644 --- a/woa/init.py +++ b/woa/init.py @@ -4,12 +4,12 @@ from aiohttp import web, ClientSession, FormData, ClientTimeout from wechatpy.crypto import WeChatCrypto from wechatpy.exceptions import InvalidSignatureException, WeChatClientException from wechatpy.messages import ( - Message, TextMessage, ImageMessage, VoiceMessage, VideoMessage, - LocationMessage, LinkMessage, EventMessage + Message, TextMessage, ImageMessage, VoiceMessage, VideoMessage, + LocationMessage, LinkMessage, EventMessage ) from wechatpy.replies import ( - TextReply, ImageReply, VoiceReply, VideoReply, - ArticlesReply, MusicReply + TextReply, ImageReply, VoiceReply, VideoReply, + ArticlesReply, MusicReply ) from ahserver.configuredServer import add_cleanupctx from ahserver.serverenv import ServerEnv @@ -37,8 +37,8 @@ class WOAHandler: if tim > self.client_token_expire_in - 20: f = awaitify(self.client.fetch_access_token) data = await f() - self.client_token = data['access_token'] - self.client_token_expire_in = time.time() + data['expire_in'] + self.client_token = data['access_token'] + self.client_token_expire_in = time.time() + data['expire_in'] return self.client_token async def upload_media(self, media_type:str, file_path:str) -> str: @@ -75,7 +75,7 @@ class WOAHandler: async def messagehandler(self, request:web.Request, msg:Message): """ TextMessage, ImageMessage, VoiceMessage, VideoMessage, - LocationMessage, LinkMessage, EventMessage + LocationMessage, LinkMessage, EventMessage """ dic = DictObject() dic.received_at = time.time() @@ -133,9 +133,9 @@ class WOAHandler: message=msg, title=rzt_msg.title, description=rzt_msg.description, - music_url=rzt_msg.music_url, # 核心:播放链接 + music_url=rzt_msg.music_url, # 核心:播放链接 hq_music_url=rzt_msg.hq_music_url, # 核心:高质量链接 - thumb_media_id=media_id # 核心:封面图 media_id + thumb_media_id=media_id # 核心:封面图 media_id ) return reply if rzt_msg.msgtype == 'article':