| | |
| | | def __test(): |
| | | while True: |
| | | try: |
| | | trading_order_canceled("002582", 18505388) |
| | | trading_order_canceled("603106", 6114878) |
| | | time.sleep(5) |
| | | except: |
| | | pass |
| | |
| | | |
| | | |
| | | if __name__ == "__main__": |
| | | |
| | | # l2.l2_data_util.save_l2_data(code, None, datas) |
| | | |
| | | # ClientSocketManager.add_client(ClientSocketManager.CLIENT_TYPE_TRADE, "1", None) |
| | | # ClientSocketManager.add_client(ClientSocketManager.CLIENT_TYPE_TRADE, "2", None) |
| | | # ClientSocketManager.add_client(ClientSocketManager.CLIENT_TYPE_TRADE, "3", None) |
| | | # |
| | | # for i in range(0, 3): |
| | | # t1 = threading.Thread(target=lambda: test1()) |
| | | # t1.setDaemon(True) |
| | | # t1.start() |
| | | # |
| | | # for i in range(0, 3): |
| | | # t1 = threading.Thread(target=lambda: test2()) |
| | | # t1.setDaemon(True) |
| | | # t1.start() |
| | | # |
| | | |
| | | code="603106" |
| | | l2_data_util.load_l2_data(code, load_latest=False) |
| | | buy_no_map = l2_data_util.local_today_buyno_map.get(code) |
| | | print(buy_no_map.get("6114878")) |
| | | while True: |
| | | time.sleep(10) |