package com.xiaopeng.order.job.base;
|
|
import com.xiaopeng.api.feignClient.automaticPilot.OrderMissionClient;
|
import com.xiaopeng.api.feignClient.pushMessage.XpPushMessageClient;
|
import com.xiaopeng.api.feignClient.vehicleConvoy.UserVehicleClient;
|
import com.xiaopeng.api.feignClient.vehicleConvoy.XpVehicleClient;
|
import com.xiaopeng.api.model.order.XpCruiseOrder;
|
import com.xiaopeng.order.service.IXpCruiseOrderService;
|
import com.xiaopeng.order.service.IXpOrderService;
|
import com.xiaopeng.order.job.utils.SpringContextsUtil;
|
import com.xiaopeng.order.service.XpOrderTimeoutLogService;
|
import org.quartz.Job;
|
import org.quartz.JobExecutionContext;
|
import org.quartz.JobExecutionException;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
public abstract class AbstractJob implements Job {
|
protected Logger logger = LoggerFactory.getLogger(getClass());
|
|
@Override
|
public abstract void execute(JobExecutionContext context) throws JobExecutionException;
|
|
protected IXpOrderService xpOrderService;
|
protected XpPushMessageClient xpPushMessageClient;
|
protected XpOrderTimeoutLogService xpOrderTimeoutLogService;
|
protected IXpCruiseOrderService xpCruiseOrderService;
|
protected OrderMissionClient orderMissionClient;
|
protected XpVehicleClient xpVehicleClient;
|
protected UserVehicleClient userVehicleClient;
|
public AbstractJob(){
|
this.xpOrderService = SpringContextsUtil.getBean(IXpOrderService.class);
|
this.xpPushMessageClient = SpringContextsUtil.getBean(XpPushMessageClient.class);
|
this.xpOrderTimeoutLogService = SpringContextsUtil.getBean(XpOrderTimeoutLogService.class);
|
this.xpCruiseOrderService = SpringContextsUtil.getBean(IXpCruiseOrderService.class);
|
this.orderMissionClient = SpringContextsUtil.getBean(OrderMissionClient.class);
|
this.xpVehicleClient = SpringContextsUtil.getBean(XpVehicleClient.class);
|
this.userVehicleClient = SpringContextsUtil.getBean(UserVehicleClient.class);
|
}
|
|
|
}
|
