| | |
| | | from code_attribute import code_volumn_manager, limit_up_time_manager, global_data_loader, gpcode_manager |
| | | import constant |
| | | from utils import global_util, tool |
| | | from log_module import log |
| | | from log_module import log, log_export |
| | | from l2 import l2_data_manager, l2_data_util, transaction_progress, l2_data_manager_new, code_price_manager |
| | | from l2.cancel_buy_strategy import HourCancelBigNumComputer |
| | | import l2.l2_data_manager_new |
| | |
| | | if trade_state == trade_manager.TRADE_STATE_BUY_PLACE_ORDER or trade_state == trade_manager.TRADE_STATE_BUY_DELEGATED or trade_state == trade_manager.TRADE_STATE_BUY_SUCCESS: |
| | | hcancel_datas_dict, cancel_indexes_set = HourCancelBigNumComputer.get_watch_index_dict(code) |
| | | # 根据日志读取实时的计算数据 |
| | | h_cancel_latest_compute_info = log.get_h_cancel_compute_info(code) |
| | | h_cancel_latest_compute_info = log_export.get_h_cancel_compute_info(code) |
| | | if hcancel_datas_dict: |
| | | temp_list = [(k, hcancel_datas_dict[k][0]) for k in hcancel_datas_dict] |
| | | canceled_indexs = set([int(k.split("-")[0]) for k in cancel_indexes_set]) |
| | |
| | | break_time = limit_up_info[1] |
| | | records = [] |
| | | try: |
| | | records = log.load_buy_score_recod(code) |
| | | records = log_export.load_buy_score_recod(code) |
| | | except: |
| | | pass |
| | | records_new = [] |