| | |
|---|
| | | if ret != 0: |
|---|
| | | raise Exception('ReqOrderInsert fail, ret[%d]' % ret) |
|---|
| | | |
|---|
| | | if queue_trade_w_l2_r is not None: |
|---|
| | | queue_trade_w_l2_r.put_nowait( |
|---|
| | | if queue_other_w_l2_r is not None: |
|---|
| | | queue_other_w_l2_r.put_nowait( |
|---|
| | | json.dumps({"type": "listen_volume", "data": {"code": code, |
|---|
| | | "volume": count}}).encode( |
|---|
| | | 'utf-8')) |
|---|
| | |
|---|
| | | addr, port = constant.SERVER_IP, constant.SERVER_PORT |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(trade_response_: TradeResponse = None, queue_trade_w_l2_r_: multiprocessing.Queue = None, |
|---|
| | | def run(trade_response_: TradeResponse = None, queue_other_w_l2_r_: multiprocessing.Queue = None, |
|---|
| | | queue_strategy_trade_write_=None, |
|---|
| | | queue_strategy_trade_read=None): |
|---|
| | | try: |
|---|
| | | logger_system.info("交易进程ID：{}", os.getpid()) |
|---|
| | | logger_system.info(f"trade 线程ID:{tool.get_thread_id()}") |
|---|
| | | __init_trade_data_server() |
|---|
| | | global queue_trade_w_l2_r |
|---|
| | | queue_trade_w_l2_r = queue_trade_w_l2_r_ |
|---|
| | | global queue_other_w_l2_r |
|---|
| | | queue_other_w_l2_r = queue_other_w_l2_r_ |
|---|
| | | |
|---|
| | | global queue_strategy_trade_write |
|---|
| | | queue_strategy_trade_write = queue_strategy_trade_write_ |
|---|
