| | |
|---|
| | | if code not in cls.__human_radical_buy_mark_info: |
|---|
| | | return False, "没有人买入信号" |
|---|
| | | single_time_ms, space_time_ms, expire_time_ms, _ = cls.__human_radical_buy_mark_info[code] |
|---|
| | | if tool.trade_time_sub_with_ms(L2DataUtil.get_time_with_ms(data["val"]), |
|---|
| | | now_time_ms = L2DataUtil.get_time_with_ms(data["val"]) |
|---|
| | | if tool.trade_time_sub_with_ms(now_time_ms, |
|---|
| | | expire_time_ms) > 0: |
|---|
| | | cls.__human_radical_buy_mark_info.pop(code) |
|---|
| | | async_log_util.info(logger_l2_not_buy_reasons, f"{code}#大单足够，人为下单： 超过信号生效时间-{now_time_ms}/{expire_time_ms}") |
|---|
| | | return False, "超过信号生效时间" |
|---|
| | | return True, cls.__human_radical_buy_mark_info[code] |
|---|
| | | |
|---|
| | |
|---|
| | | else: |
|---|
| | | human_radical_result = cls.__compute_human_radical_order_begin_pos(code, compute_start_index, |
|---|
| | | compute_end_index) |
|---|
| | | l2_log.debug(code, f"大单足够，人为下单计算结果({compute_start_index}-{compute_end_index}):{human_radical_result}") |
|---|
| | | if human_radical_result[0]: |
|---|
| | | radical_result = list(human_radical_result[2]) |
|---|
| | | # 改变执行位置 |
|---|
| | |
|---|
| | | code), 0) |
|---|
| | | if big_order_deal_enough_result[6] <= 0: |
|---|
| | | HumanRadicalBuySingleManager.add_single(code, total_datas[-1], radical_result) |
|---|
| | | async_log_util.info(logger_l2_not_buy_reasons, f"{code}#大单足够，需要根据人为下单") |
|---|
| | | async_log_util.info(logger_l2_not_buy_reasons, f"{code}#大单足够，需要根据人为下单({compute_start_index}-{compute_end_index})：{radical_result[1]}") |
|---|
| | | return |
|---|
| | | # 下单前一步，移除人为下单信号 |
|---|
| | | is_human_radical_buy = HumanRadicalBuySingleManager.has_single(code) |
|---|
