package com.doumee.service.business.impl; 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.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; import com.doumee.core.model.LoginUserInfo; 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.CarsQuery; import com.doumee.dao.admin.response.CarsDTO; import com.doumee.dao.business.CarsMapper; import com.doumee.dao.business.MemberMapper; import com.doumee.dao.business.join.CarJoinMapper; import com.doumee.dao.business.join.ParkBookJoinMapper; import com.doumee.dao.business.model.*; import com.doumee.dao.system.model.SystemUser; import com.doumee.service.business.CarsService; import com.doumee.service.business.impl.hksync.HkSyncParkServiceImpl; import com.github.yulichang.wrapper.MPJLambdaWrapper; import org.apache.commons.lang3.StringUtils; import org.apache.shiro.SecurityUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import java.util.*; /** * 车辆信息表Service实现 * @author 江蹄蹄 * @date 2023/11/30 15:33 */ @Service public class CarsServiceImpl implements CarsService { @Autowired private CarsMapper carsMapper; @Autowired private CarJoinMapper carJoinMapper; @Autowired private MemberMapper memberMapper; @Autowired private ParkBookJoinMapper parkBookJoinMapper; @Override public Integer create(Cars model) { LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); if(loginUserInfo == null){ loginUserInfo = model.getLoginUserInfo(); } if(StringUtils.isBlank(model.getCode()) ||model.getType()==null ||model.getCateId()==null ||model.getType()<0 ||model.getType()>3 ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } if(model.getMemberId()!=null){ //检查车主信息 Member member =memberMapper.selectOne(new QueryWrapper().lambda() .eq(Member::getId,model.getMemberId() ) .eq(Member::getType,Constants.TWO ) .eq(Member::getIsdeleted,Constants.ZERO) .last("limit 1")); if(member == null){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，车主信息不存在，请返回刷新重试!"); } model.setMemberHkId(member.getHkId()); } if(!Constants.checkCarNo(model.getCode())){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"请输入正确的车牌!"); }; //检查车牌号是否重复 if(carsMapper.selectCount(new QueryWrapper().lambda() .eq(Cars::getCode,model.getCode() ) .eq(Cars::getIsdeleted,Constants.ZERO ) ) >0){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，车辆已经录入，不能重复录入!"); } model.setType(Constants.formatIntegerNum(model.getType())); model.setCreateDate(new Date()); model.setCreator(loginUserInfo.getId()); model.setEditDate(new Date()); model.setEdirot(loginUserInfo.getId()); model.setStatus(Constants.ZERO); model.setIsdeleted(Constants.ZERO); model.setHkStatus(Constants.ZERO); model.setAuthStatus(Constants.ZERO); model.setRemark(""); // model.setHkDate(model.getCreateDate()); // model.setHkId(UUID.randomUUID().toString().replace("-","")); carsMapper.insert(model); return model.getId(); } @Override @Transactional(rollbackFor = {BusinessException.class,Exception.class}) public void deleteById(Integer id, LoginUserInfo user) { Cars car = carJoinMapper.selectById(id); if(car ==null ||Constants.equalsInteger(car.getIsdeleted(),Constants.ONE)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，车辆信息不存在！"); } Date date = new Date(); //删除已授权下发的包期授权 dealCancelBookBiz(car.getCode(),date); Cars model = new Cars(); model.setEditDate(date); model.setEdirot(user.getId()); model.setId(id); model.setIsdeleted(Constants.ONE); carsMapper.update(null,new UpdateWrapper().lambda() .eq(Cars::getId,model.getId()) .set(Cars::getStartTime,null) .set(Cars::getEndTime,null) .set(Cars::getAuthStatus,Constants.ZERO) .set(Cars::getIsdeleted,Constants.ONE) .set(Cars::getEditDate,model.getEditDate()) .set(Cars::getEdirot,model.getEdirot()) ); carsMapper.updateById(model); } public boolean dealCancelBookBiz(String code,Date date){ List parkBooks = parkBookJoinMapper.selectJoinList(ParkBook.class,new MPJLambdaWrapper() .selectAll(ParkBook.class ) .selectAs(Parks::getHkId,ParkBook::getParkHkId ) .leftJoin(Parks.class,Parks::getId,ParkBook::getParkId) .eq(ParkBook::getCarCode,code) .eq(ParkBook::getIsdeleted,Constants.ZERO )); if(parkBooks !=null){ for(ParkBook c : parkBooks){ //如果取消预约，则进行取消包期 if(StringUtils.isNotBlank(c.getParkHkId()) && StringUtils.isNotBlank(c.getCarCode())){ boolean result = HkSyncParkServiceImpl.cancelParkBookHk(c); if(!result){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，取消已下发授权失败，请联系管理员处理~"); } c.setHkStatus(Constants.ONE); c.setRemark("取消包期成功"); }else{ c.setHkStatus(Constants.TWO);//下发失败 c.setRemark("无效停车场授权下发，取消包期失败，直接删除记录"); } c.setHkDate(date); c.setIsdeleted(Constants.ONE); parkBookJoinMapper.updateById(c); } } return true; } @Override public void delete(Cars cars) { UpdateWrapper deleteWrapper = new UpdateWrapper<>(cars); carsMapper.delete(deleteWrapper); } @Override @Transactional(rollbackFor = {BusinessException.class,Exception.class}) public void deleteByIdInBatch(List ids, LoginUserInfo user) { if (CollectionUtils.isEmpty(ids)) { return; } for(Integer id : ids){ deleteById(id,user); } } @Override public void updateById(Cars model) { LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); if(loginUserInfo == null){ loginUserInfo = model.getLoginUserInfo(); } if(StringUtils.isBlank(model.getCode()) ||model.getId()==null ||model.getType()==null ||model.getCateId()==null ||model.getType()<0 ||model.getType()>3 ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } Cars car = carJoinMapper.selectById(model.getId()); if(car ==null ||Constants.equalsInteger(car.getIsdeleted(),Constants.ONE)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，车辆信息不存在！"); } if(!Constants.checkCarNo(model.getCode())){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"请输入正确的车牌!"); }; if(model.getMemberId()!=null){ //检查车主信息 Member member =memberMapper.selectOne(new QueryWrapper().lambda() .eq(Member::getId,model.getMemberId() ) .eq(Member::getType,Constants.TWO ) .eq(Member::getIsdeleted,Constants.ZERO) .last("limit 1")); if(member == null){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，车主信息不存在，请返回刷新重试!"); } model.setMemberHkId(member.getHkId()); } //检查车牌号是否重复 if(carsMapper.selectCount(new QueryWrapper().lambda() .eq(Cars::getCode,model.getCode() ) .ne(Cars::getId,model.getId() ) .eq(Cars::getIsdeleted,Constants.ZERO ) ) >0){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，车辆已经录入，不能重复录入!"); } model.setType(Constants.formatIntegerNum(model.getType())); model.setEditDate(new Date()); model.setEdirot(loginUserInfo.getId()); model.setIsdeleted(Constants.ZERO); model.setHkStatus(Constants.ZERO); model.setRemark(""); model.setAuthStatus(Constants.ZERO); dealCancelBookBiz(model.getCode(),model.getEditDate()); carsMapper.update(null,new UpdateWrapper().lambda() .eq(Cars::getId,model.getId()) .set(Cars::getAuthStatus,Constants.ZERO) .set(Cars::getType,model.getType()) .set(Cars::getCode,model.getCode()) .set(Cars::getGroupId,model.getGroupId()) .set(Cars::getCateId,model.getCateId()) .set(Cars::getEditDate,model.getEditDate()) .set(Cars::getEdirot,model.getEdirot()) .set(Cars::getMemberId,model.getMemberId()) .set(Cars::getStartTime,null) .set(Cars::getEndTime,null) ); } @Override public void updateByIdInBatch(List carss) { if (CollectionUtils.isEmpty(carss)) { return; } for (Cars cars: carss) { this.updateById(cars); } } @Override public Cars findById(Integer id) { return carsMapper.selectById(id); } @Override public Cars findOne(Cars cars) { QueryWrapper wrapper = new QueryWrapper<>(cars); return carsMapper.selectOne(wrapper); } @Override public List findList(Cars cars) { QueryWrapper wrapper = new QueryWrapper<>(cars); wrapper.lambda().eq(Cars::getIsdeleted,Constants.ZERO); return carsMapper.selectList(wrapper); } @Override public PageData findPage(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); queryWrapper.selectAll(Cars.class); queryWrapper.selectAs(Member::getType,Cars::getMemberType); queryWrapper.selectAs(Member::getName,Cars::getMemberName); queryWrapper.selectAs(SystemUser::getRealname,Cars::getEditorName); queryWrapper.selectAs(Member::getPhone,Cars::getMemberPhone); queryWrapper.selectAs(Company::getCompanyNamePath,Cars::getCompanyName); queryWrapper.selectAs(Category::getParentId,Cars::getCatePId); queryWrapper.selectAs(Category::getName,Cars::getCateName); queryWrapper.select(" c.name as catePName"); queryWrapper.select(" c1.COMPANY_NAME_PATH as carCompanyNamePath"); queryWrapper.select(" c1.name as carCompanyName"); queryWrapper.leftJoin(Member.class,Member::getId,Cars::getMemberId); queryWrapper.leftJoin(SystemUser.class,SystemUser::getId,Cars::getEdirot); queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId); queryWrapper.leftJoin(Category.class,Category::getId,Cars::getCateId); queryWrapper.leftJoin("category c on t4.PARENT_ID = c.id"); queryWrapper.leftJoin("company c1 on t.GROUP_ID = c1.id"); queryWrapper.and(StringUtils.isNotBlank(pageWrap.getModel().getMemberName()), ms->ms.like(Member::getName,pageWrap.getModel().getMemberName()) .or().like(Member::getPhone,pageWrap.getModel().getMemberName())); queryWrapper.like(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName()),Company::getCompanyNamePath,pageWrap.getModel().getCompanyName()); queryWrapper.eq(Objects.nonNull(pageWrap.getModel().getMemberType()),Member::getType,pageWrap.getModel().getMemberType()); queryWrapper.like(StringUtils.isNotBlank(pageWrap.getModel().getCode()),Cars::getCode,pageWrap.getModel().getCode()); queryWrapper.eq(Cars::getIsdeleted,Constants.ZERO); queryWrapper.eq(pageWrap.getModel().getType()!=null,Cars::getType,pageWrap.getModel().getType()); queryWrapper.eq(pageWrap.getModel().getAuthStatus()!=null,Cars::getAuthStatus,pageWrap.getModel().getAuthStatus()); queryWrapper.orderByDesc(Cars::getCreateDate); //数据权限开始--------------------start---------------- LoginUserInfo userInfo =pageWrap.getModel().getLoginUserInfo(); if(userInfo!=null && userInfo.getCompanyIdList()!=null){ if( userInfo.getCompanyIdList().size() ==0){ //只能看自己(拜访人） queryWrapper.eq(Cars::getMemberId,userInfo.getMemberId()); }else{ queryWrapper.in(Cars::getGroupId ,userInfo.getCompanyIdList()); } } //数据权限开始--------------------end---------------- IPage result = carJoinMapper.selectJoinPage(page, Cars.class,queryWrapper); if(result!=null && result.getRecords()!=null && result.getRecords().size()>0){ List codes = new ArrayList<>(); for(Cars cars :result.getRecords()){ codes.add(cars.getCode()); } List parkBooks = parkBookJoinMapper.selectJoinList(ParkBook.class,new MPJLambdaWrapper() .selectAll(ParkBook.class) .selectAs(Parks::getName,ParkBook::getParksName) .leftJoin(Parks.class,Parks::getId,ParkBook::getParkId) .in(ParkBook::getCarCode,codes) .eq(ParkBook::getIsdeleted,Constants.ZERO) ); for(Cars cars :result.getRecords()){ cars.setParkBookList(getParkbookListByCode(cars.getCode(),parkBooks)); } } return PageData.from(result); } private List getParkbookListByCode(String code, List parkBooks) { List list =null; for(ParkBook p : parkBooks){ if(StringUtils.equals(p.getCarCode(),code)){ if(list == null){ list = new ArrayList<>(); } list.add(p); } } return list; } @Override public long count(Cars cars) { QueryWrapper wrapper = new QueryWrapper<>(cars); return carsMapper.selectCount(wrapper); } @Override public PageData findCarPage(PageWrap pageWrap) { MPJLambdaWrapper wrapper = new MPJLambdaWrapper<>(); IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); Utils.MP.blankToNull(pageWrap.getModel()); wrapper.leftJoin(Member.class,Member::getId,ParkBook::getMemberId) .leftJoin(Company.class,Company::getId,Member::getCompanyId) .leftJoin(Parks.class,Parks::getId,ParkBook::getParkId); wrapper.selectAs(ParkBook::getCarCode,CarsDTO::getCode) .selectAs(ParkBook::getParkId,CarsDTO::getParkId) .selectAs(ParkBook::getRemark,CarsDTO::getRemark) .selectAs(Parks::getName,CarsDTO::getParkName) .selectAs(ParkBook::getMemberId,CarsDTO::getMemberId) .selectAs(Member::getName,CarsDTO::getMemberName) .selectAs(Member::getType,CarsDTO::getMemberType) .selectAs(Company::getName,CarsDTO::getCompanyName) .selectAs(ParkBook::getTimeType,CarsDTO::getTimeType) .selectAs(ParkBook::getStartTime,CarsDTO::getStartTime) .selectAs(ParkBook::getEndTime,CarsDTO::getEndTime) .selectAs(ParkBook::getCreateDate,CarsDTO::getCreateDate); wrapper.orderByDesc(ParkBook::getCreateDate); IPage carsDTOIPage = parkBookJoinMapper.selectJoinPage(page, CarsDTO.class, wrapper); return PageData.from(carsDTOIPage); } }