"""
|
L2相关数据处理
|
"""
|
|
|
# L2交易队列
|
class L2TradeQueueUtils(object):
|
# 获取成交进度索引
|
def find_traded_progress_index(cls, buy_1_price, total_datas, local_today_num_operate_map, queueList):
|
if len(queueList) == 0:
|
return None
|
index_set = set()
|
for num in queueList:
|
buy_datas = local_today_num_operate_map.get(
|
"{}-{}-{}".format(num, "0", buy_1_price))
|
if buy_datas is not None and len(buy_datas) > 0:
|
for data in buy_datas:
|
index_set.add(data["index"])
|
index_list = list(index_set)
|
index_list.sort()
|
num_list = []
|
new_index_list = []
|
for index in index_list:
|
for i in range(0, total_datas[index]["re"]):
|
num_list.append(total_datas[index]["val"]["num"])
|
new_index_list.append(index)
|
index_list_str = ",".join(list(map(str, num_list)))
|
queue_list_str = ",".join(list(map(str, queueList)))
|
find_index = index_list_str.find(queue_list_str)
|
if find_index >= 0:
|
temp_str = index_list_str[0:find_index]
|
return new_index_list[len(temp_str.split(","))]
|
raise Exception("尚未找到成交进度")
|
|
|
if __name__ == "__main__":
|
pass
|
