| | |
|---|
| | | |
|---|
| | | if price_rate > 0.03: |
|---|
| | | if not self.__code_blocks_for_radical_buy.get(code): |
|---|
| | | start_time = time.time() |
|---|
| | | blocks = kpl_api.getCodeJingXuanBlocks(code, jx=False) |
|---|
| | | blocks = set([b[1] for b in blocks]) |
|---|
| | | # fblocks = BlockMapManager().filter_blocks(blocks) |
|---|
| | | async_log_util.info(logger_kpl_block_can_buy, |
|---|
| | | f"{code}:获取到板块(激进买) 过滤前-{blocks} 耗时:{int(time.time() - start_time)}s") |
|---|
| | | self.save_jx_blocks_for_radical_buy(code, list(blocks)) |
|---|
| | | self.load_jx_blocks_radical(code) |
|---|
| | | except Exception as e: |
|---|
| | | logger_kpl_block_can_buy.error(f"{code} 获取板块出错") |
|---|
| | | logger_kpl_block_can_buy.exception(e) |
|---|
| | | |
|---|
| | | def load_jx_blocks_radical(self, code): |
|---|
| | | start_time = time.time() |
|---|
| | | blocks = kpl_api.getCodeJingXuanBlocks(code, jx=False) |
|---|
| | | blocks = set([b[1] for b in blocks]) |
|---|
| | | # fblocks = BlockMapManager().filter_blocks(blocks) |
|---|
| | | async_log_util.info(logger_kpl_block_can_buy, |
|---|
| | | f"{code}:获取到板块(激进买) 过滤前-{blocks} 耗时:{int(time.time() - start_time)}s") |
|---|
| | | self.save_jx_blocks_for_radical_buy(code, list(blocks)) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 禁止下单的板块 |
|---|
| | | class ForbiddenBlockManager: |
|---|
