"""
|
涨停时间管理器
|
"""
|
from log_module import log_export, async_log_util
|
from log_module.log import logger_first_limit_up_time
|
from utils import tool, l2_huaxin_util
|
|
|
class FirstLimitUpTimeManager:
|
"""
|
首次涨停时间管理器
|
"""
|
__instance = None
|
__first_limit_up_price_dict = {}
|
|
def __new__(cls, *args, **kwargs):
|
if not cls.__instance:
|
cls.__instance = super(FirstLimitUpTimeManager, cls).__new__(cls, *args, **kwargs)
|
cls.__load_data()
|
return cls.__instance
|
|
def process(self, market_info):
|
"""
|
处理Market数据
|
:param market_info:
|
:return:
|
"""
|
# 只处理股票代码
|
if not tool.is_stock(market_info[0]):
|
return
|
if market_info[0] in self.__first_limit_up_price_dict:
|
return
|
limit_up_price = tool.get_limit_up_price(market_info[0], market_info[8])
|
if abs(float(limit_up_price) - market_info[1]) < 0.0001:
|
# 涨停价
|
time_str = l2_huaxin_util.convert_time(market_info[9])
|
async_log_util.info(logger_first_limit_up_time, f"{(market_info[0], time_str)}")
|
self.__first_limit_up_price_dict[market_info[0]] = time_str
|
|
def get_first_limit_up_time(self, code):
|
"""
|
获取首次涨停时间
|
:param code:
|
:return:
|
"""
|
self.__first_limit_up_price_dict.get(code)
|
|
@classmethod
|
def __load_data(cls):
|
cls.__first_limit_up_price_dict = log_export.load_first_limit_up_time()
|
