1
This commit is contained in:
薇薇安
parent
baa8277aee
commit
d985b94161
|
|
@ -1822,40 +1822,20 @@ async def sync_positions(
|
|||
except Exception as e:
|
||||
logger.debug(f"获取 {symbol} 成交记录失败: {e}")
|
||||
client_order_id = None
|
||||
prefix_matched = False
|
||||
is_clearly_manual = False
|
||||
if system_order_prefix:
|
||||
if not entry_order_id:
|
||||
logger.debug(f" {symbol} 无法获取开仓订单号，将用「是否有止损/止盈单」兜底判断")
|
||||
else:
|
||||
if entry_order_id:
|
||||
try:
|
||||
order_info = await client.client.futures_get_order(symbol=symbol, orderId=int(entry_order_id), recvWindow=20000)
|
||||
cid = (order_info or {}).get("clientOrderId") or ""
|
||||
client_order_id = cid or None
|
||||
if cid.startswith(system_order_prefix):
|
||||
prefix_matched = True
|
||||
else:
|
||||
logger.debug(f" {symbol} 开仓订单 clientOrderId={cid!r} 非系统前缀，将用「是否有止损/止盈单」兜底判断")
|
||||
if cid and not cid.startswith(system_order_prefix):
|
||||
is_clearly_manual = True
|
||||
logger.debug(f" {symbol} 开仓订单 clientOrderId={cid!r} 非系统前缀，视为手动单，跳过补建")
|
||||
except Exception as e:
|
||||
logger.debug(f" {symbol} 查询开仓订单失败: {e}，将用「是否有止损/止盈单」兜底判断")
|
||||
if not prefix_matched:
|
||||
has_sltp = False
|
||||
try:
|
||||
normal = await client.get_open_orders(symbol)
|
||||
for o in (normal or []):
|
||||
if _order_is_sltp(o, "type"):
|
||||
has_sltp = True
|
||||
break
|
||||
if not has_sltp:
|
||||
algo = await client.futures_get_open_algo_orders(symbol=symbol, algo_type="CONDITIONAL")
|
||||
for o in (algo or []):
|
||||
if _order_is_sltp(o, "orderType"):
|
||||
has_sltp = True
|
||||
break
|
||||
except Exception as e:
|
||||
logger.debug(f"检查 {symbol} 止盈止损单失败: {e}")
|
||||
if only_recover_when_has_sltp and not has_sltp:
|
||||
logger.debug(f" {symbol} 未匹配系统前缀且无止损/止盈单，跳过补建")
|
||||
continue
|
||||
logger.debug(f" {symbol} 查询开仓订单失败: {e}，按系统单补建")
|
||||
if is_clearly_manual:
|
||||
continue
|
||||
elif only_recover_when_has_sltp:
|
||||
has_sltp = False
|
||||
try:
|
||||
|
|
|
|||
|
|
@ -9,14 +9,15 @@
|
|||
### 1. 持仓与币安一致
|
||||
|
||||
- **仪表板「当前持仓」**：数据来自 **币安实时持仓**（`get_open_positions()`），与币安页面一致（仅受 `POSITION_MIN_NOTIONAL_USDT` 过滤影响）。
|
||||
- **补建逻辑**：只有「开仓订单 `clientOrderId` 以配置前缀开头」的持仓会补建 DB 记录，避免把手动单算进系统。
|
||||
- **补建逻辑**：配置了 `SYSTEM_ORDER_ID_PREFIX` 时，**仅当**能明确查到开仓订单且 `clientOrderId` 非空且**不以**该前缀开头时视为手动单并跳过；其余（含历史单、查不到订单、cid 为空）一律补建并加入监控，避免漏掉系统单。
|
||||
|
||||
### 2. 订单记录与币安可对账
|
||||
|
||||
- **开仓**：系统下单时写入 `newClientOrderId = 前缀_时间戳_随机`，并保存 `entry_order_id` 到 DB。
|
||||
- **开仓**：交易系统**所有开仓单**（非 reduce_only）在配置了 `SYSTEM_ORDER_ID_PREFIX` 时都会带 `newClientOrderId = 前缀_时间戳_随机`（如 `SYS_xxx`），成交后写入 DB 的 `entry_order_id` 与 `client_order_id`，与币安一致。
|
||||
- **成交后落库**：开仓成交后 `position_manager` 会调用 `Trade.create(..., entry_order_id=..., client_order_id=...)`，订单记录与币安一一对应；若当时落库失败（超时/崩溃），后续同步会通过「补建」把缺失记录补上并纳入监控。
|
||||
- **平仓**：平仓时保存 `exit_order_id`，`Trade.update_exit` 会做 `get_by_exit_order_id` 防重复。
|
||||
- **同步**：
|
||||
- `POST /api/account/positions/sync`：只对「开仓订单 clientOrderId 前缀匹配」的持仓补建，且从成交里取 `orderId` 作为 `entry_order_id`。
|
||||
- `POST /api/account/positions/sync` 与进程内定时同步：仅当开仓订单 `clientOrderId` **明确非**系统前缀时跳过补建，其余一律补建（含历史单、未带前缀的单），保证「币安有仓且为系统单」都会被监控。
|
||||
- `POST /api/trades/sync-binance`：用 `get_by_exit_order_id(order_id)` 判断是否已同步，避免重复；开仓侧用 `get_by_entry_order_id(order_id)` 判断是否已存在。
|
||||
- 因此：**每条 DB 记录都可与币安订单一一对应**（通过 `entry_order_id` / `exit_order_id`），订单记录与币安在「谁开的、谁平的」上一致。
|
||||
|
||||
|
|
|
|||
|
|
@ -2864,8 +2864,7 @@ class PositionManager:
|
|||
system_order_prefix = (config.TRADING_CONFIG.get("SYSTEM_ORDER_ID_PREFIX") or "").strip()
|
||||
if system_order_prefix:
|
||||
logger.info(
|
||||
f" → 补建「系统单」记录：开仓订单 clientOrderId 前缀为 {system_order_prefix!r} 时创建；"
|
||||
"未匹配前缀时若有止损/止盈单也补建（便于历史单/监控一致）"
|
||||
f" → 补建「系统单」记录：仅当开仓订单 clientOrderId 明确非 {system_order_prefix!r} 前缀时跳过（视为手动单），其余一律补建"
|
||||
)
|
||||
else:
|
||||
logger.info(" → 补建「系统单」记录（仅当存在止损/止盈单时创建，避免手动单误建）" if sync_recover_only_has_sltp else " → 补建缺失持仓记录")
|
||||
|
|
@ -2892,27 +2891,26 @@ class PositionManager:
|
|||
except Exception:
|
||||
pass
|
||||
client_order_id_sync = None
|
||||
prefix_matched = False # 是否通过 clientOrderId 前缀确认为系统单
|
||||
# 仅当「明确查到开仓订单且 clientOrderId 非空且不以系统前缀开头」时视为手动单并跳过；其余一律补建（避免漏掉系统单）
|
||||
is_clearly_manual = False
|
||||
if system_order_prefix:
|
||||
if not entry_order_id:
|
||||
logger.debug(f" {symbol} 无法获取开仓订单号，将用「是否有止损/止盈单」兜底判断")
|
||||
else:
|
||||
if entry_order_id:
|
||||
try:
|
||||
order_info = await self.client.client.futures_get_order(symbol=symbol, orderId=int(entry_order_id), recvWindow=20000)
|
||||
cid = (order_info or {}).get("clientOrderId") or ""
|
||||
client_order_id_sync = cid or None
|
||||
if cid.startswith(system_order_prefix):
|
||||
prefix_matched = True
|
||||
else:
|
||||
logger.debug(f" {symbol} 开仓订单 clientOrderId={cid!r} 非系统前缀，将用「是否有止损/止盈单」兜底判断")
|
||||
if cid and not cid.startswith(system_order_prefix):
|
||||
is_clearly_manual = True
|
||||
logger.debug(f" {symbol} 开仓订单 clientOrderId={cid!r} 非系统前缀，视为手动单，跳过补建")
|
||||
except Exception as e:
|
||||
logger.debug(f" {symbol} 查询开仓订单失败: {e}，将用「是否有止损/止盈单」兜底判断")
|
||||
# 未通过前缀确认时：若有止损/止盈单则仍补建（历史单或前缀未写入时也能被监控）
|
||||
if not prefix_matched and sync_recover_only_has_sltp and not (await _symbol_has_sltp(symbol)):
|
||||
logger.debug(f" {symbol} 未匹配系统前缀且无止损/止盈单，跳过补建")
|
||||
logger.debug(f" {symbol} 查询开仓订单失败: {e}，按系统单补建")
|
||||
# 无法获取订单或 cid 为空（历史单/未带前缀）时不视为手动单，继续补建
|
||||
else:
|
||||
# 未配置前缀时，用「是否有止损/止盈单」区分
|
||||
if sync_recover_only_has_sltp and not (await _symbol_has_sltp(symbol)):
|
||||
logger.debug(f" {symbol} 无止损/止盈单，跳过补建")
|
||||
continue
|
||||
elif sync_recover_only_has_sltp and not (await _symbol_has_sltp(symbol)):
|
||||
logger.debug(f" {symbol} 无止损/止盈单，跳过补建")
|
||||
if is_clearly_manual:
|
||||
continue
|
||||
if entry_order_id and hasattr(Trade, "get_by_entry_order_id"):
|
||||
try:
|
||||
|
|
|
|||
Loading…
Reference in New Issue
Block a user