| | |
|---|
| | | if trade_indexs[i][1] == index: |
|---|
| | | return trade_indexs[i] |
|---|
| | | return None |
|---|
| | | |
|---|
| | | logger_debug.info("准备加载L2Map数据-----") |
|---|
| | | # 数据预处理 |
|---|
| | | num_operate_map = {} |
|---|
| | |
|---|
| | | logger_debug.info(f"循环组装数据开始：长度-{len(datas)} 主动卖长度-{len(active_sell_nos)}") |
|---|
| | | index = 0 |
|---|
| | | fdatas = [] |
|---|
| | | # 数据太多就需要过滤掉小金额 |
|---|
| | | is_data_too_large = len(datas) > 20000 |
|---|
| | | for data in datas: |
|---|
| | | index += 1 |
|---|
| | | if is_data_too_large and data['val']['num'] * float(data['val']['price']) < 5000: |
|---|
| | | if data["index"] not in real_position_indexes: |
|---|
| | | continue |
|---|
| | | |
|---|
| | | # 先移除 |
|---|
| | | if data['val']['orderNo'] in active_sell_nos: |
|---|
| | | # 过滤主动卖 |
|---|
