L1目标代码增加到200个数据

Administrator

2023-08-29 58a0f47d761719baf5fb48b17647f29ed642ed2c

 outside_api_command_manager.py

@@ -51,6 +51,8 @@
API_TYPE_CODE_ATRRIBUTE = "code_attribute"  # 代码属性
API_TYPE_CODE_TRADE_STATE = "code_trade_state"  # 代码交易状态
API_TYPE_GET_ENV = "get_env"  # 获取环境信息
API_TYPE_SYNC_L1_TARGET_CODES = "sync_l1_subscript_codes"  # 同步L1需要订阅的代码
API_TYPE_SYSTEM_LOG = "system_log"  # 系统日志


class ActionCallback(object):
@@ -86,6 +88,9 @@
        pass

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

    def OnSyncL2SubscriptCodes(self, client_id, request_id):
        pass


@@ -181,6 +186,10 @@
                            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_SYNC_L1_TARGET_CODES:
                            cls.action_callback.OnSyncL2SubscriptCodes(client_id, request_id)
                        elif content_type == API_TYPE_SYSTEM_LOG:
                            cls.action_callback.OnSystemLog(client_id, request_id, data)
                    except Exception as e:
                        logging.exception(e)
                        pass
@@ -208,12 +217,8 @@
        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("错误")
                print("心跳信息发送失败", _type, client_id)
                logging.exception(e)
                if _type == CLIENT_TYPE_TRADE:
                    if client_id in cls.trade_client_dict:
                        cls.trade_client_dict.pop(client_id)