| | |
| | | buy_progress_index) |
| | | # ---------------------------------判断板块是否跟上来了------------------------------- |
| | | try: |
| | | order_begin_pos = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(code) |
| | | volume_rate = 0 |
| | | volume_info = L2TradeDataProcessor.volume_rate_info.get(code) |
| | | if volume_info: |
| | | volume_rate = volume_info[0] |
| | | need_cancel, msg = UCancelBigNumComputer().need_cancel(code, buy_progress_index, order_begin_pos, |
| | | kpl_data_manager.KPLLimitUpDataRecordManager.get_current_reason_codes_dict(), |
| | | volume_rate) |
| | | if need_cancel: |
| | | L2TradeDataProcessor.cancel_buy(code, msg) |
| | | pass |
| | | # order_begin_pos = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(code) |
| | | # volume_rate = 0 |
| | | # volume_info = L2TradeDataProcessor.volume_rate_info.get(code) |
| | | # if volume_info: |
| | | # volume_rate = volume_info[0] |
| | | # need_cancel, msg = UCancelBigNumComputer().need_cancel(code, buy_progress_index, order_begin_pos, |
| | | # kpl_data_manager.KPLLimitUpDataRecordManager.get_current_reason_codes_dict(), |
| | | # volume_rate) |
| | | # if need_cancel: |
| | | # L2TradeDataProcessor.cancel_buy(code, msg) |
| | | except Exception as e: |
| | | logger_debug.exception(e) |
| | | else: |