| | |
| | | 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; |
| | |
| | | private RedisTemplate<String, Object> redisTemplate; |
| | | @Resource |
| | | private GoodsSkuClient goodsSkuClient; |
| | | |
| | | @Resource |
| | | private OrderClient orderClient; |
| | | @Resource |
| | | private AuctionClient auctionClient; |
| | | public RedisListener(RedisMessageListenerContainer listenerContainer, |
| | |
| | | }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); |
| | |
| | | } |
| | | |
| | | @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); |
| | | } |