|
1 | 1 | from __future__ import annotations |
2 | 2 |
|
3 | | -from nonebot import get_adapter, logger |
| 3 | +from nonebot import logger, get_adapter |
| 4 | +from nonebot.rule import is_type |
| 5 | +from nonebot.drivers import Request |
| 6 | +from nonebot.plugin.on import on_message |
| 7 | +from nonebot.adapters.telegram import Bot as TGBot |
4 | 8 | from nonebot.adapters.onebot.v11 import ( |
5 | 9 | Bot as OB11Bot, |
| 10 | +) |
| 11 | +from nonebot.adapters.onebot.v11 import ( |
6 | 12 | Message as OB11Message, |
| 13 | +) |
| 14 | +from nonebot.adapters.onebot.v11 import ( |
7 | 15 | MessageEvent as OB11MessageEvent, |
| 16 | +) |
| 17 | +from nonebot.adapters.onebot.v11 import ( |
| 18 | + MessageSegment as OB11Segment, |
| 19 | +) |
| 20 | +from nonebot.adapters.onebot.v11 import ( |
8 | 21 | GroupMessageEvent as OB11GroupMessageEvent, |
| 22 | +) |
| 23 | +from nonebot.adapters.onebot.v11 import ( |
9 | 24 | PrivateMessageEvent as OB11PrivateMessageEvent, |
10 | | - MessageSegment as OB11Segment, |
11 | 25 | ) |
12 | | -from nonebot.adapters.telegram import Bot as TGBot |
13 | 26 | from nonebot.adapters.telegram.event import MessageEvent as TGMessageEvent |
14 | 27 | from nonebot.adapters.telegram.message import ( |
15 | | - Message as TGMessage, |
16 | 28 | File, |
17 | 29 | Entity, |
18 | 30 | ) |
19 | | -from nonebot.drivers import Request |
20 | | -from nonebot.plugin.on import on_message |
21 | | -from nonebot.rule import is_type |
| 31 | +from nonebot.adapters.telegram.message import ( |
| 32 | + Message as TGMessage, |
| 33 | +) |
22 | 34 |
|
23 | 35 | from .config import Config |
24 | 36 |
|
@@ -87,9 +99,7 @@ async def _download_tg_file(tg_bot: TGBot, file_id: str) -> bytes | None: |
87 | 99 | # ============================================================ |
88 | 100 | # TG Message → OneBot V11 Message |
89 | 101 | # ============================================================ |
90 | | -async def _tg_message_to_ob11( |
91 | | - tg_bot: TGBot, event: TGMessageEvent |
92 | | -) -> OB11Message: |
| 102 | +async def _tg_message_to_ob11(tg_bot: TGBot, event: TGMessageEvent) -> OB11Message: |
93 | 103 | segments: list[OB11Segment] = [] |
94 | 104 |
|
95 | 105 | for seg in event.get_message(): |
@@ -180,15 +190,17 @@ async def _send_to_tg( |
180 | 190 | try: |
181 | 191 | await tg_bot.send_to( |
182 | 192 | chat_id=chat_id, |
183 | | - message=TGMessage([first_seg]) + TGMessage([Entity.text(full_caption)]), |
| 193 | + message=TGMessage([first_seg]) |
| 194 | + + TGMessage([Entity.text(full_caption)]), |
184 | 195 | ) |
185 | 196 | except Exception as e: |
186 | 197 | logger.error(f"[{mode}] 发送图片到 TG 失败: {e}") |
187 | 198 | else: |
188 | 199 | try: |
189 | 200 | await tg_bot.send_to( |
190 | 201 | chat_id=chat_id, |
191 | | - message=TGMessage([first_seg]) + TGMessage([Entity.text(full_caption)]), |
| 202 | + message=TGMessage([first_seg]) |
| 203 | + + TGMessage([Entity.text(full_caption)]), |
192 | 204 | ) |
193 | 205 | for seg in file_segments[1:]: |
194 | 206 | await tg_bot.send_to(chat_id=chat_id, message=seg) |
@@ -279,7 +291,13 @@ async def handle_ob11_message(event: OB11MessageEvent): |
279 | 291 | # ---------- 转发模式(QQ → TG 单向) ---------- |
280 | 292 | if config.onebot2tg_enable_forward and config.onebot2tg_forward_target_chat_id: |
281 | 293 | if is_group: |
282 | | - source = f"[群:{event.group_id}] {display_name}" |
| 294 | + group_name = "" |
| 295 | + try: |
| 296 | + group_info = await ob11_bot.get_group_info(group_id=event.group_id) |
| 297 | + group_name = group_info.get("group_name", "") |
| 298 | + except Exception as e: |
| 299 | + logger.warning(f"获取群信息失败: {e}") |
| 300 | + source = f"[群:{group_name or event.group_id}] {display_name}" |
283 | 301 | elif isinstance(event, OB11PrivateMessageEvent): |
284 | 302 | source = f"[私聊] {display_name}" |
285 | 303 | else: |
|
0 commit comments