| | |
| | | l2_data_manager.run_upload_common() |
| | | l2_data_manager.run_upload_trading_canceled() |
| | | l2_data_manager.run_log() |
| | | l2_data_manager.run_test() |
| | | global l2CommandManager |
| | | l2CommandManager = command_manager.L2CommandManager() |
| | | l2CommandManager.init(MyL2ActionCallback()) |
| | |
| | | |
| | | |
| | | def run_upload_trading_canceled(): |
| | | # TODO 测试 |
| | | trading_order_canceled("002582", 18505388) |
| | | t = threading.Thread(target=lambda: __run_upload_trading_canceled(), daemon=True) |
| | | t.start() |
| | | |
| | |
| | | t.start() |
| | | |
| | | |
| | | def __test(): |
| | | while True: |
| | | try: |
| | | trading_order_canceled("002582", 18505388) |
| | | time.sleep(5) |
| | | except: |
| | | pass |
| | | |
| | | |
| | | def run_test(): |
| | | t = threading.Thread(target=lambda: __test(), daemon=True) |
| | | t.start() |
| | | |
| | | |
| | | if __name__ == "__main__": |
| | | upload_data("000798", "trading_order_canceled", 30997688, new_sk=True) |