| | |
|---|
| | | |
|---|
| | | queue_r.put_nowait(json.dumps({"type": "l2_cmd", "data": [demo_datas[0]]})) |
|---|
| | | time.sleep(1) |
|---|
| | | |
|---|
| | | while True: |
|---|
| | | spi.l2_data_upload_manager.add_l2_order_detail( |
|---|
| | | {'SecurityID': '603002', 'Price': 6.35, 'Volume': 275000, 'Side': "1", 'OrderType': '0', |
|---|
| | | 'OrderTime': '13000015', |
|---|
| | |
|---|
| | | {'SecurityID': '603002', 'Price': 6.35, 'Volume': 100, 'Side': "1", 'OrderType': '0', |
|---|
| | | 'OrderTime': '13000015', |
|---|
| | | 'MainSeq': 2, 'SubSeq': 6739148, 'OrderNO': 5512467, 'OrderStatus': 'D'}, 0) |
|---|
| | | time.sleep(10) |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(queue_r: multiprocessing.Queue, order_queues: List[multiprocessing.Queue], |
|---|
