Localize LongBridge strategy notifications

Author: Pigbibi

application/rebalance_service.py

@@ -25,9 +25,13 @@
     ("regime=risk_on", "市场阶段=进攻"),
     ("benchmark_trend=down", "基准趋势=向下"),
     ("benchmark_trend=up", "基准趋势=向上"),
+    ("benchmark=down", "基准趋势=向下"),
+    ("benchmark=up", "基准趋势=向上"),
     ("breadth=", "市场宽度="),
     ("target_stock=", "目标股票仓位="),
     ("realized_stock=", "实际股票仓位="),
+    ("stock_exposure=", "股票目标仓位="),
+    ("safe_haven=", "避险仓位="),
     ("selected=", "入选标的数="),
     ("top=", "前排标的="),
     ("no_selection", "无入选标的"),
@@ -212,9 +216,17 @@ def run_strategy(
     current_min_trade = float(execution["current_min_trade"])
     portfolio_rows = tuple(portfolio["portfolio_rows"])
     def record_dry_run(symbol, side, quantity, price, *, order_type):
-        price_text = f"${price:.2f}" if price is not None else "market"
-        suffix = " LIMIT" if order_type == "limit" else ""
-        message = f"🧪 DRY_RUN {side.upper()} {symbol} {quantity} @ {price_text}{suffix}"
+        price_text = f"${price:.2f}" if price is not None else translator("order_type_market")
+        side_key = "side_buy" if str(side).lower() == "buy" else "side_sell"
+        order_type_key = "order_type_limit" if order_type == "limit" else "order_type_market"
+        message = translator(
+            "dry_run_order",
+            side=translator(side_key),
+            symbol=symbol,
+            qty=quantity,
+            price=price_text,
+            order_type=translator(order_type_key),
+        )
         logs.append(message)
         print(with_prefix(message), flush=True)
         return True

notifications/order_alerts.py

@@ -158,6 +158,17 @@ def monitor_submitted_order_status(
         )
 
 
+
+def _append_order_id_suffix(log_message, order_id, *, translator):
+    order_id_text = str(order_id or "").strip()
+    if not order_id_text:
+        return log_message
+    suffix = str(translator("order_id_suffix", order_id=order_id_text)).strip()
+    if not suffix or suffix == "order_id_suffix":
+        suffix = f"[order_id={order_id_text}]"
+    return f"{log_message} {suffix}"
+
+
 def submit_order_with_alert(
     trade_context,
     symbol,
@@ -190,7 +201,7 @@ def submit_order_with_alert(
             submitted_price=submitted_price,
         )
         order_id = report.broker_order_id or ""
-        log_with_order_id = f"{log_message} [order_id={order_id}]" if order_id else log_message
+        log_with_order_id = _append_order_id_suffix(log_message, order_id, translator=translator)
         print_with_prefix(f"OK {log_with_order_id}")
         logs.append(log_with_order_id)
         monitor_submitted_order_status(

notifications/telegram.py

@@ -17,7 +17,7 @@
 I18N = {
     "zh": {
         "rebalance_title": "🔔 【调仓指令】",
-        "dry_run_banner": "🧪 dry-run 模式，本次不会真实下单",
+        "dry_run_banner": "🧪 模拟运行模式，本次不会真实下单",
         "strategy_label": "🧭 策略: {name}",
         "market_status": "📊 市场状态: {status}",
         "risk_position": "💼 交易层风险仓位: {ratio}",
@@ -36,6 +36,7 @@
         "order_filled": "✅ 订单成交 | {symbol} {side} {qty}股 均价 ${price} (ID: {order_id})",
         "order_partial": "⚠️ 订单部分成交 | {symbol} {side} 已成交 {executed}/{qty}股 均价 ${price} (ID: {order_id})",
         "order_error": "❌ 订单异常 | {symbol} {side} {qty}股 已{status} (ID: {order_id}) 原因: {reason}",
+        "order_id_suffix": "（订单号: {order_id}）",
         "error_title": "🚨 【策略异常】",
         "buy_skipped": "⚪️ [买入跳过] {detail}",
         "sell_skipped": "⚪️ [卖出跳过] {detail}",
@@ -47,6 +48,9 @@
         "market_buy": "📈 [市价买入] {symbol}: {qty}股 @ ${price}",
         "limit_sell": "📉 [限价卖出] {symbol}: {qty}股 @ ${price}",
         "market_sell": "📉 [市价卖出] {symbol}: {qty}股 @ ${price}",
+        "dry_run_order": "🧪 模拟{order_type}{side} {symbol}: {qty}股 @ {price}",
+        "order_type_market": "市价",
+        "order_type_limit": "限价",
         "side_buy": "买入",
         "side_sell": "卖出",
         "status_rejected": "拒绝",
@@ -87,6 +91,7 @@
         "order_filled": "✅ Order Filled | {symbol} {side} {qty} shares avg ${price} (ID: {order_id})",
         "order_partial": "⚠️ Partial Fill | {symbol} {side} filled {executed}/{qty} shares avg ${price} (ID: {order_id})",
         "order_error": "❌ Order Error | {symbol} {side} {qty} shares {status} (ID: {order_id}) reason: {reason}",
+        "order_id_suffix": "[order_id={order_id}]",
         "error_title": "🚨 【Strategy Error】",
         "buy_skipped": "⚪️ [Buy skipped] {detail}",
         "sell_skipped": "⚪️ [Sell skipped] {detail}",
@@ -98,6 +103,9 @@
         "market_buy": "📈 [Market buy] {symbol}: {qty} shares @ ${price}",
         "limit_sell": "📉 [Limit sell] {symbol}: {qty} shares @ ${price}",
         "market_sell": "📉 [Market sell] {symbol}: {qty} shares @ ${price}",
+        "dry_run_order": "🧪 DRY_RUN {order_type} {side} {symbol} {qty} @ {price}",
+        "order_type_market": "market",
+        "order_type_limit": "limit",
         "side_buy": "Buy",
         "side_sell": "Sell",
         "status_rejected": "Rejected",

tests/test_order_alerts.py

@@ -0,0 +1,33 @@
+from types import SimpleNamespace
+
+from notifications.order_alerts import submit_order_with_alert
+from notifications.telegram import build_translator
+
+
+def test_submit_order_with_alert_localizes_order_id_suffix_for_zh():
+    logs = []
+    printed = []
+
+    submitted = submit_order_with_alert(
+        trade_context=object(),
+        symbol="BOXX.US",
+        order_type="market",
+        side="buy",
+        quantity=49,
+        logs=logs,
+        log_message="📈 [市价买入] BOXX: 49股 @ $116.31",
+        submit_order=lambda *_args, **_kwargs: SimpleNamespace(broker_order_id="1227343614540054528"),
+        fetch_order_status=lambda *_args, **_kwargs: None,
+        translator=build_translator("zh"),
+        send_tg_message=lambda _message: None,
+        notify_issue=lambda *_args, **_kwargs: None,
+        order_poll_interval_sec=0,
+        order_poll_max_attempts=0,
+        sleeper=lambda _seconds: None,
+        print_with_prefix=printed.append,
+    )
+
+    assert submitted is True
+    assert logs == ["📈 [市价买入] BOXX: 49股 @ $116.31 （订单号: 1227343614540054528）"]
+    assert "order_id=" not in logs[0]
+    assert printed == ["OK 📈 [市价买入] BOXX: 49股 @ $116.31 （订单号: 1227343614540054528）"]

tests/test_rebalance_service.py

@@ -163,7 +163,7 @@ def fake_submit_order_with_alert(
             submitted_price=None,
         ):
             del trade_context, order_type, side, quantity, submitted_price
-            logs.append(f"{log_message} [order_id=test-order]")
+            logs.append(f"{log_message} （订单号: test-order）")
             return True
 
         plan_side_effect = [plan, refreshed_plan or plan]
@@ -444,9 +444,9 @@ def test_dry_run_replaces_real_order_submission_with_summary_lines(self):
         )
 
         self.assertEqual(len(sent_messages), 1)
-        self.assertIn("🧪 dry-run 模式", sent_messages[0])
-        self.assertIn("🧪 DRY_RUN SELL SOXL.US", sent_messages[0])
-        self.assertIn("🧪 DRY_RUN BUY SOXX.US", sent_messages[0])
+        self.assertIn("🧪 模拟运行模式", sent_messages[0])
+        self.assertIn("🧪 模拟限价卖出 SOXL.US", sent_messages[0])
+        self.assertIn("🧪 模拟限价买入 SOXX.US", sent_messages[0])
 
     def test_heartbeat_accepts_normalized_portfolio_and_execution_sections(self):
         plan = _build_plan(
@@ -517,7 +517,7 @@ def test_hybrid_heartbeat_hides_empty_semiconductor_fields_and_shows_benchmark_l
         self.assertEqual(len(sent_messages), 1)
         self.assertIn("💓 【心跳检测】", sent_messages[0])
         self.assertIn("🧭 策略: TQQQ 增长收益", sent_messages[0])
-        self.assertIn("🧪 dry-run 模式", sent_messages[0])
+        self.assertIn("🧪 模拟运行模式", sent_messages[0])
         self.assertIn("QQQ: 588.50 | MA200: 595.25 | Exit: 573.00", sent_messages[0])
         self.assertIn("🎯 信号: 💤 等待信号", sent_messages[0])
         self.assertNotIn("📊 市场状态: ", sent_messages[0])