| | |
| | | private final ISupplierService supplierService; |
| | | private final IWarehouseAreaService warehouseAreaService; |
| | | |
| | | private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) { |
| | | String implMethodName = lambda.getImplMethodName(); |
| | | boolean z = true; |
| | | switch (implMethodName.hashCode()) { |
| | | case -1104365260: |
| | | if (implMethodName.equals("getProcessId")) { |
| | | z = false; |
| | | break; |
| | | } |
| | | break; |
| | | case 98245393: |
| | | if (implMethodName.equals("getId")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case 1949578200: |
| | | if (implMethodName.equals("getBizId")) { |
| | | 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/modules/cps/entity/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getProcessId(); |
| | | }; |
| | | } |
| | | 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/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getProcessId(); |
| | | }; |
| | | } |
| | | 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/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getProcessId(); |
| | | }; |
| | | } |
| | | 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/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getId(); |
| | | }; |
| | | } |
| | | 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/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getId(); |
| | | }; |
| | | } |
| | | 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/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getId(); |
| | | }; |
| | | } |
| | | 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/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getBizId(); |
| | | }; |
| | | } |
| | | 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/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getBizId(); |
| | | }; |
| | | } |
| | | break; |
| | | } |
| | | throw new IllegalArgumentException("Invalid lambda deserialization"); |
| | | } |
| | | |
| | | public ProcessAssociationServiceImpl(final IWorkstationService workstationService, final ISupplierService supplierService, final IWarehouseAreaService warehouseAreaService) { |
| | | this.workstationService = workstationService; |
| | |
| | | @Override // org.springblade.modules.cps.service.IProcessAssociationService |
| | | public ProcessAssociationVO listAssociation(Long processId) { |
| | | ProcessAssociationVO processAssociationVO = new ProcessAssociationVO(); |
| | | List<ProcessAssociation> processAssociationList = list(Wrappers.<ProcessAssociation>query() |
| | | .lambda() |
| | | .eq(ProcessAssociation::getProcessId, processId)); |
| | | /* |
| | | List<ProcessAssociation> processAssociationList = list((Wrapper) Wrappers.query().lambda().eq((v0) -> { |
| | | return v0.getProcessId(); |
| | | }, processId)); |
| | | }, processId));*/ |
| | | if (Func.isNotEmpty(processAssociationList)) { |
| | | Map<Integer, List<ProcessAssociation>> map = (Map) processAssociationList.stream().filter(type -> { |
| | | Map<Integer, List<ProcessAssociation>> map = processAssociationList.stream().filter(type -> { |
| | | return type.getType() != null; |
| | | }).collect(Collectors.groupingBy((v0) -> { |
| | | return v0.getType(); |
| | | })); |
| | | map.forEach(type2, value -> { |
| | | map.forEach((type2, value) -> { |
| | | switch (type2.intValue()) { |
| | | case 1: |
| | | List<Long> list = (List) value.stream().map((v0) -> { |
| | | List<Long> list = value.stream().map((v0) -> { |
| | | return v0.getBizId(); |
| | | }).collect(Collectors.toList()); |
| | | List<Workstation> workstationList = this.workstationService.list((Wrapper) Wrappers.query().lambda().in((v0) -> { |
| | | return v0.getId(); |
| | | }, list)); |
| | | List<Workstation> workstationList = this.workstationService.list(Wrappers.<Workstation>query().lambda().in(Workstation::getId, list)); |
| | | List<ProcessWorkstationTypeVO> processWorkstationTypeVOList = new ArrayList<>(); |
| | | workstationList.forEach(record -> { |
| | | ProcessWorkstationTypeVO processWorkstationTypeVO = ProcessWorkstationTypeVO.builder().id(record.getId()).workstationCode(record.getCode()).workstationName(record.getName()).build(); |
| | |
| | | processAssociationVO.setWorkstationList(processWorkstationTypeVOList); |
| | | return; |
| | | case 2: |
| | | List<Long> list2 = (List) value.stream().map((v0) -> { |
| | | return v0.getBizId(); |
| | | }).collect(Collectors.toList()); |
| | | List<WarehouseArea> warehouseAreaList = this.warehouseAreaService.list((Wrapper) Wrappers.query().lambda().in((v0) -> { |
| | | return v0.getId(); |
| | | }, list2)); |
| | | List<Long> list2 = value.stream().map(ProcessAssociation::getBizId).collect(Collectors.toList()); |
| | | List<WarehouseArea> warehouseAreaList = this.warehouseAreaService.list(Wrappers.<WarehouseArea>query().lambda().in(WarehouseArea::getId, list2)); |
| | | List<ProcessWarehouseAreaTypeVO> areaTypeVOList = new ArrayList<>(); |
| | | warehouseAreaList.forEach(record2 -> { |
| | | ProcessWarehouseAreaTypeVO processWarehouseAreaTypeVO = ProcessWarehouseAreaTypeVO.builder().id(record2.getId()).warehouseAreaCode(record2.getCode()).warehouseAreaName(record2.getName()).build(); |
| | |
| | | processAssociationVO.setWarehouseAreaList(areaTypeVOList); |
| | | return; |
| | | case 3: |
| | | List<Long> list3 = (List) value.stream().map((v0) -> { |
| | | return v0.getBizId(); |
| | | }).collect(Collectors.toList()); |
| | | List<Supplier> supplierList = this.supplierService.list((Wrapper) Wrappers.query().lambda().in((v0) -> { |
| | | return v0.getId(); |
| | | }, list3)); |
| | | List<Long> list3 = value.stream().map(ProcessAssociation::getBizId).collect(Collectors.toList()); |
| | | List<Supplier> supplierList = this.supplierService.list(Wrappers.<Supplier>query().lambda().in(Supplier::getId, list3)); |
| | | List<ProcessSupplierTypeVO> processSupplierTypeVOList = new ArrayList<>(); |
| | | supplierList.forEach(record3 -> { |
| | | ProcessSupplierTypeVO processSupplierTypeVO = ProcessSupplierTypeVO.builder().id(record3.getId()).supplierCode(record3.getCode()).supplierName(record3.getName()).build(); |
| | |
| | | |
| | | @Override // org.springblade.modules.cps.service.IProcessAssociationService |
| | | public Boolean delete(Long bizId, Long processId) { |
| | | return Boolean.valueOf(remove(Wrappers.<ProcessAssociation>query().lambda() |
| | | .eq(Func.isNotEmpty(bizId), ProcessAssociation::getBizId, bizId) |
| | | .eq(Func.isNotEmpty(processId), ProcessAssociation::getProcessId, processId))); |
| | | |
| | | /* |
| | | return Boolean.valueOf(remove(Wrappers.query().lambda().eq(Func.isNotEmpty(bizId), (v0) -> { |
| | | return v0.getBizId(); |
| | | }, bizId).eq(Func.isNotEmpty(processId), (v0) -> { |
| | | return v0.getProcessId(); |
| | | }, processId))); |
| | | */ |
| | | } |
| | | |
| | | private void checkProcessAssociation(ProcessAssociationSaveVO processAssociationSaveVO) { |
| | | Long count = Long.valueOf(count(Wrappers.query().lambda().eq(Func.isNotEmpty(processAssociationSaveVO.getProcessId()), (v0) -> { |
| | | return v0.getProcessId(); |
| | | }, processAssociationSaveVO.getProcessId()).eq(Func.isNotEmpty(processAssociationSaveVO.getBizId()), (v0) -> { |
| | | return v0.getBizId(); |
| | | }, processAssociationSaveVO.getBizId()))); |
| | | Long count = Long.valueOf(count(Wrappers.<ProcessAssociation>query().lambda() |
| | | .eq(Func.isNotEmpty(processAssociationSaveVO.getProcessId()), ProcessAssociation::getProcessId, processAssociationSaveVO.getProcessId()) |
| | | .eq(Func.isNotEmpty(processAssociationSaveVO.getBizId()), ProcessAssociation::getBizId, processAssociationSaveVO.getBizId()))); |
| | | if (count.longValue() > 0) { |
| | | throw new ServiceException(MessageUtils.message("cps.process.association.type.already.exists", new Object[0])); |
| | | } |