| | |
|---|
| | | 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): |
|---|
| | |
|---|
| | | 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: |
|---|
| | | 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 |
|---|
| | |
|---|
| | | sk.send(socket_util.load_header(json.dumps({"type": "heart", "client_id": client_id}).encode('utf-8'))) |
|---|
| | | # 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) |
|---|
