bug修复

Administrator

2024-10-11 c131be702b0583d3374f15e61885457ff391e0d7

bug修复

 servers/huaxin_trade_server.py

@@ -808,6 +808,8 @@
                # 取缓存
                result = result_cache[1]
                if result[0]:
                    # 买入的板块
                    buy_blocks = result[0]
                    # 如果关键词包含已成交的原因就不再下单
                    # 获取已经成交代码的板块
                    try:
@@ -838,7 +840,7 @@

                    # -----根据成交比例判断是否可买------
                    result_by_volume = radical_buy_strategy.limit_up_active_buy_deal(code, transaction_datas)
                    async_log_util.info(logger_l2_radical_buy, f"量买入结果判断：{code}, 结果：{result_by_volume}")
                    async_log_util.info(logger_l2_radical_buy, f"量买入结果判断：{code}, 结果：{result_by_volume} 板块：{buy_blocks}")
                    if result_by_volume[0] != radical_buy_strategy.BUY_MODE_NONE:
                        if result_by_volume[0] == radical_buy_strategy.BUY_MODE_DIRECT:
                            refer_sell_data = L2MarketSellManager().get_refer_sell_data(code,
@@ -858,7 +860,7 @@
                                                                     max_num_set=set(),
                                                                     buy_volume_rate=buy_volume_rate,
                                                                     mode=OrderBeginPosInfo.MODE_RADICAL,
                                                                     mode_desc="激进买入",
                                                                     mode_desc=f"扫入买入：{buy_blocks}",
                                                                     sell_info=sell_info,
                                                                     threshold_money=threshold_money)
                            L2TradeDataProcessor.save_order_begin_data(code, order_begin_pos_info)

 third_data/third_blocks_manager.py

@@ -211,10 +211,10 @@
        for block in blocks:
            if block.endswith("概念"):
                block = block[:-2]
            b = self.get_map_blocks_cache(block)
            if b:
                fbs |= b
            # fbs.add(block)
            # b = self.get_map_blocks_cache(block)
            # if b:
            #     fbs |= b
            fbs.add(block)
        return fbs

    def get_all_blocks(self):