| | |
| | | import copy |
| | | import logging |
| | | import threading |
| | | import time as t |
| | |
| | | # 2.距离最近的非板上成交的时间大于一个阈值 |
| | | if abs(limit_up_price - float(trade_price)) < 0.001: |
| | | latest_exec_indexes = cls.__latest_exec_indexes[code] |
| | | if not latest_exec_indexes: |
| | | latest_exec_indexes = [] |
| | | # 判断是否是炸开后买入 |
| | | last_exec_index = 0 |
| | | if len(latest_exec_indexes) > 1: |
| | |
| | | limit_up_sell_count = L2TradeSingleDataProcessor.get_latest_limit_up_sell_order_count(code) |
| | | if (limit_up_sell_count == 0 or active_buy_blocks) and not single: |
| | | # 如果没有涨停卖数据/激进下单而且还没有成交买入信号,就按照原来的总卖额计算 |
| | | threshold_money, sell_1_price = refer_sell_data[1], refer_sell_data[3][0] |
| | | threshold_money, sell_1_price = copy.deepcopy(refer_sell_data[1]), refer_sell_data[3][0] |
| | | for i in range(start_index - 1, -1, -1): |
| | | val = total_datas[i]["val"] |
| | | if tool.compare_time(val["time"], refer_sell_data[0]) < 0: |
| | |
| | | if yesterday_codes is None: |
| | | yesterday_codes = set() |
| | | result = RadicalBuyBlockManager.is_radical_buy(code, yesterday_codes) |
| | | if result[0]: |
| | | if refer_sell_data[1] < 500 * 1e4: |
| | | async_log_util.info(logger_l2_radical_buy, f"不能扫:{code}-总卖额偏少{refer_sell_data[1]}/500w") |
| | | else: |
| | | async_log_util.info(logger_l2_radical_buy, f"可以扫:{result}") |
| | | |
| | | async_log_util.info(logger_l2_radical_buy, f"计算板块结果:{code}-{result}") |
| | | else: |
| | | volume_rate = code_volumn_manager.get_volume_rate(code) |
| | |
| | | continue |
| | | buy1_money = huaxin_l1_data_manager.get_buy1_money(code) |
| | | # 买1是否大于5000w |
| | | # TODO 测试 |
| | | if not constant.TEST: |
| | | if not buy1_money or buy1_money < 5e7: |
| | | continue |
| | |
| | | @return: |
| | | """ |
| | | # 10点之前才能买入 |
| | | # TODO 测试 |
| | | if not constant.TEST: |
| | | if int(tool.get_now_time_str().replace(":", "")) > 100000: |
| | | return False, "超过生效时间" |