| | |
|---|
| | | break |
|---|
| | | |
|---|
| | | changed = True |
|---|
| | | if code in self.__last_l_up_compute_info: |
|---|
| | | if self.__last_l_up_compute_info[code] == watch_indexes: |
|---|
| | | __last_l_up_compute_info = self.__last_l_up_compute_info.get(code) |
|---|
| | | if __last_l_up_compute_info: |
|---|
| | | if __last_l_up_compute_info == watch_indexes: |
|---|
| | | changed = False |
|---|
| | | # 保存数据 |
|---|
| | | if changed: |
|---|
| | | threshold_time = 1 if tool.is_sz_code(code) else 2 |
|---|
| | | if time.time() - __last_l_up_compute_info[0] < threshold_time: |
|---|
| | | l2_log.l_cancel_debug(code, f"L前监控更新太频繁：{threshold_time}") |
|---|
| | | return |
|---|
| | | l2_log.l_cancel_debug(code, f"L前监控范围：{watch_indexes} 计算范围：{start_index}-{end_index}") |
|---|
| | | self.__set_near_by_trade_progress_indexes(code, buy_single_index, watch_indexes) |
|---|
| | | self.__last_l_up_compute_info[code] = (time.time(), watch_indexes) |
|---|
