| | |
| | | api.Init() |
| | | |
| | | logger_system.info("L1订阅服务启动成功") |
| | | # TODO 测试链路 |
| | | level1_data_dict["000969"] = ( |
| | | "000969", 9.46, 9.11, 771000*100, time.time()) |
| | | level1_data_dict["000961"] = ( |
| | | "000961",1.93, 10.29, 2638000 * 100, time.time()) |
| | | # 测试链路 |
| | | # level1_data_dict["000969"] = ( |
| | | # "000969", 9.46, 9.11, 771000*100, time.time()) |
| | | # level1_data_dict["000961"] = ( |
| | | # "000961",1.93, 10.29, 2638000 * 100, time.time()) |
| | | |
| | | # 等待程序结束 |
| | | while True: |
| | |
| | | |
| | | |
| | | def is_trade_time(): |
| | | return True |
| | | relative_timestamp = time.time() % (24 * 60 * 60) + 8 * 60 * 60 |
| | | start1 = 60 * 60 * 9 + 24 * 60 |
| | | end1 = 60 * 60 * 11 + 31 * 60 |
| | |
| | | |
| | | # pipe的交易通道是否正常 |
| | | def is_pipe_channel_normal(): |
| | | return False #trade_pipe_channel_error_count < 3 |
| | | return trade_pipe_channel_error_count < 3 |
| | | |
| | | |
| | | # 测试交易通道 |