From 45b79f58ec7e8aa82bc086f636d89a5ec253b0e7 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 25 八月 2023 12:53:15 +0800
Subject: [PATCH] S撤改进

---
 outside_api_command_manager.py |    7 ++++++-
 1 files changed, 6 insertions(+), 1 deletions(-)

diff --git a/outside_api_command_manager.py b/outside_api_command_manager.py
index 958a99c..29755c1 100644
--- a/outside_api_command_manager.py
+++ b/outside_api_command_manager.py
@@ -51,6 +51,7 @@
 API_TYPE_CODE_ATRRIBUTE = "code_attribute"  # 浠g爜灞炴��
 API_TYPE_CODE_TRADE_STATE = "code_trade_state"  # 浠g爜浜ゆ槗鐘舵��
 API_TYPE_GET_ENV = "get_env"  # 鑾峰彇鐜淇℃伅
+API_TYPE_SYNC_L1_TARGET_CODES = "sync_l1_subscript_codes"  # 鍚屾L1闇�瑕佽闃呯殑浠g爜
 
 
 class ActionCallback(object):
@@ -86,6 +87,9 @@
         pass
 
     def OnGetEnvInfo(self, client_id, request_id, data):
+        pass
+
+    def OnSyncL2SubscriptCodes(self, client_id, request_id):
         pass
 
 
@@ -181,6 +185,8 @@
                             cls.action_callback.OnGetCodeTradeState(client_id, request_id, data)
                         elif content_type == API_TYPE_GET_ENV:
                             cls.action_callback.OnGetEnvInfo(client_id, request_id, data)
+                        elif content_type == API_TYPE_GET_ENV:
+                            cls.action_callback.OnSyncL2SubscriptCodes(client_id, request_id)
                     except Exception as e:
                         logging.exception(e)
                         pass
@@ -208,7 +214,6 @@
         while True:
             try:
                 sk.send(socket_util.load_header(json.dumps({"type": "heart", "client_id": client_id}).encode('utf-8')))
-                logger_debug.debug("蹇冭烦淇℃伅鍙戦�侊細{}",client_id)
                 # print("蹇冭烦淇℃伅鍙戦�佹垚鍔�", client_id)
             except Exception as e:
                 logging.error("閿欒")

--
Gitblit v1.8.0