板块强度数据日志修改

admin

2025-03-27 e311e55bc80e39349448d19b1461aef37ed31ab5

板块强度数据日志修改

 data_server.py

@@ -176,6 +176,10 @@
                response_data = json.dumps(result)
            except Exception as e:
                response_data = json.dumps({"code": 1, "msg": str(e)})
        elif url.path == "/load_kpl_stock_of_markets_plate":
            # 加载数据
            KPLStockOfMarketsPlateLogManager().load_data()
            response_data = json.dumps({"code": 0, "msg": "暂无内容"})
        elif url.path == "/get_kpl_stock_of_markets_plate":
            # 获取开盘啦流入板块详细信息
            print("==========get_kpl_stock_of_markets_plate==========")

 strategy/kpl_data_manager.py

@@ -12,23 +12,25 @@
    def __init__(self):
        # 过滤后的日志数据
        self.__filter_log_datas = []
        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))
        if tool.get_now_time_str() > '15:00:00':
            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 load_data(self):
        self.__load_data()

    def __filter_origin_data(self, data):
        return (data[0], [x[1] for x in data[1][0]],
                           {p: [(xx[0], xx[1], xx[6]) for xx in data[1][1][p]] for p in data[1][1]})
                {p: [(xx[0], xx[1], xx[6]) for xx in data[1][1][p]] for p in data[1][1]})

    def add_log(self, in_plates_info, plate_codes_info):
        oringin_data = (tool.get_now_time_str(), in_plates_info, plate_codes_info)
        self.__filter_log_datas.append(self.__filter_origin_data(oringin_data))
        async_log_util.info(logger_stock_of_markets_plate, f"{(oringin_data[1], oringin_data[2])}")

    def get_filter_log_datas(self):
@@ -36,4 +38,4 @@


if __name__ == '__main__':
    KPLStockOfMarketsPlateLogManager()
    KPLStockOfMarketsPlateLogManager()