mitao
2025-03-14 392b42c4891cf2e6beda57ab32c51598f290f4b7
ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/listener/RedisListener.java
@@ -7,6 +7,7 @@
import com.ruoyi.system.api.constants.DelayTaskEnum;
import com.ruoyi.system.api.feignClient.AuctionClient;
import com.ruoyi.system.api.feignClient.GoodsSkuClient;
import com.ruoyi.system.api.feignClient.OrderClient;
import java.util.Date;
import javax.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
@@ -30,6 +31,9 @@
    private RedisTemplate<String, Object> redisTemplate;
    @Resource
    private GoodsSkuClient goodsSkuClient;
    @Resource
    private OrderClient orderClient;
    @Resource
    private AuctionClient auctionClient;
    public RedisListener(RedisMessageListenerContainer listenerContainer,
@@ -72,6 +76,9 @@
                    }else if(DelayTaskEnum.ORDER_AUTOMATIC_CANCEL.getCode().equals(operation)){
                        //自动取消订单
                        autoCancelOrder(id);
                    }
                    else if(DelayTaskEnum.AUTOMATIC_CANCEL.getCode().equals(operation)){
                        tusonUser(id);
                    }
                    //删除失效的key
                    redisTemplate.delete(expiredKey);
@@ -132,6 +139,17 @@
    }
    @Async
    public void orderClient(Long oid) {
        log.info("autoEndGroupPurchase scheduler task is running :{}", oid);
        orderClient.autoCancelOrder(oid, SecurityConstants.INNER);
    }
    @Async
    public void tusonUser(Long tusonUserIdId) {
        goodsSkuClient.tusonUser(tusonUserIdId, SecurityConstants.INNER);
    }
    @Async
    public void autoCancelOrder(Long orderId) {
        log.info("autoCancelOrder scheduler task is running :{}", orderId);
    }