yangys
2024-03-28 23a939ed820ee32f9a4309f9c81b7bab5a566f30
smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/ProcessAssociationServiceImpl.java
@@ -36,79 +36,6 @@
    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;
@@ -119,24 +46,26 @@
    @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();
@@ -145,12 +74,8 @@
                        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();
@@ -159,12 +84,8 @@
                        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();
@@ -190,19 +111,23 @@
    @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]));
        }