Redis实现订单过期删除的方法步骤_Redis_

import com.coolplay.trade.dto.req.CancelOrderReq; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections.CollectionUtils; import org.springframework.data.redis.core.ZSetOperations; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.util.Set; import java.util.concurrent.TimeUnit; @Service @Slf4j public class OrderRedisDelayQueueOperator extends AbstractOrderScheduleDelayQueue {     @Resource(name = "redisTemplate")     private ZSetOperations orderRedis;     /**      * 预售、现货生成订单15分钟后未支付，需要取消订单      */     private static final String DELAY_QUEUE_NAME = "order";     /**      * 每1秒执行一次      */     @Override     @Scheduled(cron = "0/1 * * * * ? ")     public void orderEventProcess() {         if (!redisLock.tryLock(this.getClass().getSimpleName(), TimeUnit.MILLISECONDS, 10, 100)) {             return;         }         Set dq = orderRedis.range(DELAY_QUEUE_NAME, 0L, Long.MAX_VALUE);         if (CollectionUtils.isEmpty(dq)) {             return;         }         for (String orderNo : dq) {             Double xs = orderRedis.score(DELAY_QUEUE_NAME, orderNo);             Double now = System.currentTimeMillis() * 1.0;             if (xs <= now) {                 log.info("{} timed out", orderNo);                 super.threadPoolTaskExecutor.execute(() -> {                     CancelOrderReq req = new CancelOrderReq();                     req.setOrderNo(orderNo);                     req.setCancelType(OrderActionEnum.TIME_OUT_CANCEL);                     orderService.cancelOrder(req);                 });             } else {                 //log.info("{} no time out", orderNo);                 //如果最小的都没有过期，剩余的则不用处理了                 break;             }         }     }     public void addToRedis(String orderNo, long delayTime) {         orderRedis.add(DELAY_QUEUE_NAME, orderNo, delayTime * 1.0);     }     public void removeFromRedis(String orderNo) {         orderRedis.remove(DELAY_QUEUE_NAME, orderNo);     } }

/**      * 取消订单--10分钟--20分钟执行一次      */     @XxlJob("cancelOrder20Minutes")     public void cancelOrderTenMinutes() {         log.info("*****[开始：下单十分钟以后系统自动取消订单]*****");         Date start = DateUtil.dateRoll(new Date(), Calendar.MINUTE,-20);         Date end = new Date();        List clorderList =clOrderMapper.selectListAllOrdrWaiting(start,end);        if(ObjectUtil.isNotEmpty(clorderList)){            for(int i=0;i10){                        ClOrder clOrderTemp = new ClOrder();                        clOrderTemp.setOrderState("3");                        clOrderTemp.setId(clOrder.getId());                        clOrderTemp.setMemberId(clOrder.getMemberId());                        String msg="您的订单已经取消，订单金额已发放至您的账户请查收~";                        try {                            boolean b = orderService.cancelOrder(clOrderTemp,msg);                            if(!b){                                log.info("[订单失效：定时任务兜底策略更新失败]**订单ID: {}",clOrderTemp.getId());                            }                            log.info("[Redis订单取消订单失效，定时任务兜底策略生效]");                        }catch (Exception e){                            log.info("[订单失效：定时任务兜底策略更新失败]**订单ID: {}",clOrderTemp.getId());                            e.printStackTrace();                        }                    }                }            }        }         log.info("*****[结束：下单十分钟以后系统自动取消订单]*****");     }