From 4231dc5dba02568b70e2caa4a0fe7c6455223c5c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 10 十二月 2024 10:13:08 +0800
Subject: [PATCH] 订阅
---
trade/current_price_process_manager.py | 20 +++++++++++++-------
1 files changed, 13 insertions(+), 7 deletions(-)
diff --git a/trade/current_price_process_manager.py b/trade/current_price_process_manager.py
index a9c32a3..7653318 100644
--- a/trade/current_price_process_manager.py
+++ b/trade/current_price_process_manager.py
@@ -11,15 +11,19 @@
import constant
from code_attribute import gpcode_manager
from third_data.kpl_data_constant import LimitUpCodesBlockRecordManager, LimitUpDataConstant
+from trade.buy_radical import radical_buy_data_manager
from trade.buy_radical.block_special_codes_manager import BlockSpecialCodesManager
from trade.buy_radical.radical_buy_data_manager import RadicalBuyBlockManager, RadicalBuyDataManager
from utils import tool, import_util
from trade import trade_manager, l2_trade_util, trade_constant
from trade.trade_data_manager import CodeActualPriceProcessor, RadicalBuyDealCodesManager
+import concurrent.futures
trade_gui = import_util.import_lib("trade.trade_gui")
__actualPriceProcessor = CodeActualPriceProcessor()
+
+__pre_big_order_deal_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=10)
latest_add_codes = set()
@@ -179,17 +183,19 @@
# 鏄惁鍜屼笂娆′竴鏍�
try:
add_code_set = set(add_code_list)
- # global latest_add_codes
- # if not latest_add_codes:
- # latest_add_codes = set()
+ global latest_add_codes
+ if not latest_add_codes:
+ latest_add_codes = set()
# # 鍒ゆ柇璁剧疆鐨勪唬鐮佹槸鍚︾浉鍚�
# dif1 = latest_add_codes - add_code_set
- # dif2 = add_code_set - latest_add_codes
- # if dif1 or dif2:
+ dif2 = add_code_set - latest_add_codes
+ if dif2:
+ # 鏂板鍔犵殑璁㈤槄闇�瑕佹媺鍙栦箣鍓嶇殑澶у崟
+ for c in dif2:
+ __pre_big_order_deal_thread_pool.submit(radical_buy_data_manager.pull_pre_deal_big_orders, c)
if True:
- global latest_add_codes
async_log_util.info(logger_l2_codes_subscript,
- f"({request_id})棰勫鐞嗘柊澧炶闃呬唬鐮侊細{add_code_set - latest_add_codes}")
+ f"({request_id})棰勫鐞嗘柊澧炶闃呬唬鐮侊細{dif2}")
latest_add_codes = add_code_set
add_datas = []
for d in add_code_list:
--
Gitblit v1.8.0