This commit is contained in:
yumoqing 2026-03-03 16:24:06 +08:00
parent 1c9b6416e7
commit 97ef9067d3

View File

@ -172,12 +172,18 @@ class WOAHandler:
"msgtype": "video",
"media_file": fs.realPath('/UiEi7hKqAmU1-jqQEVhZe/5/171/99/17/vidu-1.mp4')
})
if rzt_dic.msgtype in ['video', 'image', 'audio'] and rzt_dic.media_file:
rzt_dic.media_id = await self.media_manager.upload_media(
rzt_dic.media_file,
rzt_dic.msgtype,
is_permanent=False,
title= rzt_dic.title,
description=rzt_dic.description
)
return rzt_dic
await zmq_publish(config.woa_handler_id, json.dumps(msg, ensure_ascii=False))
result = await zmq_subcribe(msg.subscribe_id)
rzt_dic = DictObject(**json.loads(result))
if rzt_dic.msgtype in ['video', 'image', 'audio']:
rzt_dic.media_id = await self.media_manager.upload_media(rzt_dic.msgtype, rzt_dic.media_filepath)
return rzt_dic
async def build_reply(self, msg:DictObject, rzt_msg:DictObject, timestamp):
@ -188,9 +194,6 @@ class WOAHandler:
if rzt_msg.msgtype == 'text':
reply = ReplyBuilder.text(msg, content=rzt_msg.content, create_time=timestamp)
return reply
if rzt_msg.msgtype in ['image', 'video', 'voice']:
rzt_msg.media_id = await self.upload_media(rzt_msg.msgtype,
rzt_msg.media_file)
if rzt_msg.msgtype == 'image':
reply = ReplyBuilder.image(msg, media_id=rzt_msg.media_id, create_time=timestamp)
return reply