This commit is contained in:
aaron 2026-02-21 19:40:29 +08:00
parent 7d04608216
commit ae9f4cf87c
3 changed files with 8 additions and 3 deletions

View File

@ -73,7 +73,12 @@ def check_abnormal_orders():
print("-" * 80)
one_hour_ago = datetime.now() - timedelta(hours=1)
closed_abnormal = db.query(PaperOrder).filter(
PaperOrder.status.in_([OrderStatus.CLOSED, OrderStatus.CLOSED_TP, OrderStatus.CLOSED_SL, OrderStatus.CLOSED_BE]),
PaperOrder.status.in_([
OrderStatus.CLOSED_TP,
OrderStatus.CLOSED_SL,
OrderStatus.CLOSED_BE,
OrderStatus.CLOSED_MANUAL
]),
PaperOrder.closed_at >= one_hour_ago,
(
(PaperOrder.filled_price == None) | (PaperOrder.filled_price == 0) |

View File

@ -44,7 +44,7 @@ SELECT
closed_at,
'平仓订单价格异常' as issue
FROM paper_orders
WHERE status IN ('CLOSED', 'CLOSED_TP', 'CLOSED_SL', 'CLOSED_BE')
WHERE status IN ('CLOSED_TP', 'CLOSED_SL', 'CLOSED_BE', 'CLOSED_MANUAL')
AND closed_at >= datetime('now', '-1 hour')
AND (
filled_price IS NULL OR filled_price = 0 OR

View File

@ -73,7 +73,7 @@ SELECT
' | 成交:' || COALESCE(CAST(filled_price AS TEXT), 'NULL') ||
' | 出场:' || COALESCE(CAST(exit_price AS TEXT), 'NULL')
FROM paper_orders
WHERE status IN ('CLOSED', 'CLOSED_TP', 'CLOSED_SL', 'CLOSED_BE')
WHERE status IN ('CLOSED_TP', 'CLOSED_SL', 'CLOSED_BE', 'CLOSED_MANUAL')
AND closed_at >= datetime('now', '-1 hour')
AND (
filled_price IS NULL OR filled_price = 0 OR