| | |
|---|
| | | from log_module import log_export, async_log_util |
|---|
| | | from log_module.log import logger_stock_of_markets_plate |
|---|
| | | from log_module.log import logger_stock_of_markets_plate, logger_debug |
|---|
| | | from utils import tool |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | self.__load_data() |
|---|
| | | |
|---|
| | | def __load_data(self): |
|---|
| | | logger_debug.info("KPLStockOfMarketsPlateLogManager 开始加载数据") |
|---|
| | | datas = log_export.load_stock_of_markets_plate() |
|---|
| | | |
|---|
| | | for data in datas: |
|---|
| | | # (发生时间,[净流入板块], {"板块":(代码, 名称, 涨幅)}) |
|---|
| | | self.__filter_log_datas.append(self.__filter_origin_data(data)) |
|---|
| | | logger_debug.info("KPLStockOfMarketsPlateLogManager 数据加载完成：{}", len(self.__filter_log_datas)) |
|---|
| | | |
|---|
| | | def __filter_origin_data(self, data): |
|---|
| | | return (data[0], [x[1] for x in data[1][0]], |
|---|
