| | |
|---|
| | | for k in keys: |
|---|
| | | RedisUtils.delete(redis_l2, k.format(code), auto_free=False) |
|---|
| | | RedisUtils.realse(redis_l2) |
|---|
| | | l2.l2_data_manager.TradePointManager.delete_buy_point(code) |
|---|
| | | l2.l2_data_manager.TradePointManager().delete_buy_point(code) |
|---|
| | | big_money_num_manager.reset(code) |
|---|
| | | RedisUtils.delete( redis_manager.RedisManager(2).getRedis(), "trade-state-{}".format(code)) |
|---|
| | | trade_data_manager.PlaceOrderCountManager.clear_place_order_count(code) |
|---|
| | | trade_data_manager.PlaceOrderCountManager().clear_place_order_count(code) |
|---|
| | | redis_info = redis_manager.RedisManager(0).getRedis() |
|---|
| | | keys = RedisUtils.keys(redis_info, "*{}*".format(code), auto_free=False) |
|---|
| | | for k in keys: |
|---|
| | |
|---|
| | | decimal.Decimal("0.00")) |
|---|
| | | # 获取执行位时间 |
|---|
| | | exec_time = None |
|---|
| | | buy_single_index, buy_exec_index, compute_index, num, count, max_num_set, volume_rate = l2_data_manager.TradePointManager.get_buy_compute_start_data( |
|---|
| | | buy_single_index, buy_exec_index, compute_index, num, count, max_num_set, volume_rate = l2_data_manager.TradePointManager().get_buy_compute_start_data( |
|---|
| | | code) |
|---|
| | | if buy_exec_index: |
|---|
| | | try: |
|---|
| | |
|---|
| | | time_s = tool.get_time_as_second(time_) - i - 1 |
|---|
| | | volumn = THSBuy1VolumnManager().get_buy_1_volumn(code, tool.time_seconds_format(time_s)) |
|---|
| | | if volumn is not None: |
|---|
| | | l2.cancel_buy_strategy.L2LimitUpMoneyStatisticUtil.verify_num(code, int(volumn), |
|---|
| | | tool.time_seconds_format(time_s)) |
|---|
| | | l2.cancel_buy_strategy.L2LimitUpMoneyStatisticUtil().verify_num(code, int(volumn), tool.time_seconds_format(time_s)) |
|---|
| | | break |
|---|
| | | # 设置委买队列 |
|---|
| | | for i in range(0, len(buy_queues)): |
|---|
| | |
|---|
| | | # L2LimitUpMoneyStatisticUtil.process_data(code, buy_single_index, buy_exec_index, buy_single_index, |
|---|
| | | # buy_exec_index, False) |
|---|
| | | # |
|---|
| | | # l2_data_manager.TradePointManager.get_buy_compute_start_data = mock.Mock(return_value=(426, 479, 479, 0, 100)) |
|---|
| | | # buy_single_index, buy_exec_index, compute_index, num, count = l2_data_manager.TradePointManager.get_buy_compute_start_data( |
|---|
| | | # l2_data_manager.TradePointManager().get_buy_compute_start_data = mock.Mock(return_value=(426, 479, 479, 0, 100)) |
|---|
| | | # buy_single_index, buy_exec_index, compute_index, num, count = l2_data_manager.TradePointManager().get_buy_compute_start_data( |
|---|
| | | # code) |
|---|
| | | # processor.unreal_buy_dict[code] = mock.Mock(return_value=(479, 167234623)) |
|---|
| | | # |
|---|
