修复09:30:00之前开盘啦精选板块可能没有加载的bug

Administrator

2023-10-17 5717d0a91fe322e78cddc369783d23cf1049c519

修复09:30:00之前开盘啦精选板块可能没有加载的bug

 trade/huaxin/huaxin_trade_api_server.py

@@ -454,6 +454,7 @@
                    if int("092400") < int(tool.get_now_time_str().replace(":", "")) < int("093000"):
                        for d in datas:
                            KPLCodeJXBlockManager().load_jx_blocks(d[0], gpcode_manager.get_price(d[0]), float(d[2]))
                            time.sleep(1)
                    logger_l2_codes_subscript.info("({})发送到华鑫L2代码处理队列：数量-{}", request_id, len(datas))
        except Exception as e:
            logging.exception(e)

 trade/huaxin/huaxin_trade_server.py

@@ -307,7 +307,7 @@
    def l2_transaction(cls, code, datas):
        async_log_util.info(hx_logger_l2_transaction, f"{code}#{datas}")
        if datas:
            HuaXinTransactionDatasProcessor.process_huaxin_transaction_datas(code,datas)
            HuaXinTransactionDatasProcessor.process_huaxin_transaction_datas(code, datas)

    @classmethod
    def l2_market_data(cls, code, data):
@@ -325,7 +325,7 @@
            code_price_manager.Buy1PriceManager().process(code, buy_1_price, time_str,
                                                          limit_up_price,
                                                          sell_1_price, sell_1_volume // 100)
            cls.__KPLCodeJXBlockManager.load_jx_blocks(code,buy_1_price,limit_up_price)
            cls.__KPLCodeJXBlockManager.load_jx_blocks(code, buy_1_price, limit_up_price)
            # 更新板块信息
            yesterday_codes = kpl_data_manager.get_yesterday_limit_up_codes()
            CodePlateKeyBuyManager.update_can_buy_blocks(code,