From 2e2a87d660a0d9b2ec6e1900c57f9affcadbac95 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Thu, 5 Nov 2026 15:33:21 +0800 Subject: [PATCH 01/22] dev-llm-content --- main.py | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/main.py b/main.py index 819a756..e4602b2 100644 --- a/main.py +++ b/main.py @@ -2,7 +2,7 @@ from astrbot.api.event import filter, AstrMessageEvent, MessageEventResult from astrbot.api.star import Context, Star, register from astrbot.api import logger from astrbot.api.provider import ProviderRequest - +from astrbot.core.agent.message import TextPart @register("helloworld", "YourName", "一个简单的 Hello World 插件", "1.0.0") class MyPlugin(Star): def __init__(self, context: Context): @@ -16,10 +16,16 @@ class MyPlugin(Star): async def helloworld(self, event: AstrMessageEvent,req : ProviderRequest): """这是一个 hello world 指令""" # 这是 handler 的描述，将会被解析方便用户了解插件内容。建议填写。 logger.info("系统提示词：",req.system_prompt) - - @filter.event_message_type(filter.EventMessageType.PRIVATE_MESSAGE) - async def awa(self,event:AstrMessageEvent): - yield event.plain_result(event.get_message_str()) + req.extra_user_content_parts.append(TextPart( + text=( + "使用x模板输入想要等待的时间。单位为s\n" + "最短2s最长3min(180s)\n" + "例如'5'-->等待5秒后再次唤醒." + ) + )) + # @filter.event_message_type(filter.EventMessageType.PRIVATE_MESSAGE) + # async def awa(self,event:AstrMessageEvent): + # yield event.plain_result(event.get_message_str()) async def terminate(self): """可选择实现异步的插件销毁方法，当插件被卸载/停用时会调用。""" From 5740e7d41e0902484a20dcab2bab48cf43964099 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Thu, 5 Nov 2026 15:36:56 +0800 Subject: [PATCH 02/22] dev --- main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/main.py b/main.py index e4602b2..f2a3a33 100644 --- a/main.py +++ b/main.py @@ -15,7 +15,7 @@ class MyPlugin(Star): @filter.on_llm_request() async def helloworld(self, event: AstrMessageEvent,req : ProviderRequest): """这是一个 hello world 指令""" # 这是 handler 的描述，将会被解析方便用户了解插件内容。建议填写。 - logger.info("系统提示词：",req.system_prompt) + # logger.info("系统提示词："+req.system_prompt) req.extra_user_content_parts.append(TextPart( text=( "使用x模板输入想要等待的时间。单位为s\n" From 094cab95ca0f7aab39d260d512f7d61cf079827b Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Thu, 5 Nov 2026 15:52:31 +0800 Subject: [PATCH 03/22] dev --- main.py | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/main.py b/main.py index f2a3a33..1a1c81b 100644 --- a/main.py +++ b/main.py @@ -18,9 +18,17 @@ class MyPlugin(Star): # logger.info("系统提示词："+req.system_prompt) req.extra_user_content_parts.append(TextPart( text=( - "使用x模板输入想要等待的时间。单位为s\n" - "最短2s最长3min(180s)\n" - "例如'5'-->等待5秒后再次唤醒." + "在回复内容中加入n模板输入想要等待的时间,n=等待秒数\n" + "最短2s最长30min(1800s),不添加则正常回复(只有对方回复你才会被唤醒)\n" + "例如'5'-->等待5秒后再次唤醒.\n" + "使用场景:希望对方在多久之后能回你，或者希望这个话题能在短期内继续而不是因为对方的不回复就夭折\n" + "例如如下场景:\n" + "assistant:'你觉得咸粽子好吃韩式甜粽子好吃?40'\n" + "(系统时间：四十秒后,系统定时唤醒)\n" + "user:'无回应'\n" + "assistant:'你怎么不理我40'\n" + "(系统时间：二十秒后,用户回复，定时任务取消)\n" + "user:'抱歉啊刚看到，我觉得咸的好吃awa'" ) )) # @filter.event_message_type(filter.EventMessageType.PRIVATE_MESSAGE) From a89239030087f700c95547047acc4f93ea3ed04b Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Thu, 5 Nov 2026 16:11:21 +0800 Subject: [PATCH 04/22] stlyle:context --- main.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/main.py b/main.py index 1a1c81b..cf0ac4d 100644 --- a/main.py +++ b/main.py @@ -18,17 +18,21 @@ class MyPlugin(Star): # logger.info("系统提示词："+req.system_prompt) req.extra_user_content_parts.append(TextPart( text=( + "-----wt使用----" "在回复内容中加入n模板输入想要等待的时间,n=等待秒数\n" "最短2s最长30min(1800s),不添加则正常回复(只有对方回复你才会被唤醒)\n" "例如'5'-->等待5秒后再次唤醒.\n" "使用场景:希望对方在多久之后能回你，或者希望这个话题能在短期内继续而不是因为对方的不回复就夭折\n" "例如如下场景:\n" + "--\n" "assistant:'你觉得咸粽子好吃韩式甜粽子好吃?40'\n" "(系统时间：四十秒后,系统定时唤醒)\n" "user:'无回应'\n" "assistant:'你怎么不理我40'\n" "(系统时间：二十秒后,用户回复，定时任务取消)\n" - "user:'抱歉啊刚看到，我觉得咸的好吃awa'" + "user:'抱歉啊刚看到，我觉得咸的好吃awa'\n" + "每主动回复消息必须带上wt标签，标签必须闭合且只包裹你要等待的秒数!\n" + "-------" ) )) # @filter.event_message_type(filter.EventMessageType.PRIVATE_MESSAGE) From d4fd53ed4be0fed660b7843ea61f0b32f8c2c130 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Thu, 5 Nov 2026 21:40:00 +0800 Subject: [PATCH 05/22] dev --- main.py | 15 ++++++++++++--- tool/pattern.py | 48 ++++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 60 insertions(+), 3 deletions(-) create mode 100644 tool/pattern.py diff --git a/main.py b/main.py index cf0ac4d..431f881 100644 --- a/main.py +++ b/main.py @@ -1,9 +1,11 @@ from astrbot.api.event import filter, AstrMessageEvent, MessageEventResult +from astrbot.core.message.message_event_result import MessageChain from astrbot.api.star import Context, Star, register from astrbot.api import logger -from astrbot.api.provider import ProviderRequest +from astrbot.api.provider import (ProviderRequest,LLMResponse ) from astrbot.core.agent.message import TextPart -@register("helloworld", "YourName", "一个简单的 Hello World 插件", "1.0.0") +from tool.pattern import Pattern +@register("wait_msg", "Wbucket", "一个简单的 llm等待回复插件", "0.0.1") class MyPlugin(Star): def __init__(self, context: Context): super().__init__(context) @@ -13,7 +15,7 @@ class MyPlugin(Star): # 注册指令的装饰器。指令名为 helloworld。注册成功后，发送 `/helloworld` 就会触发这个指令，并回复 `你好, {user_name}!` @filter.on_llm_request() - async def helloworld(self, event: AstrMessageEvent,req : ProviderRequest): + async def content_inject(self, event: AstrMessageEvent,req : ProviderRequest): """这是一个 hello world 指令""" # 这是 handler 的描述，将会被解析方便用户了解插件内容。建议填写。 # logger.info("系统提示词："+req.system_prompt) req.extra_user_content_parts.append(TextPart( @@ -39,5 +41,12 @@ class MyPlugin(Star): # async def awa(self,event:AstrMessageEvent): # yield event.plain_result(event.get_message_str()) + @filter.on_llm_response() + async def pattern_extract(self,event:AstrMessageEvent,req:LLMResponse): + if not req.role == 'assistant': + return + llm_res = req.completion_text + dump = Pattern(llm_res) + await event.send(MessageChain().message("awa定时时间消息:{0}过滤后:{1}".format(dump.count,dump.string))) async def terminate(self): """可选择实现异步的插件销毁方法，当插件被卸载/停用时会调用。""" diff --git a/tool/pattern.py b/tool/pattern.py new file mode 100644 index 0000000..25a698a --- /dev/null +++ b/tool/pattern.py @@ -0,0 +1,48 @@ +import re + +class Pattern: + _pattern = r'((?!wt).)*' + + _MAX_SEC = 1800 + _MIN_SEC = 10 + # 定义最大与最小的范围，固定输入的规范 + def __init__(self,o_str:str) -> None: + res = self.extract(o_str) + self.count:int|None = res['second'] + self.string:str = res["content"] + + + def sec_range(self,i)->int: + if i > Pattern._MAX_SEC: + return Pattern._MAX_SEC + if i < Pattern._MIN_SEC : + return Pattern._MIN_SEC + return i + + + def load(self,pattern_str:str)->int|None: + content = pattern_str.strip().removeprefix("").removesuffix("").strip() + print(content) + try: + num = int(content) + return self.sec_range(num) + except: + return None + + def extract(self,o_str:str): + # 多次匹配防止重复模板 + timerSec :None|int = None + res=re.finditer(Pattern._pattern,o_str) + for i in res : + # 对结果和源字符串处理 + o_str = o_str.replace(i.group(),"",1) + num = self.load(i.group()) + if num and timerSec: + timerSec = num + #消除不完整/非法模板 + o_str= o_str.replace("","") + o_str=o_str.replace("","") + return { + "content":o_str, + "second":timerSec + } From 4512c4a4cca9fe35cadfce809af78da309f33743 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Thu, 5 Nov 2026 21:46:22 +0800 Subject: [PATCH 06/22] =?UTF-8?q?dev=20=E7=9B=B8=E5=AF=B9=E5=AF=BC?= =?UTF-8?q?=E5=85=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/main.py b/main.py index 431f881..8ad6eb6 100644 --- a/main.py +++ b/main.py @@ -4,7 +4,7 @@ from astrbot.api.star import Context, Star, register from astrbot.api import logger from astrbot.api.provider import (ProviderRequest,LLMResponse ) from astrbot.core.agent.message import TextPart -from tool.pattern import Pattern +from .tool.pattern import Pattern @register("wait_msg", "Wbucket", "一个简单的 llm等待回复插件", "0.0.1") class MyPlugin(Star): def __init__(self, context: Context): From 0a17dc8a43d91a8dd54d3d128fe299ffe5b7ca8d Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Thu, 5 Nov 2026 21:51:44 +0800 Subject: [PATCH 07/22] dev logger --- main.py | 2 ++ tool/pattern.py | 5 ++++- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/main.py b/main.py index 8ad6eb6..84309ad 100644 --- a/main.py +++ b/main.py @@ -45,6 +45,8 @@ class MyPlugin(Star): async def pattern_extract(self,event:AstrMessageEvent,req:LLMResponse): if not req.role == 'assistant': return + + logger.info("[wait_msg]:开始解析模板") llm_res = req.completion_text dump = Pattern(llm_res) await event.send(MessageChain().message("awa定时时间消息:{0}过滤后:{1}".format(dump.count,dump.string))) diff --git a/tool/pattern.py b/tool/pattern.py index 25a698a..ae32f4d 100644 --- a/tool/pattern.py +++ b/tool/pattern.py @@ -1,5 +1,5 @@ import re - +from astrbot.api import logger class Pattern: _pattern = r'((?!wt).)*' @@ -27,6 +27,7 @@ class Pattern: num = int(content) return self.sec_range(num) except: + logger.debug ("[wait_msg]:模板内容错误:{}".format(content)) return None def extract(self,o_str:str): @@ -42,6 +43,8 @@ class Pattern: #消除不完整/非法模板 o_str= o_str.replace("","") o_str=o_str.replace("","") + + logger.info("[wait_msg]:获得模板:{0}s".format(timerSec)) return { "content":o_str, "second":timerSec From f08a36f833deb6764cf1940f6d379ac74e3a9109 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Thu, 5 Nov 2026 22:05:46 +0800 Subject: [PATCH 08/22] dev --- tool/pattern.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/tool/pattern.py b/tool/pattern.py index ae32f4d..aa6e7c8 100644 --- a/tool/pattern.py +++ b/tool/pattern.py @@ -27,7 +27,7 @@ class Pattern: num = int(content) return self.sec_range(num) except: - logger.debug ("[wait_msg]:模板内容错误:{}".format(content)) + logger.debug ("模板内容错误:{}".format(content)) return None def extract(self,o_str:str): @@ -38,14 +38,16 @@ class Pattern: # 对结果和源字符串处理 o_str = o_str.replace(i.group(),"",1) num = self.load(i.group()) + logger.info("获得模板:{0}s".format(i.group())) + if num and timerSec: timerSec = num #消除不完整/非法模板 o_str= o_str.replace("","") o_str=o_str.replace("","") - logger.info("[wait_msg]:获得模板:{0}s".format(timerSec)) return { "content":o_str, "second":timerSec } +print(Pattern("awdwadawdada")) From 101d276d9a456f0d32e4fa1d454a5de05623cefe Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Thu, 5 Nov 2026 22:10:10 +0800 Subject: [PATCH 09/22] =?UTF-8?q?dev-log=20and=20=E5=88=A4=E5=88=AB?= =?UTF-8?q?=E5=BC=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tool/pattern.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tool/pattern.py b/tool/pattern.py index aa6e7c8..04764cd 100644 --- a/tool/pattern.py +++ b/tool/pattern.py @@ -38,9 +38,9 @@ class Pattern: # 对结果和源字符串处理 o_str = o_str.replace(i.group(),"",1) num = self.load(i.group()) - logger.info("获得模板:{0}s".format(i.group())) + logger.info("获得模板:{0}".format(i.group())) - if num and timerSec: + if num and not timerSec: timerSec = num #消除不完整/非法模板 o_str= o_str.replace("","") From 6f79cae3a31845a184f08042933b7247174621f0 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Thu, 5 Nov 2026 22:54:18 +0800 Subject: [PATCH 10/22] =?UTF-8?q?dev:style=20=E9=A1=B9=E7=9B=AE=E7=BB=93?= =?UTF-8?q?=E6=9E=84=E5=92=8C=E5=88=86=E7=B1=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- main.py | 27 +++++++++++---------------- service/timer.py | 15 +++++++++++++++ tool/pattern.py | 5 +++-- 3 files changed, 29 insertions(+), 18 deletions(-) create mode 100644 service/timer.py diff --git a/main.py b/main.py index 84309ad..777e0ab 100644 --- a/main.py +++ b/main.py @@ -1,10 +1,12 @@ from astrbot.api.event import filter, AstrMessageEvent, MessageEventResult -from astrbot.core.message.message_event_result import MessageChain + from astrbot.api.star import Context, Star, register from astrbot.api import logger from astrbot.api.provider import (ProviderRequest,LLMResponse ) from astrbot.core.agent.message import TextPart -from .tool.pattern import Pattern +from .service.timer import timer + + @register("wait_msg", "Wbucket", "一个简单的 llm等待回复插件", "0.0.1") class MyPlugin(Star): def __init__(self, context: Context): @@ -13,7 +15,7 @@ class MyPlugin(Star): async def initialize(self): """可选择实现异步的插件初始化方法，当实例化该插件类之后会自动调用该方法。""" - # 注册指令的装饰器。指令名为 helloworld。注册成功后，发送 `/helloworld` 就会触发这个指令，并回复 `你好, {user_name}!` + # 注册指令的装饰器 @filter.on_llm_request() async def content_inject(self, event: AstrMessageEvent,req : ProviderRequest): """这是一个 hello world 指令""" # 这是 handler 的描述，将会被解析方便用户了解插件内容。建议填写。 @@ -22,8 +24,8 @@ class MyPlugin(Star): text=( "-----wt使用----" "在回复内容中加入n模板输入想要等待的时间,n=等待秒数\n" - "最短2s最长30min(1800s),不添加则正常回复(只有对方回复你才会被唤醒)\n" - "例如'5'-->等待5秒后再次唤醒.\n" + "最短10s最长30min(1800s),不添加则正常回复(只有对方回复你才会被唤醒)\n" + "例如'15'-->等待15秒后再次唤醒.\n" "使用场景:希望对方在多久之后能回你，或者希望这个话题能在短期内继续而不是因为对方的不回复就夭折\n" "例如如下场景:\n" "--\n" @@ -33,22 +35,15 @@ class MyPlugin(Star): "assistant:'你怎么不理我40'\n" "(系统时间：二十秒后,用户回复，定时任务取消)\n" "user:'抱歉啊刚看到，我觉得咸的好吃awa'\n" - "每主动回复消息必须带上wt标签，标签必须闭合且只包裹你要等待的秒数!\n" + "每主动发出消息建议带上wt标签，标签必须闭合且只包裹你要等待的秒数。\n" + "如果话题完结了，不想再无意义被唤醒，或者回复完毕别人的问题还没被追问的时候则不必再加。自己看着决定即可。\n" "-------" ) )) - # @filter.event_message_type(filter.EventMessageType.PRIVATE_MESSAGE) - # async def awa(self,event:AstrMessageEvent): - # yield event.plain_result(event.get_message_str()) @filter.on_llm_response() async def pattern_extract(self,event:AstrMessageEvent,req:LLMResponse): - if not req.role == 'assistant': - return - - logger.info("[wait_msg]:开始解析模板") - llm_res = req.completion_text - dump = Pattern(llm_res) - await event.send(MessageChain().message("awa定时时间消息:{0}过滤后:{1}".format(dump.count,dump.string))) + await timer(event,req) + async def terminate(self): """可选择实现异步的插件销毁方法，当插件被卸载/停用时会调用。""" diff --git a/service/timer.py b/service/timer.py new file mode 100644 index 0000000..ae2d768 --- /dev/null +++ b/service/timer.py @@ -0,0 +1,15 @@ +from astrbot.api.event import AstrMessageEvent +from astrbot.api.provider import LLMResponse +from astrbot.api import logger +from astrbot.core.message.message_event_result import MessageChain +from ..tool.pattern import Pattern + +# 解析模板并进行定时 +async def timer(event:AstrMessageEvent,req:LLMResponse): + if not req.role == 'assistant': + return + + logger.info("[wait_msg]:开始解析模板") + llm_res = req.completion_text + dump = Pattern(llm_res) + await event.send(MessageChain().message("awa定时时间消息:{0}过滤后:{1}".format(dump.count,dump.string))) \ No newline at end of file diff --git a/tool/pattern.py b/tool/pattern.py index 04764cd..2af896c 100644 --- a/tool/pattern.py +++ b/tool/pattern.py @@ -1,5 +1,7 @@ import re from astrbot.api import logger + +# 输入内容，获取过滤后的字符串与定时秒数 class Pattern: _pattern = r'((?!wt).)*' @@ -22,7 +24,7 @@ class Pattern: def load(self,pattern_str:str)->int|None: content = pattern_str.strip().removeprefix("").removesuffix("").strip() - print(content) + try: num = int(content) return self.sec_range(num) @@ -50,4 +52,3 @@ class Pattern: "content":o_str, "second":timerSec } -print(Pattern("awdwadawdada")) From dc8753b87ce8f0d27538d70ea06a96c128c15d93 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Fri, 6 Nov 2026 15:30:23 +0800 Subject: [PATCH 11/22] style: context --- main.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/main.py b/main.py index 777e0ab..5cdfbf0 100644 --- a/main.py +++ b/main.py @@ -29,9 +29,9 @@ class MyPlugin(Star): "使用场景:希望对方在多久之后能回你，或者希望这个话题能在短期内继续而不是因为对方的不回复就夭折\n" "例如如下场景:\n" "--\n" - "assistant:'你觉得咸粽子好吃韩式甜粽子好吃?40'\n" + "assistant:'你觉得咸粽子好吃还是甜粽子好吃?40'\n" "(系统时间：四十秒后,系统定时唤醒)\n" - "user:'无回应'\n" + "user:'40s过去了，对方无回应'\n" "assistant:'你怎么不理我40'\n" "(系统时间：二十秒后,用户回复，定时任务取消)\n" "user:'抱歉啊刚看到，我觉得咸的好吃awa'\n" From 33dc032d8290bd4fc9b28e87a15626d51a4d4965 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Fri, 6 Nov 2026 21:06:51 +0800 Subject: [PATCH 12/22] =?UTF-8?q?fix:=20=E4=B8=8D=E6=AD=A3=E7=A1=AE?= =?UTF-8?q?=E7=9A=84=E4=BA=8B=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- main.py | 10 ++++++---- service/timer.py | 44 +++++++++++++++++++++++++++++++++++--------- 2 files changed, 41 insertions(+), 13 deletions(-) diff --git a/main.py b/main.py index 5cdfbf0..803688b 100644 --- a/main.py +++ b/main.py @@ -4,7 +4,7 @@ from astrbot.api.star import Context, Star, register from astrbot.api import logger from astrbot.api.provider import (ProviderRequest,LLMResponse ) from astrbot.core.agent.message import TextPart -from .service.timer import timer +from .service.timer import TimerService @register("wait_msg", "Wbucket", "一个简单的 llm等待回复插件", "0.0.1") @@ -12,6 +12,8 @@ class MyPlugin(Star): def __init__(self, context: Context): super().__init__(context) + self.Timer = TimerService(self) + async def initialize(self): """可选择实现异步的插件初始化方法，当实例化该插件类之后会自动调用该方法。""" @@ -41,9 +43,9 @@ class MyPlugin(Star): ) )) - @filter.on_llm_response() - async def pattern_extract(self,event:AstrMessageEvent,req:LLMResponse): - await timer(event,req) + @filter.on_decorating_result() + async def pattern_extract(self,event:AstrMessageEvent): + await self.Timer.timer(event) async def terminate(self): """可选择实现异步的插件销毁方法，当插件被卸载/停用时会调用。""" diff --git a/service/timer.py b/service/timer.py index ae2d768..a03c478 100644 --- a/service/timer.py +++ b/service/timer.py @@ -1,15 +1,41 @@ from astrbot.api.event import AstrMessageEvent from astrbot.api.provider import LLMResponse from astrbot.api import logger -from astrbot.core.message.message_event_result import MessageChain +from astrbot.core.message.message_event_result import MessageChain,Plain from ..tool.pattern import Pattern +from astrbot.api.star import Star +import asyncio -# 解析模板并进行定时 -async def timer(event:AstrMessageEvent,req:LLMResponse): - if not req.role == 'assistant': - return +class TimerService: + def __init__(self,star:Star) -> None: + self.star = star + pass - logger.info("[wait_msg]:开始解析模板") - llm_res = req.completion_text - dump = Pattern(llm_res) - await event.send(MessageChain().message("awa定时时间消息:{0}过滤后:{1}".format(dump.count,dump.string))) \ No newline at end of file + # 解析模板并进行定时 + async def parse(self,event:AstrMessageEvent): + res = event.get_result() + if not res: + return + + Second:int|None = None + logger.info("[wait_msg]:开始解析模板") + + chain = res.chain + for i in chain : + if not isinstance(i,Plain): + continue + dump = Pattern(i.text) + i.text = dump.string + Second = dump.count + if not Second is None: + self.timer(event,Second) + + yield + + # 定时: + def timer(self,event:AstrMessageEvent,Sec:int): + asyncio.create_task(self.timer_task()) + + async def timer_task(self): + await asyncio.sleep(1) + logger.warning("awa现在过去一秒了哦") \ No newline at end of file From fe7864853bb6b8ab8292c8629ba7b54540b0043b Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Fri, 6 Nov 2026 21:10:18 +0800 Subject: [PATCH 13/22] fix --- main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/main.py b/main.py index 803688b..c7acd1a 100644 --- a/main.py +++ b/main.py @@ -45,7 +45,7 @@ class MyPlugin(Star): @filter.on_decorating_result() async def pattern_extract(self,event:AstrMessageEvent): - await self.Timer.timer(event) + self.Timer.parse(event) async def terminate(self): """可选择实现异步的插件销毁方法，当插件被卸载/停用时会调用。""" From c6fff5a539095df425d11706a28b60d903380cd4 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Fri, 6 Nov 2026 21:54:24 +0800 Subject: [PATCH 14/22] dev:fix --- service/timer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/service/timer.py b/service/timer.py index a03c478..59e6e94 100644 --- a/service/timer.py +++ b/service/timer.py @@ -22,7 +22,7 @@ class TimerService: chain = res.chain for i in chain : - if not isinstance(i,Plain): + if not isinstance(i,Plain) or i.type == "Plain": continue dump = Pattern(i.text) i.text = dump.string From 140dc6244e293ffc2ead65c7d3b54dce56f35048 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Fri, 6 Nov 2026 21:57:51 +0800 Subject: [PATCH 15/22] dev --- service/timer.py | 1 + 1 file changed, 1 insertion(+) diff --git a/service/timer.py b/service/timer.py index 59e6e94..1e9ee91 100644 --- a/service/timer.py +++ b/service/timer.py @@ -22,6 +22,7 @@ class TimerService: chain = res.chain for i in chain : + logger.info(f"获得消息链类型:{i.type}内容:{i}") if not isinstance(i,Plain) or i.type == "Plain": continue dump = Pattern(i.text) From 498761ba030bca8f98d634e0df614e91ee48b3ff Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Fri, 6 Nov 2026 22:00:27 +0800 Subject: [PATCH 16/22] dev --- service/timer.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/service/timer.py b/service/timer.py index 1e9ee91..5a3a5c7 100644 --- a/service/timer.py +++ b/service/timer.py @@ -13,8 +13,9 @@ class TimerService: # 解析模板并进行定时 async def parse(self,event:AstrMessageEvent): - res = event.get_result() + res = event.get_result() if not res: + logger.info("[wait_msg]:解析失败：没拿到消息链") return Second:int|None = None From 3823b83d9e610991ae9282061168108c856ef087 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Fri, 6 Nov 2026 22:06:00 +0800 Subject: [PATCH 17/22] dev --- main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/main.py b/main.py index c7acd1a..991f386 100644 --- a/main.py +++ b/main.py @@ -45,7 +45,7 @@ class MyPlugin(Star): @filter.on_decorating_result() async def pattern_extract(self,event:AstrMessageEvent): - self.Timer.parse(event) + yield self.Timer.parse(event) async def terminate(self): """可选择实现异步的插件销毁方法，当插件被卸载/停用时会调用。""" From 7610960cb6200c0d52482d0efd9d2c454b25c229 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Fri, 6 Nov 2026 22:08:54 +0800 Subject: [PATCH 18/22] fix: no yield --- main.py | 2 +- service/timer.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/main.py b/main.py index 991f386..6b2099f 100644 --- a/main.py +++ b/main.py @@ -45,7 +45,7 @@ class MyPlugin(Star): @filter.on_decorating_result() async def pattern_extract(self,event:AstrMessageEvent): - yield self.Timer.parse(event) + await self.Timer.parse(event) async def terminate(self): """可选择实现异步的插件销毁方法，当插件被卸载/停用时会调用。""" diff --git a/service/timer.py b/service/timer.py index 5a3a5c7..b0fedf4 100644 --- a/service/timer.py +++ b/service/timer.py @@ -32,11 +32,11 @@ class TimerService: if not Second is None: self.timer(event,Second) - yield + # 定时: def timer(self,event:AstrMessageEvent,Sec:int): - asyncio.create_task(self.timer_task()) + asyncio.create_task(self.timer_task()) async def timer_task(self): await asyncio.sleep(1) From a7c4925106ebb425d08afd806bcb1be40564fee0 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Fri, 6 Nov 2026 22:10:46 +0800 Subject: [PATCH 19/22] fix: no async --- main.py | 2 +- service/timer.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/main.py b/main.py index 6b2099f..c7acd1a 100644 --- a/main.py +++ b/main.py @@ -45,7 +45,7 @@ class MyPlugin(Star): @filter.on_decorating_result() async def pattern_extract(self,event:AstrMessageEvent): - await self.Timer.parse(event) + self.Timer.parse(event) async def terminate(self): """可选择实现异步的插件销毁方法，当插件被卸载/停用时会调用。""" diff --git a/service/timer.py b/service/timer.py index b0fedf4..ad3da9d 100644 --- a/service/timer.py +++ b/service/timer.py @@ -12,7 +12,7 @@ class TimerService: pass # 解析模板并进行定时 - async def parse(self,event:AstrMessageEvent): + def parse(self,event:AstrMessageEvent): res = event.get_result() if not res: logger.info("[wait_msg]:解析失败：没拿到消息链") From 8ce5aa884797480078fa4110b27fdec3649894cc Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Fri, 6 Nov 2026 22:41:33 +0800 Subject: [PATCH 20/22] fix: pointer --- service/timer.py | 11 +++++++---- tool/pattern.py | 3 ++- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/service/timer.py b/service/timer.py index ad3da9d..5ff2354 100644 --- a/service/timer.py +++ b/service/timer.py @@ -13,7 +13,7 @@ class TimerService: # 解析模板并进行定时 def parse(self,event:AstrMessageEvent): - res = event.get_result() + res = event.get_result() if not res: logger.info("[wait_msg]:解析失败：没拿到消息链") return @@ -21,17 +21,20 @@ class TimerService: Second:int|None = None logger.info("[wait_msg]:开始解析模板") - chain = res.chain - for i in chain : + for index,i in enumerate(res.chain) : logger.info(f"获得消息链类型:{i.type}内容:{i}") if not isinstance(i,Plain) or i.type == "Plain": continue dump = Pattern(i.text) i.text = dump.string Second = dump.count + # 改变信息 + res.chain[index] = i + + event.set_result(res) if not Second is None: self.timer(event,Second) - + return # 定时: diff --git a/tool/pattern.py b/tool/pattern.py index 2af896c..7ea6369 100644 --- a/tool/pattern.py +++ b/tool/pattern.py @@ -29,7 +29,7 @@ class Pattern: num = int(content) return self.sec_range(num) except: - logger.debug ("模板内容错误:{}".format(content)) + logger.warning ("模板内容错误:{}".format(content)) return None def extract(self,o_str:str): @@ -47,6 +47,7 @@ class Pattern: #消除不完整/非法模板 o_str= o_str.replace("","") o_str=o_str.replace("","") + logger.info(f"过滤后消息:{o_str}") return { "content":o_str, From 5e3643a2373eb74615be2499285867fc3715aa09 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Fri, 6 Nov 2026 23:04:10 +0800 Subject: [PATCH 21/22] dev --- tool/pattern.py | 1 + 1 file changed, 1 insertion(+) diff --git a/tool/pattern.py b/tool/pattern.py index 7ea6369..6e6526a 100644 --- a/tool/pattern.py +++ b/tool/pattern.py @@ -9,6 +9,7 @@ class Pattern: _MIN_SEC = 10 # 定义最大与最小的范围，固定输入的规范 def __init__(self,o_str:str) -> None: + logger.debug(f"模板消息:{o_str}") res = self.extract(o_str) self.count:int|None = res['second'] self.string:str = res["content"] From c49635faba8f186311fd32889d1b9aa40da7a033 Mon Sep 17 00:00:00 2001 From: Wbucket <2595141012@stu.hqu.edu.cn> Date: Fri, 6 Nov 2026 23:06:42 +0800 Subject: [PATCH 22/22] dev:fxxking 'not' decide --- service/timer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/service/timer.py b/service/timer.py index 5ff2354..0414c92 100644 --- a/service/timer.py +++ b/service/timer.py @@ -23,7 +23,7 @@ class TimerService: for index,i in enumerate(res.chain) : logger.info(f"获得消息链类型:{i.type}内容:{i}") - if not isinstance(i,Plain) or i.type == "Plain": + if not isinstance(i,Plain) or not i.type == "Plain": continue dump = Pattern(i.text) i.text = dump.string