This commit is contained in:
2026-09-09 18:28:32 +08:00
parent 91ad2dabdf
commit 32460e37bc
2 changed files with 3 additions and 2 deletions

View File

@@ -346,7 +346,6 @@ def format_holding(positions):
return holding return holding
def format_orders(orders): def format_orders(orders):
"""显式转换委托/成交字段,保留原始数值类型。"""
result = [] result = []
for order in orders: for order in orders:
result.append({ result.append({
@@ -370,7 +369,6 @@ def format_orders(orders):
return result return result
def format_deals(deals): def format_deals(deals):
"""显式转换委托/成交字段,保留原始数值类型。"""
result = [] result = []
for d in deals: for d in deals:
result.append({ result.append({

View File

@@ -1,6 +1,7 @@
from dataclasses import asdict, is_dataclass from dataclasses import asdict, is_dataclass
from datetime import date, datetime from datetime import date, datetime
from enum import Enum from enum import Enum
import json
from typing import Any from typing import Any
from strategy.trend.boot import get_collector_snapshot from strategy.trend.boot import get_collector_snapshot
import httpx import httpx
@@ -43,6 +44,8 @@ def collector_push(account_id: str, assets: Any, positions: Any) -> None:
"positions": positions, "positions": positions,
} }
) )
pretty_json = json.dumps(payload, indent=4, ensure_ascii=False)
print(pretty_json)
httpx.post(COLLECTOR_URL, json=payload, timeout=3.0) httpx.post(COLLECTOR_URL, json=payload, timeout=3.0)
except BaseException: except BaseException:
# Collection must never interrupt or affect the trading workflow. # Collection must never interrupt or affect the trading workflow.