| | |
|---|
| | | # 获取最近的主动买成交量 |
|---|
| | | deal_infos = HuaXinSellOrderStatisticManager.get_latest_6s_active_buy_deal_volumes(code) |
|---|
| | | async_log_util.info(logger_l2_radical_buy, f"最近主动买成交：{code}-{deal_infos}") |
|---|
| | | async_log_util.info(logger_l2_radical_buy) |
|---|
| | | if refer_sell_data and refer_sell_data[1] > 100 * 1e4: |
|---|
| | | if refer_sell_data: # and refer_sell_data[1] > 100 * 1e4: |
|---|
| | | # 总卖额要大于100w |
|---|
| | | deal_volume = 0 |
|---|
| | | for i in range(len(deal_infos) - 1, -1, -1): |
|---|
| | | for i in range(0, len(deal_infos)): |
|---|
| | | # >=统计到的总卖 |
|---|
| | | if int(refer_sell_time.replace(":", "")) > int(deal_infos[i][0].replace(":", "")): |
|---|
| | | break |
|---|
| | | deal_volume += deal_infos[i][1] |
|---|
| | | async_log_util.info(logger_l2_radical_buy, f"成交量：{deal_volume}/{refer_sell_data[2]}") |
|---|
| | | # 判断参考时间之后是否有大单成交 |
|---|
| | | big_deal_money_list = BigOrderDealManager().get_total_buy_money_list(code) |
|---|
| | | if len(big_deal_money_list)>0: |
|---|
| | | if len(big_deal_money_list) > 0 or True: |
|---|
| | | # 有大单成交 |
|---|
| | | yesterday_codes = kpl_data_manager.get_yesterday_limit_up_codes() |
|---|
| | | if yesterday_codes is None: |
|---|
| | | yesterday_codes = set() |
|---|
| | | result = RadicalBuyBlockManager.is_radical_buy(code, yesterday_codes) |
|---|
| | | async_log_util.info(logger_l2_radical_buy, f"计算板块结果：{code}-{result}") |
|---|
| | | else: |
|---|
| | | volume_rate = code_volumn_manager.get_volume_rate(code) |
|---|
| | | async_log_util.info(logger_l2_radical_buy, f"图形不符合要求：{code},量比：{volume_rate}") |
|---|
| | | except Exception as e: |
|---|
| | | async_log_util.info(logger_debug, f"激进买计算异常：{str(e)}") |
|---|
| | | |
|---|
