From 0d82ecf0d6dca56ffbe319f3fd2efcd4bd9fb79f Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 02 十二月 2024 17:51:50 +0800
Subject: [PATCH] 结构调整
---
api/outside_api_command_callback.py | 33 +++++++++++++++++++++++++--------
1 files changed, 25 insertions(+), 8 deletions(-)
diff --git a/api/outside_api_command_callback.py b/api/outside_api_command_callback.py
index d39d432..666e10f 100644
--- a/api/outside_api_command_callback.py
+++ b/api/outside_api_command_callback.py
@@ -36,7 +36,7 @@
logger_real_place_order_position, logger_device
from output import l2_output_util
from third_data import kpl_util, history_k_data_manager, huaxin_l1_data_manager, third_blocks_manager, kpl_data_manager
-from third_data.code_plate_key_manager import KPLCodeJXBlockManager
+from third_data.code_plate_key_manager import KPLCodeJXBlockManager
from third_data.history_k_data_manager import HistoryKDataManager
from third_data.history_k_data_util import JueJinApi, HistoryKDatasUtils
from third_data.kpl_data_manager import KPLDataManager
@@ -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
@@ -53,6 +54,7 @@
from trade.buy_radical.radical_buy_data_manager import RadicalBuyBlockManager
from trade.sell import sell_manager
from trade.sell.sell_rule_manager import TradeRuleManager, SellRule
+from trade.trade_data_manager import RadicalBuyDealCodesManager
from trade.trade_manager import TradeTargetCodeModeManager, AutoCancelSellModeManager
from settings.trade_setting import MarketSituationManager, TradeBlockBuyModeManager
from utils import socket_util, data_export_util, tool, huaxin_util, output_util, global_util
@@ -1083,10 +1085,18 @@
limit_up_data = kpl_data_manager.KPLLimitUpDataRecordManager.record_code_dict.get(code)
# 鑾峰彇褰撳墠鏉垮潡
try:
- limit_up_sequence = CodeLimitUpSequenceManager.get_current_limit_up_sequence(code)
- if limit_up_sequence:
- fdata[
- 'block'] = f"{limit_up_sequence[0]}-{limit_up_sequence[1]}({limit_up_sequence[2]}&{limit_up_sequence[2] - limit_up_sequence[3]})"
+ limit_up_sequences = CodeLimitUpSequenceManager.get_current_limit_up_sequence(code)
+ if limit_up_sequences:
+ buy_blocks = RadicalBuyDealCodesManager().get_code_blocks(code)
+ blocks_info = []
+ for limit_up_sequence in limit_up_sequences:
+ # 鑾峰彇浠ｇ爜涓嬪崟鐨勬澘鍧�
+ if buy_blocks and limit_up_sequence[0] not in buy_blocks:
+ continue
+ blocks_info.append(
+ f"{limit_up_sequence[0]}-{limit_up_sequence[1]}({limit_up_sequence[2]}&{limit_up_sequence[2] - limit_up_sequence[3]})")
+ if buy_blocks:
+ fdata['block'] = "/".join(blocks_info)
except:
pass
# 鑾峰彇娑ㄥ仠鏃堕棿
@@ -1258,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
@@ -1358,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