| | |
|---|
| | | from l2 import l2_log, l2_data_source_util |
|---|
| | | from l2.l2_data_util import L2DataUtil, local_today_num_operate_map, local_today_datas, local_today_buyno_map, \ |
|---|
| | | local_today_canceled_buyno_map |
|---|
| | | from log_module.log import logger_buy_1_volumn, logger_l2_l_cancel |
|---|
| | | from log_module.log import logger_buy_1_volumn, logger_l2_l_cancel, logger_l2_h_cancel |
|---|
| | | from utils.tool import CodeDataCacheUtil |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | for index in range(transaction_index + 1, start_compute_index): |
|---|
| | | data = total_datas[index] |
|---|
| | | val = data['val'] |
|---|
| | | if not L2DataUtil.is_limit_up_price_buy(index): |
|---|
| | | if not L2DataUtil.is_limit_up_price_buy(val): |
|---|
| | | continue |
|---|
| | | if float(val['price']) * val['num'] < 5000: |
|---|
| | | continue |
|---|
| | |
|---|
| | | self.__compute_watch_index(code) |
|---|
| | | except Exception as e: |
|---|
| | | l2_log.h_cancel_debug(code, "设置成交进度位置出错：{}", str(e)) |
|---|
| | | logger_l2_h_cancel.exception(e) |
|---|
| | | |
|---|
| | | # 设置真实下单位置 |
|---|
| | | def set_real_place_order_index(self, code, index, buy_single_index): |
|---|
