strategy/kpl_data_manager.py
@@ -2,9 +2,9 @@
from log_module.log import logger_stock_of_markets_plate, logger_debug, logger_kpl_market_sift_plate
from utils import tool
# 开盘啦个股强度日志管理
# 开盘啦板块强度日志管理
@tool.singleton
class KPLMarketStockHeatLogManager:
class KPLMarketsSiftPlateLogManager:
    """
    精选流入板块与板块代码日志管理
    """
@@ -15,12 +15,12 @@
    def __load_data(self):
        if tool.get_now_time_str() > '13:10:00':
            logger_debug.info("KPLMarketStockHeatLogManager 开始加载数据")
            logger_debug.info("KPLMarketsSiftPlateLogManager 开始加载数据")
            datas = log_export.load_market_stock_heat()
            for data in datas:
                # (发生时间,[净流入板块], {"板块":(代码, 名称, 涨幅)})
                self.__filter_log_datas.append(self.__filter_origin_data(data))
            logger_debug.info("KPLMarketStockHeatLogManager 数据加载完成:{}", len(self.__filter_log_datas))
            logger_debug.info("KPLMarketsSiftPlateLogManager 数据加载完成:{}", len(self.__filter_log_datas))
    def load_data(self):
        self.__load_data()
@@ -38,7 +38,7 @@
# 开盘啦个股强度日志管理
@tool.singleton
class KPLStockOfMarketsPlateLogManager:
class KPLMarketStockHeatLogManager:
    """
    精选流入板块与板块代码日志管理
    """
@@ -50,7 +50,7 @@
    def __load_data(self):
        if tool.get_now_time_str() > '13:10:00':
            logger_debug.info("KPLStockOfMarketsPlateLogManager 开始加载数据")
            datas = log_export.load_stock_of_markets_plate()
            datas = log_export.load_kpl_market_stock_heat()
            for data in datas:
                # (发生时间,[净流入板块], {"板块":(代码, 名称, 涨幅)})
                self.__filter_log_datas.append(self.__filter_origin_data(data))
@@ -72,4 +72,4 @@
if __name__ == '__main__':
    KPLStockOfMarketsPlateLogManager()
    KPLMarketStockHeatLogManager()