| | |
|---|
| | | 华鑫LV2处理工具类 |
|---|
| | | """ |
|---|
| | | |
|---|
| | | |
|---|
| | | # 处理逐笔委托 |
|---|
| | | # item逐笔委托 |
|---|
| | | # (data['SecurityID'], data['Price'], data['Volume'], data['Side'], data['OrderType'], |
|---|
| | |
|---|
| | | datas = [] |
|---|
| | | dataIndexs = {} |
|---|
| | | same_time_num = {} |
|---|
| | | for item in origin_datas: |
|---|
| | | for i in range(0, len(origin_datas)): |
|---|
| | | item = origin_datas[i] |
|---|
| | | # 解析数据 |
|---|
| | | time = item["time"] |
|---|
| | | if time in same_time_num: |
|---|
| | |
|---|
| | | # 数据重复次数默认为1 |
|---|
| | | datas.append({"key": key, "val": item, "re": 1}) |
|---|
| | | dataIndexs.setdefault(key, len(datas) - 1) |
|---|
| | | # TODO 测试的时候开启，方便记录大单数据 |
|---|
| | | # l2_data_util.save_big_data(code, same_time_num, data) |
|---|
| | | return datas |
|---|
| | | |
|---|
| | | |
|---|
| | | def get_format_l2_datas(code, origin_datas, limit_up_price): |
|---|
| | | def get_format_l2_datas(code, origin_datas, limit_up_price, start_index): |
|---|
| | | # 先转变数据格式 |
|---|
| | | datas = [__convert_order(x, limit_up_price) for x in origin_datas] |
|---|
| | | return __format_l2_data(datas, code, limit_up_price) |
|---|
| | | fdatas = __format_l2_data(datas, code, limit_up_price) |
|---|
| | | for i in range(0, len(fdatas)): |
|---|
| | | fdatas[i]["index"] = start_index + i |
|---|
