| | |
|---|
| | | logger_debug.exception(e) |
|---|
| | | |
|---|
| | | def process_limit_up_active_buy(self, code, transaction_datas, is_almost_open_limit_up=False, |
|---|
| | | l2_market_time_str=''): |
|---|
| | | l2_market_time_str='', no_left_limit_up_sell=False): |
|---|
| | | """ |
|---|
| | | 处理涨停主动买 |
|---|
| | | @param no_left_limit_up_sell: 是否还有剩余涨停卖尚未成交 |
|---|
| | | @param code: |
|---|
| | | @param transaction_datas: |
|---|
| | | @param is_almost_open_limit_up: 是否即将炸板 |
|---|
| | |
|---|
| | | |
|---|
| | | # -----根据成交比例判断是否可买------ |
|---|
| | | result_by_volume = radical_buy_strategy.process_limit_up_active_buy_deal(code, transaction_datas, |
|---|
| | | is_almost_open_limit_up) |
|---|
| | | 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}") |
|---|
| | | in_blocks = RealTimeKplMarketData.get_top_market_jingxuan_blocks() |
|---|
| | | buy_blocks_with_money = [(b, RealTimeKplMarketData.get_jx_block_in_money(b), |
|---|
| | |
|---|
| | | if use_time > 0.005: |
|---|
| | | async_log_util.info(logger_debug, f"扫入处理时长：{code}-{use_time}") |
|---|
| | | |
|---|
| | | def OnLimitUpActiveBuy(self, code, transaction_datas): |
|---|
| | | can_clear_before_data = self.process_limit_up_active_buy(code, transaction_datas) |
|---|
| | | def OnLimitUpActiveBuy(self, code, transaction_datas, no_left_limit_up_sell): |
|---|
| | | can_clear_before_data = self.process_limit_up_active_buy(code, transaction_datas, |
|---|
| | | no_left_limit_up_sell=no_left_limit_up_sell) |
|---|
| | | if can_clear_before_data: |
|---|
| | | # 清除 |
|---|
| | | EveryLimitupBigDealOrderManager.clear(code) |
|---|
