From b37fe91f5eed9ac691a4ee9acaec506af1267506 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 12 三月 2025 18:51:28 +0800
Subject: [PATCH] 日志调整/L后重新囊括修改
---
l2/l2_transaction_data_manager.py | 15 ++++++++-------
1 files changed, 8 insertions(+), 7 deletions(-)
diff --git a/l2/l2_transaction_data_manager.py b/l2/l2_transaction_data_manager.py
index 730e31f..34074da 100644
--- a/l2/l2_transaction_data_manager.py
+++ b/l2/l2_transaction_data_manager.py
@@ -9,10 +9,9 @@
from db.redis_manager_delegate import RedisUtils
from l2 import l2_log
from l2.huaxin import l2_huaxin_util
-from l2.l2_data_util import local_today_sellno_map, local_today_datas
from l2.place_order_single_data_manager import L2TradeSingleDataProcessor, L2TradeSingleDataManager
-from log_module import async_log_util, log_export
+from log_module import log_export
from log_module.log import hx_logger_l2_transaction_desc, hx_logger_l2_transaction_sell_order, hx_logger_l2_active_sell, \
hx_logger_l2_transaction_big_buy_order, hx_logger_l2_transaction_big_sell_order, hx_logger_l2_upload
@@ -235,7 +234,7 @@
cls.__dealing_order_info_dict[code][7] += money
else:
# 淇濆瓨涓婁竴鏉℃暟鎹�
- async_log_util.info(hx_logger_l2_transaction_desc, f"{code}#{cls.__dealing_order_info_dict[code]}")
+ l2_log.info(code, hx_logger_l2_transaction_desc, f"{code}#{cls.__dealing_order_info_dict[code]}")
# 璁剧疆鏈�杩戞垚浜ゅ畬鎴愮殑涓�鏉℃暟鎹�
deal_info = cls.__dealing_order_info_dict[code]
cls.__latest_deal_order_info_dict[code] = deal_info
@@ -325,7 +324,7 @@
cls.__dealing_order_info_dict[code][2] += data[2] * data[1]
else:
# 淇濆瓨涓婁竴鏉℃暟鎹�
- async_log_util.info(hx_logger_l2_transaction_desc, f"{code}#{cls.__dealing_order_info_dict[code]}")
+ l2_log.info(code, hx_logger_l2_transaction_desc, f"{code}#{cls.__dealing_order_info_dict[code]}")
# 璁剧疆鏈�杩戞垚浜ゅ畬鎴愮殑涓�鏉℃暟鎹�
deal_info = cls.__dealing_order_info_dict[code]
# 鏄惁涓哄ぇ涔板崟
@@ -466,6 +465,7 @@
# 鏄惁涓轰富鍔ㄥ崠
def is_active_sell(sell_no, buy_no):
return sell_no > buy_no
+
f_start_time = time.time()
use_time_list = []
# q.append((data['SecurityID'], data['TradePrice'], data['TradeVolume'],
@@ -489,7 +489,8 @@
__start_time = time.time()
# 鏄惁杩樻湁娑ㄥ仠鍗栧墿涓�
- no_left_limit_up_sell = L2TradeSingleDataProcessor.process_passive_limit_up_sell_data(code, datas, limit_up_price)
+ no_left_limit_up_sell = L2TradeSingleDataProcessor.process_passive_limit_up_sell_data(code, datas,
+ limit_up_price)
use_time = time.time() - __start_time
__start_time = time.time()
use_time_list.append(("澶勭悊娑ㄥ仠鍗�", use_time))
@@ -622,8 +623,8 @@
use_time = time.time() - f_start_time
if use_time > 0.01:
- async_log_util.info(hx_logger_l2_upload,
- f"{code}澶勭悊鎴愪氦璇︾粏鐢ㄦ椂锛歿use_time} 鏁版嵁鏁伴噺锛歿len(datas)} 璇︽儏:{use_time_list}")
+ l2_log.info(code, hx_logger_l2_upload,
+ f"{code}澶勭悊鎴愪氦璇︾粏鐢ㄦ椂锛歿use_time} 鏁版嵁鏁伴噺锛歿len(datas)} 璇︽儏:{use_time_list}")
return total_sell_info
# 鑾峰彇鏈�杩戞垚浜ゆ暟鎹�
--
Gitblit v1.8.0