| | |
| | | price = round(params.get("price"), 2) # 价格 |
| | | result = huaxin_trade_api.order(2, code, volume, price, blocking=True) |
| | | result_str = json.dumps(result) |
| | | elif url.path == "/cancel_order": |
| | | params = self.__parse_request() |
| | | # 签名验证 |
| | | if not self.__is_sign_right(params): |
| | | result_str = json.dumps({"code": 1001, "msg": "签名错误"}) |
| | | return |
| | | # 卖出 |
| | | print("撤单", params) |
| | | direction = params.get("direction") |
| | | code = params.get("code") # 代码 |
| | | orderSysID = params.get("orderSysID") # 系统订单编号 |
| | | result = huaxin_trade_api.cancel_order(direction, code, orderSysID, blocking=True) |
| | | result_str = json.dumps(result) |
| | | except Exception as e: |
| | | result_str = json.dumps({"code": 1, "msg": str(e)}) |
| | | finally: |
| | |
| | | httpd.serve_forever() |
| | | except Exception as e: |
| | | pass |
| | | |
| | |
| | | |
| | | def cancel_order(direction, code, orderSysID, orderRef=None, blocking=False, sinfo=None, request_id=None, |
| | | recancel=False): |
| | | """ |
| | | 撤单 |
| | | :param direction: 1-买入 2-卖出 |
| | | :param code: |
| | | :param orderSysID: |
| | | :param orderRef: |
| | | :param blocking: |
| | | :param sinfo: |
| | | :param request_id: |
| | | :param recancel: |
| | | :return: |
| | | """ |
| | | if tool.trade_time_sub(tool.get_now_time_str(), "14:57:00") >= 0 and tool.trade_time_sub(tool.get_now_time_str(), |
| | | "15:00:01") <= 0: |
| | | # 集合竞价不撤单 |