package com.doumee.service.business.impl; import cn.hutool.core.lang.PatternPool; import cn.hutool.core.lang.Validator; import cn.hutool.core.util.ReUtil; import com.doumee.dao.business.vo.RetentionCarsVO; import com.doumee.service.business.third.model.PageData; import com.doumee.service.business.third.model.PageWrap; import com.doumee.core.utils.Constants; import com.doumee.core.utils.Utils; import com.doumee.dao.business.RetentionMapper; import com.doumee.dao.business.join.RetentionJoinMapper; import com.doumee.dao.business.model.*; import com.doumee.dao.business.vo.RetentionVo; import com.doumee.dao.system.SystemDictDataMapper; import com.doumee.dao.system.model.SystemDictData; import com.doumee.service.business.RetentionService; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.github.yulichang.wrapper.MPJLambdaWrapper; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import java.util.*; import java.util.function.Function; import java.util.stream.Collectors; /** * 在厂人员信息 表(滞留)Service实现 * @author 江蹄蹄 * @date 2023/11/30 15:33 */ @Service public class RetentionServiceImpl implements RetentionService { @Autowired private RetentionMapper retentionMapper; @Autowired private RetentionJoinMapper retentionJoinMapper; @Autowired private SystemDictDataMapper systemDictDataMapper; @Override public Integer create(Retention retention) { retentionMapper.insert(retention); return retention.getId(); } @Override public void deleteById(Integer id) { // retentionMapper.update(null,new UpdateWrapper().lambda().set(Retention::getIsdeleted,Constants.ONE) // .eq(Retention::getId,id)); retentionMapper.deleteById(id); } @Override public void delete(Retention retention) { UpdateWrapper deleteWrapper = new UpdateWrapper<>(retention); retentionMapper.delete(deleteWrapper); } @Override public void deleteByIdInBatch(List ids) { if (CollectionUtils.isEmpty(ids)) { return; } retentionMapper.deleteBatchIds(ids); } @Override public void updateById(Retention retention) { retentionMapper.updateById(retention); } @Override public void updateByIdInBatch(List retentions) { if (CollectionUtils.isEmpty(retentions)) { return; } for (Retention retention: retentions) { this.updateById(retention); } } @Override public Retention findById(Integer id) { return retentionMapper.selectById(id); } @Override public Retention findOne(Retention retention) { QueryWrapper wrapper = new QueryWrapper<>(retention); return retentionMapper.selectOne(wrapper); } @Override public List findList(Retention retention) { QueryWrapper wrapper = new QueryWrapper<>(retention); return retentionMapper.selectList(wrapper); } @Override public PageData findPage(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); QueryWrapper queryWrapper = new QueryWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); if (pageWrap.getModel().getId() != null) { queryWrapper.lambda().eq(Retention::getId, pageWrap.getModel().getId()); } if (pageWrap.getModel().getCreator() != null) { queryWrapper.lambda().eq(Retention::getCreator, pageWrap.getModel().getCreator()); } if (pageWrap.getModel().getCreateDate() != null) { queryWrapper.lambda().ge(Retention::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())); queryWrapper.lambda().le(Retention::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())); } if (pageWrap.getModel().getEditor() != null) { queryWrapper.lambda().eq(Retention::getEditor, pageWrap.getModel().getEditor()); } if (pageWrap.getModel().getEditDate() != null) { queryWrapper.lambda().ge(Retention::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())); queryWrapper.lambda().le(Retention::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())); } if (pageWrap.getModel().getIsdeleted() != null) { queryWrapper.lambda().eq(Retention::getIsdeleted, pageWrap.getModel().getIsdeleted()); } if (pageWrap.getModel().getRemark() != null) { queryWrapper.lambda().eq(Retention::getRemark, pageWrap.getModel().getRemark()); } if (pageWrap.getModel().getCompanyId() != null) { queryWrapper.lambda().eq(Retention::getCompanyId, pageWrap.getModel().getCompanyId()); } if (pageWrap.getModel().getFaceImg() != null) { queryWrapper.lambda().eq(Retention::getFaceImg, pageWrap.getModel().getFaceImg()); } if (pageWrap.getModel().getImgurl() != null) { queryWrapper.lambda().eq(Retention::getImgurl, pageWrap.getModel().getImgurl()); } if (pageWrap.getModel().getType() != null) { queryWrapper.lambda().eq(Retention::getType, pageWrap.getModel().getType()); } if (pageWrap.getModel().getName() != null) { queryWrapper.lambda().eq(Retention::getName, pageWrap.getModel().getName()); } if (pageWrap.getModel().getBirthday() != null) { queryWrapper.lambda().ge(Retention::getBirthday, Utils.Date.getStart(pageWrap.getModel().getBirthday())); queryWrapper.lambda().le(Retention::getBirthday, Utils.Date.getEnd(pageWrap.getModel().getBirthday())); } if (pageWrap.getModel().getPhone() != null) { queryWrapper.lambda().eq(Retention::getPhone, pageWrap.getModel().getPhone()); } if (pageWrap.getModel().getIdcardNo() != null) { queryWrapper.lambda().eq(Retention::getIdcardNo, pageWrap.getModel().getIdcardNo()); } if (pageWrap.getModel().getIdcardDecode() != null) { queryWrapper.lambda().eq(Retention::getIdcardDecode, pageWrap.getModel().getIdcardDecode()); } if (pageWrap.getModel().getCode() != null) { queryWrapper.lambda().eq(Retention::getCode, pageWrap.getModel().getCode()); } if (pageWrap.getModel().getClasses() != null) { queryWrapper.lambda().eq(Retention::getClasses, pageWrap.getModel().getClasses()); } if (pageWrap.getModel().getEventDate() != null) { queryWrapper.lambda().ge(Retention::getEventDate, Utils.Date.getStart(pageWrap.getModel().getEventDate())); queryWrapper.lambda().le(Retention::getEventDate, Utils.Date.getEnd(pageWrap.getModel().getEventDate())); } if (pageWrap.getModel().getMemberId() != null) { queryWrapper.lambda().eq(Retention::getMemberId, pageWrap.getModel().getMemberId()); } if (pageWrap.getModel().getEventCode() != null) { queryWrapper.lambda().eq(Retention::getEventCode, pageWrap.getModel().getEventCode()); } for(PageWrap.SortData sortData: pageWrap.getSorts()) { if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { queryWrapper.orderByDesc(sortData.getProperty()); } else { queryWrapper.orderByAsc(sortData.getProperty()); } } return PageData.from(retentionMapper.selectPage(page, queryWrapper)); } @Override public long count(Retention retention) { QueryWrapper wrapper = new QueryWrapper<>(retention); return retentionMapper.selectCount(wrapper); } @Override public PageData findTrainTimePage(PageWrap pageWrap) { IPage retentionIPage = getDataInfo(pageWrap); if(null != retentionIPage && retentionIPage.getRecords().size() > 0) { List codes = Arrays.asList(Constants.FTP_RESOURCE_PATH,Constants.MEMBER_IMG); List list = systemDictDataMapper.list(codes); Map dataMap = list.stream().collect(Collectors.toMap(SystemDictData::getLabel, Function.identity())); retentionIPage.getRecords().stream().forEach(obj->{ obj.setTypeName(Constants.Status.COMPANY_TYPE_FK.getDes()); if(null != obj.getCompanyType()) { if(Constants.ZERO == obj.getCompanyType()){ obj.setTypeName(Constants.Status.COMPANY_TYPE_REL.getDes()); }else if(Constants.ONE == obj.getCompanyType()) { obj.setTypeName(Constants.Status.COMPANY_TYPE_INTERNAL.getDes()); } } if(StringUtils.isNotBlank(obj.getFaceImg())){ obj.setFaceImgFull(dataMap.get(Constants.FTP_RESOURCE_PATH).getCode() +dataMap.get(Constants.MEMBER_IMG).getCode() +obj.getFaceImg()); } if(Objects.nonNull(obj.getType())){ if(!obj.getType().equals(Constants.memberType.visitor)){ obj.setExcelCompanyName(obj.getCompanyName()); }else{ obj.setExcelCompanyName(obj.getVisitCompanyName()); } } }); } return PageData.from(retentionIPage); } @Override public PageData findPageForCars(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); queryWrapper.select(Retention::getId,Retention::getCarNo,Retention::getCreateDate,Retention::getCarType,Retention::getType) .leftJoin(Member.class,Member::getId,Retention::getMemberId) .leftJoin(Member.class,Member::getId,Retention::getMemberId) .leftJoin(Company.class,Company::getId,Member::getCompanyId) .leftJoin(Category.class,Category::getId,Retention::getCategoryId) .selectAs(Company::getCompanyNamePath,Retention::getCompanyName) .selectAs(Member::getName,Retention::getName) .selectAs(Category::getName,Retention::getCategoryName) .selectAs(Member::getPhone,Retention::getPhone) .selectAs(Member::getVisitCompanyName,Retention::getVisitCompanyName) .and(StringUtils.isNotBlank(pageWrap.getModel().getKeyWords()),w->{ w.like( Member::getPhone,pageWrap.getModel().getKeyWords()) .or().like( Member::getName,pageWrap.getModel().getKeyWords()); }) .eq(Retention::getType,3) .eq(Retention::getIsdeleted,Constants.ZERO) .and(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName()), p-> p.like(Company::getName, pageWrap.getModel().getCompanyName()) .or().like(Member::getVisitCompanyName, pageWrap.getModel().getCompanyName())) // .eq(Objects.nonNull(pageWrap.getModel().getCarType()), // Retention::getCarType,pageWrap.getModel().getCarType()) .like(Objects.nonNull(pageWrap.getModel().getCarNo()), Retention::getCarNo,pageWrap.getModel().getCarNo()) .like(Objects.nonNull(pageWrap.getModel().getCategoryName()), Retention::getCategoryName,pageWrap.getModel().getCategoryName()) .ge(Objects.nonNull(pageWrap.getModel().getStartTime()), Retention::getCreateDate,pageWrap.getModel().getStartTime()) .le(Objects.nonNull(pageWrap.getModel().getEndTime()), Retention::getCreateDate,pageWrap.getModel().getEndTime()); queryWrapper.orderByDesc(Retention::getCreateDate); IPage retentionIPage = retentionJoinMapper.selectJoinPage(page, RetentionCarsVO.class, queryWrapper); if(retentionIPage!=null && retentionIPage.getRecords()!=null){ for(RetentionCarsVO model : retentionIPage.getRecords()){ model.setCompanyName(StringUtils.defaultString(model.getCompanyName(),model.getVisitCompanyName())); } } return PageData.from(retentionIPage); } @Override public List findPageExcel(PageWrap pageWrap) { IPage retentionInfo = getDataInfo(pageWrap); List retentionVoList = new ArrayList<>(); if(null != retentionInfo && retentionInfo.getRecords().size() > 0) { for (Retention obj:retentionInfo.getRecords()) { RetentionVo vo = new RetentionVo(); vo.setCompanyName(obj.getCompanyName()); vo.setTypeName(Constants.Status.COMPANY_TYPE_FK.getDes()); if(null != obj.getCompanyType()) { if(Constants.ZERO == obj.getCompanyType()){ vo.setTypeName(Constants.Status.COMPANY_TYPE_REL.getDes()); }else if(Constants.ONE == obj.getCompanyType()) { vo.setTypeName(Constants.Status.COMPANY_TYPE_INTERNAL.getDes()); } } vo.setName(obj.getName()); vo.setPhone(obj.getPhone()); vo.setIdcardNo(obj.getIdcardNo()); vo.setDeviceName(obj.getDeviceName()); vo.setEventDate(obj.getEventDate()); retentionVoList.add(vo); } } return retentionVoList; } private IPage getDataInfo(PageWrap pageWrap) { //是否是数字 // boolean number = Validator.isNumber(pageWrap.getModel().getKeyWords()); // //是否包含中文 // boolean b = Validator.hasChinese(pageWrap.getModel().getKeyWords()); // //是否包含英文 // boolean hasWord = ReUtil.contains(PatternPool.WORD, pageWrap.getModel().getKeyWords()); IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); queryWrapper.leftJoin(Company.class,Company::getId,Retention::getCompanyId); queryWrapper.selectAll(Retention.class) .selectAs(Company::getName,Retention::getCompanyName) .selectAs(Company::getType,Retention::getCompanyType) .select(" ( SELECT v.company_name FROM visits v WHERE v.member_id = t.member_id and v.status = "+Constants.VisitStatus.signin+" ORDER BY create_date DESC limit 1 ) as visitCompanyName ") .selectAs(Category::getBizType,Retention::getBizType) .leftJoin(Category.class,Category::getId,Retention::getCategoryId) .eq(Retention::getIsdeleted,Constants.ZERO) // .eq(Company::getIsdeleted,Constants.ZERO) .and(StringUtils.isNotBlank(pageWrap.getModel().getKeyWords()),w->{ w.like( Retention::getPhone,pageWrap.getModel().getKeyWords()) .or().like( Retention::getName,pageWrap.getModel().getKeyWords()); }) .eq(Objects.nonNull(pageWrap.getModel().getType()), Retention::getType, pageWrap.getModel().getType()) .isNull(Objects.nonNull(pageWrap.getModel().getQueryUserType())&&Constants.equalsInteger(pageWrap.getModel().getQueryUserType(),Constants.ZERO), Retention::getCompanyId) .eq(Objects.nonNull(pageWrap.getModel().getQueryUserType())&&Constants.equalsInteger(pageWrap.getModel().getQueryUserType(),Constants.ONE), Retention::getType,Constants.FOUR) .eq(Objects.nonNull(pageWrap.getModel().getQueryUserType())&&Constants.equalsInteger(pageWrap.getModel().getQueryUserType(),Constants.TWO), Retention::getType,Constants.TWO) .eq(Objects.nonNull(pageWrap.getModel().getBizType()), Category::getBizType,pageWrap.getModel().getBizType()) //过滤车辆数据 .ne(Retention::getType,3) .and(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName()), p-> p.like(Company::getName, pageWrap.getModel().getCompanyName()) .or() .exists(" select 1 from visits v where v.member_id = t.member_id and v.company_name like '%"+pageWrap.getModel().getCompanyName()+"%' and v.status = "+Constants.VisitStatus.signin+"")) .ge(Objects.nonNull(pageWrap.getModel().getStartTime()), Retention::getEventDate,pageWrap.getModel().getStartTime()) .le(Objects.nonNull(pageWrap.getModel().getEndTime()), Retention::getEventDate,pageWrap.getModel().getEndTime()); queryWrapper.orderByDesc(Retention::getCreateDate); IPage retentionIPage = retentionJoinMapper.selectJoinPage(page, Retention.class, queryWrapper); return retentionIPage; } }