From b08e6ba79de6b15d4638988d9afc6eb7023986c7 Mon Sep 17 00:00:00 2001
From: KimigaiiWuyi <444835641@qq.com>
Date: Thu, 8 May 2025 12:13:57 +0800
Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9B=20=E4=BF=AE=E5=A4=8D=E4=B8=80?=
 =?UTF-8?q?=E4=B8=AABUG,=20=E8=AF=A5BUG=E4=BC=9A=E5=AF=BC=E8=87=B4?=
 =?UTF-8?q?=E5=B0=86=E6=9B=B4=E6=96=B0=E8=AE=B0=E5=BD=95=E5=8F=91=E9=80=81?=
 =?UTF-8?q?=E8=87=B3=E4=BB=BB=E6=84=8F=E7=BE=A4=E5=86=85=20(#117)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 gsuid_core/utils/database/models.py | 8 +++++++-
 gsuid_core/utils/message.py         | 2 +-
 2 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/gsuid_core/utils/database/models.py b/gsuid_core/utils/database/models.py
index 38dcf72..e1a303e 100644
--- a/gsuid_core/utils/database/models.py
+++ b/gsuid_core/utils/database/models.py
@@ -44,17 +44,23 @@ class Subscribe(BaseModel, table=True):
         sep: str = '\n',
         command_tips: str = '请输入以下命令之一:',
         command_start_text: str = '',
+        force_direct: bool = False,
     ):
         for bot_id in gss.active_bot:
             BOT = gss.active_bot[bot_id]
+            if force_direct:
+                user_type = 'direct'
+            else:
+                user_type = self.user_type
             ev = Event(
                 bot_id=self.bot_id,
                 user_id=self.user_id,
                 bot_self_id=self.bot_self_id,
-                user_type=self.user_type,  # type: ignore
+                user_type=user_type,  # type: ignore
                 group_id=self.group_id,
                 real_bot_id=self.bot_id,
             )
+
             bot = Bot(BOT, ev)
             await bot.send_option(
                 reply,
diff --git a/gsuid_core/utils/message.py b/gsuid_core/utils/message.py
index 6a03796..ea88db6 100644
--- a/gsuid_core/utils/message.py
+++ b/gsuid_core/utils/message.py
@@ -24,4 +24,4 @@ async def send_msg_to_master(
     datas = await gs_subscribe.get_subscribe('主人用户')
     if datas:
         for subscribe in datas:
-            await subscribe.send(message)
+            await subscribe.send(message, force_direct=True)