From cb6874174975a370cb60f1557704c9d49a05f9e6 Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期五, 05 一月 2024 08:59:40 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- server/dmvisit_service/src/main/java/com/doumee/service/business/impl/CarEventServiceImpl.java | 149 ++++++++++++++++++++++++++++++++++++++----------- 1 files changed, 116 insertions(+), 33 deletions(-) diff --git a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/CarEventServiceImpl.java b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/CarEventServiceImpl.java index 460c1d2..97192ed 100644 --- a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/CarEventServiceImpl.java +++ b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/CarEventServiceImpl.java @@ -3,14 +3,21 @@ import cn.hutool.core.lang.PatternPool; import cn.hutool.core.lang.Validator; import cn.hutool.core.util.ReUtil; +import com.doumee.core.haikang.model.HKConstants; import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; +import com.doumee.core.utils.Constants; import com.doumee.core.utils.Utils; import com.doumee.dao.admin.request.VisitEventQuery; import com.doumee.dao.admin.response.CarEventDTO; +import com.doumee.dao.admin.response.DeviceEventDTO; +import com.doumee.dao.admin.response.VisitEventDTO; import com.doumee.dao.business.CarEventMapper; import com.doumee.dao.business.join.CarEventJoinMapper; import com.doumee.dao.business.model.*; +import com.doumee.dao.system.SystemDictDataMapper; +import com.doumee.dao.system.model.SystemDictData; +import com.doumee.dao.system.vo.CarEventVo; import com.doumee.service.business.CarEventService; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; @@ -22,8 +29,9 @@ import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; -import java.util.List; -import java.util.Objects; +import java.util.*; +import java.util.function.Function; +import java.util.stream.Collectors; /** * 鍋滆溅鍦轰簨浠舵帹閫佽褰曡〃Service瀹炵幇 @@ -38,6 +46,9 @@ @Autowired private CarEventJoinMapper carEventJoinMapper; + + @Autowired + private SystemDictDataMapper systemDictDataMapper; @Override public Integer create(CarEvent carEvent) { @@ -265,6 +276,55 @@ @Override public PageData<CarEventDTO> findVisitCarPage(PageWrap<CarEvent> pageWrap) { + IPage<CarEventDTO> carEventDTOIPage = getDataInfo(pageWrap); + if(null != carEventDTOIPage && carEventDTOIPage.getRecords().size() > 0) { + carEventDTOIPage.setRecords(newCarEventDTO(carEventDTOIPage.getRecords())); + } + return PageData.from(carEventDTOIPage); + } + + @Override + public List<CarEventVo> findPageExcel(PageWrap<CarEvent> pageWrap) { + IPage<CarEventDTO> carEventExcel = getDataInfo(pageWrap); + List<CarEventVo> newDataList = new ArrayList<>(); + if(null != carEventExcel && carEventExcel.getRecords().size() > 0) { + carEventExcel.getRecords().stream().forEach(obj->{ + CarEventVo vo = new CarEventVo(); + if(Constants.formatIntegerNum(obj.getEventType()) == HKConstants.EventTypes.PARK_LINE_IN.getKey()){ + vo.setEventTypeName(HKConstants.EventTypes.PARK_LINE_IN.getName()); + }else if(Constants.formatIntegerNum(obj.getEventType()) == HKConstants.EventTypes.PARK_PASS_IN.getKey()){ + vo.setEventTypeName(HKConstants.EventTypes.PARK_PASS_IN.getName()); + }else if(Constants.formatIntegerNum(obj.getEventType()) == HKConstants.EventTypes.PARK_LINE_OUT.getKey()){ + vo.setEventTypeName(HKConstants.EventTypes.PARK_LINE_OUT.getName()); + }else{ + vo.setEventTypeName(HKConstants.EventTypes.PARK_PASS_OUT.getName()); + } + if(null != obj.getPersonType()) { + if(Constants.ZERO == obj.getPersonType()){ + vo.setTypeName(Constants.Status.LW_FK.getDes()); + }else if(Constants.ONE == obj.getPersonType()) { + vo.setTypeName(Constants.Status.PT_FK.getDes()); + }else { + vo.setTypeName(Constants.Status.NB_FK.getDes()); + } + }else { + vo.setTypeName(""); + } + vo.setPlateNos(obj.getPlateNos()); + vo.setPersonName(obj.getPersonName()); + vo.setPersonPhone(obj.getPersonPhone()); + vo.setPersonCompanyName(obj.getPersonCompanyName()); + vo.setParkName(obj.getParkName()); + vo.setGateName(obj.getGateName()); + vo.setInoutType(obj.getInoutType()); + vo.setHappenTime(obj.getHappenTime()); + newDataList.add(vo); + }); + } + return newDataList; + } + + private IPage<CarEventDTO> getDataInfo(PageWrap<CarEvent> pageWrap) { //鏄惁鏄暟瀛� boolean number = Validator.isNumber(pageWrap.getModel().getKeyWords()); //鏄惁鍖呭惈涓枃 @@ -272,43 +332,66 @@ //鏄惁鍖呭惈鑻辨枃 boolean hasWord = ReUtil.contains(PatternPool.WORD, pageWrap.getModel().getKeyWords()); - IPage<VisitEvent> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); + IPage<CarEvent> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper<CarEvent> queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); queryWrapper.leftJoin(Cars.class,Cars::getCode,CarEvent::getPlateNos) - .leftJoin(Member.class,Member::getId,Cars::getMemberId) - .leftJoin(Company.class,Company::getId,Member::getCompanyId); + .leftJoin(Member.class,Member::getId,Cars::getMemberId) + .leftJoin(Company.class,Company::getId,Member::getCompanyId); queryWrapper.selectAll(CarEvent.class) - .selectAs(Member::getType,CarEventDTO::getPersonType) - .selectAs(Member::getPhone,CarEventDTO::getPersonPhone) - .selectAs(Member::getIdcardDecode,CarEventDTO::getPersonIdcardDecode) - .selectAs(Member::getName,CarEventDTO::getPersonName) - .selectAs(Company::getName,CarEventDTO::getPersonCompanyName); + .selectAs(Member::getType,CarEventDTO::getPersonType) + .selectAs(Member::getPhone,CarEventDTO::getPersonPhone) + .selectAs(Member::getIdcardDecode,CarEventDTO::getPersonIdcardDecode) + .selectAs(Member::getName,CarEventDTO::getPersonName) + .selectAs(Company::getName,CarEventDTO::getPersonCompanyName); queryWrapper.like(StringUtils.isNotBlank(pageWrap.getModel().getPlateNos()), - CarEvent::getPlateNos, - pageWrap.getModel().getPlateNos()) - .like(number, - Member::getPhone, - pageWrap.getModel().getKeyWords()) - .like((b || hasWord), - Member::getPhone, - pageWrap.getModel().getKeyWords()) - .like(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName()), - Company::getName, - pageWrap.getModel().getCompanyName()) - .eq(StringUtils.isNotBlank(pageWrap.getModel().getMemberType()), - Member::getType, - pageWrap.getModel().getMemberType()) - .eq(Objects.nonNull(pageWrap.getModel().getEventType()), - CarEvent::getEventType, - pageWrap.getModel().getEventType()) - .ge(Objects.nonNull(pageWrap.getModel().getStartTime()), - CarEvent::getCreateDate, pageWrap.getModel().getStartTime()) - .le(Objects.nonNull(pageWrap.getModel().getEndTime()), - CarEvent::getCreateDate, pageWrap.getModel().getEndTime()); + CarEvent::getPlateNos, + pageWrap.getModel().getPlateNos()) + .like(number, + Member::getPhone, + pageWrap.getModel().getKeyWords()) + .like((b || hasWord), + Member::getPhone, + pageWrap.getModel().getKeyWords()) + .like(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName()), + Company::getName, + pageWrap.getModel().getCompanyName()) + .eq(StringUtils.isNotBlank(pageWrap.getModel().getMemberType()), + Member::getType, + pageWrap.getModel().getMemberType()) + .eq(Objects.nonNull(pageWrap.getModel().getEventType()), + CarEvent::getEventType, + pageWrap.getModel().getEventType()) + .ge(Objects.nonNull(pageWrap.getModel().getStartTime()), + CarEvent::getCreateDate, pageWrap.getModel().getStartTime()) + .le(Objects.nonNull(pageWrap.getModel().getEndTime()), + CarEvent::getCreateDate, pageWrap.getModel().getEndTime()); IPage<CarEventDTO> carEventDTOIPage = carEventJoinMapper.selectJoinPage(page, CarEventDTO.class, queryWrapper); - - return PageData.from(carEventDTOIPage); + return carEventDTOIPage; } + + private List<CarEventDTO> newCarEventDTO(List<CarEventDTO> newCarEventDTOList) { + List<String> codes = Arrays.asList(Constants.FTP_RESOURCE_PATH,Constants.CAR_EVENT_IMG); + List<SystemDictData> list = systemDictDataMapper.list(codes); + Map<String,SystemDictData> dataMap = list.stream().collect(Collectors.toMap(SystemDictData::getLabel, Function.identity())); + List<CarEventDTO> newDataList = new ArrayList<>(); + newCarEventDTOList.stream().forEach(obj->{ + obj.setVehiclePicUrl(dataMap.get(Constants.FTP_RESOURCE_PATH).getCode() + +dataMap.get(Constants.CAR_EVENT_IMG).getCode() + +obj.getVehiclePicUrl()); + if(Constants.formatIntegerNum(obj.getEventType()) == HKConstants.EventTypes.PARK_LINE_IN.getKey()){ + obj.setEventTypeName(HKConstants.EventTypes.PARK_LINE_IN.getName()); + }else if(Constants.formatIntegerNum(obj.getEventType()) == HKConstants.EventTypes.PARK_PASS_IN.getKey()){ + obj.setEventTypeName(HKConstants.EventTypes.PARK_PASS_IN.getName()); + }else if(Constants.formatIntegerNum(obj.getEventType()) == HKConstants.EventTypes.PARK_LINE_OUT.getKey()){ + obj.setEventTypeName(HKConstants.EventTypes.PARK_LINE_OUT.getName()); + }else{ + obj.setEventTypeName(HKConstants.EventTypes.PARK_PASS_OUT.getName()); + } + newDataList.add(obj); + }); + return newDataList; + } + } -- Gitblit v1.9.3