| | |
|---|
| | | async_log_util.info(logger_kpl_block_can_buy, |
|---|
| | | f"{code}:获取到精选板块-{blocks} 耗时:{int(time.time() - start_time)}s") |
|---|
| | | self.save_jx_blocks(code, blocks, current_limit_up_blocks) |
|---|
| | | # 跟随精选板块一起更新 |
|---|
| | | self.load_jx_blocks_radical(code) |
|---|
| | | else: |
|---|
| | | # 还没涨停的需要更新精选板块 更新精选板块 |
|---|
| | | if abs(float(buy_1_price) - float(limit_up_price)) >= 0.001: |
|---|
| | |
|---|
| | | async_log_util.info(logger_kpl_block_can_buy, |
|---|
| | | f"{code}:获取到精选板块（更新）-{blocks} 耗时:{int(time.time() - start_time)}s") |
|---|
| | | self.save_jx_blocks(code, blocks, current_limit_up_blocks) |
|---|
| | | # 跟随精选板块一起更新 |
|---|
| | | self.load_jx_blocks_radical(code) |
|---|
| | | elif price_rate > 0.03: |
|---|
| | | # 添加备用板块 |
|---|
| | | if not self.get_jx_blocks_cache(code, by=True): |
|---|
| | |
|---|
| | | self.save_jx_blocks(code, blocks, current_limit_up_blocks, by=True) |
|---|
| | | async_log_util.info(logger_kpl_block_can_buy, |
|---|
| | | f"{code}:获取到精选板块(备用)-{blocks} 耗时:{int(time.time() - start_time)}s") |
|---|
| | | # 跟随精选板块一起更新 |
|---|
| | | self.load_jx_blocks_radical(code) |
|---|
| | | |
|---|
| | | if price_rate > 0.03: |
|---|
| | | if not self.__code_blocks_for_radical_buy.get(code): |
|---|
| | |
|---|
| | | if blocks is None: |
|---|
| | | blocks = set() |
|---|
| | | # 将获取涨停原因与涨停推荐 |
|---|
| | | keys = TargetCodePlateKeyManager().get_plate_keys(code, contains_today=False) |
|---|
| | | keys = TargetCodePlateKeyManager().get_plate_keys(code, contains_today=True) |
|---|
| | | if keys and keys[0]: |
|---|
| | | blocks |= set(keys[0]) |
|---|
| | | return blocks |
|---|
