| | |
|---|
| | | import json |
|---|
| | | |
|---|
| | | import constant |
|---|
| | | import redis_manager |
|---|
| | | from db import redis_manager |
|---|
| | | import tool |
|---|
| | | from l2 import l2_data_manager |
|---|
| | | import l2.l2_data_util |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | # 保存成交索引 |
|---|
| | | def save_traded_index(self, code, buy1_price, buyQueueBig): |
|---|
| | | total_datas = l2_data_manager.local_today_datas.get(code) |
|---|
| | | today_num_operate_map = l2_data_manager.local_today_num_operate_map.get(code) |
|---|
| | | total_datas = l2.l2_data_util.local_today_datas.get(code) |
|---|
| | | today_num_operate_map = l2.l2_data_util.local_today_num_operate_map.get(code) |
|---|
| | | index = l2.l2_data_util.L2TradeQueueUtils.find_traded_progress_index(buy1_price, total_datas, |
|---|
| | | today_num_operate_map, buyQueueBig,self.__get_latest_not_limit_up_time(code)) |
|---|
| | | if index is not None: |
|---|
