| | |
| | | private final OssBuilder ossBuilder; |
| | | private final ICodeGeneratorService codeGeneratorService; |
| | | |
| | | private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) { |
| | | String implMethodName = lambda.getImplMethodName(); |
| | | boolean z = true; |
| | | switch (implMethodName.hashCode()) { |
| | | case -75622813: |
| | | if (implMethodName.equals("getCode")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case -75308287: |
| | | if (implMethodName.equals("getName")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case 771206363: |
| | | if (implMethodName.equals("getTenantId")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case 803533544: |
| | | if (implMethodName.equals("getStatus")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case 837211371: |
| | | if (implMethodName.equals("getTypeId")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case 961079513: |
| | | if (implMethodName.equals("getIsDeleted")) { |
| | | z = false; |
| | | break; |
| | | } |
| | | break; |
| | | case 1084758859: |
| | | if (implMethodName.equals("getProperty")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | } |
| | | switch (z) { |
| | | case false: |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) { |
| | | return (v0) -> { |
| | | return v0.getIsDeleted(); |
| | | }; |
| | | } |
| | | break; |
| | | case true: |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/Material") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) { |
| | | return (v0) -> { |
| | | return v0.getProperty(); |
| | | }; |
| | | } |
| | | break; |
| | | case true: |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/Material") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getName(); |
| | | }; |
| | | } |
| | | break; |
| | | case true: |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) { |
| | | return (v0) -> { |
| | | return v0.getStatus(); |
| | | }; |
| | | } |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) { |
| | | return (v0) -> { |
| | | return v0.getStatus(); |
| | | }; |
| | | } |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) { |
| | | return (v0) -> { |
| | | return v0.getStatus(); |
| | | }; |
| | | } |
| | | break; |
| | | case true: |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/tenant/mp/TenantEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getTenantId(); |
| | | }; |
| | | } |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/tenant/mp/TenantEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getTenantId(); |
| | | }; |
| | | } |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/tenant/mp/TenantEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getTenantId(); |
| | | }; |
| | | } |
| | | break; |
| | | case RegionCache.VILLAGE_LEVEL /* 5 */: |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/Material") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getTypeId(); |
| | | }; |
| | | } |
| | | break; |
| | | case true: |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/Material") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getCode(); |
| | | }; |
| | | } |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/Material") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getCode(); |
| | | }; |
| | | } |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/Material") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getCode(); |
| | | }; |
| | | } |
| | | break; |
| | | } |
| | | throw new IllegalArgumentException("Invalid lambda deserialization"); |
| | | } |
| | | |
| | | public MaterialServiceImpl(final IMaterialTypeService materialTypeService, final OssBuilder ossBuilder, final ICodeGeneratorService codeGeneratorService) { |
| | | this.materialTypeService = materialTypeService; |
| | |
| | | @Override // org.springblade.modules.cps.service.IMaterialService |
| | | public List<MaterialVO> listByProperty(Integer property) { |
| | | List<MaterialType> materialTypeList = this.materialTypeService.list(); |
| | | Map<Long, MaterialType> typeIdToValue = (Map) materialTypeList.stream().collect(Collectors.toMap((v0) -> { |
| | | Map<Long, MaterialType> typeIdToValue = materialTypeList.stream().collect(Collectors.toMap((v0) -> { |
| | | return v0.getId(); |
| | | }, v -> { |
| | | return v; |
| | | })); |
| | | List<Material> materialList = list(Wrappers.<Material>lambdaQuery() |
| | | .eq(Material::getProperty, property) |
| | | .eq(Material::getStatus, CommonConstant.ENABLE)); |
| | | /* |
| | | List<Material> materialList = list((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getProperty(); |
| | | }, property)).eq((v0) -> { |
| | | return v0.getStatus(); |
| | | }, CommonConstant.ENABLE)); |
| | | }, CommonConstant.ENABLE));*/ |
| | | List<MaterialVO> materialVoList = MaterialConvert.INSTANCE.convertList(materialList); |
| | | materialVoList.forEach(materialVo -> { |
| | | MaterialType materialType = (MaterialType) typeIdToValue.get(materialVo.getTypeId()); |
| | |
| | | @Override // org.springblade.modules.cps.service.IMaterialService |
| | | public IPage<MaterialVO> getPageMaterial(MaterialQueryVO vo, Query query) { |
| | | Integer status = Func.isNull(vo.getStatus()) ? CommonConstant.ENABLE : vo.getStatus(); |
| | | |
| | | QueryWrapper<MaterialQueryVO> wrapper = Wrappers.<MaterialQueryVO>query().eq("bm.status", status) |
| | | .eq(!Func.isNull(vo.getProperty()), "property", vo.getProperty()) |
| | | .eq(!Func.isNull(vo.getTypeId()), "bm.type_id", vo.getTypeId()) |
| | | .and(Func.isNotBlank(vo.getKeyWord()), i -> i.likeRight("bm.name", vo.getKeyWord()).or().likeRight("bm.code", vo.getKeyWord())) |
| | | .orderByDesc("bm.create_time", new String[] { "bm.id" }); |
| | | |
| | | /* |
| | | Wrapper<MaterialQueryVO> wrapper = (QueryWrapper) ((QueryWrapper) Wrappers.query().eq("bm.status", status)).eq(!Func.isNull(vo.getProperty()), "property", vo.getProperty()).eq(!Func.isNull(vo.getTypeId()), "bm.type_id", vo.getTypeId()).and(Func.isNotBlank(vo.getKeyWord()), i -> { |
| | | QueryWrapper queryWrapper = (QueryWrapper) ((QueryWrapper) ((QueryWrapper) i.likeRight("bm.name", vo.getKeyWord())).or()).likeRight("bm.code", vo.getKeyWord()); |
| | | }).orderByDesc("bm.create_time", new String[]{"bm.id"}); |
| | | */ |
| | | return this.baseMapper.getPageMaterial(Condition.getPage(query), Func.isNotBlank(wrapper.getSqlSegment()) ? wrapper : null); |
| | | } |
| | | |
| | | @Override // org.springblade.modules.cps.service.IMaterialService |
| | | public boolean checkMaterialIsExist(List<Long> idList) { |
| | | List<Material> materialList = list(Wrappers.<Material>query().lambda() |
| | | .eq(Func.isNotEmpty(AuthUtil.getTenantId()), Material::getTenantId, AuthUtil.getTenantId()) |
| | | .in(Material::getTypeId, idList) |
| | | .eq(Material::getIsDeleted, 0)); |
| | | /* |
| | | List<Material> materialList = list((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq(Func.isNotEmpty(AuthUtil.getTenantId()), (v0) -> { |
| | | return v0.getTenantId(); |
| | | }, AuthUtil.getTenantId()).in((v0) -> { |
| | | return v0.getTypeId(); |
| | | }, idList)).eq((v0) -> { |
| | | return v0.getIsDeleted(); |
| | | }, 0)); |
| | | }, 0));*/ |
| | | return Func.isNotEmpty(materialList); |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | private void checkCodeIsExist(String code) { |
| | | Material material = getOne(Wrappers.<Material>query().lambda() |
| | | .eq(Material::getStatus, CommonConstant.ENABLE) |
| | | .eq(Func.isNotEmpty(AuthUtil.getTenantId()), Material::getTenantId, AuthUtil.getTenantId()) |
| | | .eq(Material::getCode, code)); |
| | | /* |
| | | Material material = (Material) getOne((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> { |
| | | return v0.getStatus(); |
| | | }, CommonConstant.ENABLE)).eq(Func.isNotEmpty(AuthUtil.getTenantId()), (v0) -> { |
| | | return v0.getTenantId(); |
| | | }, AuthUtil.getTenantId()).eq((v0) -> { |
| | | return v0.getCode(); |
| | | }, code)); |
| | | }, code));*/ |
| | | if (!Func.isNull(material)) { |
| | | throw new ServiceException(MessageUtils.message("cps.material.code.already.exists", new Object[0])); |
| | | } |
| | | Material material2 = (Material) getOne((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> { |
| | | return v0.getStatus(); |
| | | }, CommonConstant.DEACTIVATE)).eq(Func.isNotEmpty(AuthUtil.getTenantId()), (v0) -> { |
| | | return v0.getTenantId(); |
| | | }, AuthUtil.getTenantId()).eq((v0) -> { |
| | | return v0.getCode(); |
| | | }, code)); |
| | | Material material2 = getOne(Wrappers.<Material>query().lambda() |
| | | .eq(Material::getStatus, CommonConstant.DEACTIVATE) |
| | | .eq(Func.isNotEmpty(AuthUtil.getTenantId()), Material::getTenantId, AuthUtil.getTenantId()) |
| | | .eq(Material::getCode, code)); |
| | | |
| | | if (!Func.isNull(material2)) { |
| | | throw new ServiceException(MessageUtils.message("cps.material.code.unable.already.exists", new Object[0])); |
| | | } |
| | |
| | | @Override // org.springblade.modules.cps.service.IMaterialService |
| | | @Transactional(rollbackFor = {Exception.class}) |
| | | public boolean deleteMaterial(List<String> ids, Integer type) { |
| | | List<Long> idList = (List) ids.stream().map(Long::valueOf).collect(Collectors.toList()); |
| | | List<Long> idList = ids.stream().map(Long::valueOf).collect(Collectors.toList()); |
| | | if (StatusType.REMOVE.getType().equals(type)) { |
| | | return removeByIds(idList); |
| | | } |
| | |
| | | if (Func.isEmpty(data)) { |
| | | throw new ServiceException(MessageUtils.message("excel.import.data.can.not.be.null", new Object[0])); |
| | | } |
| | | Map<String, MaterialType> materialTypeCodeEnable = (Map) this.materialTypeService.list().stream().filter(c -> { |
| | | Map<String, MaterialType> materialTypeCodeEnable = this.materialTypeService.list().stream().filter(c -> { |
| | | return CommonConstant.ENABLE.equals(c.getStatus()); |
| | | }).collect(Collectors.toMap((v0) -> { |
| | | return v0.getCode(); |
| | | }, v -> { |
| | | return v; |
| | | })); |
| | | Map<String, MaterialType> materialTypeCodeDisable = (Map) this.materialTypeService.list().stream().filter(c2 -> { |
| | | Map<String, MaterialType> materialTypeCodeDisable = this.materialTypeService.list().stream().filter(c2 -> { |
| | | return CommonConstant.DEACTIVATE.equals(c2.getStatus()); |
| | | }).collect(Collectors.toMap((v0) -> { |
| | | return v0.getCode(); |
| | |
| | | return v2; |
| | | })); |
| | | List<Material> materialList = list(); |
| | | Map<String, String> dictValueToKey = (Map) DictCache.getList(DictEnum.MATERIAL_PROPERTY.getName()).stream().collect(Collectors.toMap((v0) -> { |
| | | Map<String, String> dictValueToKey = DictCache.getList(DictEnum.MATERIAL_PROPERTY.getName()).stream().collect(Collectors.toMap((v0) -> { |
| | | return v0.getDictValue(); |
| | | }, (v0) -> { |
| | | return v0.getDictKey(); |
| | |
| | | flag = Boolean.FALSE.booleanValue(); |
| | | } |
| | | if (!flag) { |
| | | MultipartFile multipartFile = ExcelUtil.exportFillTemplateToMultipartFile(ExcelConstant.DIRECTORY + "materialFailTemplate" + ExcelConstant.SUFFIX, MessageUtils.message("excel.import.failed.report.name", new Object[0]) + ExcelConstant.SUFFIX, "物料信息表", (List) data.stream().filter(x -> { |
| | | MultipartFile multipartFile = ExcelUtil.exportFillTemplateToMultipartFile(ExcelConstant.DIRECTORY + "materialFailTemplate" + ExcelConstant.SUFFIX, MessageUtils.message("excel.import.failed.report.name", new Object[0]) + ExcelConstant.SUFFIX, "物料信息表", data.stream().filter(x -> { |
| | | return Func.isNotEmpty(x.getFailReason()); |
| | | }).collect(Collectors.toList()), (Object) null, (AbstractMergeStrategy) null); |
| | | return this.ossBuilder.tempTemplate().putFile(multipartFile.getOriginalFilename(), multipartFile); |
| | |
| | | @Override // org.springblade.modules.cps.service.IMaterialService |
| | | public List<MaterialVO> getMaterialListByIds(MaterialIdListVO materialIdListVO) { |
| | | List<Material> materialList = listByIds(materialIdListVO.getIds()); |
| | | List<Long> typeIdList = (List) materialList.stream().map((v0) -> { |
| | | List<Long> typeIdList = materialList.stream().map((v0) -> { |
| | | return v0.getTypeId(); |
| | | }).distinct().collect(Collectors.toList()); |
| | | LinkedHashMap<Long, MaterialType> typeMap = new LinkedHashMap<>(); |
| | |
| | | @Override // org.springblade.modules.cps.service.IMaterialService |
| | | @Transactional(rollbackFor = {Exception.class}) |
| | | public Boolean synchronizedMaterial(SynchronizedProductMaterialVO synchronizedProductMaterialVO) { |
| | | List<String> nameList = (List) synchronizedProductMaterialVO.getProductList().stream().map(i -> { |
| | | List<String> nameList = synchronizedProductMaterialVO.getProductList().stream().map(i -> { |
| | | return i.getName(); |
| | | }).collect(Collectors.toList()); |
| | | List<String> codeList = (List) synchronizedProductMaterialVO.getProductList().stream().map(i2 -> { |
| | | List<String> codeList = synchronizedProductMaterialVO.getProductList().stream().map(i2 -> { |
| | | return i2.getCode(); |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<Material> list = list(Wrappers.<Material>query().lambda() |
| | | .and(i -> i.in(Material::getName, nameList)) |
| | | .or(i -> i.in(Material::getCode, codeList))); |
| | | /* |
| | | List<Material> list = list((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().and(i3 -> { |
| | | LambdaQueryWrapper lambdaQueryWrapper = (LambdaQueryWrapper) i3.in((v0) -> { |
| | | return v0.getName(); |
| | |
| | | LambdaQueryWrapper lambdaQueryWrapper = (LambdaQueryWrapper) i4.in((v0) -> { |
| | | return v0.getCode(); |
| | | }, codeList); |
| | | })); |
| | | }));*/ |
| | | List<ProductVO> needAddList = new ArrayList<>(); |
| | | List<Long> deleteIdList = new ArrayList<>(); |
| | | list.forEach(m -> { |
| | |
| | | } |
| | | |
| | | private Boolean insertProductMaterial(SynchronizedProductMaterialVO synchronizedProductMaterialVO) { |
| | | List<Material> insertList = (List) synchronizedProductMaterialVO.getProductList().stream().map(i -> { |
| | | List<Material> insertList = synchronizedProductMaterialVO.getProductList().stream().map(i -> { |
| | | Material bean = new Material(); |
| | | bean.setName(i.getName()); |
| | | bean.setCode(i.getCode()); |