| | |
|---|
| | | import zmq |
|---|
| | | |
|---|
| | | from code_attribute import gpcode_manager |
|---|
| | | from huaxin_client import constant as huaxin_client_constant |
|---|
| | | from huaxin_client import constant as huaxin_client_constant, huaxin_sinfo_util |
|---|
| | | from log_module import async_log_util |
|---|
| | | from log_module.log import hx_logger_trade_debug, hx_logger_trade_loop, hx_logger_trade_callback, logger_trade, \ |
|---|
| | | logger_system |
|---|
| | |
|---|
| | | @param shadow_price: |
|---|
| | | @return: |
|---|
| | | """ |
|---|
| | | timestamp = round(time.time() * 1000) |
|---|
| | | if not sinfo: |
|---|
| | | sinfo = f"ba_{code}_{timestamp}" |
|---|
| | | sinfo = huaxin_sinfo_util.create_place_order_sinfo(code, direction == 1, False) # f"ba_{code}_{timestamp}" |
|---|
| | | if not order_ref: |
|---|
| | | order_ref = huaxin_util.create_order_ref() |
|---|
| | | if not request_id: |
|---|
| | |
|---|
| | | """ |
|---|
| | | timestamp = round(time.time() * 1000) |
|---|
| | | if not sinfo: |
|---|
| | | sinfo = f"ba_{code}_{timestamp}" |
|---|
| | | sinfo = huaxin_sinfo_util.create_place_order_sinfo(code, direction == 1, False) #f"ba_{code}_{timestamp}" |
|---|
| | | if not request_id: |
|---|
| | | request_id = __get_request_id(ClientSocketManager.CLIENT_TYPE_TRADE) |
|---|
| | | for i in range(1): |
|---|
| | |
|---|
| | | "price_type": price_type, |
|---|
| | | "sinfo": sinfo, |
|---|
| | | "blocking": blocking, |
|---|
| | | "cancel_shadow": False}, |
|---|
| | | "cancel_shadow": False |
|---|
| | | }, |
|---|
| | | request_id=request_id, |
|---|
| | | is_trade=True) |
|---|
| | | try: |
|---|
