| | |
|---|
| | | 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) |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
| | |
|---|
| | | 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) |
|---|
