| | |
| | | from l2 import l2_data_source_util, l2_data_util |
| | | from log_module.log import logger_debug |
| | | from trade import deal_big_money_manager |
| | | from trade.buy_money_count_setting import BuyMoneyUtil |
| | | from utils import tool |
| | | |
| | | # 缓存L2数据,格式:{"日期":{数据}} |
| | |
| | | fdatas = [] |
| | | # 数据太多就需要过滤掉小金额 |
| | | is_data_too_large = len(datas) > 20000 |
| | | |
| | | limit_up_price = gpcode_manager.get_limit_up_price_as_num(code) |
| | | if limit_up_price: |
| | | # 需要订阅的特殊的量 |
| | | special_volumes = BuyMoneyUtil.get_possible_buy_volumes(limit_up_price) |
| | | else: |
| | | special_volumes = [] |
| | | |
| | | for data in datas: |
| | | index += 1 |
| | | if is_data_too_large and data['val']['num'] * float(data['val']['price']) < 5000: |
| | | if data["index"] not in real_position_indexes: |
| | | # 小单 |
| | | if data["index"] not in real_position_indexes and data['val']['num']*100 not in special_volumes: |
| | | continue |
| | | |
| | | # 先移除 |