|  |  |  | 
|---|
|  |  |  | package com.matrix.system.job; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.matrix.core.tools.LogUtil; | 
|---|
|  |  |  | import com.matrix.system.constance.Dictionary; | 
|---|
|  |  |  | import com.matrix.system.hive.bean.MoneyCardUse; | 
|---|
|  |  |  | import com.matrix.system.hive.bean.SysProjUse; | 
|---|
|  |  |  | import com.matrix.system.hive.dao.MoneyCardUseDao; | 
|---|
|  |  |  | import com.matrix.system.hive.dao.ShoppingGoodsDao; | 
|---|
|  |  |  | import com.matrix.system.hive.dao.SysProjUseDao; | 
|---|
|  |  |  | import com.matrix.system.hive.plugin.util.CollectionUtils; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | import org.springframework.scheduling.annotation.Scheduled; | 
|---|
|  |  |  | import org.springframework.stereotype.Component; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.util.List; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * @author wzy19 | 
|---|
|  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private MoneyCardUseDao moneyCardUseDao; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private ShoppingGoodsDao shoppingGoodsDao; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Scheduled(cron = "0 0 0 * * ?") | 
|---|
|  |  |  | public void setProjUseToInvalid() { | 
|---|
|  |  |  | LogUtil.info("#项目,套餐失效任务处理#"); | 
|---|
|  |  |  | List<SysProjUse> sysProjUses = sysProjUseDao.selectHasValidProjUse(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | List<MoneyCardUse> moneyCardUses = moneyCardUseDao.selectHasValidMoneyCardUse(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (CollectionUtils.isNotEmpty(sysProjUses)) { | 
|---|
|  |  |  | sysProjUses.forEach(item -> { | 
|---|
|  |  |  | item.setStatus(Dictionary.MONEYCARD_STATUS_WX); | 
|---|
|  |  |  | sysProjUseDao.update(item); | 
|---|
|  |  |  | }); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (CollectionUtils.isNotEmpty(moneyCardUses)) { | 
|---|
|  |  |  | moneyCardUses.forEach(item -> { | 
|---|
|  |  |  | item.setStatus(Dictionary.MONEYCARD_STATUS_WX); | 
|---|
|  |  |  | moneyCardUseDao.update(item); | 
|---|
|  |  |  | }); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | sysProjUseDao.updateInvalidProjUse(); | 
|---|
|  |  |  | moneyCardUseDao.updateInvalidMoneyCardUse(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Scheduled(cron = "0 0 0 * * ?") | 
|---|
|  |  |  | public void setProductAutoSoldOut() { | 
|---|
|  |  |  | LogUtil.info("#商品自动下架任务处理#"); | 
|---|
|  |  |  | shoppingGoodsDao.updateInvalidProduct(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|