Merge main and resolve plugin copy conflicts.

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: Pigbibi

notifications/telegram.py

@@ -17,6 +17,18 @@
 except ImportError:  # pragma: no cover - compatibility with older pinned shared wheels
     _merge_strategy_plugin_i18n = None
 
+_TELEGRAM_MARKET_SYMBOL_LINK_RE = re.compile(r"(?<![A-Za-z0-9_])([A-Z0-9]{1,12})\.([A-Z]{2,4})(?![A-Za-z0-9_])")
+_TELEGRAM_MARKET_SYMBOL_LINK_JOINER = "\u2060"
+
+
+def _break_telegram_market_symbol_auto_links(value: object) -> str:
+    text = str(value or "")
+    return _TELEGRAM_MARKET_SYMBOL_LINK_RE.sub(
+        lambda match: f"{match.group(1)}.{_TELEGRAM_MARKET_SYMBOL_LINK_JOINER}{match.group(2)}",
+        text,
+    )
+
+
 _PRICE_SOURCE_LABELS = {
     "longbridge_candlesticks": ("LongBridge 日线K线", "LongBridge daily candlesticks"),
     "schwab_daily_history_with_live_quote_overlay": ("Schwab 日线历史", "Schwab daily history"),
@@ -185,12 +197,13 @@ def format_small_account_whole_share_bootstrap_notes(
         "strategy_plugin_line": "🧩 插件：{plugin} | 启用：{enabled} | 状态：{route} | 提醒：{action}",
         "strategy_plugin_enabled_true": "是",
         "strategy_plugin_enabled_false": "否",
-        "strategy_plugin_consumption_auto": "🧩 插件消费：已按策略规则参与本轮仓位计算",
-        "strategy_plugin_consumption_auto_defend": "🧩 插件消费：已按策略规则参与本轮仓位计算；风险仓位按防守规则处理",
-        "strategy_plugin_consumption_auto_delever": "🧩 插件消费：已按策略规则参与本轮仓位计算；杠杆仓位按降档规则缩放",
-        "strategy_plugin_consumption_loaded_not_applied": "🧩 插件消费：已加载但未改写仓位；当前策略未启用该状态的自动消费",
-        "strategy_plugin_consumption_review_only": "🧩 插件消费：仅通知复核，未参与自动仓位计算",
-        "strategy_plugin_consumption_unavailable": "🧩 插件消费：未消费插件信号",
+        "strategy_plugin_consumption_auto": "🧩 插件本次影响：已按策略规则参与本轮仓位计算",
+        "strategy_plugin_consumption_auto_defend": "🧩 插件本次影响：已触发防守规则并参与本轮仓位计算",
+        "strategy_plugin_consumption_auto_delever": "🧩 插件本次影响：已触发降杠杆规则并参与本轮仓位计算",
+        "strategy_plugin_consumption_loaded_not_applied": "🧩 插件本次影响：已加载；该状态未启用自动仓位改写",
+        "strategy_plugin_consumption_review_only": "🧩 插件本次影响：仅通知复核；当前状态未触发自动仓位改写",
+        "strategy_plugin_consumption_unavailable": "🧩 插件本次影响：未加载可用插件信号",
+
         "strategy_plugin_alert_subject": "🚨 策略插件告警：{plugin} | {route}",
         "strategy_plugin_alert_title": "🚨 【策略插件告警】",
         "strategy_plugin_alert_context": "运行环境：{context}",
@@ -346,12 +359,13 @@ def format_small_account_whole_share_bootstrap_notes(
         "strategy_plugin_line": "🧩 Plugin: {plugin} | enabled: {enabled} | status: {route} | notice: {action}",
         "strategy_plugin_enabled_true": "yes",
         "strategy_plugin_enabled_false": "no",
-        "strategy_plugin_consumption_auto": "🧩 Plugin consumption: included in this cycle's position calculation under strategy rules",
-        "strategy_plugin_consumption_auto_defend": "🧩 Plugin consumption: included in this cycle's position calculation; risk exposure follows defensive rules",
-        "strategy_plugin_consumption_auto_delever": "🧩 Plugin consumption: included in this cycle's position calculation; leveraged exposure follows de-risking rules",
-        "strategy_plugin_consumption_loaded_not_applied": "🧩 Plugin consumption: loaded but did not rewrite positions; this strategy does not enable automatic consumption for this state",
-        "strategy_plugin_consumption_review_only": "🧩 Plugin consumption: review-only notice, not used for automatic position calculation",
-        "strategy_plugin_consumption_unavailable": "🧩 Plugin consumption: no plugin signal consumed",
+        "strategy_plugin_consumption_auto": "🧩 Plugin impact this run: included in this cycle's position calculation under strategy rules",
+        "strategy_plugin_consumption_auto_defend": "🧩 Plugin impact this run: triggered defensive rules and joined this cycle's position calculation",
+        "strategy_plugin_consumption_auto_delever": "🧩 Plugin impact this run: triggered de-levering rules and joined this cycle's position calculation",
+        "strategy_plugin_consumption_loaded_not_applied": "🧩 Plugin impact this run: loaded; this state did not enable automatic position rewrites",
+        "strategy_plugin_consumption_review_only": "🧩 Plugin impact this run: review-only notice; current state did not trigger automatic position rewrites",
+        "strategy_plugin_consumption_unavailable": "🧩 Plugin impact this run: no usable plugin signal loaded",
+
         "strategy_plugin_alert_subject": "🚨 Strategy plugin alert: {plugin} | {route}",
         "strategy_plugin_alert_title": "🚨 【Strategy Plugin Alert】",
         "strategy_plugin_alert_context": "Context: {context}",
@@ -522,7 +536,11 @@ def send_tg_message(message: str) -> None:
             return
         url = f"https://api.telegram.org/bot{token}/sendMessage"
         try:
-            requests_module.post(url, json={"chat_id": chat_id, "text": message}, timeout=15)
+            requests_module.post(
+                url,
+                json={"chat_id": chat_id, "text": _break_telegram_market_symbol_auto_links(message)},
+                timeout=15,
+            )
         except Exception as exc:
             print(f"Telegram send failed: {type(exc).__name__}", flush=True)
 

tests/test_notifications.py

@@ -0,0 +1,34 @@
+import sys
+from pathlib import Path
+
+
+ROOT = Path(__file__).resolve().parents[1]
+if str(ROOT) not in sys.path:
+    sys.path.insert(0, str(ROOT))
+PLATFORM_KIT_SRC = ROOT.parent / "QuantPlatformKit" / "src"
+if str(PLATFORM_KIT_SRC) not in sys.path:
+    sys.path.insert(0, str(PLATFORM_KIT_SRC))
+
+from notifications.telegram import build_sender
+
+
+class FakeRequests:
+    def __init__(self):
+        self.calls = []
+
+    def post(self, url, json, timeout):
+        self.calls.append((url, json, timeout))
+        return object()
+
+
+def test_build_sender_breaks_market_symbol_auto_links():
+    fake_requests = FakeRequests()
+    sender = build_sender("token-1", "chat-1", requests_module=fake_requests)
+    sender("SOXL.US and 00700.HK")
+
+    assert len(fake_requests.calls) == 1
+    url, payload, timeout = fake_requests.calls[0]
+    assert "token-1" in url
+    assert payload["chat_id"] == "chat-1"
+    assert payload["text"] == "SOXL.\u2060US and 00700.\u2060HK"
+    assert timeout == 15

tests/test_rebalance_service.py

@@ -453,7 +453,7 @@ def test_run_strategy_cycle_strategy_plugin_load_error_is_non_blocking(monkeypat
     assert result["strategy_plugin_error"].startswith("JSONDecodeError:")
     assert result["strategy_plugin_error_lines"] == (
         "⚠️ Plugin signal failed to load: invalid plugin mount JSON; this run falls back to built-in strategy rules",
-        "🧩 Plugin consumption: no plugin signal consumed",
+        "🧩 Plugin impact this run: no usable plugin signal loaded",
     )
     assert result["strategy_plugin_alert_email_sent_count"] == 0
     assert result["strategy_plugin_alert_sms_sent_count"] == 0