dev:调用和发送
This commit is contained in:
+8
-2
@@ -41,7 +41,7 @@ class TimerService:
|
||||
|
||||
# 定时:
|
||||
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))
|
||||
self.tasks.append(TimerTask(event=event,task=task))
|
||||
|
||||
@@ -77,7 +77,8 @@ class TimerService:
|
||||
req = await self.star.context.llm_generate(
|
||||
chat_provider_id=provider,
|
||||
prompt="<你等待的时间内对方没有回复>",
|
||||
contexts=history_list
|
||||
contexts=history_list,
|
||||
tools=None
|
||||
|
||||
)
|
||||
except:
|
||||
@@ -85,6 +86,11 @@ class TimerService:
|
||||
return
|
||||
logger.debug(f"llm结果:{req.completion_text }")
|
||||
|
||||
# 保存至历史消息
|
||||
|
||||
#发送至平台
|
||||
await event.send(MessageChain().message(req.completion_text))
|
||||
|
||||
class TimerTask:
|
||||
def __init__(self,event:AstrMessageEvent,task:asyncio.Task) -> None:
|
||||
self.event = event
|
||||
|
||||
Reference in New Issue
Block a user