From 01d6fa48a0de7a21988e89f71721b6b85e53b517 Mon Sep 17 00:00:00 2001 From: mitao <2763622819@qq.com> Date: 星期四, 06 三月 2025 16:33:53 +0800 Subject: [PATCH] 去掉资讯图片必填限制 --- ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/task/GoodsScheduler.java | 21 +++++++++++++-------- 1 files changed, 13 insertions(+), 8 deletions(-) diff --git a/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/task/GoodsScheduler.java b/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/task/GoodsScheduler.java index 85603d1..a4b5749 100644 --- a/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/task/GoodsScheduler.java +++ b/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/task/GoodsScheduler.java @@ -1,11 +1,11 @@ package com.ruoyi.goods.task; -import com.ruoyi.common.core.enums.ListingStatusEnum; import com.ruoyi.common.core.enums.StartStatusEnum; -import com.ruoyi.goods.domain.GoodsGroupPurchase; +import com.ruoyi.common.core.utils.StringUtils; import com.ruoyi.goods.service.IGoodsGroupPurchaseService; import com.ruoyi.goods.service.IGoodsSeckillService; import com.ruoyi.goods.service.async.AsyncMethodService; +import com.ruoyi.system.api.domain.GoodsGroupPurchase; import com.ruoyi.system.api.domain.GoodsSeckill; import java.time.LocalDateTime; import java.util.List; @@ -36,19 +36,24 @@ log.info(">>>>>>>>>>>>>>>>>>>>定时任务秒杀/团购开始执行<<<<<<<<<<<<<<<<<<<<"); LocalDateTime checkTime = LocalDateTime.now().plusHours(1); List<GoodsSeckill> list = goodsSeckillService.lambdaQuery() - .eq(GoodsSeckill::getListingStatus, ListingStatusEnum.ON_SHELVES) .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); } } + + // 每天凌晨执行 + @Scheduled(cron = "0 0 0 * * ?") + private void timingTaskEnd() { + log.info(">>>>>>>>>>>>>>>>>>>>结束异常秒杀任务<<<<<<<<<<<<<<<<<<<<"); + goodsSeckillService.updSeckillStatus(); + } } -- Gitblit v1.7.1