买点的策略类型区分

Administrator

2024-07-11 e70bdf6ab8e20c122cd5eb9e5fd6e384ab903b8d

 trade/buy_strategy.py

@@ -3,9 +3,9 @@
"""
import decimal

from log_module import async_log_util
from log_module import async_log_util, log_export
from log_module.log import logger_trade
from third_data.kpl_data_manager import KPLLimitUpDataRecordManager, CodePlateKeyBuyManager
from third_data.kpl_data_manager import KPLLimitUpDataRecordManager
from trade.l2_transaction_data_manager import HuaXinBuyOrderManager
from utils import tool, l2_huaxin_util

@@ -181,3 +181,39 @@
        limit_up_datas = KPLLimitUpDataRecordManager.latest_origin_datas
        for item in limit_up_datas:
            pass


class StrategyBuyOrderRefManager:
    """
    策略买入记录管理
    """
    __instance = None
    __order_ref_strategy_dict = {}

    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(StrategyBuyOrderRefManager, cls).__new__(cls, *args, **kwargs)
            cls.__load_data()
        return cls.__instance

    @classmethod
    def __load_data(cls):
        cls.__order_ref_strategy_dict = log_export.load_order_ref_strategy()

    def add(self, order_ref, strategy_type):
        """
        添加数据
        :param order_ref:
        :param strategy_type:
        :return:
        """
        async_log_util.info(logger_trade, f"可转载策略下单结果：({order_ref},{strategy_type})")
        self.__order_ref_strategy_dict[order_ref] = strategy_type

    def get_strategy_type(self, order_ref):
        """
        获取策略类型
        :param order_ref:
        :return:
        """
        return self.__order_ref_strategy_dict.get(order_ref)