| | |
|---|
| | | # 下单L2的安全笔数管理 |
|---|
| | | import json |
|---|
| | | |
|---|
| | | from l2 import l2_data_source_util |
|---|
| | | from trade import l2_trade_factor |
|---|
| | | from db import redis_manager |
|---|
| | | import tool |
|---|
| | |
|---|
| | | buy_num += int(val["num"]) * data["re"] |
|---|
| | | elif L2DataUtil.is_limit_up_price_buy_cancel(val): |
|---|
| | | # 获取买入信息 |
|---|
| | | buy_index, buy_data = l2_data_util.get_buy_data_with_cancel_data(data, local_today_num_operate_map) |
|---|
| | | buy_index = l2_data_source_util.L2DataSourceUtils.get_buy_index_with_cancel_data(code, data, |
|---|
| | | local_today_num_operate_map) |
|---|
| | | if buy_index is not None: |
|---|
| | | if last_buy_single_index <= buy_index <= end_index: |
|---|
| | | cancel_num += int(val["num"]) * data["re"] |
|---|
