| | |
|---|
| | | # 不处于可下单状态 |
|---|
| | | return True |
|---|
| | | if transaction_datas: |
|---|
| | | async_log_util.info(logger_l2_radical_buy, f"涨停主动买：{code}-{transaction_datas[-1]}") |
|---|
| | | l2_log.info(code, logger_l2_radical_buy, f"涨停主动买：{code}-{transaction_datas[-1]}") |
|---|
| | | else: |
|---|
| | | async_log_util.info(logger_l2_radical_buy, |
|---|
| | | f"即将炸板：{code}-{is_almost_open_limit_up}-{l2_market_time_str}") |
|---|
| | | l2_log.info(code, logger_l2_radical_buy, f"即将炸板：{code}-{is_almost_open_limit_up}-{l2_market_time_str}") |
|---|
| | | deal_codes = RadicalBuyDealCodesManager().get_deal_codes() |
|---|
| | | # 判断今日扫入的代码数量是否大于阈值 |
|---|
| | | radical_buy_setting = BuyMoneyAndCountSetting().get_radical_buy_setting() |
|---|
| | |
|---|
| | | if not WantBuyCodesManager().is_in_cache(code): |
|---|
| | | # 加绿不判断板块是否成交 |
|---|
| | | if len(deal_codes) >= MAX_COUNT: |
|---|
| | | async_log_util.info(logger_l2_radical_buy, f"扫入成交代码个数大于{MAX_COUNT}个：{code}-{deal_codes}") |
|---|
| | | l2_log.info(code, logger_l2_radical_buy, f"扫入成交代码个数大于{MAX_COUNT}个：{code}-{deal_codes}") |
|---|
| | | return True |
|---|
| | | if code in deal_codes: |
|---|
| | | async_log_util.info(logger_l2_radical_buy, f"该代码已经成交：{code}") |
|---|
| | | l2_log.info(code, logger_l2_radical_buy, f"该代码已经成交：{code}") |
|---|
| | | return True |
|---|
| | | |
|---|
| | | # 单票是否可买 |
|---|
| | |
|---|
| | | DealAndDelegateWithBuyModeDataManager().get_delegates_codes_info( |
|---|
| | | mode)) |
|---|
| | | if not can_buy: |
|---|
| | | async_log_util.info(logger_l2_radical_buy, f"当前时间段已不能扫入：{code}-{msg}") |
|---|
| | | l2_log.info(code, logger_l2_radical_buy, f"当前时间段已不能扫入：{code}-{msg}") |
|---|
| | | return True |
|---|
| | | |
|---|
| | | # -----根据成交比例判断是否可买------ |
|---|
| | | result_by_volume = radical_buy_strategy.process_limit_up_active_buy_deal(code, transaction_datas, |
|---|
| | | is_almost_open_limit_up, |
|---|
| | | no_left_limit_up_sell=no_left_limit_up_sell) |
|---|
| | | async_log_util.info(logger_l2_radical_buy, f"量买入结果判断：{code}, 结果：{result_by_volume} 板块：{buy_blocks}") |
|---|
| | | l2_log.info(code, logger_l2_radical_buy, f"量买入结果判断：{code}, 结果：{result_by_volume} 板块：{buy_blocks}") |
|---|
| | | in_blocks = RealTimeKplMarketData.get_top_market_jingxuan_blocks() |
|---|
| | | buy_blocks_with_money = [(b, RealTimeKplMarketData.get_jx_block_in_money(b), |
|---|
| | | in_blocks.index(b) if b in in_blocks else -1) for b in buy_blocks] |
|---|
| | |
|---|
| | | # 判断是否开得太高 |
|---|
| | | open_price = L1DataManager.get_open_price(code) |
|---|
| | | if not radical_buy_strategy.is_can_buy_with_open_price(code, open_price): |
|---|
| | | async_log_util.info(logger_l2_radical_buy, |
|---|
| | | f"开得太高：{code}") |
|---|
| | | l2_log.info(code, logger_l2_radical_buy, f"开得太高：{code}") |
|---|
| | | radical_buy_data_manager.ExcludeIndexComputeCodesManager.add_code(code) |
|---|
| | | return True |
|---|
| | | # if not RadicalCodeMarketInfoManager().is_opened_limit_up(code): |
|---|
| | |
|---|
| | | latest_deal_time, buy_blocks_with_money, is_almost_open_limit_up) |
|---|
| | | return False |
|---|
| | | else: |
|---|
| | | async_log_util.info(logger_l2_radical_buy, f"不能下单：{code}-{result_by_volume}") |
|---|
| | | l2_log.info(code, logger_l2_radical_buy, f"不能下单：{code}-{result_by_volume}") |
|---|
| | | return False |
|---|
| | | else: |
|---|
| | | volume_rate = code_volumn_manager.CodeVolumeManager().get_volume_rate(code) |
|---|
| | | async_log_util.info(logger_l2_radical_buy, f"没有可扫入的板块：{code},量比：{volume_rate}") |
|---|
| | | l2_log.info(code, logger_l2_radical_buy, f"没有可扫入的板块：{code},量比：{volume_rate}") |
|---|
| | | return True |
|---|
| | | else: |
|---|
| | | async_log_util.info(logger_l2_radical_buy, f"目前代码不可交易：{code}-{can_buy_result[1]}") |
|---|
| | | l2_log.info(code, logger_l2_radical_buy, f"目前代码不可交易：{code}-{can_buy_result[1]}") |
|---|
| | | return True |
|---|
| | | except Exception as e: |
|---|
| | | async_log_util.info(logger_debug, f"激进买计算异常：{str(e)}") |
|---|
| | | l2_log.info(code, logger_debug, f"激进买计算异常：{str(e)}") |
|---|
| | | logger_debug.exception(e) |
|---|
| | | finally: |
|---|
| | | use_time = time.time() - __start_time |
|---|
| | | if use_time > 0.005: |
|---|
| | | async_log_util.info(logger_debug, f"扫入处理时长：{code}-{use_time}") |
|---|
| | | l2_log.info(code, logger_debug, f"扫入处理时长：{code}-{use_time}") |
|---|
| | | |
|---|
| | | def OnLimitUpActiveBuy(self, code, transaction_datas, no_left_limit_up_sell): |
|---|
| | | can_clear_before_data = self.process_limit_up_active_buy(code, transaction_datas, |
|---|
| | |
|---|
| | | result = huaxin_trade_api.order(huaxin_trade_api.TRADE_DIRECTION_BUY, code, volume, limit_up_price, |
|---|
| | | blocking=False, |
|---|
| | | shadow_price=shadow_price, shadow_volume=volume) |
|---|
| | | async_log_util.info(logger_trade, f"{code}下单结束：{result}") |
|---|
| | | l2_log.info(code, logger_trade, f"{code}下单结束：{result}") |
|---|
| | | buy_open_limit_up_strategy.BuyOpenLimitupDataManager().set_place_order_info(code, volume, volume, |
|---|
| | | result.get("order_ref")) |
|---|
| | | except Exception as e: |
|---|
