| | |
|---|
| | | final_blocks = copy.deepcopy(blocks) |
|---|
| | | if len(blocks) > 2: |
|---|
| | | final_blocks.clear() |
|---|
| | | # 根据涨幅排序 |
|---|
| | | blocks.sort(key=lambda x: x[2]) |
|---|
| | | blocks.reverse() |
|---|
| | | for b in blocks: |
|---|
| | | if b[1] not in constant.KPL_INVALID_BLOCKS: |
|---|
| | | if b not in constant.KPL_INVALID_BLOCKS: |
|---|
| | | final_blocks.append(b) |
|---|
| | | if len(final_blocks) < 2: |
|---|
| | | final_blocks = blocks |
|---|
| | |
|---|
| | | if price_rate > 0.07: |
|---|
| | | jx_blocks_info = self.get_jx_blocks_cache(code) |
|---|
| | | if not jx_blocks_info: |
|---|
| | | blocks = kpl_api.getCodeJingXuanBlocks(code) |
|---|
| | | blocks = kpl_api.getCodeBlocks(code) |
|---|
| | | self.save_jx_blocks(code, blocks, current_limit_up_blocks) |
|---|
| | | async_log_util.info(logger_kpl_block_can_buy, f"{code}:获取到精选板块-{blocks}") |
|---|
| | | else: |
|---|
| | |
|---|
| | | |
|---|
| | | if time.time() - jx_blocks_info[1] > UPDATE_TIME_SPACE: |
|---|
| | | # 距离上次更新时间过去了5分钟 |
|---|
| | | blocks = kpl_api.getCodeJingXuanBlocks(code) |
|---|
| | | blocks = kpl_api.getCodeBlocks(code) |
|---|
| | | self.save_jx_blocks(code, blocks, current_limit_up_blocks) |
|---|
| | | async_log_util.info(logger_kpl_block_can_buy, f"{code}:获取到精选板块（更新）-{blocks}") |
|---|
| | | |
|---|
| | | elif price_rate > 0.03: |
|---|
| | | # 添加备用板块 |
|---|
| | | if not self.get_jx_blocks_cache(code, by=True): |
|---|
| | | blocks = kpl_api.getCodeJingXuanBlocks(code) |
|---|
| | | blocks = kpl_api.getCodeBlocks(code) |
|---|
| | | self.save_jx_blocks(code, blocks, current_limit_up_blocks, by=True) |
|---|
| | | async_log_util.info(logger_kpl_block_can_buy, f"{code}:获取到精选板块(备用)-{blocks}") |
|---|
| | | except Exception as e: |
|---|
| | |
|---|
| | | jingxuan_block_info = self.__KPLCodeJXBlockManager.get_jx_blocks_cache(code, by=True) |
|---|
| | | if jingxuan_block_info: |
|---|
| | | jingxuan_blocks = jingxuan_block_info[0] |
|---|
| | | k4 |= set([x[1] for x in jingxuan_blocks]) |
|---|
| | | k4 |= jingxuan_blocks #set([x[1] for x in jingxuan_blocks]) |
|---|
| | | for k in [k1, k11, k2, k3, k4]: |
|---|
| | | keys |= k |
|---|
| | | |
|---|
