| | |
| | | package com.ruoyi.system.listener; |
| | | |
| | | |
| | | import com.ruoyi.common.core.constant.SecurityConstants; |
| | | import com.ruoyi.common.core.utils.DateUtils; |
| | | import com.ruoyi.common.core.utils.StringUtils; |
| | | import com.ruoyi.system.api.constants.DelayTaskEnum; |
| | |
| | | @Async |
| | | public void autoStartSeckill(Long seckillId) { |
| | | log.info("autoStartSeckill scheduler task is running :{}", seckillId); |
| | | goodsSkuClient.startSeckill(seckillId); |
| | | goodsSkuClient.startSeckill(seckillId, SecurityConstants.INNER); |
| | | |
| | | } |
| | | |
| | | @Async |
| | | public void autoEndSeckill(Long seckillId) { |
| | | log.info("autoEndSeckill scheduler task is running :{}", seckillId); |
| | | goodsSkuClient.endSeckill(seckillId); |
| | | goodsSkuClient.endSeckill(seckillId, SecurityConstants.INNER); |
| | | } |
| | | |
| | | @Async |
| | | public void autoStartGroupPurchase(Long GroupPurchaseId) { |
| | | log.info("autoStartGroupPurchase scheduler task is running :{}", GroupPurchaseId); |
| | | goodsSkuClient.startGroupPurchase(GroupPurchaseId); |
| | | goodsSkuClient.startGroupPurchase(GroupPurchaseId, SecurityConstants.INNER); |
| | | } |
| | | |
| | | @Async |
| | | public void autoEndGroupPurchase(Long GroupPurchaseId) { |
| | | log.info("autoEndGroupPurchase scheduler task is running :{}", GroupPurchaseId); |
| | | goodsSkuClient.endGroupPurchase(GroupPurchaseId); |
| | | goodsSkuClient.endGroupPurchase(GroupPurchaseId, SecurityConstants.INNER); |
| | | } |
| | | |
| | | @Async |