| | |
| | | cancel_shadow = data.get("cancel_shadow") |
| | | if cancel_shadow is None: |
| | | cancel_shadow = True |
| | | if shadow_volume is None: |
| | | shadow_volume = constant.SHADOW_ORDER_VOLUME |
| | | |
| | | if direction == 1: |
| | | async_log_util.info(logger_trade, f"{code}华鑫本地开始下单") |
| | |
| | | # 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, cancel_shadow) |
| | | shadow_price, cancel_shadow, shadow_volume) |
| | | async_log_util.info(logger_trade, f"{code}华鑫本地下单线程结束") |
| | | except Exception as e: |
| | | send_response(json.dumps({"code": 1, "msg": str(e)}), TYPE_ORDER, client_id, |