|
@ -1,5 +1,6 @@ |
|
|
package com.qs.serve.task; |
|
|
package com.qs.serve.task; |
|
|
|
|
|
|
|
|
|
|
|
import java.time.LocalDate; |
|
|
import java.util.List; |
|
|
import java.util.List; |
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|
|
import com.qs.serve.common.util.AuthContextUtils; |
|
|
import com.qs.serve.common.util.AuthContextUtils; |
|
@ -10,6 +11,8 @@ import com.qs.serve.modules.tbs.entity.TbsActivityTemplate; |
|
|
import com.qs.serve.modules.tbs.service.TbsActivityService; |
|
|
import com.qs.serve.modules.tbs.service.TbsActivityService; |
|
|
import com.qs.serve.modules.tbs.service.TbsActivityTemplateService; |
|
|
import com.qs.serve.modules.tbs.service.TbsActivityTemplateService; |
|
|
import lombok.AllArgsConstructor; |
|
|
import lombok.AllArgsConstructor; |
|
|
|
|
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; |
|
|
|
|
|
import org.springframework.scheduling.annotation.Scheduled; |
|
|
import org.springframework.stereotype.Component; |
|
|
import org.springframework.stereotype.Component; |
|
|
|
|
|
|
|
|
import java.time.LocalDateTime; |
|
|
import java.time.LocalDateTime; |
|
@ -20,24 +23,27 @@ import java.time.LocalDateTime; |
|
|
*/ |
|
|
*/ |
|
|
@Component |
|
|
@Component |
|
|
@AllArgsConstructor |
|
|
@AllArgsConstructor |
|
|
|
|
|
@ConditionalOnProperty(value = "project.task", havingValue = "true") |
|
|
public class TbsTask { |
|
|
public class TbsTask { |
|
|
|
|
|
|
|
|
private final TbsActivityService activityService; |
|
|
private final TbsActivityService activityService; |
|
|
private final TbsActivityTemplateService activityTemplateService; |
|
|
private final TbsActivityTemplateService activityTemplateService; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//todo 每日更新过期的活动,过期则进行冻结
|
|
|
//每日更新过期的活动,过期则进行冻结
|
|
|
|
|
|
@Scheduled(cron="0 0 9 * * ?") |
|
|
public void task1(){ |
|
|
public void task1(){ |
|
|
AuthContextUtils.setTenant("001"); |
|
|
AuthContextUtils.setTenant("001"); |
|
|
LambdaQueryWrapper<TbsActivity> lqw = new LambdaQueryWrapper<>(); |
|
|
LambdaQueryWrapper<TbsActivity> lqw = new LambdaQueryWrapper<>(); |
|
|
lqw.le(TbsActivity::getPreEndDate, LocalDateTime.now()); |
|
|
lqw.le(TbsActivity::getPreEndDate, LocalDate.now()); |
|
|
lqw.eq(TbsActivity::getReopenFlag,0); |
|
|
lqw.eq(TbsActivity::getReopenFlag,0); |
|
|
TbsActivity param = new TbsActivity(); |
|
|
TbsActivity param = new TbsActivity(); |
|
|
param.setActivityState(TbsActivityState.STATE_1_Baning); |
|
|
param.setActivityState(TbsActivityState.STATE_1_Baning); |
|
|
activityService.update(param,lqw); |
|
|
activityService.update(param,lqw); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
//todo 启用和停用模板规则
|
|
|
//启用和停用模板规则
|
|
|
|
|
|
@Scheduled(cron="0 0 9 * * ?") |
|
|
public void task2(){ |
|
|
public void task2(){ |
|
|
AuthContextUtils.setTenant("001"); |
|
|
AuthContextUtils.setTenant("001"); |
|
|
LocalDateTime nowTime = LocalDateTime.now(); |
|
|
LocalDateTime nowTime = LocalDateTime.now(); |
|
|