From 07aecbafd7397b0aaa5d18edc697b64e8c62d454 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 05 十一月 2024 18:02:37 +0800
Subject: [PATCH] 排1优化
---
servers/huaxin_trade_server.py | 30 ++++++++++++++++++++++++++----
1 files changed, 26 insertions(+), 4 deletions(-)
diff --git a/servers/huaxin_trade_server.py b/servers/huaxin_trade_server.py
index 0af072c..35c3cfb 100644
--- a/servers/huaxin_trade_server.py
+++ b/servers/huaxin_trade_server.py
@@ -368,15 +368,14 @@
for d in datas:
if gpcode_manager.BuyOpenLimitUpCodeManager().is_in_cache(d[0]):
# 09:19:50 鍒� 09:20:00鍒ゆ柇鏄惁瑕佹挙鍗�
- if int("091950") <= tool.get_now_time_as_int() < int("092000"):
+ if int("091950") <= int(d[9].replace(":", "")) < int("092000"):
async_log_util.info(logger_debug, f"鎺�1鎾ゅ崟锛歿d}")
- if d[8]*d[5] < 1e8:
+ if d[8] * d[5] < 1e8:
code = d[0]
current_delegates = DelegateRecordManager().list_current_delegates(code)
if current_delegates:
for c in current_delegates:
huaxin_trade_api.cancel_order(1, code, c["orderSysID"])
-
# 鑾峰彇L1鐜颁环
@classmethod
@@ -943,11 +942,34 @@
pass
+def __subscript_fixed_codes_l2():
+ """
+ 璁㈤槄鍥哄畾浠ｇ爜鐨凩2鏁版嵁
+ @return:
+ """
+ codes = gpcode_manager.BuyOpenLimitUpCodeManager().get_codes()
+ add_datas = []
+ for code in codes:
+ limit_up_price = gpcode_manager.get_limit_up_price_as_num(code)
+ if not limit_up_price:
+ init_data_util.re_set_price_pre(code)
+ limit_up_price = gpcode_manager.get_limit_up_price_as_num(code)
+ min_volume = int(round(50 * 10000 / limit_up_price))
+ # 浼犻�掔瀛愪环
+ add_datas.append(
+ # 锛堜唬鐮�, 鏈�灏忛噺, 娑ㄥ仠浠凤紝褰卞瓙璁㈠崟浠锋牸,涔伴噺, 鐗规畩浠锋牸锛�
+ (code, min_volume, limit_up_price, round(tool.get_shadow_price(limit_up_price), 2),
+ tool.get_buy_volume(limit_up_price),
+ [tool.get_buy_volume_by_money(limit_up_price, x) for x in constant.AVAILABLE_BUY_MONEYS]))
+ huaxin_target_codes_manager.HuaXinL2SubscriptCodesManager.push(add_datas, 0)
+
+
# 鍋氫竴浜涘垵濮嬪寲鐨勬搷浣�
def __init():
def run_pending():
schedule.every().day.at("15:10:00").do(zyltgb_util.update_all_zylt_volumes)
- schedule.every().day.at("01:25:01").do(__test_pre_place_order)
+ schedule.every().day.at("01:02:00").do(__test_pre_place_order)
+ schedule.every().day.at("09:10:00").do(__subscript_fixed_codes_l2)
schedule.every().day.at("08:00:01").do(history_k_data_manager.update_history_k_bars)
schedule.every().day.at("08:30:01").do(history_k_data_manager.update_history_k_bars)
schedule.every().day.at("09:00:01").do(history_k_data_manager.update_history_k_bars)
--
Gitblit v1.8.0