From 1c76abc59af35931b70b4742038dae0cfe4890d4 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 18 七月 2023 16:28:18 +0800
Subject: [PATCH] 华鑫适配
---
server.py | 12 +++++++++---
1 files changed, 9 insertions(+), 3 deletions(-)
diff --git a/server.py b/server.py
index 707fd91..432cea9 100644
--- a/server.py
+++ b/server.py
@@ -22,7 +22,7 @@
import l2.l2_data_util
from output import code_info_output
-from third_data import hot_block_data_process, block_info, kpl_api
+from third_data import block_info, kpl_api
from third_data.code_plate_key_manager import CodesHisReasonAndBlocksManager
from third_data.history_k_data_util import HistoryKDatasUtils
from third_data.kpl_data_manager import KPLCodeLimitUpReasonManager, KPLLimitUpDataRecordManager
@@ -46,6 +46,8 @@
def __init__(self, server_address, RequestHandlerClass, bind_and_activate=True, pipe_juejin=None, pipe_ui=None):
self.pipe_juejin = pipe_juejin # 澧炲姞鐨勫弬鏁�
self.pipe_ui = pipe_ui
+ # 鍒濆鍖栨暟鎹�
+ block_info.init()
socketserver.TCPServer.__init__(self, server_address, RequestHandlerClass, bind_and_activate=bind_and_activate)
@@ -387,6 +389,10 @@
gpcode_manager.get_limit_up_price(code),
volumes_data)
gpcode_manager.FirstCodeManager.add_record(codes)
+ # 鍒濆鍖栨澘鍧椾俊鎭�
+ for code in codes:
+ block_info.init_code(code)
+
if new_add_codes:
gpcode_manager.set_first_gp_codes_with_data(HistoryKDatasUtils.get_gp_latest_info(codes,
fields="symbol,sec_name,sec_type,sec_level"))
@@ -776,8 +782,8 @@
data_json = data_process.parse(_str)
day = data_json["day"]
datas = data_json["data"]
- if datas:
- hot_block_data_process.save_datas(day, datas)
+ # if datas:
+ # hot_block_data_process.save_datas(day, datas)
print(datas)
elif type == 71:
# 鏍规嵁浠ｇ爜鑾峰彇閫夎偂瀹濈儹闂ㄦ蹇�
--
Gitblit v1.8.0