A类服务器切换

Administrator

2023-11-13 117fa1cb5ce77d9f34cf8c0dbce838bdf256c8db

 outside_api_command_manager.py

@@ -54,6 +54,9 @@
API_TYPE_SYNC_L1_TARGET_CODES = "sync_l1_subscript_codes"  # 同步L1需要订阅的代码
API_TYPE_SYSTEM_LOG = "system_log"  # 系统日志
API_TYPE_GET_FROM_DATA_SERVER = "get_from_data_server"  # 从数据服务器拉取数据
API_TYPE_CODE_TRADE_INFO = "code_trade_info"  # 代码交易信息
API_TYPE_CODE_L2_LISTEN_ACTIVE_COUNT = "l2_listen_active_count"  # L2有效监听数量


class ActionCallback(object):
    # 交易
@@ -94,6 +97,13 @@
        pass

    def OnGetFromDataServer(self, client_id, request_id, data):
        pass

    # 代码的交易信息
    def OnGetCodeTradeInfo(self, client_id, request_id, data):
        pass

    def OnGetActiveListenCount(self, client_id, request_id):
        pass


@@ -195,6 +205,11 @@
                            cls.action_callback.OnSystemLog(client_id, request_id, data)
                        elif content_type == API_TYPE_GET_FROM_DATA_SERVER:
                            cls.action_callback.OnGetFromDataServer(client_id, request_id, data)
                        elif content_type == API_TYPE_CODE_TRADE_INFO:
                            cls.action_callback.OnGetCodeTradeInfo(client_id, request_id, data)
                        elif content_type == API_TYPE_CODE_L2_LISTEN_ACTIVE_COUNT:
                            cls.action_callback.OnGetActiveListenCount(client_id, request_id)

                    except Exception as e:
                        logging.exception(e)
                        pass