| | |
|---|
| | | codes.add(code) |
|---|
| | | self.codes_volume_and_price_dict[code] = (d[1], d[2], d[3], d[4]) |
|---|
| | | self.l2_data_upload_manager.set_order_fileter_condition(code, d[1], round(float(d[2]), 2), d[3], d[4]) |
|---|
| | | logger_l2_codes_subscript.info("华鑫L2订阅总数：{}", len(codes)) |
|---|
| | | add_codes = codes - self.subscripted_codes |
|---|
| | | del_codes = self.subscripted_codes - codes |
|---|
| | | print("add del codes", add_codes, del_codes) |
|---|
| | |
|---|
| | | self.l2_data_upload_manager.release_distributed_upload_queue(c) |
|---|
| | | l2_data_manager.del_target_code(c) |
|---|
| | | for c in codes: |
|---|
| | | self.l2_data_upload_manager.distribute_upload_queue(c) |
|---|
| | | self.l2_data_upload_manager.distribute_upload_queue(c, codes) |
|---|
| | | l2_data_manager.add_target_code(c) |
|---|
| | | except Exception as e: # TODO 清除原来还没释放掉的数据 |
|---|
| | | logger_system.error(f"L2代码分配上传队列出错:{str(e)}") |
|---|
