联讯物业系统后台
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
java110
2023-05-16 d516e38fd44e186f393bbb05c4e7ca34b323b609 
 service-job/src/main/java/com/java110/job/task/parkingSpace/ReleaseParkingSpaceTemplate.java


@@ -1,45 +1,48 @@


package com.java110.job.task.parkingSpace;




import com.alibaba.fastjson.JSONObject;


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.machine.CarBlackWhiteDto;


import com.java110.dto.parking.ParkingSpaceDto;


import com.java110.dto.task.TaskDto;


import com.java110.dto.visit.VisitDto;


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.intf.community.IVisitInnerServiceSMO;


import com.java110.intf.user.ICarBlackWhiteV1InnerServiceSMO;


import com.java110.job.adapt.hcIot.asyn.IIotSendAsyn;


import com.java110.job.quartz.TaskSystemQuartz;


import com.java110.po.car.OwnerCarPo;


import com.java110.po.ownerCarAttr.OwnerCarAttrPo;


import com.java110.po.car.CarBlackWhitePo;


import com.java110.po.parking.ParkingSpacePo;


import com.java110.utils.util.StringUtil;


import org.slf4j.Logger;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Component;




import java.text.ParseException;


import java.text.SimpleDateFormat;


import java.util.Date;


import java.util.List;




/**


 * @author fqz


 * @Description 释放预约车车位


 * @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;


    private IVisitInnerServiceSMO visitInnerServiceSMOImpl;




    @Autowired


    private IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMOImpl;




    @Autowired


    private ICarBlackWhiteV1InnerServiceSMO carBlackWhiteV1InnerServiceSMOImpl;




    @Autowired


    private IIotSendAsyn hcCarBlackWhiteAsynImpl;




    private static Logger logger = LoggerFactory.getLogger(ReleaseParkingSpaceTemplate.class);




@@ -59,57 +62,67 @@


     * @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) {


    private void doReleaseParkingSpace(TaskDto taskDto, CommunityDto communityDto) throws ParseException {


        //查询小区下的访客信息


        VisitDto visitDto = new VisitDto();


        visitDto.setCommunityId(communityDto.getCommunityId());


        visitDto.setCarNumNoEmpty("1"); //车辆不为空


        visitDto.setFlag("1"); //车位不为空


        List<VisitDto> visitDtos = visitInnerServiceSMOImpl.queryVisits(visitDto);


        if (visitDtos == null || visitDtos.size() < 1) {


            return;


        }


        for (OwnerCarDto ownerCar : ownerCarDtos) {


        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");


        for (VisitDto visit : visitDtos) {


            //查看是否有车位


            ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto();


            parkingSpaceDto.setPsId(ownerCar.getPsId());


            //查询车位


            parkingSpaceDto.setPsId(visit.getPsId());


            List<ParkingSpaceDto> parkingSpaceDtos = parkingSpaceInnerServiceSMOImpl.queryParkingSpaces(parkingSpaceDto);


            if (parkingSpaceDtos == null || parkingSpaceDtos.size() < 1) { //车位不存在


            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) { //只看是否是预约车属性


            if (StringUtil.isEmpty(parkingSpaceDtos.get(0).getState()) || !parkingSpaceDtos.get(0).getState().equals("H")) { //出售 S，出租 H ，空闲 F


                continue;


            }


            if (!ownerCarAttrDtos.get(0).getValue().equals("true")) { //不是预约车的不走定时任务


            if (StringUtil.isEmpty(visit.getFreeTime())) {


                continue;


            }


            //获取车辆截租时间


            Date endTime = ownerCar.getEndTime();


            //查看车辆是否在黑白名单里


            CarBlackWhiteDto carBlackWhiteDto = new CarBlackWhiteDto();


            carBlackWhiteDto.setCarNum(visit.getCarNum());


            carBlackWhiteDto.setCommunityId(visit.getCommunityId());


            carBlackWhiteDto.setBlackWhite("2222"); //1111 黑名单 2222 白名单


            carBlackWhiteDto.setStartTime(visit.getVisitTime());


            carBlackWhiteDto.setEndTime(visit.getFreeTime());


            List<CarBlackWhiteDto> carBlackWhiteDtos = carBlackWhiteV1InnerServiceSMOImpl.queryCarBlackWhites(carBlackWhiteDto);


            if (carBlackWhiteDtos == null || carBlackWhiteDtos.size() != 1) {


                continue;


            }


            //获取预约车免费时间


            Date freeTime = df.parse(visit.getFreeTime());


            //当前时间


            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);


            if (freeTime.getTime() <= date.getTime()) { //如果预约车免费时间小于等于当前时间，说明到期了，需要释放掉


                ParkingSpacePo parkingSpacePo = new ParkingSpacePo();


                parkingSpacePo.setPsId(ownerCar.getPsId());


                parkingSpacePo.setPsId(visit.getPsId());


                parkingSpacePo.setState("F");//车位状态 出售 S，出租 H ，空闲 F


                //车位状态改为空闲状态


                parkingSpaceInnerServiceSMOImpl.updateParkingSpace(parkingSpacePo);


                //删除白名单


                CarBlackWhitePo carBlackWhitePo = new CarBlackWhitePo();


                carBlackWhitePo.setBwId(carBlackWhiteDtos.get(0).getBwId());


                carBlackWhitePo.setStatusCd("1");


                carBlackWhiteV1InnerServiceSMOImpl.deleteCarBlackWhite(carBlackWhitePo);


                //向第三方物联网推送删除白名单信息


                JSONObject postParameters = new JSONObject();


                postParameters.put("extBwId", carBlackWhiteDtos.get(0).getBwId());


                postParameters.put("carNum", carBlackWhiteDtos.get(0).getCarNum());


                postParameters.put("extPaId", carBlackWhiteDtos.get(0).getPaId());


                postParameters.put("extCommunityId", carBlackWhiteDtos.get(0).getCommunityId());


                postParameters.put("startTime", carBlackWhiteDtos.get(0).getStartTime());


                postParameters.put("endTime", carBlackWhiteDtos.get(0).getEndTime());


                postParameters.put("blackWhite", carBlackWhiteDtos.get(0).getBlackWhite());


                hcCarBlackWhiteAsynImpl.deleteCarBlackWhite(postParameters);


            }


        }


    }