|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.math.BigDecimal; | 
|---|
|  |  |  | import java.util.*; | 
|---|
|  |  |  | import java.util.concurrent.TimeUnit; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 车辆信息表Service实现 | 
|---|
|  |  |  | 
|---|
|  |  |  | 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(""); | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @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; | 
|---|