From ad3cc1a24c4b413bae3069cc6d1c2a1923540ce3 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 25 七月 2025 15:51:48 +0800
Subject: [PATCH] 开盘啦TCP请求/委托数据持久化异步处理
---
task/task_manager.py | 18 +++++++++++++++---
1 files changed, 15 insertions(+), 3 deletions(-)
diff --git a/task/task_manager.py b/task/task_manager.py
index 3d74925..a7c4746 100644
--- a/task/task_manager.py
+++ b/task/task_manager.py
@@ -4,9 +4,11 @@
import threading
import time
+import constant
from db import redis_manager_delegate as redis_manager
from l2 import l2_log
from l2.huaxin import huaxin_target_codes_manager
+from l2.subscript import l2_subscript_manager
from log_module import async_log_util
from log_module.log import logger_system, logger_l2_codes_subscript, logger_debug
from servers.huaxin_trade_server import TradeServerProcessor
@@ -63,9 +65,19 @@
codes = [d[0] for d in datas]
for code in codes:
block_info.init_code(code)
- root_data = {"type": ClientSocketManager.CLIENT_TYPE_CMD_L2,
- "data": datas}
- queue_other_w_l2_r.put_nowait(json.dumps(root_data))
+ if constant.IS_L2_NEW:
+ process_manager: l2_subscript_manager.TargetCodeProcessManager = l2_subscript_manager\
+ .process_manager
+ queue_codes_list = process_manager.set_codes(set(codes))
+ code_data_dict = {d[0]: d for d in datas}
+ for queue_codes in queue_codes_list:
+ root_data = {"type": ClientSocketManager.CLIENT_TYPE_CMD_L2,
+ "data": [code_data_dict.get(c) for c in queue_codes[1]]}
+ queue_codes[0].put_nowait(json.dumps(root_data))
+ else:
+ root_data = {"type": ClientSocketManager.CLIENT_TYPE_CMD_L2,
+ "data": datas}
+ queue_other_w_l2_r.put_nowait(json.dumps(root_data))
# 濡傛灉鍦�9:25-9:29 闇�瑕佸姞杞芥澘鍧�
# if int("092500") < int(tool.get_now_time_str().replace(":", "")) < int("092900"):
# for d in datas:
--
Gitblit v1.8.0