diff --git a/main.py b/main.py index 9d45c96..ff94e26 100644 --- a/main.py +++ b/main.py @@ -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()