| | |
|---|
| | | class L2TradeQueueUtils(object): |
|---|
| | | # 获取成交进度索引 |
|---|
| | | @classmethod |
|---|
| | | def find_traded_progress_index(cls, buy_1_price, total_datas, local_today_num_operate_map, queueList,last_index, |
|---|
| | | def find_traded_progress_index(cls, buy_1_price, total_datas, local_today_num_operate_map, queueList, last_index, |
|---|
| | | latest_not_limit_up_time=None): |
|---|
| | | if len(queueList) == 0: |
|---|
| | | return None |
|---|
| | |
|---|
| | | # 在最近一次非涨停买1更新的时间之后才有效 |
|---|
| | | if latest_not_limit_up_time is None or tool.trade_time_sub(data["val"]["time"], |
|---|
| | | latest_not_limit_up_time) >= 0: |
|---|
| | | if data["index"]>=last_index: |
|---|
| | | if data["index"] >= last_index: |
|---|
| | | index_set.add(data["index"]) |
|---|
| | | index_list = list(index_set) |
|---|
| | | index_list.sort() |
|---|
