From 4f8a0860978295fba6aba3c4804c4aba4d1b1fb7 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 20 十二月 2024 14:04:30 +0800
Subject: [PATCH] 增加接口/bug修改
---
api/outside_api_command_callback.py | 21 +++++++++++++++++++++
1 files changed, 21 insertions(+), 0 deletions(-)
diff --git a/api/outside_api_command_callback.py b/api/outside_api_command_callback.py
index 16addcb..d891aa1 100644
--- a/api/outside_api_command_callback.py
+++ b/api/outside_api_command_callback.py
@@ -39,6 +39,7 @@
from third_data.code_plate_key_manager import KPLCodeJXBlockManager, RealTimeKplMarketData
from third_data.history_k_data_manager import HistoryKDataManager
from third_data.history_k_data_util import JueJinApi, HistoryKDatasUtils
+from third_data.kpl_data_constant import LimitUpDataConstant
from third_data.kpl_data_manager import KPLDataManager
from third_data.kpl_limit_up_data_manager import CodeLimitUpSequenceManager
from third_data.kpl_util import KPLDataType
@@ -1392,6 +1393,26 @@
client_id,
request_id)
+ elif ctype == "get_same_block_limit_up_codes_count":
+ # 鑾峰彇鐩稿悓鏉垮潡鐨勬定鍋滀唬鐮佹暟閲�
+ codes = data.get("codes")
+ codes = json.loads(codes)
+ block_codes = {}
+ for code in codes:
+ # 鑾峰彇鏉垮潡
+ fblocks, before_fblocks = RadicalBuyBlockManager.get_code_blocks(code)
+ # 鑾峰彇鏉垮潡鍘嗗彶娑ㄥ仠
+ for b in fblocks:
+ codes = LimitUpDataConstant.get_history_limit_up_block_codes(b)
+ if codes:
+ if code not in block_codes:
+ block_codes[code] = {}
+ block_codes[code][b] = len(codes)
+ self.send_response({"code": 0, "data": json.dumps(block_codes)},
+ client_id,
+ request_id)
+
+
except Exception as e:
logging.exception(e)
--
Gitblit v1.8.0