策略修改

Administrator

2024-06-26 5dab25fb56ee7f21e525c93a8ef1d028394964b7

策略修改

 main.py

@@ -290,6 +290,10 @@
                market_info = code_market_manager.get_market_info(cb_code)
                limit_up_price = target_codes_manager.get_limit_up_price(cb_code)
                if market_info:
                    if market_info.rate > 0.139:
                        async_log_util.info(logger_trade, f"可转债涨幅过高：：{cb_code}-{market_info.rate}")
                        continue

                    volume = int(__get_buy_money()/ float(limit_up_price))
                    volume = (volume // 10) * 10
                    buy_price = round(min(float(market_info.price * 1.02), float(limit_up_price)), 3)

 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
@@ -55,7 +57,18 @@
        try:
            if info["TradePrice"] == self.__limit_up_price_dict.get(code):
                # 当前为涨停价
                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"]
@@ -76,8 +89,3 @@
        limit_up_datas = KPLLimitUpDataRecordManager.latest_origin_datas
        for item in limit_up_datas:
            pass