From 2c707e6083d8d60b088a7f91a0020370e65c8c7f Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 29 十月 2024 17:10:24 +0800
Subject: [PATCH] 昨日跌幅过大不扫入/添加日志记录
---
servers/huaxin_trade_server.py | 8 +++++++-
1 files changed, 7 insertions(+), 1 deletions(-)
diff --git a/servers/huaxin_trade_server.py b/servers/huaxin_trade_server.py
index b688be3..88940e2 100644
--- a/servers/huaxin_trade_server.py
+++ b/servers/huaxin_trade_server.py
@@ -18,7 +18,7 @@
from cancel_strategy.s_l_h_cancel_strategy import SCancelBigNumComputer
from code_attribute import gpcode_manager, code_volumn_manager, global_data_loader, zyltgb_util, code_nature_analyse
from code_attribute.code_l1_data_manager import L1DataManager
-from code_attribute.gpcode_manager import CodePrePriceManager
+from code_attribute.gpcode_manager import CodePrePriceManager, CodesNameManager
from huaxin_client import l2_data_transform_protocol
from huaxin_client.trade_transform_protocol import TradeResponse
from l2 import l2_data_manager_new, l2_log, code_price_manager, l2_data_util, transaction_progress, \
@@ -232,6 +232,7 @@
# 鑾峰彇level1鐨勪唬鐮�
list_ = JueJinApi.get_exchanges_codes(["SHSE", "SZSE"])
fdatas = []
+ code_name_map = {}
for d in list_:
if not tool.is_target_code(d["sec_id"]):
continue
@@ -244,6 +245,11 @@
days=100)).timestamp() > datetime.datetime.now().timestamp():
continue
fdatas.append(d["sec_id"])
+ code_name_map[d["sec_id"]] = d["sec_name"]
+ # 淇濆瓨浠ｇ爜鍚嶇О
+ for k in code_name_map:
+ CodesNameManager.add_code_name(k, code_name_map[k])
+
sk.sendall(
socket_util.load_header(json.dumps({"code": 0, "data": fdatas}).encode(encoding='utf-8')))
--
Gitblit v1.8.0