联讯物业系统后台
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xiaogang
2023-02-14 c2b97e88614a8c0bb641848a4d868f54cb8382df 
 service-job/src/main/java/com/java110/job/task/parkingSpace/ReleaseCarParkingSpaceTemplate.java


@@ -1,20 +1,28 @@


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


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.dto.visit.VisitDto;


import com.java110.intf.community.IParkingSpaceInnerServiceSMO;


import com.java110.intf.community.IVisitInnerServiceSMO;


import com.java110.intf.user.ICarBlackWhiteV1InnerServiceSMO;


import com.java110.intf.user.IOwnerCarAttrInnerServiceSMO;


import com.java110.intf.user.IOwnerCarAttrV1InnerServiceSMO;


import com.java110.intf.user.IOwnerCarV1InnerServiceSMO;


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


import com.java110.job.quartz.TaskSystemQuartz;


import com.java110.po.car.CarBlackWhitePo;


import com.java110.po.car.OwnerCarPo;


import com.java110.po.ownerCarAttr.OwnerCarAttrPo;


import com.java110.po.parking.ParkingSpacePo;


import com.java110.utils.util.Assert;


import com.java110.utils.util.StringUtil;


import org.slf4j.Logger;


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


import org.springframework.stereotype.Component;


@@ -24,7 +32,7 @@


import java.util.List;




/**


 * 预约车定时释放车位


 * 预约车定时释放车位（依据访客预约结束时间）


 *


 * @author fqz


 * @date 2022-04-21


@@ -46,6 +54,12 @@




    @Autowired


    private IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMOImpl;




    @Autowired


    private ICarBlackWhiteV1InnerServiceSMO carBlackWhiteV1InnerServiceSMOImpl;




    @Autowired


    private IIotSendAsyn hcCarBlackWhiteAsynImpl;




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




@@ -78,6 +92,21 @@


            return;


        }


        for (VisitDto visit : visitDtos) {


            if (StringUtil.isEmpty(visit.getPsId()) || visit.getPsId().equals("-1")) {


                continue;


            }


            ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto();


            parkingSpaceDto.setPsId(visit.getPsId());


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


            if (parkingSpaceDtos == null || parkingSpaceDtos.size() == 0) {


                continue;


            }


            if (parkingSpaceDtos != null && parkingSpaceDtos.size() > 1) {


                throw new IllegalArgumentException("查询车位错误！");


            }


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


                continue;


            }


            OwnerCarDto ownerCarDto = new OwnerCarDto();


            ownerCarDto.setCommunityId(communityDto.getCommunityId());


            ownerCarDto.setCarTypeCd(OwnerCarDto.CAR_TYPE_TEMP); //临时车


@@ -118,6 +147,33 @@


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


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


            parkingSpaceInnerServiceSMOImpl.updateParkingSpace(parkingSpacePo);


            //删除白名单车辆信息


            if (!StringUtil.isEmpty(visit.getCarNum())) {


                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;


                }


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


            }


        }


    }