From 66aa33990688c98e96439ce941af741999e7a1be Mon Sep 17 00:00:00 2001
From: van <van333@foxmail.com>
Date: Thu, 23 Apr 2026 22:20:34 +0800
Subject: [PATCH] 1

---
 .../src/main/resources/application-dev.yml    |  2 +-
 .../src/main/resources/application-prod.yml   |  2 +-
 .../service/impl/OpenPhoneForwardService.java | 21 +++++++------------
 3 files changed, 10 insertions(+), 15 deletions(-)

diff --git a/ruoyi-admin/src/main/resources/application-dev.yml b/ruoyi-admin/src/main/resources/application-dev.yml
index 41a7345..621d0a0 100644
--- a/ruoyi-admin/src/main/resources/application-dev.yml
+++ b/ruoyi-admin/src/main/resources/application-dev.yml
@@ -237,7 +237,7 @@ jarvis:
     # wait_reply 时服务端会等多条 Bot 回复，宜适当加大
     read-timeout-ms: 120000
     wait-reply: true
-    # reply_take_nth 由 Java 按 bot 固定：开(AJL05_bot)=2，慢开(QingBao)=3
+    # reply_take_nth：仅「开」用 2；「慢开」由 tg_bridge reply_adaptive_skip_middle_ad 在 2/3 条间自适应
   # Ollama 大模型服务（监控健康度调试用）
   ollama:
     base-url: http://192.168.8.34:11434
diff --git a/ruoyi-admin/src/main/resources/application-prod.yml b/ruoyi-admin/src/main/resources/application-prod.yml
index 9d9574d..59d076c 100644
--- a/ruoyi-admin/src/main/resources/application-prod.yml
+++ b/ruoyi-admin/src/main/resources/application-prod.yml
@@ -226,7 +226,7 @@ jarvis:
     connect-timeout-ms: 8000
     read-timeout-ms: 120000
     wait-reply: true
-    # reply_take_nth：Java 按 bot 固定（开=2，慢开=3）
+    # 「开」取第 2 条；「慢开」由桥接自适应第 2/3 条
   # Ollama 大模型服务（监控健康度调试用）
   ollama:
     base-url: http://192.168.8.34:11434
diff --git a/ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/OpenPhoneForwardService.java b/ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/OpenPhoneForwardService.java
index ce03610..5c54c6c 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/OpenPhoneForwardService.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/OpenPhoneForwardService.java
@@ -21,8 +21,9 @@ import java.util.regex.Pattern;
  * 企微「开」/「慢开」+ 手机号：POST 局域网 /v1/forward，body 含 {@code text}（手机号）与 {@code bot}，
  * 将 JSON 中的 {@code reply_text} 作为回显。
  * <p>
- * {@code wait_reply} 时按 Bot 取第 N 条回复：{@code AJL05_bot} 为第 2 条，{@code QingBaoJuXWsgkbot} 为第 3 条；
- * 「慢开」返回正文会去掉固定广告行（替换为空格）。
+ * {@code wait_reply} 时：{@code AJL05_bot} 固定取第 2 条；{@code QingBaoJuXWsgkbot} 由 tg_bridge
+ * 在同一会话内多次收取（仅一次发送 query），按第 2 条是否已为结果决定在 2/3 条间取值，避免重复计费。
+ * 「慢开」返回仍会去掉尾部固定推广行。
  * </p>
  */
 @Service
@@ -40,8 +41,6 @@ public class OpenPhoneForwardService {
 
     private static final int REPLY_TAKE_NTH_OPEN_BOT = 2;
 
-    private static final int REPLY_TAKE_NTH_SLOW_BOT = 3;
-
     /**
      * QingBao 机器人回复尾部的固定推广行（👉 与正文间可能含 ZWJ U+200D），整段替换为空格。
      */
@@ -121,9 +120,12 @@ public class OpenPhoneForwardService {
             body.put("text", phone);
             body.put("bot", bot);
             if (waitReply) {
-                int nth = replyTakeNthForBot(bot);
                 body.put("wait_reply", true);
-                body.put("reply_take_nth", nth);
+                if (BOT_SLOW_OPEN.equals(bot)) {
+                    body.put("reply_adaptive_skip_middle_ad", true);
+                } else {
+                    body.put("reply_take_nth", REPLY_TAKE_NTH_OPEN_BOT);
+                }
             }
             byte[] bytes = body.toJSONString().getBytes(StandardCharsets.UTF_8);
 
@@ -169,13 +171,6 @@ public class OpenPhoneForwardService {
         }
     }
 
-    private static int replyTakeNthForBot(String bot) {
-        if (BOT_SLOW_OPEN.equals(bot)) {
-            return REPLY_TAKE_NTH_SLOW_BOT;
-        }
-        return REPLY_TAKE_NTH_OPEN_BOT;
-    }
-
     /** 将固定广告段替换为空格后 trim。 */
     private static String filterQingBaoAdLines(String reply) {
         String s = reply;