策略修改

Administrator

2024-06-26 5dab25fb56ee7f21e525c93a8ef1d028394964b7

 trade/buy_strategy.py

@@ -3,6 +3,8 @@
"""
import decimal

from log_module import async_log_util
from log_module.log import logger_trade
from third_data.kpl_data_manager import KPLLimitUpDataRecordManager
from trade.l2_transaction_data_manager import HuaXinBuyOrderManager
from utils import tool
@@ -36,7 +38,7 @@
            self.set_pre_close_price(code, info[8])
        self.__latest_market_info_dict[info[0]] = info

    def add_transaction_info(self, info, backtest = False):
    def add_transaction_info(self, info, backtest=False):

        """
        添加成交信息
@@ -55,8 +57,19 @@
        try:
            if info["TradePrice"] == self.__limit_up_price_dict.get(code):
                # 当前为涨停价
                if self.__latest_trade_price_dict.get(code) != self.__limit_up_price_dict.get(code):
                    return True
                if code not in self.__latest_trade_price_dict:
                    # 开1
                    # 查询买1金额
                    markekt = self.__latest_market_info_dict.get(info[0])
                    if markekt and markekt[3] * markekt[4] >= 1e8:
                        async_log_util.info(logger_trade, f"{code}：买1（{markekt[3] * markekt[4]}）超过1亿")
                        return True
                    else:
                        return False
                else:
                    if self.__latest_trade_price_dict.get(code) != self.__limit_up_price_dict.get(code):
                        # 之前那一次不是涨停价
                        return True
        finally:
            self.__latest_trade_price_dict[code] = info["TradePrice"]
        return False
@@ -76,8 +89,3 @@
        limit_up_datas = KPLLimitUpDataRecordManager.latest_origin_datas
        for item in limit_up_datas:
            pass