| | |
| | | |
| | | # 获取委托列表 |
| | | # can_cancel:是否可以撤 |
| | | def get_delegate_list(can_cancel=True, blocking=True): |
| | | def get_delegate_list(can_cancel=True, blocking=True, timeout=TIMEOUT): |
| | | request_id, client = __request(ClientSocketManager.CLIENT_TYPE_DELEGATE_LIST, |
| | | {"type": ClientSocketManager.CLIENT_TYPE_DELEGATE_LIST, |
| | | "can_cancel": 1 if can_cancel else 0}) |
| | | |
| | | return __read_response(client, request_id, blocking) |
| | | return __read_response(client, request_id, blocking, timeout=timeout) |
| | | |
| | | |
| | | # 获取成交列表 |
| | |
| | | hx_logger_trade_debug.info(f"获取交易数据开始:{type_}") |
| | | |
| | | if type_ == "delegate_list": |
| | | dataJSON = huaxin_trade_api.get_delegate_list(can_cancel=False) |
| | | dataJSON = huaxin_trade_api.get_delegate_list(can_cancel=False, timeout=5) |
| | | print("获取委托列表", dataJSON) |
| | | if dataJSON["code"] == 0: |
| | | data = dataJSON["data"] |
| | |
| | | trade_manager.process_trade_delegate_data([{"code":c} for c in codes]) |
| | | except Exception as e: |
| | | logging.exception(e) |
| | | |
| | | |
| | | |
| | | |
| | | elif type_ == "money": |
| | | dataJSON = huaxin_trade_api.get_money() |
| | | if dataJSON["code"] == 0: |