From 54012c9e60af4d4fc3537e01f497b6649d5a1548 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 12 六月 2024 18:53:51 +0800
Subject: [PATCH] L1订阅日志添加
---
huaxin_client/l1_client_for_output.py | 5 +++++
1 files changed, 5 insertions(+), 0 deletions(-)
diff --git a/huaxin_client/l1_client_for_output.py b/huaxin_client/l1_client_for_output.py
index f911f9b..a265f37 100644
--- a/huaxin_client/l1_client_for_output.py
+++ b/huaxin_client/l1_client_for_output.py
@@ -53,6 +53,7 @@
def subscribe_codes(self, codes_sh, codes_sz):
# 閲嶆柊璁㈤槄浠ｇ爜
printlog(f"璁㈤槄鏁伴噺锛歴h-{len(codes_sh)} sz-{len(codes_sz)}")
+ logger_system.info(f"璁㈤槄鏁伴噺锛歴h-{len(codes_sh)} sz-{len(codes_sz)}")
if codes_sh:
ret = self.__api.SubscribeMarketData(codes_sh, xmdapi.TORA_TSTP_EXD_SSE)
if ret != 0:
@@ -70,6 +71,7 @@
def OnRspUserLogin(self, pRspUserLoginField, pRspInfoField, nRequestID):
if pRspInfoField.ErrorID == 0:
printlog('Login success! [%d]' % nRequestID)
+ logger_system.info('Login success! [%d]' % nRequestID)
'''
璁㈤槄琛屾儏
@@ -88,6 +90,8 @@
else:
+ logger_system.info('Login fail!!! [%d] [%d] [%s]'
+ % (nRequestID, pRspInfoField.ErrorID, pRspInfoField.ErrorMsg))
printlog('Login fail!!! [%d] [%d] [%s]'
% (nRequestID, pRspInfoField.ErrorID, pRspInfoField.ErrorMsg))
@@ -131,6 +135,7 @@
def __upload_codes_info(datas):
printlog("涓婁紶鏁版嵁鏁伴噺", len(datas))
+ logger_system.info("涓婁紶鏁版嵁鏁伴噺:{}", len(datas))
# if not tool.is_trade_time():
# return
data_bytes = socket_util.load_header(json.dumps({"type": "l1_data", "data": datas}).encode("utf-8"))
--
Gitblit v1.8.0