diff --git a/pjcloud-supermarket/pjcloud-supermarket-api/src/main/java/com/bsd/pjcloud/supermarket/validarot/ErpSpuValidator.java b/pjcloud-supermarket/pjcloud-supermarket-api/src/main/java/com/bsd/pjcloud/supermarket/validarot/ErpSpuValidator.java index 1fe62ae27..a3ea4514e 100644 --- a/pjcloud-supermarket/pjcloud-supermarket-api/src/main/java/com/bsd/pjcloud/supermarket/validarot/ErpSpuValidator.java +++ b/pjcloud-supermarket/pjcloud-supermarket-api/src/main/java/com/bsd/pjcloud/supermarket/validarot/ErpSpuValidator.java @@ -21,18 +21,18 @@ public class ErpSpuValidator { if (StringUtils.isEmpty(entity.getUnit())) { errors.add("第" + (rowIndex + 1) + "行: 单位不能为空"); } - if (StringUtils.isEmpty(entity.getSpec())) { - errors.add("第" + (rowIndex + 1) + "行: 规格不能为空"); - } - if (StringUtils.isEmpty(entity.getClassification())) { - errors.add("第" + (rowIndex + 1) + "行: 分类不能为空"); - } - if (StringUtils.isEmpty(entity.getCommodityNature())) { - errors.add("第" + (rowIndex + 1) + "行: 商品性质不能为空"); - } - if (StringUtils.isEmpty(entity.getSupplier())) { - errors.add("第" + (rowIndex + 1) + "行: 货商不能为空"); - } +// if (StringUtils.isEmpty(entity.getSpec())) { +// errors.add("第" + (rowIndex + 1) + "行: 规格不能为空"); +// } +// if (StringUtils.isEmpty(entity.getClassification())) { +// errors.add("第" + (rowIndex + 1) + "行: 分类不能为空"); +// } +// if (StringUtils.isEmpty(entity.getCommodityNature())) { +// errors.add("第" + (rowIndex + 1) + "行: 商品性质不能为空"); +// } +// if (StringUtils.isEmpty(entity.getSupplier())) { +// errors.add("第" + (rowIndex + 1) + "行: 货商不能为空"); +// } if (null==entity.getPurchasePrice()) { errors.add("第" + (rowIndex + 1) + "行: 进价不能为空"); } diff --git a/pjcloud-supermarket/pjcloud-supermarket-biz/src/main/java/com/bsd/pjcloud/supermarket/controller/SmErpSpuController.java b/pjcloud-supermarket/pjcloud-supermarket-biz/src/main/java/com/bsd/pjcloud/supermarket/controller/SmErpSpuController.java index 6a021456d..c9964d334 100644 --- a/pjcloud-supermarket/pjcloud-supermarket-biz/src/main/java/com/bsd/pjcloud/supermarket/controller/SmErpSpuController.java +++ b/pjcloud-supermarket/pjcloud-supermarket-biz/src/main/java/com/bsd/pjcloud/supermarket/controller/SmErpSpuController.java @@ -231,14 +231,14 @@ public class SmErpSpuController { @PostMapping("/import") @PreAuthorize("@pms.hasPermission('supermarket_supermarketSpu_export')" ) public R importErpSpu(@RequestExcel List dtos, BindingResult bindingResult) { - List collect = dtos.stream().filter(smErpSpuImportDto -> smErpSpuImportDto.getProductCode() == null).collect(Collectors.toList()); + List collect = dtos.stream().filter(smErpSpuImportDto -> smErpSpuImportDto.getProductCode() != null).collect(Collectors.toList()); // String taskId = taskStoreService.createTask(dtos.size()); // smErpSpuService.asyncExecuteImport(taskId, collect); // return R.ok(Collections.singletonMap("taskId", taskId)); System.out.println(collect); - List collect1 = dtos.stream().filter(smErpSpuImportDto -> StringUtils.isBlank(smErpSpuImportDto.getClassification())).collect(Collectors.toList()); - System.out.println(collect1); - return smErpSpuService.importErpSpu(dtos, bindingResult); +// List collect1 = dtos.stream().filter(smErpSpuImportDto -> StringUtils.isBlank(smErpSpuImportDto.getClassification())).collect(Collectors.toList()); +// System.out.println(collect); + return smErpSpuService.importErpSpu(collect, bindingResult); } diff --git a/pjcloud-supermarket/pjcloud-supermarket-biz/src/main/java/com/bsd/pjcloud/supermarket/service/impl/SmErpSpuServiceImpl.java b/pjcloud-supermarket/pjcloud-supermarket-biz/src/main/java/com/bsd/pjcloud/supermarket/service/impl/SmErpSpuServiceImpl.java index 9fe569873..78ec4f74e 100644 --- a/pjcloud-supermarket/pjcloud-supermarket-biz/src/main/java/com/bsd/pjcloud/supermarket/service/impl/SmErpSpuServiceImpl.java +++ b/pjcloud-supermarket/pjcloud-supermarket-biz/src/main/java/com/bsd/pjcloud/supermarket/service/impl/SmErpSpuServiceImpl.java @@ -234,22 +234,25 @@ public class SmErpSpuServiceImpl extends ServiceImpl records = pageData.getRecords(); - Set erpSpuIds = records.stream().map(smErpSpuEntity -> smErpSpuEntity.getId()).collect(Collectors.toSet()); + if (CollectionUtils.isNotEmpty(records)){ + Set erpSpuIds = records.stream().map(smErpSpuEntity -> smErpSpuEntity.getId()).collect(Collectors.toSet()); // 批量查询库存信息 - List stocks = smErpStockMapper.selectList( + List stocks = smErpStockMapper.selectList( new LambdaQueryWrapper() .in(SmErpStockEntity::getErpSpuId, erpSpuIds)); // 建立SPU ID与库存的映射关系 - Map stockMap = stocks.stream() + Map stockMap = stocks.stream() .collect(Collectors.toMap(SmErpStockEntity::getErpSpuId,smErpStockEntity -> smErpStockEntity)); - records.forEach(spu -> - { - SmErpStockEntity smErpStockEntity = stockMap.get(spu.getId()); - spu.setStock(smErpStockEntity != null ? smErpStockEntity.getCurrentStock() : 0); - }); + records.forEach(spu -> + { + SmErpStockEntity smErpStockEntity = stockMap.get(spu.getId()); + spu.setStock(smErpStockEntity != null ? smErpStockEntity.getCurrentStock() : 0); + }); + } + return pageData; } @@ -853,6 +856,8 @@ public class SmErpSpuServiceImpl extends ServiceImpl dtos) { executor.execute(() -> { List> errors = new ArrayList<>();