From b53b0f632cca75df8f39a17fab3d26caeecb2caf Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 15 十一月 2024 18:44:23 +0800
Subject: [PATCH] 自定义板块净流入
---
third_data/code_plate_key_manager.py | 50 +++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 49 insertions(+), 1 deletions(-)
diff --git a/third_data/code_plate_key_manager.py b/third_data/code_plate_key_manager.py
index e101820..28d6f7f 100644
--- a/third_data/code_plate_key_manager.py
+++ b/third_data/code_plate_key_manager.py
@@ -18,7 +18,7 @@
from log_module import async_log_util
from db import redis_manager_delegate as redis_manager
-from log_module.log import logger_kpl_block_can_buy, logger_kpl_jx_out
+from log_module.log import logger_kpl_block_can_buy, logger_kpl_jx_out, logger_kpl_jx_in
from third_data.kpl_util import KPLPlatManager
from trade import trade_manager, l2_trade_util, trade_constant
@@ -360,6 +360,8 @@
# break
# blocks.add(data[1])
# cls.__top_jx_blocks = blocks
+ if True:
+ return
blocks = set()
for data in datas:
if data[1] in constant.KPL_INVALID_BLOCKS:
@@ -371,6 +373,28 @@
break
blocks.add(kpl_util.filter_block(data[1]))
# 璁板綍绮鹃�夋祦鍑烘棩蹇�
+ async_log_util.info(logger_kpl_jx_in, f"鍘熸暟鎹細{datas[:20]} 鏉垮潡锛歿blocks}")
+ cls.__top_jx_blocks = BlockMapManager().filter_blocks(blocks)
+
+ @classmethod
+ def set_market_jingxuan_blocks_from_custom(cls, datas):
+ """
+ 璁剧疆鑷畾涔夌簿閫夋祦鍏ユ暟鎹�
+ @param datas:[(鏉垮潡,娴佸叆閲戦)]
+ @return:
+ """
+ blocks = set()
+ for data in datas:
+ if data[0] in constant.KPL_INVALID_BLOCKS:
+ continue
+ if data[1] < 5e7:
+ continue
+ blocks.add(data[0])
+ if len(blocks) >= 10:
+ break
+ blocks.add(kpl_util.filter_block(data[0]))
+ # 璁板綍绮鹃�夋祦鍑烘棩蹇�
+ async_log_util.info(logger_kpl_jx_in, f"鍘熸暟鎹細{datas[:20]} 鏉垮潡锛歿blocks}")
cls.__top_jx_blocks = BlockMapManager().filter_blocks(blocks)
@classmethod
@@ -380,6 +404,8 @@
@param datas:
@return:
"""
+ if True:
+ return
blocks = set()
for data in datas:
if data[1] in constant.KPL_INVALID_BLOCKS:
@@ -396,6 +422,28 @@
cls.__top_jx_out_blocks = BlockMapManager().filter_blocks(blocks)
@classmethod
+ def set_market_jingxuan_out_blocks_from_custom(cls, datas):
+ """
+ 璁剧疆鑷畾涔夌簿閫夋祦鍑烘暟鎹�
+ @param datas:[(鏉垮潡,娴佸叆閲戦)]
+ @return:
+ """
+ blocks = set()
+ for data in datas:
+ if data[0] in constant.KPL_INVALID_BLOCKS:
+ continue
+ if data[1] > -5e7:
+ # 杩囨护5鍗冧竾浠ヤ笂鐨�
+ break
+ blocks.add(data[0])
+ if len(blocks) >= 10:
+ break
+ blocks.add(kpl_util.filter_block(data[0]))
+ # 璁板綍绮鹃�夋祦鍑烘棩蹇�
+ async_log_util.info(logger_kpl_jx_out, f"鍘熸暟鎹細{datas[:10]} 鏉垮潡锛歿blocks}")
+ cls.__top_jx_out_blocks = BlockMapManager().filter_blocks(blocks)
+
+ @classmethod
def get_top_market_jingxuan_blocks(cls):
return cls.__top_jx_blocks
--
Gitblit v1.8.0