| | |
| | | # 统计净涨停买的数量 |
| | | not_cancel_indexes = [] |
| | | re_start_index = start_index |
| | | MAX_COUNT = 5 |
| | | for j in range(start_index, end_index): |
| | | data = total_datas[j] |
| | | val = data['val'] |
| | |
| | | # 取后1/3的数据 |
| | | temp_index = int(temp_count * 2 / 3) |
| | | re_start_index = not_cancel_indexes[temp_index] |
| | | MAX_COUNT = len(not_cancel_indexes[temp_index:]) // 3 |
| | | |
| | | if MAX_COUNT < 5: |
| | | MAX_COUNT = 5 |
| | | MIN_MONEYS = [300, 200, 100, 50] |
| | | watch_indexes = set() |
| | | MAX_COUNT = 5 |
| | | for min_money in MIN_MONEYS: |
| | | for i in range(end_index, re_start_index, -1): |
| | | # if i > len(total_datas): |
| | |
| | | except Exception as e: |
| | | logger_l2_l_cancel.exception(e) |
| | | raise e |
| | | extra_msg = "L下" |
| | | extra_msg = "L后" |
| | | if not can_cancel: |
| | | # 成交位临近撤 |
| | | try: |
| | |
| | | start_index, end_index, |
| | | total_data, |
| | | is_first_code) |
| | | extra_msg = "L上" |
| | | extra_msg = "L前" |
| | | except Exception as e: |
| | | logger_l2_l_cancel.exception(e) |
| | | raise e |
| | |
| | | params["code"] = code |
| | | params["code_name"] = f"{gpcode_manager.get_code_name(code)} {code} ({','.join(code_extra_infos)})" |
| | | |
| | | score_info = None |
| | | buy_params_info = None |
| | | xgb_infos = None |
| | | total_datas = l2_data_util.local_today_datas.get(code) |
| | | if total_datas is None: |
| | | l2_data_util.load_l2_data(code) |