better handle query status

This commit is contained in:
2026-03-08 08:59:57 +08:00
parent 110892b772
commit 08ef024bf1

View File

@@ -176,17 +176,16 @@ def main():
trade_data["order"]["type"],
trade_data["order"]["side"],
trade_data["order"]["amount"],
trade_data["order"].get("price", None),
trade_data["order"]["price"],
)
if order_detail["status"] == "open":
db.data[trade_id]["order_id"]["open"].append(order_detail["id"])
db.data[trade_id]["counter"]["open"] += 1
elif order_detail["status"] == "closed":
if order_detail["status"] == "closed":
logger.info("%s: 订单成交", order_detail["id"])
csv_record(config_file_name, order_detail, accounts[trade_data["account"]].id, trade_data.get("csv_symbol", None))
db.data[trade_id]["order_id"]["filled"].append(order_detail["id"])
db.data[trade_id]["counter"]["filled"] += 1
else:
db.data[trade_id]["order_id"]["open"].append(order_detail["id"])
db.data[trade_id]["counter"]["open"] += 1
logger.warning("%s: 订单状态为 %s,未加入追踪", order_detail["id"], order_detail["status"])
db.save()