yumoqing/wechat-office-account
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2026-03-02 09:14:59 +08:00
parent a69234636a
commit 906c05acfe
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
woa/init.py
View File

@ -4,12 +4,12 @@ from aiohttp import web, ClientSession, FormData, ClientTimeout
from wechatpy.crypto import WeChatCrypto from wechatpy.crypto import WeChatCrypto
from wechatpy.exceptions import InvalidSignatureException, WeChatClientException from wechatpy.exceptions import InvalidSignatureException, WeChatClientException
from wechatpy.messages import ( from wechatpy.messages import (
Message, TextMessage, ImageMessage, VoiceMessage, VideoMessage, Message, TextMessage, ImageMessage, VoiceMessage, VideoMessage,
LocationMessage, LinkMessage, EventMessage LocationMessage, LinkMessage, EventMessage
) )
from wechatpy.replies import ( from wechatpy.replies import (
TextReply, ImageReply, VoiceReply, VideoReply, TextReply, ImageReply, VoiceReply, VideoReply,
ArticlesReply, MusicReply ArticlesReply, MusicReply
) )
from ahserver.configuredServer import add_cleanupctx from ahserver.configuredServer import add_cleanupctx
from ahserver.serverenv import ServerEnv from ahserver.serverenv import ServerEnv
@ -37,8 +37,8 @@ class WOAHandler:
if tim > self.client_token_expire_in - 20: if tim > self.client_token_expire_in - 20:
f = awaitify(self.client.fetch_access_token) f = awaitify(self.client.fetch_access_token)
data = await f() data = await f()
self.client_token = data['access_token'] self.client_token = data['access_token']
self.client_token_expire_in = time.time() + data['expire_in'] self.client_token_expire_in = time.time() + data['expire_in']
return self.client_token return self.client_token
async def upload_media(self, media_type:str, file_path:str) -> str: 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): async def messagehandler(self, request:web.Request, msg:Message):
""" """
TextMessage, ImageMessage, VoiceMessage, VideoMessage, TextMessage, ImageMessage, VoiceMessage, VideoMessage,
LocationMessage, LinkMessage, EventMessage LocationMessage, LinkMessage, EventMessage
""" """
dic = DictObject() dic = DictObject()
dic.received_at = time.time() dic.received_at = time.time()
@ -133,9 +133,9 @@ class WOAHandler:
message=msg, message=msg,
title=rzt_msg.title, title=rzt_msg.title,
description=rzt_msg.description, description=rzt_msg.description,
music_url=rzt_msg.music_url, # 核心：播放链接 music_url=rzt_msg.music_url, # 核心：播放链接
hq_music_url=rzt_msg.hq_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 return reply
if rzt_msg.msgtype == 'article': if rzt_msg.msgtype == 'article':