bug修复

Administrator

2024-06-12 d873f18025970f81d5ad93d9ba948ff4747a1964

bug修复

 log_module/log_export.py

@@ -117,6 +117,28 @@
    return fdatas


def load_big_buy_order(date=tool.get_now_date_str()):
    """
    获取大买单
    :param date:
    :return:
    """
    path = f"{constant.get_path_prefix()}/{constant.LOG_DIR}/huaxin/l2/transaction_big_buy.{date}.log"
    fdatas = {}
    with open(path, 'r') as file:
        lines = file.readlines()
        for line in lines:
            start_index = line.find("]")
            if start_index < 0:
                continue
            line = line[start_index + 1:].strip()
            ds = line.split("#")
            code = ds[0].strip()
            data = eval(ds[1])
            if code not in fdatas:
                fdatas[code] = []
            fdatas[code].append(data)
    return fdatas


if __name__ == "__main__":

 trade/l2_transaction_data_manager.py

@@ -1,5 +1,5 @@
# 成交数据统计
from log_module import async_log_util
from log_module import async_log_util, log_export
from log_module.log import hx_logger_l2_transaction_big_buy_order
from utils import l2_huaxin_util

@@ -22,7 +22,9 @@

    @classmethod
    def __load_datas(cls):
        pass
        fdatas = log_export.load_big_buy_order()
        for code in fdatas:
            cls.__total_big_buy_orders_dict[code] = fdatas[code]

    @classmethod
    def get_big_buy_orders(cls, code):
@@ -34,6 +36,11 @@
        return cls.__total_big_buy_orders_dict.get(code)

    @classmethod
    def get_big_buy_orders_from_file(cls, code):
        fdatas = log_export.load_big_buy_order()
        return fdatas.get(code)

    @classmethod
    def get_dealing_order_info(cls, code):
        """
        获取当前正在成交的数据

 utils/output_data_util.py

@@ -54,9 +54,9 @@
    # 统计板块的
    fresults["blockInfos"] = blockInfos
    fresults["blocks"] = list(blocks)
    big_orders = HuaXinBuyOrderManager.get_big_buy_orders(code)
    big_orders = HuaXinBuyOrderManager.get_big_buy_orders_from_file(code)
    if not big_orders:
        big_orders = []
    fresults["bigOrderDealCount"] = len(big_orders)
    fresults["bigOrderDealMoney"] = sum([x[1] for x in big_orders])
    fresults["bigOrderDealMoney"] = sum([x[2] for x in big_orders])
    return fresults