12.10

luodangjia

2024-12-10 31ce6be2d56798d9509e6d90335999064351f7f3

 ManagementNTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/TaskUtil.java

@@ -2,7 +2,9 @@


import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.stylefeng.guns.modular.system.model.TActivityGeneralization;
import com.stylefeng.guns.modular.system.model.TDriver;
import com.stylefeng.guns.modular.system.service.ITActivityGeneralizationService;
import com.stylefeng.guns.modular.system.service.ITDriverService;
import com.stylefeng.guns.modular.system.service.ITLocationService;
import com.stylefeng.guns.modular.system.service.IUserCouponRecordService;
@@ -11,6 +13,7 @@
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;


@@ -32,7 +35,8 @@
    @Autowired
    private ITDriverService driverService;


    @Autowired
    private ITActivityGeneralizationService activityGeneralizationService;

    /**
     * 每隔一分钟去处理的定时任务
@@ -40,6 +44,25 @@
    @Scheduled(fixedRate = 1000 * 60)
    public void taskMinute(){
        try {
            Date date = new Date();

            List<TActivityGeneralization> tActivityGeneralizations = activityGeneralizationService.selectList(null);
            for (TActivityGeneralization tActivityGeneralization : tActivityGeneralizations) {
                if (tActivityGeneralization.getState()!=4){
                    if (tActivityGeneralization.getStartTime().before(date)){
                        tActivityGeneralization.setState(2);
                    }
                    if (date.after(tActivityGeneralization.getStartTime()) && date.before(tActivityGeneralization.getEndTime())){
                        tActivityGeneralization.setState(1);
                    }
                    if (date.after(tActivityGeneralization.getEndTime())){
                        tActivityGeneralization.setState(3);
                    }
                }
            }
            activityGeneralizationService.updateBatchById(tActivityGeneralizations);


        } catch (Exception e) {
            e.printStackTrace();
        }