| | |
|---|
| | | self.__set_processed_end_index(code, end_index) |
|---|
| | | big_money_num_manager.add_num(code, total_num) |
|---|
| | | |
|---|
| | | print("m值大单计算范围：{}-{} 时间：{}".format(max(start_index, processed_index), end_index, |
|---|
| | | round(t.time() * 1000) - start_time)) |
|---|
| | | # print("m值大单计算范围：{}-{} 时间：{}".format(max(start_index, processed_index), end_index, |
|---|
| | | # round(t.time() * 1000) - start_time)) |
|---|
| | | |
|---|
| | | |
|---|
| | | class L2TradeDataProcessor: |
|---|
| | |
|---|
| | | # 加载历史数据,返回数据是否正常 |
|---|
| | | is_normal = l2.l2_data_util.load_l2_data(code) |
|---|
| | | if not is_normal: |
|---|
| | | print("历史数据异常:", code) |
|---|
| | | # print("历史数据异常:", code) |
|---|
| | | # 数据不正常需要禁止交易 |
|---|
| | | l2_trade_util.forbidden_trade(code, msg="L2历史数据异常") |
|---|
| | | # 纠正数据 |
|---|
