From 49c42567a7689b68ce8806189117d307520537aa Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 28 八月 2023 17:24:29 +0800
Subject: [PATCH] 增加L2订阅日志
---
huaxin_client/l2_client.py | 10 ++++++++--
1 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/huaxin_client/l2_client.py b/huaxin_client/l2_client.py
index 16fe8d1..732f43a 100644
--- a/huaxin_client/l2_client.py
+++ b/huaxin_client/l2_client.py
@@ -13,7 +13,7 @@
from huaxin_client.command_manager import L2ActionCallback
from log_module import log
from log_module.log import logger_local_huaxin_l2_subscript, logger_system, logger_local_huaxin_l2_transaction, \
- logger_local_huaxin_g_cancel
+ logger_local_huaxin_g_cancel, logger_l2_codes_subscript
Front_Address = "tcp://10.0.1.101:6900"
Multicast_Address = "udp://224.224.2.19:7889"
@@ -134,12 +134,17 @@
if add_codes:
logger_system.info(f"鏂板L2璁㈤槄浠ｇ爜鏁伴噺:{len(add_codes)}")
+ logger_l2_codes_subscript.info("鍗庨懌L2璁㈤槄缁撴潫锛宎dd-{} del-{}", len(add_codes), len(del_codes))
+
# 璁剧疆鏈�杩戠殑浠ｇ爜鍒楄〃
self.latest_codes_set = codes
# 璁㈤槄浠ｇ爜,[(浠ｇ爜,鏈�浣庢墜鏁�,娑ㄥ仠浠�)]
def set_codes_data(self, codes_data):
- self.__process_codes_data(codes_data)
+ try:
+ self.__process_codes_data(codes_data)
+ except Exception as e:
+ logger_l2_codes_subscript.exception(e)
def set_code_special_watch_volume(self, code, volume):
# 鏈夋晥鏈熶负3s
@@ -496,6 +501,7 @@
def OnSetL2Position(self, client_id, request_id, codes_data):
print("L2璁㈤槄鏁伴噺锛�", len(codes_data))
+ logger_l2_codes_subscript.info("鍗庨懌L2浠ｇ爜澶勭悊闃熷垪鑾峰彇鍒版暟鎹細鏁伴噺-{}", len(codes_data))
try:
spi.set_codes_data(codes_data)
except Exception as e:
--
Gitblit v1.8.0