From b749ba587dfb439f3a5fc68e269860655a0c953b Mon Sep 17 00:00:00 2001 From: RockChinQ <1010553892@qq.com> Date: Tue, 30 Jan 2024 21:56:25 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=81=A2=E5=A4=8D=E5=BC=BA=E5=88=B6?= =?UTF-8?q?=E6=B6=88=E6=81=AF=E5=BB=B6=E8=BF=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/pipeline/respback/respback.py | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/pkg/pipeline/respback/respback.py b/pkg/pipeline/respback/respback.py index 4dbddaa5..0a60a793 100644 --- a/pkg/pipeline/respback/respback.py +++ b/pkg/pipeline/respback/respback.py @@ -1,5 +1,8 @@ from __future__ import annotations +import random +import asyncio + import mirai from ...core import app @@ -17,6 +20,14 @@ class SendResponseBackStage(stage.PipelineStage): async def process(self, query: core_entities.Query, stage_inst_name: str) -> entities.StageProcessResult: """处理 """ + random_delay = random.uniform(*self.ap.cfg_mgr.data['force_delay_range']) + + self.ap.logger.debug( + "根据规则强制延迟回复: %s s", + random_delay + ) + + await asyncio.sleep(random_delay) await self.ap.im_mgr.send( query.message_event,