|
|
@@ -106,7 +106,7 @@ def sell_trader(data, positions_dict):
|
|
|
print(order_id, stock, volume)
|
|
|
|
|
|
|
|
|
-def buy_trader(data):
|
|
|
+def buy_trader(data, positions):
|
|
|
print('买入函数:', dt.now())
|
|
|
results = mp.Manager().list()
|
|
|
mp_list = []
|
|
|
@@ -184,9 +184,9 @@ def buy_trader(data):
|
|
|
asset = xt_trader.query_stock_asset(acc)
|
|
|
cash = asset.cash
|
|
|
print(cash)
|
|
|
- if stock in new_keep_stock:
|
|
|
- current_price = data[stock]['lastPrice']
|
|
|
- if cash > 2000:
|
|
|
+ if cash > 2000 and len(positions) < 12:
|
|
|
+ if stock in new_keep_stock:
|
|
|
+ current_price = data[stock]['lastPrice']
|
|
|
volume = int((cash / 3 / current_price) // 100 * 100)
|
|
|
print('volume：', volume)
|
|
|
print('买入信号！！！！！！', stock, volume, current_price)
|
|
|
@@ -207,7 +207,7 @@ def trader(data):
|
|
|
sell_trader(data, positions_dict)
|
|
|
|
|
|
# 买入条件
|
|
|
- buy_trader(data)
|
|
|
+ buy_trader(data, positions)
|
|
|
|
|
|
|
|
|
class MyXtQuantTraderCallback(XtQuantTraderCallback):
|
