| | |
| | | package com.qianwen.smartman.modules.dnc.service.impl; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.Wrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import java.lang.invoke.SerializedLambda; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.function.Function; |
| | | import java.util.stream.Collectors; |
| | | import com.qianwen.smartman.common.constant.CommonConstant; |
| | | import com.qianwen.smartman.common.utils.MessageUtils; |
| | | |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.qianwen.core.log.exception.ServiceException; |
| | | import com.qianwen.core.mp.base.BaseServiceImpl; |
| | | import com.qianwen.core.secure.utils.AuthUtil; |
| | | import com.qianwen.core.tool.utils.Func; |
| | | import com.qianwen.smartman.common.constant.CommonConstant; |
| | | import com.qianwen.smartman.common.utils.MessageUtils; |
| | | import com.qianwen.smartman.modules.dnc.entity.DncWsRelationTd; |
| | | import com.qianwen.smartman.modules.dnc.entity.TransferDirectory; |
| | | import com.qianwen.smartman.modules.dnc.entity.TransferDirectoryGroup; |
| | |
| | | import com.qianwen.smartman.modules.dnc.service.IDncWsRelationTdService; |
| | | import com.qianwen.smartman.modules.dnc.service.ITransferDirectoryService; |
| | | import com.qianwen.smartman.modules.dnc.vo.WorkstationTdVO; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | @Service |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/dnc/service/impl/DncWsRelationTdServiceImpl.class */ |
| | |
| | | private final ITransferDirectoryService transferDirectoryService; |
| | | private final IDncFixedSpaceService fixedSpaceService; |
| | | |
| | | private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) { |
| | | String implMethodName = lambda.getImplMethodName(); |
| | | boolean z = true; |
| | | switch (implMethodName.hashCode()) { |
| | | case -75308287: |
| | | if (implMethodName.equals("getName")) { |
| | | z = false; |
| | | 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/dnc/entity/TransferDirectory") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) { |
| | | return (v0) -> { |
| | | return v0.getName(); |
| | | }; |
| | | } |
| | | break; |
| | | } |
| | | throw new IllegalArgumentException("Invalid lambda deserialization"); |
| | | } |
| | | |
| | | public DncWsRelationTdServiceImpl(final ITransferDirectoryService transferDirectoryService, final IDncFixedSpaceService fixedSpaceService) { |
| | | this.transferDirectoryService = transferDirectoryService; |
| | |
| | | String workstationGroupId = workstationTdVO.getWorkstationGroupId(); |
| | | String directorTransferId = workstationTdVO.getDirectorTransferId(); |
| | | if (CommonConstant.CREATE_SAME_DIRECTORY.equals(type)) { |
| | | TransferDirectory existSameDirectory = this.transferDirectoryService.getOne(Wrappers.<TransferDirectory>lambdaQuery().eq(TransferDirectory::getName, workstationName)); |
| | | /* |
| | | TransferDirectory existSameDirectory = (TransferDirectory) this.transferDirectoryService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getName(); |
| | | }, workstationName)); |
| | | }, workstationName));*/ |
| | | if (existSameDirectory != null) { |
| | | throw new ServiceException(MessageUtils.message("dnc.workstation.directory.create.same.name.exists", new Object[0])); |
| | | } |
| | |
| | | if (Func.isEmpty(list)) { |
| | | throw new ServiceException(MessageUtils.message("dnc.ftp.directory.not.exist", new Object[0])); |
| | | } |
| | | Map<Long, TransferDirectory> transferDirectoryMap = (Map) list.stream().collect(Collectors.toMap((v0) -> { |
| | | Map<Long, TransferDirectory> transferDirectoryMap = list.stream().collect(Collectors.toMap((v0) -> { |
| | | return v0.getId(); |
| | | }, Function.identity())); |
| | | if (CommonConstant.ASSOCIATED_DIRECTORY.equals(type) && (transferDirectory = transferDirectoryMap.get(Long.valueOf(Long.parseLong(directorTransferId)))) != null) { |