From 97cc7f2d7428ea890c0a0ada76e5bffafd2463e4 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 26 十月 2023 22:56:11 +0800
Subject: [PATCH] L2总卖实现
---
trade/trade_manager.py | 11 ++++++-----
1 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/trade/trade_manager.py b/trade/trade_manager.py
index 7ac17af..160b6c7 100644
--- a/trade/trade_manager.py
+++ b/trade/trade_manager.py
@@ -42,7 +42,7 @@
# 涔版垚鍔�
TRADE_STATE_BUY_SUCCESS = 12
-guiTrade = None#trade_gui.THSGuiTrade() if trade_gui is not None else None
+guiTrade = None # trade_gui.THSGuiTrade() if trade_gui is not None else None
latest_trade_delegate_data = []
@@ -392,7 +392,7 @@
# 寮�濮嬩氦鏄�
-def start_buy(code, capture_timestamp, last_data, last_data_index):
+def start_buy(code, capture_timestamp, last_data, last_data_index, mode=0):
def is_forbidden(code):
if l2_trade_util.is_in_forbidden_trade_codes(code):
return Exception("绂佹浜ゆ槗")
@@ -432,7 +432,7 @@
async_log_util.info(logger_trade, "{} trade.manager.start_buy 鍒ゆ柇鏄惁鍙拱".format(code))
__CodesTradeStateManager.set_trade_state(code, TRADE_STATE_BUY_PLACE_ORDER)
# 鐘舵�佹敼鍙樿繃鍚庡繀椤昏鏈夋湰鍦颁笅鍗曠紪鍙�
- __buy(code, price, trade_state, capture_timestamp, last_data, last_data_index)
+ __buy(code, price, trade_state, capture_timestamp, last_data, last_data_index, mode)
finally:
async_log_util.info(logger_trade, "{} trade.manager.start_buy 缁撴潫".format(code))
@@ -444,12 +444,14 @@
# 璐拱
# @tool.async_call
-def __buy(code, price, trade_state, capture_timestamp, last_data, last_data_index):
+def __buy(code, price, trade_state, capture_timestamp, last_data, last_data_index, mode=0):
async_log_util.info(logger_trade, "{} trade_manager.__buy 寮�濮�".format(code))
try:
if constant.API_TRADE_ENABLE:
count = (constant.BUY_MONEY_PER_CODE // int(round(float(price) * 100))) * 100
+ if mode != 0:
+ count = 100
# 鏈�浣庝笅鍗�1鎵�
if count < 100:
count = 100
@@ -584,7 +586,6 @@
CodesTradeStateManager().set_trade_state(code, TRADE_STATE_BUY_SUCCESS)
# 鍒犻櫎涔版挙璁板綍鐨勪复鏃朵俊鎭�
kp_client_msg_manager.add_msg(code, "涔板叆鎴愪氦")
- l2_data_manager.TradePointManager().delete_buy_cancel_point(code)
l2_data_manager.TradePointManager().delete_buy_point(code)
# 绉婚櫎浜ゆ槗绐楀彛鍒嗛厤
if trade_gui is not None:
--
Gitblit v1.8.0