Compare commits

..
2 Commits
Author SHA1 Message Date
Wbucket bc18689f71 dev:调用和发送 2026-11-08 00:51:30 +08:00
Wbucket 1d2412bafd dev 2026-11-08 00:19:04 +08:00
+14 -4
View File
@@ -41,7 +41,7 @@ class TimerService:
# 定时: # 定时:
def timer(self,event:AstrMessageEvent,Sec:int): def timer(self,event:AstrMessageEvent,Sec:int):
logger.debug(f"进行一个{Sec}秒的对{event.get_sender_id}({event.get_sender_name})的等") logger.debug(f"进行一个{Sec}秒的对{event.get_sender_id()}({event.get_sender_name()})的等")
task = asyncio.create_task(self.timer_task(event,Sec)) task = asyncio.create_task(self.timer_task(event,Sec))
self.tasks.append(TimerTask(event=event,task=task)) self.tasks.append(TimerTask(event=event,task=task))
@@ -72,15 +72,25 @@ class TimerService:
except: except:
logger.error("消息管理失败!") logger.error("消息管理失败!")
return False return False
logger.debug(f"获取上下文:{conversation}") # logger.debug(f"获取上下文:{conversation}")
req = await self.star.context.llm_generate( try:
req = await self.star.context.llm_generate(
chat_provider_id=provider, chat_provider_id=provider,
prompt="<你等待的时间内对方没有回复>", prompt="<你等待的时间内对方没有回复>",
contexts=history_list contexts=history_list,
tools=None
) )
except:
logger.error("llm返回失败了喵...QAQ")
return
logger.debug(f"llm结果:{req.completion_text }") logger.debug(f"llm结果:{req.completion_text }")
# 保存至历史消息
#发送至平台
await event.send(MessageChain().message(req.completion_text))
class TimerTask: class TimerTask:
def __init__(self,event:AstrMessageEvent,task:asyncio.Task) -> None: def __init__(self,event:AstrMessageEvent,task:asyncio.Task) -> None:
self.event = event self.event = event