|
@ -1,10 +1,14 @@ |
|
|
package com.qs.serve.task; |
|
|
package com.qs.serve.task; |
|
|
|
|
|
|
|
|
|
|
|
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; |
|
|
|
|
|
import com.qs.serve.common.util.CollectionUtil; |
|
|
import com.qs.serve.modules.tbs.common.TbsActivityState; |
|
|
import com.qs.serve.modules.tbs.common.TbsActivityState; |
|
|
import com.qs.serve.modules.tbs.entity.TbsActivity; |
|
|
import com.qs.serve.modules.tbs.entity.TbsActivity; |
|
|
|
|
|
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 lombok.AllArgsConstructor; |
|
|
import lombok.AllArgsConstructor; |
|
|
import org.springframework.stereotype.Component; |
|
|
import org.springframework.stereotype.Component; |
|
|
|
|
|
|
|
@ -19,6 +23,7 @@ import java.time.LocalDateTime; |
|
|
public class TbsTask { |
|
|
public class TbsTask { |
|
|
|
|
|
|
|
|
private final TbsActivityService activityService; |
|
|
private final TbsActivityService activityService; |
|
|
|
|
|
private final TbsActivityTemplateService activityTemplateService; |
|
|
|
|
|
|
|
|
//todo 每日更新过期的活动,过期则进行冻结
|
|
|
//todo 每日更新过期的活动,过期则进行冻结
|
|
|
public void task1(){ |
|
|
public void task1(){ |
|
@ -31,5 +36,35 @@ public class TbsTask { |
|
|
activityService.update(param,lqw); |
|
|
activityService.update(param,lqw); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//todo 启用和停用模板规则
|
|
|
|
|
|
public void task2(){ |
|
|
|
|
|
AuthContextUtils.setTenant("001"); |
|
|
|
|
|
LocalDateTime nowTime = LocalDateTime.now(); |
|
|
|
|
|
LambdaQueryWrapper<TbsActivityTemplate> lqw = new LambdaQueryWrapper<>(); |
|
|
|
|
|
lqw.select(TbsActivityTemplate::getId); |
|
|
|
|
|
lqw.ge(TbsActivityTemplate::getStartTime,nowTime.with(LocalDateTime.MIN)); |
|
|
|
|
|
lqw.le(TbsActivityTemplate::getStartTime,nowTime.with(LocalDateTime.MAX)); |
|
|
|
|
|
lqw.eq(TbsActivityTemplate::getTemplateState,0); |
|
|
|
|
|
List<TbsActivityTemplate> preStartList = activityTemplateService.list(lqw); |
|
|
|
|
|
if(CollectionUtil.isNotEmpty(preStartList)){ |
|
|
|
|
|
preStartList.forEach(a->a.setTemplateState(1)); |
|
|
|
|
|
activityTemplateService.updateBatchById(preStartList); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
LambdaQueryWrapper<TbsActivityTemplate> lqw2 = new LambdaQueryWrapper<>(); |
|
|
|
|
|
lqw2.select(TbsActivityTemplate::getId); |
|
|
|
|
|
lqw2.ge(TbsActivityTemplate::getEndTime,nowTime.with(LocalDateTime.MIN)); |
|
|
|
|
|
lqw2.le(TbsActivityTemplate::getEndTime,nowTime.with(LocalDateTime.MAX)); |
|
|
|
|
|
lqw2.eq(TbsActivityTemplate::getTemplateState,1); |
|
|
|
|
|
List<TbsActivityTemplate> preCloseList = activityTemplateService.list(lqw2); |
|
|
|
|
|
if(CollectionUtil.isNotEmpty(preCloseList)){ |
|
|
|
|
|
preCloseList.forEach(a->a.setTemplateState(0)); |
|
|
|
|
|
activityTemplateService.updateBatchById(preCloseList); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|