开盘前自动卖出策略修改

Administrator

2024-12-24 e231e49fdbf1cc3c14b2da7738d7e049c45bfebe

 trade/l2_data_manager.py

@@ -1,4 +1,4 @@
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, hx_logger_l2_transaction_big_sell_order
from utils import tool

@@ -13,13 +13,40 @@
        self.__load_data()

    def __load_data(self):
        pass
        self.__big_buy_orders = log_export.load_huaxin_transaction_big_buy_order_infos()
        self.__big_sell_orders = log_export.load_huaxin_transaction_big_sell_order_infos()

    def get_big_buy_orders(self):
        return self.__big_buy_orders
    def get_big_buy_orders(self, code):
        """
        获取成交的大买单
        :param code:
        :return: [(买单号, 量, 金额, 时间, 最新成交价格)]
        """
        return self.__big_buy_orders.get(code)

    def get_big_sell_orders(self):
        return self.__big_sell_orders
    def get_dealing_buy_order(self, code):
        """
        获取正在成交的买单
        :param code:
        :return: (买单号, 量, 金额, 时间, 最新成交价格)
        """
        return self.__latest_buy_order.get(code)

    def get_big_sell_orders(self, code):
        """
        获取成交的卖单
        :param code:
        :return: [(买单号, 量, 金额, 时间, 最新成交价格)]
        """
        return self.__big_sell_orders.get(code)

    def get_dealing_sell_order(self, code):
        """
        获取正在成交的卖单
        :param code:
        :return: (卖单号, 量, 金额, 时间, 最新成交价格)
        """
        return self.__latest_sell_order.get(code)

    def add_transaction_data(self, code, data):
        """
@@ -74,3 +101,7 @@
                self.__big_sell_orders[code].append(d)
                async_log_util.info(hx_logger_l2_transaction_big_sell_order, f"{code}#{d}")
            self.__latest_sell_order[code] = [item[1], volume, money, order_time, price]


if __name__ == "__main__":
    L2TransactionDataManager()