测试代码

yangys

2024-05-30 a3686cfa49bf53fb91a2ceb960cf15b3ebdac641

 smart-man-boot/src/main/java/com/qianwen/smartman/modules/dnc/service/impl/TransferDirectoryFileServiceImpl.java

@@ -1,23 +1,11 @@
package com.qianwen.smartman.modules.dnc.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.google.common.collect.Lists;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.lang.invoke.SerializedLambda;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Comparator;
import java.util.Date;
import java.util.LinkedList;
@@ -28,13 +16,20 @@
import java.util.TreeSet;
import java.util.function.Function;
import java.util.stream.Collectors;

import org.apache.commons.io.IOUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.qianwen.smartman.common.cache.RegionCache;
import com.qianwen.smartman.common.constant.CommonConstant;
import com.qianwen.smartman.common.constant.DncConstant;
import com.qianwen.smartman.common.utils.MessageUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.google.common.collect.Lists;
import com.qianwen.core.log.exception.ServiceException;
import com.qianwen.core.mp.base.BaseServiceImpl;
import com.qianwen.core.mp.support.Condition;
@@ -42,6 +37,9 @@
import com.qianwen.core.secure.BladeUser;
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.constant.DncConstant;
import com.qianwen.smartman.common.utils.MessageUtils;
import com.qianwen.smartman.modules.cps.entity.Machine;
import com.qianwen.smartman.modules.cps.entity.Workstation;
import com.qianwen.smartman.modules.cps.entity.WorkstationOfMachine;
@@ -94,11 +92,8 @@
import com.qianwen.smartman.modules.resource.builder.oss.OssBuilder;
import com.qianwen.smartman.modules.system.entity.User;
import com.qianwen.smartman.modules.system.service.IUserService;
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/TransferDirectoryFileServiceImpl.class */
public class TransferDirectoryFileServiceImpl extends BaseServiceImpl<TransferDirectoryFileMapper, TransferDirectoryFile> implements ITransferDirectoryFileService {
    private static final Logger log = LoggerFactory.getLogger(TransferDirectoryFileServiceImpl.class);
    private final IWorkstationService workstationService;
@@ -114,251 +109,6 @@
    private final IObsFileService obsFileService;
    private final IDncFixedSpaceService fixedSpaceService;
    private final OssBuilder ossBuilder;

    private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) {
        String implMethodName = lambda.getImplMethodName();
        boolean z = true;
        switch (implMethodName.hashCode()) {
            case -75127775:
                if (implMethodName.equals("getTdId")) {
                    z = true;
                    break;
                }
                break;
            case 98245393:
                if (implMethodName.equals("getId")) {
                    z = true;
                    break;
                }
                break;
            case 537556537:
                if (implMethodName.equals("getIsCurrent")) {
                    z = true;
                    break;
                }
                break;
            case 727664238:
                if (implMethodName.equals("getOriginalFilename")) {
                    z = true;
                    break;
                }
                break;
            case 973507584:
                if (implMethodName.equals("getCovertTime")) {
                    z = true;
                    break;
                }
                break;
            case 989020860:
                if (implMethodName.equals("getStorageSpaceId")) {
                    z = true;
                    break;
                }
                break;
            case 1342380108:
                if (implMethodName.equals("getFileType")) {
                    z = true;
                    break;
                }
                break;
            case 1343131517:
                if (implMethodName.equals("getFilename")) {
                    z = true;
                    break;
                }
                break;
            case 1388468386:
                if (implMethodName.equals("getVersion")) {
                    z = false;
                    break;
                }
                break;
            case 1956478023:
                if (implMethodName.equals("getTransferDirectoryId")) {
                    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/dnc/entity/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getVersion();
                    };
                }
                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/dnc/entity/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getOriginalFilename();
                    };
                }
                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/dnc/entity/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getIsCurrent();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getIsCurrent();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getIsCurrent();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getIsCurrent();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getIsCurrent();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getIsCurrent();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getIsCurrent();
                    };
                }
                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/DncFactoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getIsCurrent();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getIsCurrent();
                    };
                }
                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/dnc/entity/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getFilename();
                    };
                }
                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/dnc/entity/DncFixedSpace") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getTdId();
                    };
                }
                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/DncFixedSpace") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getTdId();
                    };
                }
                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/DncFixedSpace") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getTdId();
                    };
                }
                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/dnc/entity/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/util/Date;")) {
                    return (v0) -> {
                        return v0.getCovertTime();
                    };
                }
                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();
                    };
                }
                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/dnc/entity/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getTransferDirectoryId();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getTransferDirectoryId();
                    };
                }
                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/dnc/entity/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getStorageSpaceId();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getStorageSpaceId();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getStorageSpaceId();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getStorageSpaceId();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getStorageSpaceId();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getStorageSpaceId();
                    };
                }
                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/dnc/entity/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getFileType();
                    };
                }
                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/TransferDirectoryFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getFileType();
                    };
                }
                break;
        }
        throw new IllegalArgumentException("Invalid lambda deserialization");
    }

    public TransferDirectoryFileServiceImpl(final IWorkstationService workstationService, final IDncOperationLogService operationLogService, final IFileService fileService, final IUserService userService, final IDncFactoryFileService dncFactoryFileService, final TransferDirectoryFileMapper transferDirectoryFileMapper, final IWorkstationOfMachineService workstationOfMachineService, final IMachineService machineService, final DncOnlineFileClient dncOnlineFileClient, final IDncArtFileService artFileService, final IObsFileService obsFileService, final IDncFixedSpaceService fixedSpaceService, final OssBuilder ossBuilder) {
        this.workstationService = workstationService;
@@ -376,7 +126,7 @@
        this.ossBuilder = ossBuilder;
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public SaveBatchWorkstationFileVO saveDirectoryFile(Long workstationId, List<WorkstationDirectoryFileVO> workstationDirectoryFileVOList) {
        SaveBatchWorkstationFileVO saveBatchWorkstationFileVO = new SaveBatchWorkstationFileVO();
@@ -387,7 +137,7 @@
        Map<Long, DncFixedSpace> dncFixedSpaceMap = null;
        List<DncFixedSpace> list = this.fixedSpaceService.list();
        if (Func.isNotEmpty(list)) {
            dncFixedSpaceMap = (Map) list.stream().collect(Collectors.toMap((v0) -> {
            dncFixedSpaceMap = list.stream().collect(Collectors.toMap((v0) -> {
                return v0.getId();
            }, Function.identity()));
        }
@@ -417,6 +167,11 @@
            }
            Map<String, TransferDirectoryFile> transferDirectoryFileMap = null;
            if (Func.isNotEmpty(repeatFileIds) && repeatFileIds.size() > 0) {
               update(Wrappers.<TransferDirectoryFile>lambdaUpdate().in(TransferDirectoryFile::getId, repeatFileIds)
                     .set(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.NO.getCode())
                     .set(TransferDirectoryFile::getCovertTime, new Date()));
               List<TransferDirectoryFile> exitList = list(Wrappers.<TransferDirectoryFile>lambdaQuery().in(TransferDirectoryFile::getId, repeatFileIds));
               /*
                update((Wrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate().in((v0) -> {
                    return v0.getId();
                }, repeatFileIds)).set((v0) -> {
@@ -426,9 +181,9 @@
                }, new Date()));
                List<TransferDirectoryFile> exitList = list((Wrapper) Wrappers.lambdaQuery().in((v0) -> {
                    return v0.getId();
                }, repeatFileIds));
                }, repeatFileIds));*/
                if (Func.isNotEmpty(exitList)) {
                    transferDirectoryFileMap = (Map) exitList.stream().collect(Collectors.toMap(s -> {
                    transferDirectoryFileMap = exitList.stream().collect(Collectors.toMap(s -> {
                        return s.getFilename() + "/" + s.getFileType() + "/" + s.getStorageSpaceId();
                    }, Function.identity()));
                }
@@ -480,7 +235,7 @@
        return saveBatchWorkstationFileVO;
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public List<WorkstationDirectoryFileVO> saveBatchFile(WorkstationFileVO workstationFileVo) {
        List<WorkstationDirectoryFileVO> list = new ArrayList<>();
@@ -495,24 +250,28 @@
        return list;
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public List<Long> verificationUploadFileList(Long workstationId, List<WorkstationDirectoryFileVO> workstationDirectoryFileVOList) {
        List<Long> repeatFileIds = new LinkedList<>();
        Long storageSpaceId = ((DncFixedSpace) Objects.requireNonNull(getStorageRootSpaceId(workstationId))).getId();
        workstationDirectoryFileVOList.forEach(sa -> {
            List<TransferDirectoryFile> list = null;
            if (Func.isNotEmpty(sa.getStorageSpaceId())) {
               list = list(Wrappers.<TransferDirectoryFile>lambdaQuery().eq(TransferDirectoryFile::getStorageSpaceId, sa.getStorageSpaceId())); 
               /*
                list = list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
                    return v0.getStorageSpaceId();
                }, sa.getStorageSpaceId()));
                }, sa.getStorageSpaceId()));*/
            }
            if (Func.isEmpty(sa.getStorageSpaceId())) {
               list = list(Wrappers.<TransferDirectoryFile>lambdaQuery().eq(TransferDirectoryFile::getStorageSpaceId, storageSpaceId)); 
               /*
                list = list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
                    return v0.getStorageSpaceId();
                }, storageSpaceId));
                }, storageSpaceId));*/
            }
            if (Func.isNotEmpty(list)) {
                Map<String, TransferDirectoryFile> fileMap = (Map) list.stream().filter(s -> {
                Map<String, TransferDirectoryFile> fileMap = list.stream().filter(s -> {
                    return s.getIsCurrent().equals(DncEnums.CurrentVersion.YES.getCode());
                }).collect(Collectors.toMap(s2 -> {
                    return s2.getFilename() + "/" + s2.getFileType() + "/" + s2.getStorageSpaceId();
@@ -545,21 +304,29 @@
        workstationDirectoryFileVOList.forEach(sa -> {
            List<TransferDirectoryFile> list = null;
            if (Func.isNotEmpty(sa.getStorageSpaceId())) {
               list = list(Wrappers.<TransferDirectoryFile>lambdaQuery()
                     .eq(TransferDirectoryFile::getStorageSpaceId, sa.getStorageSpaceId())
                     .eq(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode())); 
               /*
                list = list((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
                    return v0.getStorageSpaceId();
                }, sa.getStorageSpaceId())).eq((v0) -> {
                    return v0.getIsCurrent();
                }, DncEnums.CurrentVersion.YES.getCode()));
                }, DncEnums.CurrentVersion.YES.getCode()));*/
            }
            if (Func.isEmpty(sa.getStorageSpaceId())) {
               list = list(Wrappers.<TransferDirectoryFile>lambdaQuery(
                     ).eq(TransferDirectoryFile::getStorageSpaceId, storageSpaceId)
                     .eq(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode())); 
               /*
                list = list((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
                    return v0.getStorageSpaceId();
                }, storageSpaceId)).eq((v0) -> {
                    return v0.getIsCurrent();
                }, DncEnums.CurrentVersion.YES.getCode()));
                }, DncEnums.CurrentVersion.YES.getCode()));*/
            }
            if (Func.isNotEmpty(list)) {
                Map<String, TransferDirectoryFile> fileMap = (Map) list.stream().collect(Collectors.toMap(s -> {
                Map<String, TransferDirectoryFile> fileMap = list.stream().collect(Collectors.toMap(s -> {
                    return s.getFilename() + "/" + s.getFileType() + "/" + s.getStorageSpaceId();
                }, Function.identity()));
                TransferDirectoryFile transferDirectoryFile = null;
@@ -594,13 +361,13 @@
        return null;
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public Boolean existDuplicateFile(Long id, List<WorkstationDirectoryFileVO> workstationDirectoryFileVOList) {
        List<Long> longs = verificationUploadFileList(id, workstationDirectoryFileVOList);
        return Boolean.valueOf(Func.isNotEmpty(longs) && longs.size() > 0);
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public Boolean existDuplicateFileBatch(WorkstationFileVO workstationFileVo) {
        List<Long> existsIds = new ArrayList<>();
        List<Long> workstationIds = workstationFileVo.getWorkstationIds();
@@ -612,7 +379,7 @@
        return Boolean.valueOf(Func.isNotEmpty(existsIds) && existsIds.size() > 0);
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public void saveOperationLog(TransferDirectoryFile transferDirectoryFile, Integer operationType) {
        File file = (File) this.fileService.getById(transferDirectoryFile.getCraftFileId());
        List<Long> ids = new ArrayList<>();
@@ -626,11 +393,13 @@
        }
        String fromPath = "";
        if (Func.isNotEmpty(ids)) {
           fromPath = this.fileService.list(Wrappers.<File>lambdaQuery().in(File::getId, ids)).stream().map(File::getDisplayName).collect(Collectors.joining("/")); 
           /*
            fromPath = (String) this.fileService.list((Wrapper) Wrappers.lambdaQuery().in((v0) -> {
                return v0.getId();
            }, ids)).stream().map((v0) -> {
                return v0.getDisplayName();
            }).collect(Collectors.joining("/"));
            }).collect(Collectors.joining("/"));*/
        }
        DncOperationLogDto dncOperationLogDto = new DncOperationLogDto();
        WorkstationVO workstationVO = this.workstationService.getDetail(transferDirectoryFile.getWorkstationId());
@@ -655,22 +424,28 @@
        this.operationLogService.insertLog(dncOperationLogDto);
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public List<UploadFileOssVO> workstationFromFile(Integer fileType, List<UploadFileOssVO> list) {
        BladeUser user = AuthUtil.getUser();
        return this.fileService.batchSave(user, list, DncEnums.LogOperationType.UPLOAD.getCode(), fileType);
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public List<FileHistoryVO> getFileCoverHistory(String id) {
        TransferDirectoryFile transferDirectoryFile;
        Map<Long, User> userMap = (Map) this.userService.list().stream().collect(Collectors.toMap((v0) -> {
        Map<Long, User> userMap = this.userService.list().stream().collect(Collectors.toMap((v0) -> {
            return v0.getId();
        }, Function.identity()));
        if (Func.isNotBlank(id) && (transferDirectoryFile = (TransferDirectoryFile) getById(id)) != null) {
            Long transferDirectoryId = transferDirectoryFile.getTransferDirectoryId();
            String filename = transferDirectoryFile.getFilename();
            Integer fileType = transferDirectoryFile.getFileType();
            List<TransferDirectoryFile> list = list(Wrappers.<TransferDirectoryFile>lambdaQuery().eq(TransferDirectoryFile::getTransferDirectoryId, transferDirectoryId)
                    .eq(TransferDirectoryFile::getFilename, filename)
                    .eq(TransferDirectoryFile::getFileType, fileType)
                    .eq(TransferDirectoryFile::getStorageSpaceId, transferDirectoryFile.getStorageSpaceId())
                    .orderByDesc(TransferDirectoryFile::getIsCurrent).orderByDesc(TransferDirectoryFile::getVersion));
            /*
            List<TransferDirectoryFile> list = list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
                return v0.getTransferDirectoryId();
            }, transferDirectoryId)).eq((v0) -> {
@@ -683,15 +458,15 @@
                return v0.getIsCurrent();
            })).orderByDesc((v0) -> {
                return v0.getVersion();
            }));
            }));*/
            if (Func.isNotEmpty(list)) {
                List<Long> artFileIds = (List) list.stream().filter(s -> {
                List<Long> artFileIds = list.stream().filter(s -> {
                    return DncEnums.FileSource.PROCESSING_PROGRAM.getCode().equals(s.getFileSource());
                }).map((v0) -> {
                    return v0.getCraftFileId();
                }).collect(Collectors.toList());
                Map<Long, ArtFileInformationDTO> artFileInformationMap = artFileInformationMap(artFileIds);
                return (List) list.stream().map(s2 -> {
                return list.stream().map(s2 -> {
                    ArtFileInformationDTO fileInformation;
                    FileHistoryVO build = FileHistoryVO.builder().id(s2.getId()).createTime(s2.getCreateTime()).filename(s2.getFilename()).objectKey(s2.getObjectKey()).isCurrent(s2.getIsCurrent()).covertTime(s2.getCovertTime()).link(s2.getLink()).contentMd5(s2.getContentMd5()).contentLength(s2.getContentLength()).contentType(s2.getContentType()).suffix(s2.getSuffix()).createUser(String.valueOf(s2.getCreateUser())).updateUser(String.valueOf(s2.getUpdateUser())).createUserName(userMap.get(s2.getCreateUser()) != null ? ((User) userMap.get(s2.getCreateUser())).getAccount() : "").updateUserName(userMap.get(s2.getUpdateUser()) != null ? ((User) userMap.get(s2.getUpdateUser())).getAccount() : "").updateTime(s2.getUpdateTime()).version(s2.getVersion() != null ? String.valueOf(s2.getVersion()) : "1").versionDesc(s2.getVersion() + CommonConstant.FILE_SUFFIX).build();
                    if (DncEnums.FileSource.PROCESSING_PROGRAM.getCode().equals(s2.getFileSource()) && !artFileInformationMap.isEmpty() && (fileInformation = (ArtFileInformationDTO) artFileInformationMap.get(s2.getCraftFileId())) != null) {
@@ -709,10 +484,10 @@
                }).collect(Collectors.toList());
            }
        }
        return new ArrayList();
        return new ArrayList<>();
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public Boolean fileVersionSwitching(FileVersionSwitchVO fileVersionSwitchVO) {
        boolean result = false;
@@ -721,6 +496,11 @@
            if (file == null || !DncEnums.CurrentVersion.YES.getCode().equals(file.getIsCurrent())) {
                throw new ServiceException(MessageUtils.message("dnc.workstation.file.is.not.exist.or.is.not.current.version", new Object[0]));
            }
            
            boolean updateSwitch = update(Wrappers.<TransferDirectoryFile>lambdaUpdate().set(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode()).eq(TransferDirectoryFile::getId, fileVersionSwitchVO.getSwitchFileId()));
            boolean updateCurrent = update(Wrappers.<TransferDirectoryFile>lambdaUpdate().set(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.NO.getCode()).eq(TransferDirectoryFile::getId, fileVersionSwitchVO.getCurrentFileId()));
            
            /*
            boolean updateSwitch = update((Wrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate().set((v0) -> {
                return v0.getIsCurrent();
            }, DncEnums.CurrentVersion.YES.getCode())).eq((v0) -> {
@@ -731,6 +511,7 @@
            }, DncEnums.CurrentVersion.NO.getCode())).eq((v0) -> {
                return v0.getId();
            }, fileVersionSwitchVO.getCurrentFileId()));
            */
            if (updateSwitch && updateCurrent) {
                result = true;
            }
@@ -738,7 +519,7 @@
        return Boolean.valueOf(result);
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public IPage<TransferDirectoryFilePageVO> getFilePages(WorkstationFileSearchVO searchDTO, Query query) {
        List<String> suffixs = this.fileService.getSuffix();
        String keywords = searchDTO.getKeywords();
@@ -750,7 +531,7 @@
            if (collect.size() > 0) {
                noSuffix = CommonConstant.NOT_SUFFIX;
            }
            suffixs = (List) suffixs.stream().filter(s -> {
            suffixs = suffixs.stream().filter(s -> {
                return !CommonConstant.NOT_SUFFIX.equals(s);
            }).collect(Collectors.toList());
        }
@@ -762,16 +543,19 @@
            });
            return page.setRecords(filePages);
        }
        return page.setRecords(new ArrayList());
        return page.setRecords(new ArrayList<>());
    }

    private List<String> getStringList(List<String> suffixs) {
        return (List) suffixs.stream().filter((v1) -> {
    	
       return suffixs.stream().filter(CommonConstant.NOT_SUFFIX::equals).collect(Collectors.toList());
       /*
        return suffixs.stream().filter((v1) -> {
            return r1.equals(v1);
        }).collect(Collectors.toList());
        }).collect(Collectors.toList());*/
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public List<TransferDirectoryFileVo> fileList(WorkstationDetailVO workstationDetailVO) {
        String workstationId = workstationDetailVO.getWorkstationId();
        Workstation workstation = (Workstation) this.workstationService.getById(workstationId);
@@ -806,11 +590,13 @@
                    if (DncConstant.REGULAR_SPACE.equals(regularSpace)) {
                        storageSpaceIds.add(storageRootSpaceId.getId());
                    } else {
                       List<DncFixedSpace> list = this.fixedSpaceService.list(Wrappers.<DncFixedSpace>lambdaQuery().eq(DncFixedSpace::getTdId, storageRootSpaceId.getTdId()));
                       /*
                        List<DncFixedSpace> list = this.fixedSpaceService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
                            return v0.getTdId();
                        }, storageRootSpaceId.getTdId()));
                        }, storageRootSpaceId.getTdId()));*/
                        if (Func.isNotEmpty(list)) {
                            storageSpaceIds.addAll((Collection) list.stream().map((v0) -> {
                            storageSpaceIds.addAll(list.stream().map((v0) -> {
                                return v0.getId();
                            }).distinct().collect(Collectors.toList()));
                        }
@@ -823,35 +609,42 @@
            DncFixedSpace storageRootSpaceId2 = getStorageRootSpaceId(Long.valueOf(Func.toLong(workstationId)));
            if (storageRootSpaceId2 != null) {
                Long tdId = storageRootSpaceId2.getTdId();
                List<DncFixedSpace> list2 = this.fixedSpaceService.list(Wrappers.<DncFixedSpace>lambdaQuery().eq(DncFixedSpace::getTdId, tdId));
                /*
                List<DncFixedSpace> list2 = this.fixedSpaceService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
                    return v0.getTdId();
                }, tdId));
                }, tdId));*/
                if (Func.isNotEmpty(list2)) {
                    storageSpaceIds.addAll((Collection) list2.stream().map((v0) -> {
                    storageSpaceIds.addAll(list2.stream().map((v0) -> {
                        return v0.getId();
                    }).distinct().collect(Collectors.toList()));
                }
            }
        }
        Map<Long, User> userMap = (Map) this.userService.list().stream().collect(Collectors.toMap((v0) -> {
        Map<Long, User> userMap = this.userService.list().stream().collect(Collectors.toMap((v0) -> {
            return v0.getId();
        }, Function.identity()));
        Map<Long, String> fixSpaceLocationMap = this.fixedSpaceService.getFixSpaceLocation(Long.valueOf(Long.parseLong(workstationId)));
        if (Func.isNotEmpty(fileLocations) && fileLocations.contains(CommonConstant.API_SCOPE_CATEGORY) && Func.isNotEmpty(storageSpaceIds) && workstationDetailVO.getFileLocations().contains(CommonConstant.API_SCOPE_CATEGORY)) {
           List<TransferDirectoryFile> transferDirectoryFiles = list(new QueryWrapper<TransferDirectoryFile>().lambda()
                     .in(TransferDirectoryFile::getStorageSpaceId, storageSpaceIds)
                     .eq(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode())
                     .like(Func.isNotBlank(workstationDetailVO.getFileName()), TransferDirectoryFile::getOriginalFilename, workstationDetailVO.getFileName()));
           /*
            List<TransferDirectoryFile> transferDirectoryFiles = list(((LambdaQueryWrapper) ((LambdaQueryWrapper) new QueryWrapper().lambda().in((v0) -> {
                return v0.getStorageSpaceId();
            }, storageSpaceIds)).eq((v0) -> {
                return v0.getIsCurrent();
            }, DncEnums.CurrentVersion.YES.getCode())).like(Func.isNotBlank(workstationDetailVO.getFileName()), (v0) -> {
                return v0.getOriginalFilename();
            }, workstationDetailVO.getFileName()));
            List<Long> artFileIds = (List) transferDirectoryFiles.stream().filter(s -> {
            }, workstationDetailVO.getFileName()));*/
            List<Long> artFileIds = transferDirectoryFiles.stream().filter(s -> {
                return DncEnums.FileSource.PROCESSING_PROGRAM.getCode().equals(s.getFileSource());
            }).map((v0) -> {
                return v0.getCraftFileId();
            }).collect(Collectors.toList());
            Map<Long, ArtFileInformationDTO> artFileInformationMap = artFileInformationMap(artFileIds);
            List<TransferDirectoryFileVo> ethernetList = (List) transferDirectoryFiles.stream().map(transferDirectoryFile -> {
            List<TransferDirectoryFileVo> ethernetList = transferDirectoryFiles.stream().map(transferDirectoryFile -> {
                ArtFileInformationDTO fileInformation;
                TransferDirectoryFileVo transferDirectoryFileVo = TransferDirectoryFileConvert.INSTANCE.convert(transferDirectoryFile);
                User updateUser = (User) userMap.get(transferDirectoryFile.getUpdateUser());
@@ -894,26 +687,28 @@
            if (Func.isNotEmpty(ethernetList)) {
                collect.addAll(ethernetList);
            }
            List<DncFactoryFile> list3 = this.dncFactoryFileService.list(Wrappers.<DncFactoryFile>lambdaQuery().eq(DncFactoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode()));
            /*
            List<DncFactoryFile> list3 = this.dncFactoryFileService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
                return v0.getIsCurrent();
            }, DncEnums.CurrentVersion.YES.getCode()));
            }, DncEnums.CurrentVersion.YES.getCode()));*/
            if (Func.isNotEmpty(list3)) {
                List<TransferDirectoryFileVo> factoryList = (List) list3.stream().map(s2 -> {
                    User updateUser = (User) userMap.get(s2.getUpdateUser());
                    User createUser = (User) userMap.get(s2.getCreateUser());
                List<TransferDirectoryFileVo> factoryList =list3.stream().map(s2 -> {
                    User updateUser = userMap.get(s2.getUpdateUser());
                    User createUser = userMap.get(s2.getCreateUser());
                    return TransferDirectoryFileVo.builder().id(s2.getId()).fileType(DncEnums.FileType.PROCESS_DOCUMENTS.getCode()).filename(s2.getFilename()).originalFilename(s2.getOriginalFilename()).contentMd5(s2.getContentMd5()).contentLength(s2.getContentLength()).contentType(s2.getContentType()).objectKey(s2.getObjectKey()).suffix(s2.getSuffix()).link(s2.getLink()).version(s2.getVersion()).versionDesc(s2.getVersion() + CommonConstant.FILE_SUFFIX).storageSpace(DncEnums.StorageSpace.ROUTINE.getCode()).documentOwnership(DncEnums.FileOwnership.FACTORY.getName()).documentOwnerships(DncEnums.FileOwnership.FACTORY.getCode()).updateUser(String.valueOf(s2.getUpdateUser())).updateUserName(updateUser != null ? updateUser.getAccount() : "").createUser(String.valueOf(s2.getCreateUser())).createUserName(createUser != null ? createUser.getAccount() : "").updateTime(s2.getUpdateTime()).whetherArchive(s2.getWhetherArchive()).whetherArchiveDesc(DncEnums.WhetherArchive.Archive.getNameByCode(s2.getWhetherArchive())).build();
                }).collect(Collectors.toList());
                collect.addAll(factoryList);
            }
        }
        return (List) collect.stream().peek(c -> {
        return collect.stream().peek(c -> {
            if (DncConstant.TRANSMISSION_METHOD.equals(transmissionMethod) && DncEnums.FileType.PROCESSING_PROGRAM.getCode().equals(c.getFileType())) {
                c.setCanSent(1);
            }
        }).collect(Collectors.toList());
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public Map<Long, ArtFileInformationDTO> artFileInformationMap(List<Long> artFileIds) {
        Map<Long, ArtFileInformationDTO> artFileInformationMap = null;
        if (Func.isNotEmpty(artFileIds)) {
@@ -922,7 +717,7 @@
        return artFileInformationMap;
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public Boolean deleteWorkstationDirectoryFile(String fileId) {
        TransferDirectoryFile transferDirectoryFile = (TransferDirectoryFile) getById(String.valueOf(fileId));
        if (transferDirectoryFile == null) {
@@ -932,18 +727,23 @@
        return Boolean.valueOf(removeById(transferDirectoryFile.getId()));
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public List<TransferDirectoryFile> findProgram(Long id) {
       return list(Wrappers.<TransferDirectoryFile>lambdaQuery()
               .eq(TransferDirectoryFile::getTransferDirectoryId, id)
               .eq(TransferDirectoryFile::getFileType, 1)
               .eq(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode()));
       /*
        return list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
            return v0.getTransferDirectoryId();
        }, id)).eq((v0) -> {
            return v0.getFileType();
        }, 1)).eq((v0) -> {
            return v0.getIsCurrent();
        }, DncEnums.CurrentVersion.YES.getCode()));
        }, DncEnums.CurrentVersion.YES.getCode()));*/
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public MachineToolBatchWriteFileVO batchOnlineWriteFile(MachineToolBatchWriteFileVO writeFileVO) {
        List<String> workstationIds = writeFileVO.getWorkstationIds();
@@ -956,7 +756,7 @@
        return writeFileVO;
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public String writeDncOnlineFile(String workstationId, List<DncWriteFileVO> dncWriteFileVOList) {
        dncWriteFileVOList.forEach(writeFile -> {
            String fileName = writeFile.getFileName();
@@ -1010,7 +810,7 @@
        return MessageUtils.message("dnc.file.written.successfully", new Object[0]);
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public InputStream readDncOnlineFile(DncReadFileVO dncReadFileVO) {
        String fileName = dncReadFileVO.getFileName();
        String workstationId = dncReadFileVO.getWorkstationId();
@@ -1029,7 +829,7 @@
        }
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public String delOnlineFile(DncReadFileVO dncReadFileVO) {
        String workstationId = dncReadFileVO.getWorkstationId();
@@ -1065,7 +865,7 @@
        }
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public List<TransferDirectoryFileVo> getOnlineFileList(DncReadFileVO dncReadFileVO) {
        JSONArray data;
        List<TransferDirectoryFileVo> transferDirectoryFileVoList = new ArrayList<>();
@@ -1102,7 +902,7 @@
        }
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public List<SerialInfoDTO> allSerialList() {
        try {
            String str = this.dncOnlineFileClient.serialFileSerialList();
@@ -1128,7 +928,7 @@
        }
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public Integer serialDownloadSend(SerialSendVO vo) {
        log.info("远程地址: {}", vo);
        try {
@@ -1145,7 +945,7 @@
        }
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public SendScheduleVO sendSchedule() {
        try {
            String str = this.dncOnlineFileClient.sendSchedule();
@@ -1162,7 +962,7 @@
        }
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public boolean serialReceive(SerialSetting serialSetting) {
        try {
            String str = this.dncOnlineFileClient.serialReceive(serialSetting);
@@ -1178,7 +978,7 @@
        }
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public ReceiveScheduleVO receiveSchedule(String encodingType) {
        try {
            String str = this.dncOnlineFileClient.receiveSchedule(encodingType);
@@ -1195,7 +995,7 @@
        }
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public boolean transportCancel() {
        try {
            String str = this.dncOnlineFileClient.transportCancel();
@@ -1210,7 +1010,7 @@
        }
    }

    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public List<WorkstationDirectoryFileVO> serialSaveFile(WorkstationDirectoryFileVO vo) {
        Long workstationId = vo.getWorkstationId();
        Long storageSpaceId = vo.getStorageSpaceId();
@@ -1222,13 +1022,16 @@
                if (storageSpace.intValue() == 1) {
                    vo.setStorageSpaceId(rootSpaceId);
                } else {
                   List<DncFixedSpace> list1 = this.fixedSpaceService.list(Wrappers.<DncFixedSpace>lambdaQuery().eq(DncFixedSpace::getTdId, storageRootSpaceId.getTdId()));
                   /*
                    Long id = (Long) this.fixedSpaceService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
                        return v0.getTdId();
                    }, storageRootSpaceId.getTdId())).stream().map((v0) -> {
                        return v0.getId();
                    }).filter(c -> {
                        return !c.equals(rootSpaceId);
                    }).findFirst().get();
                    }).findFirst().get();*/
                   Long id = list1.stream().map(DncFixedSpace::getId).filter(c -> !c.equals(rootSpaceId)).findFirst().get();
                    vo.setStorageSpaceId(id);
                }
            }
@@ -1247,12 +1050,20 @@
            saveBatchLists.addAll(addLists);
        }
        if (Func.isNotEmpty(saveBatchLists)) {
            List<TransferDirectoryFile> collect = (List) saveBatchLists.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> {
                return new TreeSet(Comparator.comparing(alarm -> {
        	
            //gui
           /*
           List<TransferDirectoryFile> collect = saveBatchLists.stream().collect(
                     Collectors.collectingAndThen(
                       Collectors.toCollection(() -> new TreeSet(Comparator.comparing(()))), ArrayList::new));
                       */
        	            
            List<TransferDirectoryFile> collect = saveBatchLists.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> {
                return new TreeSet<>(Comparator.comparing(alarm -> {
                    return alarm.getFilename() + "===" + alarm.getStorageSpaceId() + "===" + alarm.getIsCurrent() + "===" + alarm.getVersion() + "===" + alarm.getFileType();
                }));
            }), (v1) -> {
                return new ArrayList(v1);
                return new ArrayList<>(v1);
            }));
            saveBatch(collect);
        }