package com.java110.job.task.parkingSpace;
|
|
import com.java110.core.log.LoggerFactory;
|
import com.java110.dto.community.CommunityDto;
|
import com.java110.dto.owner.OwnerCarDto;
|
import com.java110.dto.ownerCarAttr.OwnerCarAttrDto;
|
import com.java110.dto.parking.ParkingSpaceDto;
|
import com.java110.dto.task.TaskDto;
|
import com.java110.intf.community.IParkingSpaceInnerServiceSMO;
|
import com.java110.intf.user.IOwnerCarAttrInnerServiceSMO;
|
import com.java110.intf.user.IOwnerCarAttrV1InnerServiceSMO;
|
import com.java110.intf.user.IOwnerCarV1InnerServiceSMO;
|
import com.java110.job.quartz.TaskSystemQuartz;
|
import com.java110.po.car.OwnerCarPo;
|
import com.java110.po.ownerCarAttr.OwnerCarAttrPo;
|
import com.java110.po.parking.ParkingSpacePo;
|
import org.slf4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* @author fqz
|
* @Description 释放预约车车位
|
* @date 2022-04-18 17:08
|
*/
|
@Component
|
public class ReleaseParkingSpaceTemplate extends TaskSystemQuartz {
|
|
@Autowired
|
private IOwnerCarAttrInnerServiceSMO ownerCarAttrInnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerCarAttrV1InnerServiceSMO ownerCarAttrV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IOwnerCarV1InnerServiceSMO ownerCarV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMOImpl;
|
|
private static Logger logger = LoggerFactory.getLogger(ReleaseParkingSpaceTemplate.class);
|
|
@Override
|
protected void process(TaskDto taskDto) throws Exception {
|
logger.debug("开始执行微信模板信息推送" + taskDto.toString());
|
// 获取小区
|
List<CommunityDto> communityDtos = getAllCommunity();
|
for (CommunityDto communityDto : communityDtos) {
|
doReleaseParkingSpace(taskDto, communityDto);
|
}
|
}
|
|
/**
|
* 根据小区释放预约车辆车位
|
*
|
* @param taskDto
|
* @param communityDto
|
*/
|
private void doReleaseParkingSpace(TaskDto taskDto, CommunityDto communityDto) {
|
//查询预约车信息
|
OwnerCarDto ownerCarDto = new OwnerCarDto();
|
ownerCarDto.setCommunityId(communityDto.getCommunityId());
|
ownerCarDto.setCarTypeCd(OwnerCarDto.CAR_TYPE_TEMP);//临时车
|
List<OwnerCarDto> ownerCarDtos = ownerCarV1InnerServiceSMOImpl.queryOwnerCars(ownerCarDto);
|
if (ownerCarDtos == null || ownerCarDtos.size() < 1) {
|
return;
|
}
|
for (OwnerCarDto ownerCar : ownerCarDtos) {
|
ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto();
|
parkingSpaceDto.setPsId(ownerCar.getPsId());
|
//查询车位
|
List<ParkingSpaceDto> parkingSpaceDtos = parkingSpaceInnerServiceSMOImpl.queryParkingSpaces(parkingSpaceDto);
|
if (parkingSpaceDtos == null || parkingSpaceDtos.size() < 1) { //车位不存在
|
continue;
|
}
|
OwnerCarAttrDto ownerCarAttrDto = new OwnerCarAttrDto();
|
ownerCarAttrDto.setCarId(ownerCar.getCarId());
|
ownerCarAttrDto.setSpecCd("6443000036"); //是否是预约车
|
//查询车辆属性
|
List<OwnerCarAttrDto> ownerCarAttrDtos = ownerCarAttrInnerServiceSMOImpl.queryOwnerCarAttrs(ownerCarAttrDto);
|
if (ownerCarAttrDtos == null || ownerCarAttrDtos.size() != 1) { //只看是否是预约车属性
|
continue;
|
}
|
if (!ownerCarAttrDtos.get(0).getValue().equals("true")) { //不是预约车的不走定时任务
|
continue;
|
}
|
//获取车辆截租时间
|
Date endTime = ownerCar.getEndTime();
|
//当前时间
|
Date date = new Date();
|
if (endTime.getTime() <= date.getTime()) { //如果车辆截租时间小于等于当前时间，说明到期了，需要释放掉
|
OwnerCarPo car = new OwnerCarPo();
|
car.setCarId(ownerCar.getCarId());
|
car.setCommunityId(communityDto.getCommunityId());
|
car.setCarTypeCd(OwnerCarDto.CAR_TYPE_TEMP);
|
car.setState(OwnerCarDto.STATE_FINISH); //车位释放状态
|
car.setStatusCd("1"); //不可用状态
|
//修改车辆状态，改为车辆释放状态并删除
|
ownerCarV1InnerServiceSMOImpl.updateOwnerCar(car);
|
OwnerCarAttrPo ownerCarAttrPo = new OwnerCarAttrPo();
|
ownerCarAttrPo.setCarId(ownerCar.getCarId());
|
ownerCarAttrPo.setStatusCd("1");
|
//删除过期车辆属性
|
ownerCarAttrV1InnerServiceSMOImpl.updateOwnerCarAttr(ownerCarAttrPo);
|
ParkingSpacePo parkingSpacePo = new ParkingSpacePo();
|
parkingSpacePo.setPsId(ownerCar.getPsId());
|
parkingSpacePo.setState("F");//车位状态 出售 S，出租 H ，空闲 F
|
//车位状态改为空闲状态
|
parkingSpaceInnerServiceSMOImpl.updateParkingSpace(parkingSpacePo);
|
}
|
}
|
}
|
|
}
|
