bug修复

admin

2025-05-27 cae724f751e1ccc797ec6457af5f11ad8a2f24f2

bug修复

 data_server.py

@@ -193,7 +193,7 @@
                if use_time_list and use_time_list[-1][1] > 10:
                    logger_debug.warning(f"环境获取时间大于10s({request_id}):{use_time_list}")
        # 获取板块强度数据
        elif url.path == "/load_get_kpl_market_sift_plate":
        elif url.path == "/load_kpl_market_sift_plate":
            # 加载数据
            KPLMarketsSiftPlateLogManager().load_data()
            response_data = json.dumps({"code": 0, "msg": "暂无内容"})

 log_module/log_export.py

@@ -53,7 +53,7 @@
    return contents


def load_market_stock_heat(date=tool.get_now_date_str()):
def load_market_sift_plate(date=tool.get_now_date_str()):
    """
     获取精选流入的成分股
    :param date:
@@ -66,11 +66,9 @@
            lines = f.readlines()
            for line in lines:
                if line:
                    time_str = __get_async_log_time(line)
                    time_str = __get_log_time(line)
                    try:
                        data = line.split(" - ")[1].strip()
                        if data.startswith("["):
                            data = data[data.find("]") + 1:].strip()
                        data_dict = eval(data)
                        fdatas.append((time_str, data_dict))
                    except:
@@ -128,7 +126,7 @@


if __name__ == '__main__':
    datas = load_kpl_market_strong()
    datas = load_market_sift_plate()
    fdatas = []
    for data in datas:
        # (距离09:15:00的秒数, 时间, 强度)

 strategy/kpl_api.py

@@ -15,7 +15,7 @@

from strategy import data_cache
from strategy import basic_methods
# from strategy.kpl_data_manager import KPLMarketsSiftPlateLogManager
from strategy.kpl_data_manager import KPLMarketsSiftPlateLogManager
from trade import middle_api_protocol
from utils import hx_qc_value_util, tool


 strategy/kpl_data_manager.py

@@ -2,6 +2,7 @@
from log_module.log import logger_stock_of_markets_plate, logger_debug, logger_kpl_market_sift_plate
from utils import tool


# 开盘啦板块强度日志管理
@tool.singleton
class KPLMarketsSiftPlateLogManager:
@@ -16,7 +17,7 @@
    def __load_data(self):
        if tool.get_now_time_str() > '13:10:00':
            logger_debug.info("KPLMarketsSiftPlateLogManager 开始加载数据")
            datas = log_export.load_market_stock_heat()
            datas = log_export.load_market_sift_plate()
            for data in datas:
                # (发生时间,[净流入板块], {"板块":(代码, 名称, 涨幅)})
                self.__filter_log_datas.append(self.__filter_origin_data(data))
@@ -36,6 +37,7 @@
    def get_filter_log_datas(self):
        return self.__filter_log_datas


# 开盘啦个股强度日志管理
@tool.singleton
class KPLMarketStockHeatLogManager:

 strategy/plate_strength_analysis.py

@@ -7,6 +7,7 @@

from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_debug, logger_kpl_market_sift_plate
from strategy import kpl_api, data_cache, basic_methods
from strategy.kpl_data_manager import KPLMarketStockHeatLogManager
from utils import tool, hx_qc_value_util


@@ -101,7 +102,7 @@

        # logger.info(f"精选板块股票强度数据更新 == {market_sift_plate_stock_dict}")
        # 只在盘中时间获取
        kpl_api.KPLStockOfMarketsPlateLogManager().add_log(market_sift_plate['list'], log_datas)
        KPLMarketStockHeatLogManager().add_log(market_sift_plate['list'], log_datas)
    # 行情》精选板块》排名前20中》对应个股》符合条件的个股
    return market_sift_plate_stock_dict