| | |
| | | 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" |
| | | |
| | | class ActionCallback(object): |
| | | # 交易 |
| | |
| | | pass |
| | | |
| | | def OnGetFromDataServer(self, client_id, request_id, data): |
| | | pass |
| | | |
| | | # 代码的交易信息 |
| | | def OnGetCodeTradeInfo(self, client_id, request_id, data): |
| | | pass |
| | | |
| | | |
| | |
| | | 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) |
| | | except Exception as e: |
| | | logging.exception(e) |
| | | pass |