结构调整

Administrator

2024-12-02 0d82ecf0d6dca56ffbe319f3fd2efcd4bd9fb79f

 l2/l2_data_manager_new.py

@@ -41,7 +41,7 @@
from trade.trade_data_manager import CodeActualPriceProcessor, PlaceOrderCountManager, AccountMoneyManager, \
    RadicalBuyDealCodesManager

from trade.trade_manager import TradeTargetCodeModeManager
from trade.trade_manager import TradeTargetCodeModeManager, CodesTradeStateManager

from settings.trade_setting import MarketSituationManager, TradeBlockBuyModeManager

@@ -1251,12 +1251,18 @@
        if can_buy_result is None:
            async_log_util.warning(logger_debug, "没有获取到板块缓存，将获取板块")
            latest_current_limit_up_records = kpl_data_manager.get_latest_current_limit_up_records()

            codes_delegate = set(CodesTradeStateManager().get_codes_by_trade_states_cache(
                {trade_constant.TRADE_STATE_BUY_DELEGATED, trade_constant.TRADE_STATE_BUY_PLACE_ORDER}))
            codes_success = set(CodesTradeStateManager().get_codes_by_trade_states_cache(
                {trade_constant.TRADE_STATE_BUY_SUCCESS}))

            CodePlateKeyBuyManager.update_can_buy_blocks(code,
                                                         kpl_data_manager.KPLLimitUpDataRecordManager.latest_origin_datas,
                                                         kpl_data_manager.KPLLimitUpDataRecordManager.total_datas,
                                                         latest_current_limit_up_records,
                                                         block_info.get_before_blocks_dict(),
                                                         kpl_data_manager.KPLLimitUpDataRecordManager.get_current_limit_up_reason_codes_dict())
                                                         kpl_data_manager.KPLLimitUpDataRecordManager.get_current_limit_up_reason_codes_dict(), codes_delegate, codes_success)
            can_buy_result = CodePlateKeyBuyManager.can_buy(code)
        return can_buy_result