| | |
|---|
| | | |
|---|
| | | import com.ruoyi.common.core.enums.ListingStatusEnum; |
|---|
| | | import com.ruoyi.common.core.enums.StartStatusEnum; |
|---|
| | | import com.ruoyi.common.core.utils.StringUtils; |
|---|
| | | import com.ruoyi.goods.domain.GoodsGroupPurchase; |
|---|
| | | import com.ruoyi.goods.service.IGoodsGroupPurchaseService; |
|---|
| | | import com.ruoyi.goods.service.IGoodsSeckillService; |
|---|
| | |
|---|
| | | .eq(GoodsSeckill::getStartStatus, StartStatusEnum.NOT_STARTED) |
|---|
| | | .le(GoodsSeckill::getStartTime, checkTime) |
|---|
| | | .list(); |
|---|
| | | for (GoodsSeckill goodsSeckill : list) { |
|---|
| | | asyncMethodService.seckillScheduleTask(goodsSeckill); |
|---|
| | | if (StringUtils.isNotEmpty(list)) { |
|---|
| | | asyncMethodService.seckillScheduleTask(list); |
|---|
| | | } |
|---|
| | | List<GoodsGroupPurchase> groupPurchaseList = goodsGroupPurchaseService.lambdaQuery() |
|---|
| | | .eq(GoodsGroupPurchase::getListingStatus, ListingStatusEnum.ON_SHELVES) |
|---|
| | | .eq(GoodsGroupPurchase::getStartStatus, StartStatusEnum.NOT_STARTED) |
|---|
| | | .le(GoodsGroupPurchase::getStartTime, checkTime).list(); |
|---|
| | | for (GoodsGroupPurchase goodsGroupPurchase : groupPurchaseList) { |
|---|
| | | asyncMethodService.groupPurchaseScheduleTask(goodsGroupPurchase); |
|---|
| | | if (StringUtils.isNotEmpty(groupPurchaseList)) { |
|---|
| | | asyncMethodService.groupPurchaseScheduleTask(groupPurchaseList); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
