| | |
| | | if not is_normal: |
| | | # print("历史数据异常:", code) |
| | | # 数据不正常需要禁止交易 |
| | | l2_trade_util.forbidden_trade(code, msg="L2历史数据异常") |
| | | l2_trade_util.forbidden_trade(code, msg="L2历史数据异常", force=True) |
| | | # 纠正数据 |
| | | if constant.L2_SOURCE_TYPE == constant.L2_SOURCE_TYPE_THS: |
| | | # 同花顺需要纠正数据,其他渠道不需要 |
| | |
| | | is_normal = l2.l2_data_util.l2_data_is_normal(code) |
| | | if not is_normal: |
| | | # 数据不正常需要禁止交易 |
| | | l2_trade_util.forbidden_trade(code, msg="L2历史数据异常") |
| | | l2_trade_util.forbidden_trade(code, msg="L2历史数据异常", force=True) |
| | | # 转换数据格式 |
| | | _start_index = 0 |
| | | total_datas = local_today_datas.get(code) |