From 73e4f3990342d1fd01da1ff39e9f4fb0d62745e7 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 05 十二月 2024 22:34:05 +0800
Subject: [PATCH] bug修复

---
 api/outside_api_command_callback.py |   14 +++++++++++---
 1 files changed, 11 insertions(+), 3 deletions(-)

diff --git a/api/outside_api_command_callback.py b/api/outside_api_command_callback.py
index 89db1e8..666e10f 100644
--- a/api/outside_api_command_callback.py
+++ b/api/outside_api_command_callback.py
@@ -46,6 +46,7 @@
 from trade import trade_manager, l2_trade_util, trade_data_manager, trade_constant
 import l2_data_util as l2_data_util_old
 from trade.buy_money_count_setting import BuyMoneyAndCountSetting, RadicalBuyBlockCodeCountManager
+from trade.buy_radical import block_special_codes_manager
 
 from trade.huaxin import huaxin_trade_api, huaxin_trade_data_update, \
     huaxin_trade_record_manager, huaxin_trade_order_processor, huaxin_sell_util
@@ -1267,11 +1268,9 @@
                 source_origin_dict = copy.deepcopy(CodeThirdBlocksManager().get_source_blocks_origin(code))
                 if not source_origin_dict:
                     source_origin_dict = {}
-                kpl_blocks = RadicalBuyBlockManager.get_code_kpl_blocks(code)
+                kpl_blocks = set()
                 if kpl_blocks is None:
                     kpl_blocks = set()
-                if not kpl_blocks:
-                    KPLCodeJXBlockManager().load_jx_blocks_radical(code)
 
                 filter_blocks, match_blocks = RadicalBuyBlockManager.get_code_blocks(code)
                 source_origin_dict[SOURCE_TYPE_KPL] = kpl_blocks
@@ -1367,6 +1366,15 @@
                 self.send_response({"code": 0, "data": list(codes), "msg": f""},
                                    client_id,
                                    request_id)
+
+            elif ctype == "async_radical_buy_special_codes":
+                # 鍚屾鎵叆涔扮殑杈ㄨ瘑搴︿唬鐮�
+                count = block_special_codes_manager.update_block_special_codes()
+                self.send_response({"code": 0, "msg": f"鏇存柊鎴愬姛鏁伴噺锛歿count}"},
+                                   client_id,
+                                   request_id)
+
+
         except Exception as e:
             logging.exception(e)
             logger_debug.exception(e)

--
Gitblit v1.8.0