计算机毕业设计-CRMEB-Java版商城系统-task.zip

package com.zbkj.admin.task.product; import com.zbkj.common.utils.DateUtil; import com.zbkj.service.service.StoreBargainService; import com.zbkj.service.service.StoreCombinationService; import com.zbkj.service.service.StoreProductService; import com.zbkj.service.service.StoreSeckillService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; /** 操作商品库存 * +---------------------------------------------------------------------- * | CRMEB [ CRMEB赋能开发者，助力企业发展 ] * +---------------------------------------------------------------------- * | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved. * +---------------------------------------------------------------------- * | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权 * +---------------------------------------------------------------------- * | Author: CRMEB Team <[email protected]> * +---------------------------------------------------------------------- */ @Component @Configuration //读取配置 @EnableScheduling // 2.开启定时任务 public class ProductStockTask { //日志 private static final Logger logger = LoggerFactory.getLogger(ProductStockTask.class); @Autowired private StoreProductService storeProductService; @Autowired private StoreSeckillService storeSeckillService; @Autowired private StoreBargainService storeBargainService; @Autowired private StoreCombinationService storeCombinationService; @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 public void init(){ logger.info("---OrderTakeByUser task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); try { storeProductService.consumeProductStock(); // 商品本身库存任务 storeSeckillService.consumeProductStock(); // 秒杀本身库存任务 storeBargainService.consumeProductStock(); // 砍价本身库存任务 storeCombinationService.consumeProductStock(); // 拼团本身库存任务 } catch (Exception e) { e.printStackTrace(); logger.error("OrderTakeByUser.task" + " | msg : " + e.getMessage()); } } }