| | |
| | | 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: |
| | | """ |
| | | 精选流入板块与板块代码日志管理 |
| | | """ |
| | |
| | | |
| | | 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() |
| | |
| | | |
| | | # 开盘啦个股强度日志管理 |
| | | @tool.singleton |
| | | class KPLStockOfMarketsPlateLogManager: |
| | | class KPLMarketStockHeatLogManager: |
| | | """ |
| | | 精选流入板块与板块代码日志管理 |
| | | """ |
| | |
| | | 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)) |
| | |
| | | |
| | | |
| | | if __name__ == '__main__': |
| | | KPLStockOfMarketsPlateLogManager() |
| | | KPLMarketStockHeatLogManager() |