package com.xiaopeng.operation.job.jobs;
|
|
import com.xiaopeng.api.model.operation.XpSystemSetting;
|
import com.xiaopeng.api.model.order.XpOrder;
|
import com.xiaopeng.api.model.vehicleConvoy.XpVehicle;
|
import com.xiaopeng.api.vo.HotFixInfoVo;
|
import com.xiaopeng.api.vo.vehicleConvoy.CancelTaxiPassengerVo;
|
import com.xiaopeng.operation.job.base.AbstractJob;
|
import lombok.extern.slf4j.Slf4j;
|
import org.quartz.JobDataMap;
|
import org.quartz.JobExecutionContext;
|
import org.quartz.JobExecutionException;
|
|
/**
|
* 推送定时任务
|
* @author Administrator
|
*
|
*/
|
@Slf4j
|
public class HotFixJob extends AbstractJob {
|
|
public static final String name = "hot_fix";
|
|
@Override
|
public void execute(JobExecutionContext context)
|
throws JobExecutionException {
|
XpSystemSetting xpSystemSetting = xpSystemSettingService.lambdaQuery().last("limit 1").one();
|
xpSystemSetting.setHotfixStatus(0);
|
xpSystemSettingService.updateById(xpSystemSetting);
|
|
//保存热修复信息到redis
|
HotFixInfoVo hotFixInfoVo = new HotFixInfoVo();
|
hotFixInfoVo.setHotfixStatus(xpSystemSetting.getHotfixStatus() == null ? 0 : xpSystemSetting.getHotfixStatus());
|
hotFixInfoVo.setHotfixStartTime(xpSystemSetting.getHotfixStartTime());
|
hotFixInfoVo.setHotfixEndTime(xpSystemSetting.getHotfixEndTime());
|
redisService.setCacheObject("HOT_FIX_INFO", hotFixInfoVo);
|
|
}
|
|
}
|
