|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.math.BigDecimal; | 
|---|
|  |  |  | import java.util.*; | 
|---|
|  |  |  | import java.util.concurrent.TimeUnit; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 车辆信息表Service实现 | 
|---|
|  |  |  | 
|---|
|  |  |  | if(loginUserInfo == null){ | 
|---|
|  |  |  | loginUserInfo = model.getLoginUserInfo(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(StringUtils.isBlank(model.getCode()) | 
|---|
|  |  |  | /*    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){ | 
|---|
|  |  |  | //检查车主信息 | 
|---|
|  |  |  | 
|---|
|  |  |  | model.setCreateDate(new Date()); | 
|---|
|  |  |  | model.setCreator(loginUserInfo.getId()); | 
|---|
|  |  |  | model.setEditDate(new Date()); | 
|---|
|  |  |  | model.setIsdeleted(Constants.ZERO); | 
|---|
|  |  |  | model.setEdirot(loginUserInfo.getId()); | 
|---|
|  |  |  | model.setStatus(Constants.ZERO); | 
|---|
|  |  |  | model.setIsdeleted(Constants.ZERO); | 
|---|
|  |  |  | model.setHkStatus(Constants.ZERO); | 
|---|
|  |  |  | model.setAuthStatus(Constants.ZERO); | 
|---|
|  |  |  | model.setRemark(""); | 
|---|
|  |  |  | 
|---|
|  |  |  | if(loginUserInfo == null){ | 
|---|
|  |  |  | loginUserInfo = model.getLoginUserInfo(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(StringUtils.isBlank(model.getCode()) | 
|---|
|  |  |  | /* if(StringUtils.isBlank(model.getCode()) | 
|---|
|  |  |  | ||model.getId()==null | 
|---|
|  |  |  | ||model.getType()==null | 
|---|
|  |  |  | ||model.getCateId()==null | 
|---|
|  |  |  | 
|---|
|  |  |  | ||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(),"对不起,车辆信息不存在!"); | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public List<Cars> findList(Cars cars) { | 
|---|
|  |  |  | if(Objects.nonNull(cars) && Objects.nonNull(cars.getType()) | 
|---|
|  |  |  | && Constants.equalsInteger(Constants.ZERO,cars.getType())){ | 
|---|
|  |  |  | return this.getGwCar(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cars.setType(null); | 
|---|
|  |  |  | QueryWrapper<Cars> wrapper = new QueryWrapper<>(cars); | 
|---|
|  |  |  | wrapper.lambda().eq(Cars::getIsdeleted,Constants.ZERO); | 
|---|
|  |  |  | return carsMapper.selectList(wrapper); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public List<Cars> getGwCar(){ | 
|---|
|  |  |  | List<Cars> list  = carsMapper.selectJoinList(Cars.class, | 
|---|
|  |  |  | new MPJLambdaWrapper<Cars>().selectAll(Cars.class) | 
|---|
|  |  |  | .leftJoin(Category.class,Category::getId,Cars::getCateId) | 
|---|
|  |  |  | .eq(Category::getBizType,Constants.FOUR) | 
|---|
|  |  |  | .eq(Cars::getIsdeleted,Constants.ZERO) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | return list; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public PageData<Cars> findPage(PageWrap<Cars> pageWrap) { | 
|---|
|  |  |  | 
|---|
|  |  |  | if(importing!=null && importing){ | 
|---|
|  |  |  | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,已存在车辆导入任务正在执行中,请稍后再试!"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | redisTemplate.opsForValue().set(Constants.RedisKeys.IMPORTING_CARS,true); | 
|---|
|  |  |  | redisTemplate.opsForValue().set(Constants.RedisKeys.IMPORTING_CARS,true,30, TimeUnit.MINUTES); | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | ExcelImporter ie = null; | 
|---|
|  |  |  | List<CarsImport> dataList =null; | 
|---|
|  |  |  | 
|---|
|  |  |  | model.setPhone(ScientificNotationTUtil.convertToString(model.getPhone())); | 
|---|
|  |  |  | if(StringUtils.isBlank(model.getCode()) | 
|---|
|  |  |  | &&StringUtils.isBlank(model.getCategoryName()) | 
|---|
|  |  |  | &&StringUtils.isBlank(model.getType()) | 
|---|
|  |  |  | //                        &&StringUtils.isBlank(model.getType()) | 
|---|
|  |  |  | &&StringUtils.isBlank(model.getSex()) | 
|---|
|  |  |  | &&StringUtils.isBlank(model.getIdcard()) | 
|---|
|  |  |  | &&StringUtils.isBlank(model.getParkName()) | 
|---|
|  |  |  | 
|---|
|  |  |  | ,List<Company> companyList | 
|---|
|  |  |  | ,List<Category> categoryList ) { | 
|---|
|  |  |  | if(StringUtils.isBlank(model.getCode()) | 
|---|
|  |  |  | ||StringUtils.isBlank(model.getType()) | 
|---|
|  |  |  | //                ||StringUtils.isBlank(model.getType()) | 
|---|
|  |  |  | ||StringUtils.isBlank(model.getCategoryName()) | 
|---|
|  |  |  | ||StringUtils.isBlank(model.getCompanyName())){ | 
|---|
|  |  |  | throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,第"+(index+2)+"行车辆信息不完整,请检查表格内容!"); | 
|---|
|  |  |  | 
|---|
|  |  |  | cars.setIsnew(Constants.ZERO); | 
|---|
|  |  |  | updateList.add(cars); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //类型 0安泰公务车 1安泰自有物流车 2其它 | 
|---|
|  |  |  | /*  //类型 0安泰公务车 1安泰自有物流车 2其它 | 
|---|
|  |  |  | if(StringUtils.equals(model.getType(),"安泰公务车")){ | 
|---|
|  |  |  | cars.setType(Constants.ZERO); | 
|---|
|  |  |  | }else if(StringUtils.equals(model.getType(),"安泰自有物流车")){ | 
|---|
|  |  |  | cars.setType(Constants.ONE); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | cars.setType(Constants.TWO); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }*/ | 
|---|
|  |  |  | cars.setCode(model.getCode()); | 
|---|
|  |  |  | Company company = findCompanyFromList(model.getCompanyName(),companyList); | 
|---|
|  |  |  | if(company == null){ | 
|---|