package com.stylefeng.guns.modular.crossCity.server.impl;
|
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
import com.stylefeng.guns.modular.crossCity.dao.LinePriceMapper;
|
import com.stylefeng.guns.modular.crossCity.dao.LineShiftDriverMapper;
|
import com.stylefeng.guns.modular.crossCity.dao.LineShiftMapper;
|
import com.stylefeng.guns.modular.crossCity.model.LineShift;
|
import com.stylefeng.guns.modular.crossCity.model.LineShiftDriver;
|
import com.stylefeng.guns.modular.crossCity.model.OrderCrossCity;
|
import com.stylefeng.guns.modular.crossCity.server.ILineService;
|
import com.stylefeng.guns.modular.crossCity.server.ILineShiftDriverService;
|
import com.stylefeng.guns.modular.crossCity.server.ILineSiteService;
|
import com.stylefeng.guns.modular.crossCity.server.IOrderCrossCityService;
|
import com.stylefeng.guns.modular.system.dao.CarModelMapper;
|
import com.stylefeng.guns.modular.system.dao.CarServiceMapper;
|
import com.stylefeng.guns.modular.system.dao.ServerCarModelMapper;
|
import com.stylefeng.guns.modular.system.model.CarModel;
|
import com.stylefeng.guns.modular.system.model.CarService;
|
import com.stylefeng.guns.modular.system.service.ICarService;
|
import com.stylefeng.guns.modular.system.service.IDriverService;
|
import com.stylefeng.guns.modular.system.util.DateUtil;
|
import com.stylefeng.guns.modular.system.util.ResultUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
|
@Service
|
public class LineShiftDriverServiceImpl extends ServiceImpl<LineShiftDriverMapper, LineShiftDriver> implements ILineShiftDriverService {
|
|
@Resource
|
private LineShiftDriverMapper lineShiftDriverMapper;
|
|
@Autowired
|
private DateUtil dateUtil;
|
|
@Autowired
|
private ICarService carService;
|
|
@Autowired
|
private IDriverService driverService;
|
|
@Resource
|
private CarModelMapper carModelMapper;
|
|
@Resource
|
private LineShiftMapper lineShiftMapper;
|
|
@Resource
|
private LinePriceMapper linePriceMapper;
|
|
@Resource
|
private CarServiceMapper carServiceMapper;
|
|
@Autowired
|
private IOrderCrossCityService orderCrossCityService;
|
|
@Autowired
|
private ILineService lineService;
|
|
|
|
/**
|
* 预约班次操作
|
* @param lineShiftId
|
* @param time
|
* @param driverId
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public synchronized ResultUtil reservation(Integer type, Integer lineShiftId, String time, Integer driverId) throws Exception {
|
Map<String, Date> date = dateUtil.getStartAndEndDate(time);
|
List<LineShiftDriver> startTime = lineShiftDriverMapper.queryByDriver(lineShiftId, driverId, date.get("startTime"));
|
if(type == 1 && startTime.size() > 0){
|
return ResultUtil.error("不能重复预约");
|
}
|
if(type == 2 && startTime.size() == 0){
|
return ResultUtil.error("您还没预约呢");
|
}
|
if(type == 1){//预约操作
|
boolean b = this.judgeTime(driverId, lineShiftId, date.get("startTime"));
|
if(b){
|
return ResultUtil.error("预约间隔超出给定可预约范围");
|
}
|
int num = lineShiftDriverMapper.queryByDriver(lineShiftId, null, date.get("startTime")).size();
|
LineShift lineShift = lineShiftMapper.selectById(lineShiftId);
|
Integer carNum = lineShift.getCarNum();
|
if(num >= carNum){
|
return ResultUtil.error("该班次已经超出了可预约车次");
|
}
|
CarService query = carServiceMapper.query(3, driverService.selectById(driverId).getCarId());
|
Map<String, Object> query1 = linePriceMapper.query(lineShift.getLineId(), query.getServerCarModelId());
|
if(null == query1){
|
return ResultUtil.error("该线路还未设置服务车型相关数据，请联系管理员！");
|
}
|
CarModel carModel = carModelMapper.selectById(carService.selectById(driverService.selectById(driverId).getCarId()).getCarModelId());
|
LineShiftDriver lineShiftDriver = new LineShiftDriver();
|
lineShiftDriver.setLineShiftId(lineShiftId);
|
lineShiftDriver.setDriverId(driverId);
|
lineShiftDriver.setDay(date.get("startTime"));
|
lineShiftDriver.setLaveSeat(carModel.getSeat() - 1);
|
String seatNumber = "";
|
for(int i = 1; i < carModel.getSeat(); i++){
|
seatNumber += i + ",";
|
}
|
lineShiftDriver.setLaveSeatNumber(seatNumber.substring(0, seatNumber.length() - 1));
|
lineShiftDriver.setTotalSeat(carModel.getSeat() - 1);
|
lineShiftDriver.setInserTime(new Date());
|
lineShiftDriverMapper.insert(lineShiftDriver);
|
}
|
if(type == 2){//取消预约
|
Integer id = startTime.get(0).getId();
|
int i = orderCrossCityService.selectCount(
|
new EntityWrapper<OrderCrossCity>()
|
.eq("driverId", driverId)
|
.eq("lineShiftDriverId", id)
|
.eq("isDelete", 1)
|
.in("state", Arrays.asList(2, 3, 4, 5, 6, 7, 8, 9, 11))
|
);
|
if(i > 0){
|
return ResultUtil.error("班次已使用，不允许取消");
|
}
|
|
lineShiftDriverMapper.deleteById(id);
|
}
|
return ResultUtil.success();
|
}
|
|
|
|
/**
|
* 判断当前预约的班次时间与之前已经预约的班次时间的间隔是否大于设定的间隔时间
|
* @param driverId
|
* @param shiftId
|
* @param day
|
* @return
|
*/
|
public boolean judgeTime(Integer driverId, Integer shiftId, Date day) throws Exception{
|
//获取当前预约班次的开始时间
|
LineShift lineShift = lineShiftMapper.selectById(shiftId);
|
String startTime = lineShift.getStartTime();//需要预约的班次开始时间
|
String endTime1 = lineShift.getEndTime();//需要预约的班次结束时间
|
|
List<Integer> list = new ArrayList<>();//存储给定天的预约的班次
|
List<LineShiftDriver> lineShiftDrivers = lineShiftDriverMapper.queryByDriver(null, driverId, day);
|
for(LineShiftDriver lineShiftDriver : lineShiftDrivers){
|
list.add(lineShiftDriver.getLineShiftId());
|
}
|
|
if(list.size() == 0){
|
return false;
|
}
|
|
List<LineShift> lineShifts_ = lineShiftMapper.selectList(new EntityWrapper<LineShift>().eq("lineId", lineShift.getLineId()).eq("state", 1).orderBy("endTime"));
|
int index = 0;//需要预约的数据下标
|
for(int i = 0; i < lineShifts_.size(); i++){
|
if(startTime.equals(lineShifts_.get(i).getStartTime()) && endTime1.equals(lineShifts_.get(i).getEndTime())){
|
index = i;
|
break;
|
}
|
}
|
|
//找出预约数据最近的预约了的数据
|
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-DD HH:mm:ss");
|
Integer shiftInterval = lineService.selectById(lineShift.getLineId()).getShiftInterval();//获取可预约的间隔(分钟)
|
long time = simpleDateFormat.parse("1999-01-01 " + startTime + ":00").getTime();//当前预约的班次的开始时间
|
long time1 = simpleDateFormat.parse("1999-01-01 " + endTime1 + ":00").getTime();//当前预约的班次的结束时间
|
if(index == 0 && lineShifts_.size() > 1){
|
for(LineShift lineShift1 : lineShifts_){
|
if(list.contains(lineShift1.getId())){
|
long s = simpleDateFormat.parse("1999-01-01 " + lineShift1.getStartTime() + ":00").getTime();
|
long e = simpleDateFormat.parse("1999-01-01 " + lineShift1.getEndTime() + ":00").getTime();
|
if((s - time1) < (Long.valueOf(shiftInterval) * 60 * 1000)){
|
return true;
|
}
|
}
|
}
|
return false;
|
}
|
if(index == lineShifts_.size() - 1 && lineShifts_.size() > 1){
|
for(LineShift lineShift1 : lineShifts_){
|
if(list.contains(lineShift1.getId())){
|
long s = simpleDateFormat.parse("1999-01-01 " + lineShift1.getStartTime() + ":00").getTime();
|
long e = simpleDateFormat.parse("1999-01-01 " + lineShift1.getEndTime() + ":00").getTime();
|
if((time - e) < (Long.valueOf(shiftInterval) * 60 * 1000)){
|
return true;
|
}
|
}
|
}
|
return false;
|
}
|
if(index > 0 && index < lineShifts_.size() - 1 && lineShifts_.size() > 2){
|
for(int i = index + 1; i < lineShifts_.size(); i++){
|
if(list.contains(lineShifts_.get(i).getId())){
|
long s = simpleDateFormat.parse("1999-01-01 " + lineShifts_.get(i).getStartTime() + ":00").getTime();
|
long e = simpleDateFormat.parse("1999-01-01 " + lineShifts_.get(i).getEndTime() + ":00").getTime();
|
if((s - time1) < (Long.valueOf(shiftInterval) * 60 * 1000)){
|
return true;
|
}
|
}
|
}
|
for(int i = 0; i < index; i++){
|
if(list.contains(lineShifts_.get(i).getId())){
|
long s = simpleDateFormat.parse("1999-01-01 " + lineShifts_.get(i).getStartTime() + ":00").getTime();
|
long e = simpleDateFormat.parse("1999-01-01 " + lineShifts_.get(i).getEndTime() + ":00").getTime();
|
if((time - e) < (Long.valueOf(shiftInterval) * 60 * 1000)){
|
return true;
|
}
|
}
|
}
|
return false;
|
}
|
return false;
|
}
|
}
|
