| | |
| | | _volumn = global_util.today_volumn.get(code) |
| | | if _volumn is None: |
| | | _volumn = RedisUtils.get(self.__redis_manager.getRedis(), "volumn_today-{}".format(code)) |
| | | return _volumn |
| | | return int(_volumn) |
| | | |
| | | # 获取今日量 |
| | | def get_today_volumn_cache(self, code): |
| | |
| | | cancel_type = trade_constant.CANCEL_TYPE_J |
| | | |
| | | if cancel_data and not DCancelBigNumComputer().has_auto_cancel_rules(code): |
| | | l2_log.debug(code, "触发撤单,撤单位置:{} ,撤单原因:{}", cancel_data["index"], cancel_msg) |
| | | # 撤单 |
| | | cls.cancel_buy(code, cancel_msg, cancel_index=cancel_data["index"], cancel_type=cancel_type) |
| | | # 撤单成功,继续计算下单 |
| | | cls.__process_not_order(code, cancel_data["index"] + 1, end_index, capture_time, is_first_code) |
| | | try: |
| | | # 撤单 |
| | | cls.cancel_buy(code, cancel_msg, cancel_index=cancel_data["index"], cancel_type=cancel_type) |
| | | # 撤单成功,继续计算下单 |
| | | cls.__process_not_order(code, cancel_data["index"] + 1, end_index, capture_time, is_first_code) |
| | | finally: |
| | | l2_log.debug(code, "触发撤单,撤单位置:{} ,撤单原因:{}, 下单模式:{}", cancel_data["index"], cancel_msg, |
| | | f"{order_begin_pos.mode}") |
| | | else: |
| | | pass |
| | | |