diff --git a/pkg/pipeline/pipelinemgr.py b/pkg/pipeline/pipelinemgr.py index 3e126314..c19d5b6f 100644 --- a/pkg/pipeline/pipelinemgr.py +++ b/pkg/pipeline/pipelinemgr.py @@ -96,7 +96,7 @@ class RuntimePipeline: if query.pipeline_config['output']['misc']['at-sender'] and isinstance( query.message_event, platform_events.GroupMessage ): - result.user_notice.insert(0, platform_message.At(query.message_event.sender.id)) + result.user_notice.insert(0, platform_message.At(target=query.message_event.sender.id)) if await query.adapter.is_stream_output_supported(): await query.adapter.reply_message_chunk( message_source=query.message_event, diff --git a/pkg/pipeline/resprule/rules/atbot.py b/pkg/pipeline/resprule/rules/atbot.py index b35fb5e4..b6c17d98 100644 --- a/pkg/pipeline/resprule/rules/atbot.py +++ b/pkg/pipeline/resprule/rules/atbot.py @@ -25,17 +25,4 @@ class AtBotRule(rule_model.GroupRespondRule): remove_at(message_chain) remove_at(message_chain) # 回复消息时会at两次,检查并删除重复的 - # if message_chain.has(platform_message.At(query.adapter.bot_account_id)) and rule_dict['at']: - # message_chain.remove(platform_message.At(query.adapter.bot_account_id)) - - # if message_chain.has( - # platform_message.At(query.adapter.bot_account_id) - # ): # 回复消息时会at两次,检查并删除重复的 - # message_chain.remove(platform_message.At(query.adapter.bot_account_id)) - - # return entities.RuleJudgeResult( - # matching=True, - # replacement=message_chain, - # ) - return entities.RuleJudgeResult(matching=False, replacement=message_chain)