| | |
|---|
| | | sinfo = data["sinfo"] |
|---|
| | | order_ref = data.get("order_ref") |
|---|
| | | shadow_price = data.get("shadow_price") |
|---|
| | | blocking = data.get("blocking") |
|---|
| | | |
|---|
| | | if direction == 1: |
|---|
| | | async_log_util.info(logger_trade, f"{code}华鑫本地开始下单") |
|---|
| | | # 买 |
|---|
| | | try: |
|---|
| | | req_rid_dict[sinfo] = (client_id, request_id, sk, order_ref) |
|---|
| | | if blocking: |
|---|
| | | req_rid_dict[sinfo] = (client_id, request_id, sk, order_ref) |
|---|
| | | # threading.Thread(target=lambda: self.__tradeSimpleApi.buy(code, volume, price, sinfo, order_ref), |
|---|
| | | # daemon=True).start() |
|---|
| | | self.trade_thread_pool.submit(self.__tradeSimpleApi.buy, code, volume, price, sinfo, order_ref, shadow_price) |
|---|
