| | |
| | | @Autowired |
| | | private IEmployeeService employeeService; |
| | | |
| | | private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) { |
| | | String implMethodName = lambda.getImplMethodName(); |
| | | boolean z = true; |
| | | switch (implMethodName.hashCode()) { |
| | | case -2038138413: |
| | | if (implMethodName.equals("getShortCode")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case -1453405940: |
| | | if (implMethodName.equals("getMachineId")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case -1107875961: |
| | | if (implMethodName.equals("getDeviceId")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case -858902114: |
| | | if (implMethodName.equals("getMachineCode")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case -557259320: |
| | | if (implMethodName.equals("getWorkstationId")) { |
| | | z = false; |
| | | break; |
| | | } |
| | | break; |
| | | case -75622813: |
| | | if (implMethodName.equals("getCode")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case -75308287: |
| | | if (implMethodName.equals("getName")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case 98245393: |
| | | if (implMethodName.equals("getId")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case 112409713: |
| | | if (implMethodName.equals("getPlanStatus")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case 257009483: |
| | | if (implMethodName.equals("getExtendId")) { |
| | | z = true; |
| | | break; |
| | | } |
| | | break; |
| | | case 517353092: |
| | | if (implMethodName.equals("getItemId")) { |
| | | 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 1330288580: |
| | | if (implMethodName.equals("getGroupId")) { |
| | | 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/WorkstationOfMachine") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getWorkstationId(); |
| | | }; |
| | | } |
| | | 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/tpm/entity/MaintainPlan") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) { |
| | | return (v0) -> { |
| | | return v0.getPlanStatus(); |
| | | }; |
| | | } |
| | | 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/tpm/entity/MaintainPlan") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) { |
| | | return (v0) -> { |
| | | return v0.getPlanStatus(); |
| | | }; |
| | | } |
| | | 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/DeviceType") && 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/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(); |
| | | }; |
| | | } |
| | | 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/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(); |
| | | }; |
| | | } |
| | | 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 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/core/tenant/mp/TenantEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getTenantId(); |
| | | }; |
| | | } |
| | | 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/CommonGroupOfItem") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getGroupId(); |
| | | }; |
| | | } |
| | | 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/Machine") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getMachineCode(); |
| | | }; |
| | | } |
| | | 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/Machine") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getMachineCode(); |
| | | }; |
| | | } |
| | | 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/Machine") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getMachineCode(); |
| | | }; |
| | | } |
| | | 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/Machine") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getMachineCode(); |
| | | }; |
| | | } |
| | | 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/tpm/entity/MaintainPlan") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getDeviceId(); |
| | | }; |
| | | } |
| | | 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/WorkstationOfMachine") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getMachineId(); |
| | | }; |
| | | } |
| | | 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/WorkstationOfMachine") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getMachineId(); |
| | | }; |
| | | } |
| | | 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/WorkstationOfMachine") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getMachineId(); |
| | | }; |
| | | } |
| | | 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/WorkstationOfMachine") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getMachineId(); |
| | | }; |
| | | } |
| | | 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/WorkstationOfMachine") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getMachineId(); |
| | | }; |
| | | } |
| | | 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/CommonGroupOfItem") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getItemId(); |
| | | }; |
| | | } |
| | | 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/CommonGroupOfItem") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) { |
| | | return (v0) -> { |
| | | return v0.getItemId(); |
| | | }; |
| | | } |
| | | 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/Machine") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getShortCode(); |
| | | }; |
| | | } |
| | | 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/CommonGroupOfItem") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getExtendId(); |
| | | }; |
| | | } |
| | | 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/DeviceType") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getCode(); |
| | | }; |
| | | } |
| | | break; |
| | | } |
| | | throw new IllegalArgumentException("Invalid lambda deserialization"); |
| | | } |
| | | |
| | | @Override // org.springblade.modules.cps.service.IMachineService |
| | | @Transactional(rollbackFor = {Exception.class}) |
| | |
| | | |
| | | @Override // org.springblade.modules.cps.service.IMachineService |
| | | public List<WorkstationWcsDTO> getWorkstationWcsByMachineId(Long machineId, String paramName) { |
| | | List<WorkstationOfMachine> workstationOfMachineList = this.workstationOfMachineService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getMachineId(); |
| | | }, machineId)); |
| | | List<Long> workstationIdList = (List) workstationOfMachineList.stream().map((v0) -> { |
| | | List<WorkstationOfMachine> workstationOfMachineList = this.workstationOfMachineService.list(Wrappers.<WorkstationOfMachine>lambdaQuery().eq(WorkstationOfMachine::getMachineId, machineId)); |
| | | |
| | | List<Long> workstationIdList =workstationOfMachineList.stream().map((v0) -> { |
| | | return v0.getWorkstationId(); |
| | | }).collect(Collectors.toList()); |
| | | List<WorkstationWcs> workstationWcsList = this.workstationWcsMapper.getWorkstationWcsByName(workstationIdList, paramName); |
| | |
| | | machineDetailVO.setMachineLifeStatusName(DictCache.getValue(DictEnum.MACHINE_LIFE_STATUS.getName(), machineDetailVO.getMachineLifeStatus())); |
| | | machineDetailVO.setManagementClassName(DictCache.getValue(DictEnum.MACHINE_MANAGEMENT_CLASS, machineDetailVO.getManagementClass())); |
| | | machineDetailVO.setMachineUseStatusName(DictCache.getValue(DictEnum.MACHINE_USE_STATUS.getName(), machineDetailVO.getMachineUseStatus())); |
| | | List<WorkstationOfMachine> workstationOfMachineList = this.workstationOfMachineService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getMachineId(); |
| | | }, machineDetailVO.getId())); |
| | | List<WorkstationOfMachine> workstationOfMachineList = this.workstationOfMachineService.list(Wrappers.<WorkstationOfMachine>lambdaQuery().eq(WorkstationOfMachine::getMachineId, machineDetailVO.getId())); |
| | | if (Func.isNotEmpty(workstationOfMachineList)) { |
| | | List<Workstation> workstationList = this.workstationService.listByIds((Collection) workstationOfMachineList.stream().map((v0) -> { |
| | | List<Workstation> workstationList = this.workstationService.listByIds(workstationOfMachineList.stream().map((v0) -> { |
| | | return v0.getWorkstationId(); |
| | | }).collect(Collectors.toList())); |
| | | Optional.ofNullable(workstationList).ifPresent(workstations -> { |
| | | List<String> workstationCodeList = (List) workstations.stream().map((v0) -> { |
| | | List<String> workstationCodeList = workstations.stream().map((v0) -> { |
| | | return v0.getCode(); |
| | | }).collect(Collectors.toList()); |
| | | List<String> workstationNameList = (List) workstations.stream().map((v0) -> { |
| | | List<String> workstationNameList = workstations.stream().map((v0) -> { |
| | | return v0.getName(); |
| | | }).collect(Collectors.toList()); |
| | | String code = workstationCodeList.stream().reduce(a, b -> { |
| | | String code = workstationCodeList.stream().reduce((a, b) -> { |
| | | return a.concat(";").concat(b); |
| | | }).orElse(""); |
| | | String name = workstationNameList.stream().reduce(a2, b2 -> { |
| | | String name = workstationNameList.stream().reduce((a2, b2) -> { |
| | | return a2.concat(";").concat(b2); |
| | | }).orElse(""); |
| | | machineDetailVO.setWorkstationCode(code); |
| | |
| | | if (len < 4 || len > 8) { |
| | | throw new ServiceException(String.format(MessageUtils.message("cps.tpm.machine.short.code.length", new Object[0]), 4, 8)); |
| | | } |
| | | Long count = Long.valueOf(count(((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getShortCode(); |
| | | }, shortCode)).ne(Func.isNotEmpty(id), (v0) -> { |
| | | return v0.getId(); |
| | | }, id))); |
| | | |
| | | Long count = Long.valueOf(count(Wrappers.<Machine>lambdaQuery().eq(Machine::getShortCode, shortCode).ne(Func.isNotEmpty(id), Machine::getId, id))); |
| | | if (count.longValue() > 0) { |
| | | throw new ServiceException(MessageUtils.message("cps.tpm.machine.short.code.exists", new Object[0])); |
| | | } |
| | |
| | | Integer status = machineSelectVO.getStatus(); |
| | | IPage<MachineListVO> page = ((MachineMapper) this.baseMapper).pageMachine(Condition.getPage(query), machineName, machineCode, machineTypeId, groupId, CommonGroupConstant.ALL_MACHINE_ID, status == null ? CommonConstant.ENABLE : status); |
| | | List<MachineListVO> records = page.getRecords(); |
| | | List<MachineListVO> collect = (List) records.stream().peek(c -> { |
| | | List<MachineListVO> collect = records.stream().peek(c -> { |
| | | c.setMachineUseStatusName(DictCache.getValue(DictEnum.MACHINE_USE_STATUS.getName(), c.getMachineUseStatus())); |
| | | }).collect(Collectors.toList()); |
| | | page.setRecords(collect); |
| | |
| | | boolean updateById = updateById(machine); |
| | | Long groupId = machine.getGroupId(); |
| | | if (!Func.isNull(groupId)) { |
| | | this.itemService.update(Wrappers.<CommonGroupOfItem>lambdaUpdate() |
| | | .set(CommonGroupOfItem::getGroupId, groupId) |
| | | .set(CommonGroupOfItem::getExtendId, machine.getExtendId()) |
| | | .eq(CommonGroupOfItem::getItemId, machine.getId())); |
| | | /* |
| | | this.itemService.update((Wrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate().set((v0) -> { |
| | | return v0.getGroupId(); |
| | | }, groupId)).set((v0) -> { |
| | | return v0.getExtendId(); |
| | | }, machine.getExtendId())).eq((v0) -> { |
| | | return v0.getItemId(); |
| | | }, machine.getId())); |
| | | }, machine.getId()));*/ |
| | | } |
| | | if (updateById) { |
| | | CacheUtil.clear(ExtCacheConstant.POSTING_MACHINE, Boolean.FALSE); |
| | |
| | | |
| | | @Override // org.springblade.modules.cps.service.IMachineService |
| | | public void renewMachineRepairStatus(Long machineId, Integer maintenanceStatus) { |
| | | Machine machine = (Machine) getOne((Wrapper) new QueryWrapper().lambda().eq((v0) -> { |
| | | return v0.getId(); |
| | | }, machineId)); |
| | | Machine machine = (Machine)getOne(new QueryWrapper<Machine>().lambda().eq(Machine::getId, machineId)); |
| | | |
| | | if (machine != null) { |
| | | machine.setRepairStatus(maintenanceStatus); |
| | | updateById(machine); |
| | |
| | | buildMap(rawData, machineCodeMap, machineCodes, pinMap, pinCodes, shortMap, shortCodes); |
| | | List<MachineImport> failExcel = Lists.newArrayList(); |
| | | List<DeviceType> deviceTypeList = Lists.newArrayList(); |
| | | List<Workstation> workstationList = this.workstationService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getStatus(); |
| | | }, CommonConstant.ENABLE)); |
| | | Map<String, Workstation> workstationMap = (Map) workstationList.stream().collect(Collectors.toMap((v0) -> { |
| | | List<Workstation> workstationList = this.workstationService.list(Wrappers.<Workstation>lambdaQuery().eq(Workstation::getStatus, CommonConstant.ENABLE)); |
| | | Map<String, Workstation> workstationMap = workstationList.stream().collect(Collectors.toMap((v0) -> { |
| | | return v0.getCode(); |
| | | }, v -> { |
| | | return v; |
| | |
| | | if (Func.isNotEmpty(failExcel)) { |
| | | return exportFailFile(failExcel); |
| | | } |
| | | Map<String, Long> typeMap = (Map) deviceTypeList.stream().collect(Collectors.toMap((v0) -> { |
| | | Map<String, Long> typeMap = deviceTypeList.stream().collect(Collectors.toMap((v0) -> { |
| | | return v0.getCode(); |
| | | }, (v0) -> { |
| | | return v0.getId(); |
| | | }, v1, v2 -> { |
| | | },(v1, v2) -> { |
| | | return v1; |
| | | })); |
| | | saveExportMachine(rawData, typeMap, commonGroupNameMap, organizationNameMap, employeeNameMap); |
| | |
| | | } |
| | | |
| | | public void saveExportMachine(List<MachineImport> rawData, Map<String, Long> typeMap, HashMap<String, Long> commonGroupNameMap, HashMap<String, Long> organizationNameMap, EmployeeNameDTO employeeNameMap) { |
| | | List<Machine> collect = (List) rawData.stream().map(c -> { |
| | | List<Machine> collect = rawData.stream().map(c -> { |
| | | Machine machine = MachineConvert.INSTANCE.convert(c); |
| | | String machineTypeName = c.getMachineTypeName(); |
| | | String machineTypeCode = c.getMachineTypeCode(); |
| | |
| | | } |
| | | |
| | | private void buildMap(List<MachineImport> rawData, Map<String, Integer> machineCodeMap, Set<String> machineCodes, Map<String, Integer> pinMap, Set<String> pinCodes, Map<String, Integer> shortMap, Set<String> shortCodes) { |
| | | QueryWrapper<Machine> machineCodeQuery = Wrappers.query().select(new String[]{"machine_code"}); |
| | | QueryWrapper<Machine> pinCodeQuery = Wrappers.query().select(new String[]{"pin_code"}); |
| | | QueryWrapper<Machine> shortCodeQuery = Wrappers.query().select(new String[]{"short_code"}); |
| | | QueryWrapper<Machine> machineCodeQuery = Wrappers.<Machine>query().select(new String[]{"machine_code"}); |
| | | QueryWrapper<Machine> pinCodeQuery = Wrappers.<Machine>query().select(new String[]{"pin_code"}); |
| | | QueryWrapper<Machine> shortCodeQuery = Wrappers.<Machine>query().select(new String[]{"short_code"}); |
| | | boolean flag1 = false; |
| | | boolean flag2 = false; |
| | | boolean flag3 = false; |
| | |
| | | } |
| | | flag1 = true; |
| | | machineCodeQuery.nested(i -> { |
| | | QueryWrapper queryWrapper = (QueryWrapper) i.eq("machine_code", machineCode); |
| | | i.eq("machine_code", machineCode); |
| | | //QueryWrapper queryWrapper = (QueryWrapper) i.eq("machine_code", machineCode); |
| | | }); |
| | | machineCodeQuery.apply("status =1", new Object[0]); |
| | | } |
| | |
| | | } |
| | | flag2 = true; |
| | | pinCodeQuery.nested(i2 -> { |
| | | QueryWrapper queryWrapper = (QueryWrapper) i2.eq("pin_code", pinCode); |
| | | i2.eq("pin_code", pinCode); |
| | | }); |
| | | pinCodeQuery.apply("status =1", new Object[0]); |
| | | } |
| | |
| | | } |
| | | flag3 = true; |
| | | shortCodeQuery.nested(i3 -> { |
| | | QueryWrapper queryWrapper = (QueryWrapper) i3.eq("short_code", shortCode); |
| | | i3.eq("short_code", shortCode); |
| | | }); |
| | | shortCodeQuery.apply("status =1", new Object[0]); |
| | | } |
| | |
| | | throw new ServiceException(MessageUtils.message("machine.andon.not.remove", new Object[0])); |
| | | } |
| | | removeByIds(Func.toLongList(vo.getIds())); |
| | | this.workstationOfMachineService.remove((Wrapper) Wrappers.lambdaQuery().in((v0) -> { |
| | | return v0.getMachineId(); |
| | | }, vo.getIds())); |
| | | this.itemService.remove((Wrapper) Wrappers.lambdaQuery().in((v0) -> { |
| | | return v0.getItemId(); |
| | | }, vo.getIds())); |
| | | this.workstationOfMachineService.remove(Wrappers.<WorkstationOfMachine>lambdaQuery().in(WorkstationOfMachine::getMachineId, vo.getIds())); |
| | | this.itemService.remove( Wrappers.<CommonGroupOfItem>lambdaQuery().in(CommonGroupOfItem::getItemId, vo.getIds())); |
| | | CacheUtil.clear(ExtCacheConstant.POSTING_MACHINE, Boolean.FALSE); |
| | | CacheUtil.clear(ExtCacheConstant.WORKSTATION_MACHINE, Boolean.FALSE); |
| | | } |
| | |
| | | if (machine == null) { |
| | | throw new ServiceException("机器不存在"); |
| | | } |
| | | List<WorkstationOfMachine> list = this.workstationOfMachineService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getMachineId(); |
| | | }, machineId)); |
| | | List<WorkstationOfMachine> list = this.workstationOfMachineService.list(Wrappers.<WorkstationOfMachine>lambdaQuery().eq(WorkstationOfMachine::getMachineId, machineId)); |
| | | |
| | | if (Func.isNotEmpty(list)) { |
| | | List<Long> workstationIds = (List) list.stream().map((v0) -> { |
| | | List<Long> workstationIds = list.stream().map((v0) -> { |
| | | return v0.getWorkstationId(); |
| | | }).collect(Collectors.toList()); |
| | | if (Func.isNotEmpty(workstationIds)) { |
| | |
| | | return true; |
| | | } |
| | | if (Func.isNotBlank(typeName) && Func.isNotBlank(typeCode)) { |
| | | DeviceType type = (DeviceType) this.typeService.getOne((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getName(); |
| | | }, typeName)).eq((v0) -> { |
| | | return v0.getCode(); |
| | | }, typeCode)); |
| | | DeviceType type = this.typeService.getOne(Wrappers.<DeviceType>lambdaQuery().eq(DeviceType::getName, typeName) |
| | | .eq(DeviceType::getCode, typeCode)); |
| | | if (Func.isEmpty(type)) { |
| | | data.setFailReason(MessageUtils.message("cps.tpm.machine.type.not.exists", new Object[0])); |
| | | failExcel.add(data); |
| | |
| | | machineDetailVO.setMachineLifeStatusName(DictCache.getValue(DictEnum.MACHINE_LIFE_STATUS.getName(), machineDetailVO.getMachineLifeStatus())); |
| | | machineDetailVO.setManagementClassName(DictCache.getValue(DictEnum.MACHINE_MANAGEMENT_CLASS, machineDetailVO.getManagementClass())); |
| | | machineDetailVO.setMachineUseStatusName(DictCache.getValue(DictEnum.MACHINE_USE_STATUS.getName(), machineDetailVO.getMachineUseStatus())); |
| | | List<WorkstationOfMachine> workstationOfMachineList = this.workstationOfMachineService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getMachineId(); |
| | | }, machineDetailVO.getId())); |
| | | List<WorkstationOfMachine> workstationOfMachineList = this.workstationOfMachineService.list(Wrappers.<WorkstationOfMachine>lambdaQuery() |
| | | .eq(WorkstationOfMachine::getMachineId, machineDetailVO.getId())); |
| | | if (Func.isNotEmpty(workstationOfMachineList)) { |
| | | List<Workstation> workstationList = this.workstationService.listByIds((Collection) workstationOfMachineList.stream().map((v0) -> { |
| | | return v0.getWorkstationId(); |
| | | }).collect(Collectors.toList())); |
| | | List<Workstation> workstationList = this.workstationService.listByIds(workstationOfMachineList.stream().map(WorkstationOfMachine::getWorkstationId).collect(Collectors.toList())); |
| | | Optional.ofNullable(workstationList).ifPresent(workstations -> { |
| | | String code = ((Workstation) ListUtils.getFirst(workstations)).getCode(); |
| | | String name = ((Workstation) ListUtils.getFirst(workstations)).getName(); |
| | |
| | | private boolean validWorkstationBind(MachineImport data, Map<String, Workstation> workstationMap, List<MachineImport> failExcel) { |
| | | Workstation workstation = workstationMap.get(data.getMachineCode()); |
| | | if (Func.isNotEmpty(workstation)) { |
| | | long count = this.workstationOfMachineService.count(Wrappers.<WorkstationOfMachine>lambdaQuery() |
| | | .eq(WorkstationOfMachine::getWorkstationId, workstation.getId())); |
| | | /* |
| | | long count = this.workstationOfMachineService.count((Wrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getWorkstationId(); |
| | | }, workstation.getId())); |
| | | }, workstation.getId()));*/ |
| | | if (count > 0) { |
| | | data.setFailReason(MessageUtils.message("excel.import.machine.workstation.already.bound", new Object[0])); |
| | | failExcel.add(data); |
| | |
| | | } |
| | | |
| | | private boolean checkStopImportMachine(String machineCode) { |
| | | Machine machine = (Machine) getOne((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getMachineCode(); |
| | | }, machineCode)).eq((v0) -> { |
| | | return v0.getStatus(); |
| | | }, CommonConstant.DEACTIVATE)); |
| | | Machine machine = getOne(Wrappers.<Machine>lambdaQuery().eq(Machine::getMachineCode, machineCode).eq(Machine::getStatus, CommonConstant.DEACTIVATE)); |
| | | |
| | | if (machine != null) { |
| | | return Boolean.TRUE.booleanValue(); |
| | | } |
| | |
| | | } |
| | | |
| | | private void checkStopMachine(String machineCode) { |
| | | Machine machine = getOne(Wrappers.<Machine>lambdaQuery().eq(Machine::getMachineCode, machineCode).eq(Machine::getStatus, CommonConstant.DEACTIVATE)); |
| | | /* |
| | | Machine machine = (Machine) getOne((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getMachineCode(); |
| | | }, machineCode)).eq((v0) -> { |
| | | return v0.getStatus(); |
| | | }, CommonConstant.DEACTIVATE)); |
| | | }, CommonConstant.DEACTIVATE));*/ |
| | | if (machine != null) { |
| | | throw new ServiceException(MessageUtils.message("machine.code.already.exist.stop.status", new Object[0])); |
| | | } |
| | | } |
| | | |
| | | private void checkStopMachineByCode(String workstationCode) { |
| | | Machine machine = (Machine) getOne((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getMachineCode(); |
| | | }, workstationCode)).eq((v0) -> { |
| | | return v0.getStatus(); |
| | | }, CommonConstant.DEACTIVATE)); |
| | | Machine machine = getOne(Wrappers.<Machine>lambdaQuery().eq(Machine::getMachineCode, workstationCode).eq(Machine::getStatus, CommonConstant.DEACTIVATE)); |
| | | if (machine != null) { |
| | | throw new ServiceException(MessageUtils.message("machine.machine.workstation.already.exist.stop.status", new Object[0])); |
| | | } |
| | | } |
| | | |
| | | private void checkMachine(Long id, String machineCode) { |
| | | Long count = Long.valueOf(count(Wrappers.<Machine>lambdaQuery().ne(Func.isNotEmpty(id), Machine::getId, id) |
| | | .eq(Machine::getMachineCode, machineCode) |
| | | .eq(Machine::getStatus, CommonConstant.ENABLE))); |
| | | /* |
| | | Long count = Long.valueOf(count((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().ne(Func.isNotEmpty(id), (v0) -> { |
| | | return v0.getId(); |
| | | }, id).eq((v0) -> { |
| | | return v0.getMachineCode(); |
| | | }, machineCode)).eq((v0) -> { |
| | | return v0.getStatus(); |
| | | }, CommonConstant.ENABLE))); |
| | | }, CommonConstant.ENABLE)));*/ |
| | | if (count.longValue() > 0) { |
| | | throw new ServiceException(MessageUtils.message("machine.code.already.exists", new Object[0])); |
| | | } |
| | |
| | | } |
| | | |
| | | private List<MaintainPlan> checkExistPlanStatus(Long deviceId, Long id) { |
| | | List<MaintainPlan> maintainPlanList = this.maintainPlanService.list(Wrappers.<MaintainPlan>query().lambda() |
| | | .eq(Func.isNotEmpty(AuthUtil.getTenantId()), MaintainPlan::getTenantId, AuthUtil.getTenantId()) |
| | | .eq(MaintainPlan::getDeviceId, deviceId) |
| | | .notIn( |
| | | Func.isNotEmpty(id), MaintainPlan::getId, new Object[] { id }) |
| | | .notIn(MaintainPlan::getPlanStatus, new Object[] { Integer.valueOf(MaintainPlanStatusEnum.T5.getType()) }) |
| | | .orderByDesc(MaintainPlan::getPlanStatus)); |
| | | /* |
| | | List<MaintainPlan> maintainPlanList = this.maintainPlanService.list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq(Func.isNotEmpty(AuthUtil.getTenantId()), (v0) -> { |
| | | return v0.getTenantId(); |
| | | }, AuthUtil.getTenantId()).eq((v0) -> { |
| | |
| | | return v0.getPlanStatus(); |
| | | }, new Object[]{Integer.valueOf(MaintainPlanStatusEnum.T5.getType())})).orderByDesc((v0) -> { |
| | | return v0.getPlanStatus(); |
| | | })); |
| | | }));*/ |
| | | return maintainPlanList; |
| | | } |
| | | } |