| | |
| | | package com.doumee.service.business.impl.hksync; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.alibaba.nacos.shaded.org.checkerframework.checker.units.qual.C; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.doumee.biz.system.SystemDictDataBiz; |
| | |
| | | import com.doumee.dao.business.model.*; |
| | | import com.doumee.dao.business.model.Member; |
| | | import com.doumee.dao.web.reqeust.SavePlatformWarnEventDTO; |
| | | import com.doumee.service.business.VisitsService; |
| | | import com.doumee.service.business.impl.PlatformWarnEventServiceImpl; |
| | | import com.doumee.service.business.third.TmsService; |
| | | import com.doumee.service.business.third.model.request.TmsOrderInfoRequest; |
| | | import com.doumee.service.business.third.model.response.TmsOrderInfoResponse; |
| | | import com.github.yulichang.wrapper.MPJLambdaWrapper; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.ObjectUtils; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.apache.commons.net.ftp.FTP; |
| | | import org.checkerframework.checker.units.qual.C; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | |
| | | private PlatformJobMapper platformJobMapper; |
| | | @Autowired |
| | | private TmsService tmsService; |
| | | @Autowired |
| | | private VisitsService visitsService; |
| | | @Autowired |
| | | private PlatformWmsDetailMapper platformWmsDetailMapper; |
| | | @Autowired |
| | |
| | | .last("limit 1" )); |
| | | InoutRecord record = new InoutRecord(); |
| | | record.setCreateDate(DateUtil.getISO8601DateByStr2(request.getHappenTime())); |
| | | record.setTimeInfo(Utils.Date.getStart(record.getCreateDate())); |
| | | record.setType(Constants.ONE);//人员 |
| | | record.setMemberType(Constants.ZERO);//默认为未知人员(访客) |
| | | record.setIsdeleted(Constants.ZERO); |
| | |
| | | delRetentionLis.add(visits.getMemberId()); |
| | | InoutRecord record = new InoutRecord(); |
| | | record.setCreateDate(DateUtil.getISO8601DateByStr2(request.getHappenTime())); |
| | | record.setTimeInfo(Utils.Date.getStart(record.getCreateDate())); |
| | | record.setType(Constants.ONE);//人员 |
| | | record.setMemberType(Constants.ZERO); |
| | | record.setIsdeleted(Constants.ZERO); |
| | |
| | | List<CarEvent> list = new ArrayList<>(); |
| | | List<Retention> retentionList = new ArrayList<>(); |
| | | List<String> delRetentionList = new ArrayList<>(); |
| | | List<Integer> delMemberRetentionList = new ArrayList<>(); |
| | | InoutDayCount inoutDayCount = new InoutDayCount(); |
| | | List<InoutRecord> inoutRecordList = new ArrayList<>(); |
| | | for(EventParkInfoRequest request : events){ |
| | | if(request.getData() ==null ||StringUtils.isBlank(request.getData().getPlateNo())){ |
| | | continue; |
| | | } |
| | | //封装事件信息表对象 |
| | | list.add(getParkEventModelByRequest(request,delRetentionList,retentionList,inoutDayCount)); |
| | | list.add(getParkEventModelByRequest(request,delRetentionList,retentionList,delMemberRetentionList,inoutDayCount,inoutRecordList)); |
| | | } |
| | | if(list.size()>0){ |
| | | //插入门禁记录 |
| | |
| | | .eq(Retention::getType,Constants.THREE) |
| | | .in(Retention::getCarNo,delRetentionList)); |
| | | } |
| | | if(delMemberRetentionList.size()>0){ |
| | | //先删除原有的在场人员(内部人员和访客) |
| | | retentionMapper.delete(new UpdateWrapper<Retention>().lambda() |
| | | .in(Retention::getType,Constants.memberType.internal,Constants.memberType.visitor) |
| | | .in(Retention::getMemberId,delMemberRetentionList)); |
| | | } |
| | | if(retentionList.size()>0){ |
| | | //再插入最新的在厂人员 |
| | | retentionMapper.insert(retentionList); |
| | | } |
| | | if(inoutRecordList.size()>0){ |
| | | //再插入最新的人车出入明细 |
| | | inoutRecordMapper.insert(inoutRecordList); |
| | | } |
| | | dealInoutDayCountBiz(inoutDayCount); |
| | | log.info("【海康停车场事件推送】========成功======="); |
| | |
| | | * @param request |
| | | * @return |
| | | */ |
| | | private CarEvent getParkEventModelByRequest(EventParkInfoRequest request, List<String> delRetentionList , List<Retention> retentionList,InoutDayCount inoutDayCount ) { |
| | | private CarEvent getParkEventModelByRequest(EventParkInfoRequest request |
| | | , List<String> delRetentionList |
| | | , List<Retention> retentionList |
| | | , List<Integer> delMemberRetentionList |
| | | , InoutDayCount inoutDayCount |
| | | , List<InoutRecord> inoutRecordList) { |
| | | CarEvent event =initCarEventModelByRequest(request); |
| | | if(StringUtils.isNotBlank(event.getPlateNos())){ |
| | | //标记车辆进出记录 |
| | | List<Visits> visitsList = null; |
| | | InoutRecord carrecord = new InoutRecord(); |
| | | carrecord.setCreateDate(DateUtil.getISO8601DateByStr2(request.getHappenTime())); |
| | | carrecord.setTimeInfo(Utils.Date.getStart(carrecord.getCreateDate())); |
| | | carrecord.setType(Constants.ZERO);//车辆 |
| | | carrecord.setIsdeleted(Constants.ZERO); |
| | | carrecord.setObjType(Constants.ZERO); |
| | | carrecord.setHkEventId(request.getEventId()); |
| | | carrecord.setCarCode(event.getPlateNos()); |
| | | Cars carModel = carsMapper.selectJoinOne(Cars.class,new MPJLambdaWrapper<Cars>() |
| | | .selectAll(Cars.class ) |
| | | .selectAs(Company::getType,Cars::getCompanyType) |
| | | .selectAs(Member::getName,Cars::getMemberName) |
| | | .selectAs(Member::getIdcardDecode,Cars::getIdcardDecode) |
| | | .selectAs(Member::getCode,Cars::getMemberCode) |
| | | .selectAs(Member::getFaceImg,Cars::getFaceImg) |
| | | .selectAs(Member::getIdcardNo,Cars::getIdcardNo) |
| | | .selectAs(Member::getName,Cars::getMemberName) |
| | | .selectAs(Member::getPhone,Cars::getMemberPhone) |
| | | .selectAs(Company::getCompanyNamePath,Cars::getCompanyName) |
| | | .selectAs(Category::getBizType,Cars::getBizType) |
| | | .leftJoin(Company.class,Company::getId,Cars::getGroupId) |
| | | .leftJoin(Category.class,Category::getId,Cars::getCateId) |
| | | .leftJoin(Member.class,Member::getId,Cars::getMemberId) |
| | | .eq(Cars::getCode,event.getPlateNos()) |
| | | .eq(Cars::getIsdeleted,Constants.ZERO) |
| | | .last(" limit 1")); |
| | | if(carModel!=null){ |
| | | //0安泰公务车 1安泰自有物流车 2其它 |
| | | event.setMemberId(carModel.getMemberId()); |
| | | event.setCompanyId(carModel.getGroupId()); |
| | | //-----------------20250429改造----start--------------- |
| | | event.setCarType(carModel.getBizType());//车辆业务类型 |
| | | carrecord.setObjType(Constants.FOUR); |
| | | carrecord.setMemberName(carModel.getMemberName());//司机 |
| | | carrecord.setMemberPhone(carModel.getMemberPhone());//司机 |
| | | carrecord.setObjId(carModel.getId()); |
| | | carrecord.setObjType(Constants.ZERO); |
| | | carrecord.setFaceImg(carModel.getFaceImg()); |
| | | carrecord.setIdcardDecode(carModel.getIdcardDecode()); |
| | | carrecord.setIdcardNo(carModel.getIdcardNo()); |
| | | carrecord.setMemberCode(carModel.getMemberCode()); |
| | | carrecord.setCompanyId(carModel.getGroupId()); |
| | | carrecord.setCompanyName(carModel.getCompanyName()); |
| | | carrecord.setMemberType( Constants.RetentionMemberType.car);//只是车辆的记录 |
| | | if(carModel.getMemberId()!=null){ |
| | | if(Constants.equalsInteger(carModel.getCompanyType(),Constants.ONE)){ |
| | | //内部组织 |
| | | carrecord.setMemberType(Constants.RetentionMemberType.internalMember); |
| | | }else{ |
| | | //相关方组织 |
| | | carrecord.setMemberType( Constants.RetentionMemberType.relMember); |
| | | } |
| | | } |
| | | // carrecord.setMemberPhone(carTypeJob.getDrivierPhone()); |
| | | //-----------------20250429改造----end--------------- |
| | | } |
| | | if(event.getCarType() ==null || event.getCarType().equals(Constants.RetentionCarType.other)){//如果为识别到车型 |
| | | PlatformJob carTypeJob = platformJobMapper.selectJoinOne(PlatformJob.class, |
| | | new MPJLambdaWrapper<PlatformJob>(). selectAll(PlatformJob.class) |
| | | .selectAs(PlatformGroup::getType,PlatformJob::getGroupType) |
| | | .leftJoin(PlatformGroup.class,PlatformGroup::getId,PlatformJob::getPlatformGroupId) |
| | | .eq(PlatformJob::getCarCodeFront,event.getPlateNos()) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .orderByAsc(PlatformJob::getCreateDate) |
| | | .last(" limit 1")); |
| | | if(carTypeJob!=null ) { |
| | | /** |
| | | * 如果非固定车辆,检查是否货运车辆 |
| | | * 货运车辆优先级: |
| | | * 1、安泰自有车:货运车辆-安泰物流货运车辆(固定车辆上面已处理,此处不考虑) |
| | | * 2、wms推送的物流车辆(非自有车):货运车辆-外协运输车辆 对应grouptype为:安泰物流卸货 2 |
| | | * 3、安泰的预约入园车辆:货运车辆-加工烟卸货车辆 对应grouptype为0安泰物流卸货 2市公司卸货 |
| | | * 4、市公司的预约入园车辆:货运车辆-市公司卸货车辆 |
| | | */ |
| | | carrecord.setMemberName(carTypeJob.getDriverName());//司机 |
| | | carrecord.setMemberPhone(carTypeJob.getDrivierPhone());//司机 |
| | | carrecord.setObjId(carTypeJob.getId()); |
| | | carrecord.setMemberId(carTypeJob.getDriverId());//司机编码 |
| | | carrecord.setObjType(Constants.FOUR); |
| | | carrecord.setCompanyId(carTypeJob.getCompanyId()); |
| | | carrecord.setCompanyName(carTypeJob.getCompanyNamePath()); |
| | | carrecord.setMemberType(Constants.RetentionMemberType.car); |
| | | if(carModel.getMemberPhone()!=null || StringUtils.isNotBlank(carModel.getMemberName())){ |
| | | //货运司机(如果司机手机号或者姓名不为空) |
| | | carrecord.setMemberType(Constants.RetentionMemberType.driver); |
| | | } |
| | | //如果非固定车辆,则查询是否货运车辆 作业类型 0自有车卸货 1自有车装货 2外协车卸货 3外协车装货 4市公司外协车卸货 |
| | | if(Constants.equalsInteger(carTypeJob.getOrigin(),Constants.ONE)){ |
| | | //如果是推送的wms非自有车 |
| | | event.setCarType(Constants.RetentionCarType.wxysCar);//外协车 |
| | | }else if(Constants.equalsInteger(carTypeJob.getType(),Constants.FOUR)){ |
| | | if(Constants.equalsInteger(carTypeJob.getGroupType(),Constants.TWO)){ |
| | | ///安泰的预约入园车辆:货运车辆-加工烟卸货车辆 |
| | | event.setCarType(Constants.RetentionCarType.jgyxhCar);//加工烟卸货车辆 |
| | | }else if(Constants.equalsInteger(carTypeJob.getGroupType(),Constants.TWO)){ |
| | | //市公司的预约入园车辆:货运车辆-市公司卸货车辆 |
| | | event.setCarType(Constants.RetentionCarType.sgsxhCar);//市公司卸货车辆 |
| | | } |
| | | } |
| | | } |
| | | } |
| | | //处理自有车自动签到业务 |
| | | dealSelTruckAutoSignBiz(request,event); |
| | | if(Constants.formatIntegerNum(request.getEventType()) == HKConstants.EventTypes.PARK_PASS_IN.getKey()){ |
| | | //如果是入厂放行 |
| | | delRetentionList.add(event.getPlateNos()); |
| | | delMemberRetentionList.add(event.getMemberId()); |
| | | retentionList.add(getRetentionModelByParkRequest(request,event));//在厂车辆信息 |
| | | inoutDayCount.setInCarNum(Constants.formatIntegerNum(inoutDayCount.getInCarNum())+1); |
| | | carrecord.setInOrOut(Constants.ZERO); |
| | | }else if(Constants.formatIntegerNum(request.getEventType()) == HKConstants.EventTypes.PARK_PASS_OUT.getKey()){ |
| | | //如果是出场放行 |
| | | delRetentionList.add(event.getPlateNos()); |
| | | delMemberRetentionList.add(event.getMemberId()); |
| | | inoutDayCount.setOutCarNum(Constants.formatIntegerNum(inoutDayCount.getOutCarNum())+1); |
| | | carrecord.setInOrOut(Constants.ZERO); |
| | | } |
| | | //车辆进入记录对应业务类型 |
| | | if(event.getCarType() ==null || event.getCarType().equals(Constants.RetentionCarType.other)){//如果为识别到车型 |
| | | //如果不是固定车 也不是货运车辆,则检查是否是访客车 |
| | | visitsList = visitsMapper.selectList(new QueryWrapper<Visits>().lambda() |
| | | .eq(Visits::getCarNos,event.getPlateNos()) |
| | | .eq(Visits::getIsdeleted,Constants.ZERO ) |
| | | .in(Visits::getStatus,Constants.VisitStatus.signin)//最近一个已到达或者已签离 |
| | | .isNull(Visits::getParentId) |
| | | .orderByDesc(Visits::getId) |
| | | // .last("limit 1" ) |
| | | ); |
| | | if(visitsList!=null && visitsList.size()>0){ |
| | | //最近使用该车的申请人(已到达) |
| | | event.setMemberId(visitsList.get(0).getMemberId()); |
| | | event.setCarType(Constants.RetentionCarType.fkCar); |
| | | int index =0; |
| | | for(Visits v :visitsList){ |
| | | delMemberRetentionList.add(event.getMemberId()); |
| | | InoutRecord copyObj = new InoutRecord(); |
| | | BeanUtils.copyProperties(carrecord,copyObj); |
| | | copyObj.setMemberId(v.getMemberId()); |
| | | copyObj.setMemberName(v.getName()); |
| | | copyObj.setMemberPhone(v.getPhone()); |
| | | copyObj.setCompanyName(v.getCompanyName()); |
| | | copyObj.setCarBizType(Constants.RetentionCarType.fkCar); |
| | | copyObj.setMemberType(Constants.ZERO); |
| | | copyObj.setRemark(carrecord.getCarCode()); |
| | | copyObj.setCarCode(index>=0?null:carrecord.getCarCode()); |
| | | copyObj.setMemberType(Constants.RetentionMemberType.fk); |
| | | inoutRecordList.add(copyObj); |
| | | index++; |
| | | if(Constants.equalsInteger(carrecord.getInOrOut(),Constants.ONE)){ |
| | | //如果是车辆出园区,访客申请自动签离 |
| | | visitsService.visitLevelForCarOut(v); |
| | | }else{ |
| | | //如果是进入园区,访客录入在园人员记录 |
| | | retentionList.add(getRetentionModelByRequest(copyObj,request)); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | //车辆进入记录对应业务类型 |
| | | if(event.getCarType() !=null && event.getCarType().equals(Constants.RetentionCarType.fkCar)) { |
| | | //录入非访客类型车辆进出记录 |
| | | carrecord.setCarBizType(event.getCarType()==null?Constants.RetentionCarType.other:event.getCarType()); |
| | | if(Constants.equalsInteger(carrecord.getMemberType(),Constants.RetentionMemberType.internalMember) |
| | | ||Constants.equalsInteger(carrecord.getMemberType(),Constants.RetentionMemberType.relMember) |
| | | ||Constants.equalsInteger(carrecord.getMemberType(),Constants.RetentionMemberType.driver)){ |
| | | retentionList.add(getRetentionModelByRequest(carrecord,request)); |
| | | } |
| | | inoutRecordList.add(carrecord); |
| | | } |
| | | |
| | | |
| | | } |
| | | return event; |
| | | } |
| | | |
| | | private void dealSelTruckAutoSignBiz(EventParkInfoRequest request, CarEvent event) { |
| | | ParkBook cars = parkBookMapper.selectOne(new QueryWrapper<ParkBook>().lambda() |
| | | .eq(ParkBook::getCarCode,event.getPlateNos()) |
| | | .eq(ParkBook::getHkStatus,Constants.ONE ) |
| | | .eq(ParkBook::getIsdeleted,Constants.ZERO ) |
| | | .last("limit 1" )); |
| | | if(cars!=null){ |
| | | event.setMemberId(cars.getMemberId()); |
| | | //自有车 查询当前是否有待签到的任务 |
| | | if(carsMapper.selectCount(new QueryWrapper<Cars>() |
| | | .lambda().eq(Cars::getCode,event.getPlateNos()) |
| | | .eq(Cars::getType,Constants.ONE) |
| | | .eq(Cars::getIsdeleted,Constants.ZERO) |
| | | )>Constants.ZERO){ |
| | | //查询车辆当前是否存在进行中的任务 |
| | | if( platformJobMapper.selectCount(new QueryWrapper<PlatformJob>().lambda() |
| | | .eq(PlatformJob::getCarCodeFront,event.getPlateNos()) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .in(PlatformJob::getStatus, |
| | | Constants.PlatformJobStatus.IN_WAIT.getKey(), |
| | | Constants.PlatformJobStatus.CALLED.getKey(), |
| | | Constants.PlatformJobStatus.WORKING.getKey(), |
| | | Constants.PlatformJobStatus.TRANSFERING.getKey(), |
| | | Constants.PlatformJobStatus.EXCEPTION.getKey() |
| | | ) |
| | | )==Constants.ZERO){//如果没进行中任务 |
| | | PlatformJob platformJob = platformJobMapper.selectOne(new QueryWrapper<PlatformJob>().lambda() |
| | | .eq(PlatformJob::getCarCodeFront,event.getPlateNos()) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .in(PlatformJob::getStatus, |
| | | Constants.PlatformJobStatus.WAIT_CONFIRM.getKey(), |
| | | Constants.PlatformJobStatus.WART_SIGN_IN.getKey() |
| | | ) |
| | | .orderByAsc(PlatformJob::getCreateDate) |
| | | .last(" limit 1") |
| | | ); |
| | | if(Objects.nonNull(platformJob)){ |
| | | if(Constants.equalsInteger(platformJob.getType(),Constants.ONE)){ |
| | | //如果是自有车装货自动签到 |
| | | jobAutoSignBiz(platformJob); |
| | | }else if(Constants.equalsInteger(platformJob.getType(),Constants.ZERO)){ |
| | | //如果是自有车卸货 查询TMS合同状态,决定是否自动签到 |
| | | checkTmsContractStatusBiz(platformJob); |
| | | } |
| | | |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | private CarEvent initCarEventModelByRequest(EventParkInfoRequest request) { |
| | | CarEvent event = new CarEvent(); |
| | | event.setIsdeleted(Constants.ZERO); |
| | | event.setCreateDate(DateUtil.getISO8601DateByStr(request.getHappenTime())); |
| | |
| | | event.setEventCmd(request.getData().getEventCmd()); |
| | | event.setCardNo(request.getData().getCardNo()); |
| | | event.setCarAttributeName(request.getData().getCarAttributeName()); |
| | | event.setCarType(Constants.RetentionCarType.unknown);//默认未登记车辆 |
| | | event.setCarType(Constants.RetentionCarType.other);//默认未登记车辆 |
| | | if(request.getData().getInResult()!=null && request.getData().getInResult().getRlsResult() !=null ){ |
| | | //放行方式 |
| | | event.setReleaseWay(request.getData().getInResult().getRlsResult().getReleaseWay()); |
| | |
| | | //车辆和和车牌照片 |
| | | event.setVehiclePicUrl(getHkImgUrl(request.getData().getPicUrl().getVehiclePicUrl())); |
| | | event.setPlatePicUrl(getHkImgUrl(request.getData().getPicUrl().getPlatePicUrl())); |
| | | } |
| | | if(StringUtils.isNotBlank(event.getPlateNos())){ |
| | | Cars carModel = carsMapper.selectJoinOne(Cars.class,new MPJLambdaWrapper<Cars>() |
| | | .selectAll(Cars.class ) |
| | | .selectAs(Company::getType,Cars::getCompanyType) |
| | | .leftJoin(Company.class,Company::getId,Cars::getGroupId) |
| | | .eq(Cars::getCode,event.getPlateNos()) |
| | | .eq(Cars::getIsdeleted,Constants.ZERO) |
| | | .last(" limit 1")); |
| | | if(carModel!=null){ |
| | | //0安泰公务车 1安泰自有物流车 2其它 |
| | | event.setMemberId(carModel.getMemberId()); |
| | | event.setCompanyId(carModel.getGroupId()); |
| | | if(Constants.equalsInteger(carModel.getType(),Constants.ONE)){ |
| | | event.setCarType(Constants.RetentionCarType.selfTruck); |
| | | }else { |
| | | if(Constants.equalsInteger(carModel.getCompanyType(),Constants.ONE)){ |
| | | event.setCarType(Constants.RetentionCarType.internal);//内部车辆 |
| | | }else{ |
| | | event.setCarType(Constants.RetentionCarType.relation);//相关方车辆 |
| | | } |
| | | } |
| | | } |
| | | PlatformJob carTypeJob = platformJobMapper.selectOne(new QueryWrapper<PlatformJob>().lambda() |
| | | .eq(PlatformJob::getCarCodeFront,event.getPlateNos()) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .orderByAsc(PlatformJob::getCreateDate) |
| | | .last(" limit 1")); |
| | | if(carTypeJob!=null){ |
| | | //作业类型 0自有车卸货 1自有车装货 2外协车卸货 3外协车装货 4市公司外协车卸货 |
| | | if(Constants.equalsInteger(carTypeJob.getType(),Constants.FOUR)){ |
| | | event.setCarType(Constants.RetentionCarType.cityComTruck);//市公司车辆 |
| | | }else if(Constants.equalsInteger(carTypeJob.getType(),Constants.TWO) |
| | | || Constants.equalsInteger(carTypeJob.getType(),Constants.THREE)){ |
| | | event.setCarType(Constants.RetentionCarType.outTruck);//外协车 |
| | | }else{ |
| | | event.setCarType(Constants.RetentionCarType.selfTruck);//自有车 |
| | | } |
| | | } |
| | | |
| | | ParkBook cars = parkBookMapper.selectOne(new QueryWrapper<ParkBook>().lambda() |
| | | .eq(ParkBook::getCarCode,event.getPlateNos()) |
| | | .eq(ParkBook::getIsdeleted,Constants.ZERO ) |
| | | .last("limit 1" )); |
| | | if(cars!=null){ |
| | | event.setMemberId(cars.getMemberId()); |
| | | //自有车 查询当前是否有待签到的任务 |
| | | if(carsMapper.selectCount(new QueryWrapper<Cars>() |
| | | .lambda().eq(Cars::getCode,event.getPlateNos()) |
| | | .eq(Cars::getType,Constants.ONE) |
| | | .eq(Cars::getIsdeleted,Constants.ZERO) |
| | | )>Constants.ZERO){ |
| | | //查询车辆当前是否存在进行中的任务 |
| | | if( platformJobMapper.selectCount(new QueryWrapper<PlatformJob>().lambda() |
| | | .eq(PlatformJob::getCarCodeFront,event.getPlateNos()) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .in(PlatformJob::getStatus, |
| | | Constants.PlatformJobStatus.IN_WAIT.getKey(), |
| | | Constants.PlatformJobStatus.CALLED.getKey(), |
| | | Constants.PlatformJobStatus.WORKING.getKey(), |
| | | Constants.PlatformJobStatus.TRANSFERING.getKey(), |
| | | Constants.PlatformJobStatus.EXCEPTION.getKey() |
| | | ) |
| | | )==Constants.ZERO){//如果没进行中任务 |
| | | PlatformJob platformJob = platformJobMapper.selectOne(new QueryWrapper<PlatformJob>().lambda() |
| | | .eq(PlatformJob::getCarCodeFront,event.getPlateNos()) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .in(PlatformJob::getStatus, |
| | | Constants.PlatformJobStatus.WAIT_CONFIRM.getKey(), |
| | | Constants.PlatformJobStatus.WART_SIGN_IN.getKey() |
| | | ) |
| | | .orderByAsc(PlatformJob::getCreateDate) |
| | | .last(" limit 1") |
| | | ); |
| | | if(Objects.nonNull(platformJob)){ |
| | | if(Constants.equalsInteger(platformJob.getType(),Constants.ONE)){ |
| | | //如果是自有车装货自动签到 |
| | | jobAutoSignBiz(platformJob); |
| | | }else if(Constants.equalsInteger(platformJob.getType(),Constants.ZERO)){ |
| | | //如果是自有车卸货 查询TMS合同状态,决定是否自动签到 |
| | | checkTmsContractStatusBiz(platformJob); |
| | | } |
| | | |
| | | } |
| | | } |
| | | }; |
| | | }else{ |
| | | Visits visits = visitsMapper.selectOne(new QueryWrapper<Visits>().lambda() |
| | | .eq(Visits::getCarNos,event.getPlateNos()) |
| | | .eq(Visits::getIsdeleted,Constants.ZERO ) |
| | | .in(Visits::getStatus,Constants.VisitStatus.signin,Constants.VisitStatus.signout)//最近一个已到达或者已签离 |
| | | .isNull(Visits::getParentId) |
| | | .orderByDesc(Visits::getId) |
| | | .last("limit 1" )); |
| | | if(visits!=null){ |
| | | //最近使用该车的申请人(已到达) |
| | | event.setMemberId(visits.getMemberId()); |
| | | event.setCarType(Constants.RetentionCarType.visitor); |
| | | } |
| | | } |
| | | if(Constants.formatIntegerNum(request.getEventType()) == HKConstants.EventTypes.PARK_PASS_IN.getKey()){ |
| | | //如果是入厂放行 |
| | | delRetentionList.add(event.getPlateNos()); |
| | | retentionList.add(getRetentionModelByParkRequest(request,event)); |
| | | inoutDayCount.setInCarNum(Constants.formatIntegerNum(inoutDayCount.getInCarNum())+1); |
| | | }else if(Constants.formatIntegerNum(request.getEventType()) == HKConstants.EventTypes.PARK_PASS_OUT.getKey()){ |
| | | //如果是出场放行 |
| | | delRetentionList.add(event.getPlateNos()); |
| | | inoutDayCount.setOutCarNum(Constants.formatIntegerNum(inoutDayCount.getOutCarNum())+1); |
| | | } |
| | | } |
| | | return event; |
| | | } |
| | |
| | | } |
| | | platformJobMapper.updateById(platformJob); |
| | | } |
| | | |
| | | private Retention getRetentionModelByParkRequest(EventParkInfoRequest request,CarEvent event) { |
| | | private Retention getRetentionModelByRequest(InoutRecord inoutRecord, EventParkInfoRequest request) { |
| | | Retention retention = new Retention(); |
| | | retention.setIsdeleted(Constants.ZERO); |
| | | retention.setCreateDate(DateUtil.getISO8601DateByStr(request.getHappenTime())); |
| | | retention.setCode(inoutRecord.getMemberCode()); |
| | | retention.setIdcardNo(inoutRecord.getIdcardNo()); |
| | | retention.setIdcardDecode(inoutRecord.getIdcardDecode()); |
| | | retention.setName(inoutRecord.getMemberName()); |
| | | retention.setType(inoutRecord.getMemberType()); |
| | | retention.setCompanyId(inoutRecord.getCompanyId()); |
| | | retention.setCompanyName(inoutRecord.getCompanyName()); |
| | | retention.setEventCode(request.getEventType()+""); |
| | | retention.setEventDate(DateUtil.getISO8601DateByStr(request.getHappenTime())); |
| | | retention.setFaceImg(inoutRecord.getFaceImg()); |
| | | retention.setPhone(inoutRecord.getMemberPhone()); |
| | | retention.setMemberId(inoutRecord.getMemberId()); |
| | | retention.setDeviceName(request.getSrcName()); |
| | | retention.setDeviceIndex(request.getSrcIndex()); |
| | | retention.setRemark("跟随车辆入园区"); |
| | | return retention; |
| | | } |
| | | private Retention getRetentionModelByParkRequest(EventParkInfoRequest request,CarEvent event ) { |
| | | Retention retention = new Retention(); |
| | | retention.setIsdeleted(Constants.ZERO); |
| | | retention.setCreateDate(DateUtil.getISO8601DateByStr(request.getHappenTime())); |
| | |
| | | retention.setCompanyId(event.getCompanyId()); |
| | | // retention.setDeviceName(request.getSrcName()); |
| | | // retention.setDeviceIndex(request.getSrcIndex()); |
| | | |
| | | return retention; |
| | | } |
| | | |