yangys
2024-05-09 60e317f7782c718d28920060fd686d2092c99c1e
smart-man-boot/src/main/java/com/qianwen/smartman/modules/dnc/service/impl/TransferDirectoryFileServiceImpl.java
@@ -94,7 +94,6 @@
import com.qianwen.smartman.modules.system.service.IUserService;
@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;
@@ -127,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();
@@ -236,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<>();
@@ -251,7 +250,7 @@
        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();
@@ -362,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();
@@ -380,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<>();
@@ -425,13 +424,13 @@
        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 = this.userService.list().stream().collect(Collectors.toMap((v0) -> {
@@ -488,7 +487,7 @@
        return new ArrayList<>();
    }
    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public Boolean fileVersionSwitching(FileVersionSwitchVO fileVersionSwitchVO) {
        boolean result = false;
@@ -520,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();
@@ -556,7 +555,7 @@
        }).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);
@@ -709,7 +708,7 @@
        }).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)) {
@@ -718,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) {
@@ -728,7 +727,7 @@
        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)
@@ -744,7 +743,7 @@
        }, 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();
@@ -757,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();
@@ -811,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();
@@ -830,7 +829,7 @@
        }
    }
    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public String delOnlineFile(DncReadFileVO dncReadFileVO) {
        String workstationId = dncReadFileVO.getWorkstationId();
@@ -866,7 +865,7 @@
        }
    }
    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public List<TransferDirectoryFileVo> getOnlineFileList(DncReadFileVO dncReadFileVO) {
        JSONArray data;
        List<TransferDirectoryFileVo> transferDirectoryFileVoList = new ArrayList<>();
@@ -903,7 +902,7 @@
        }
    }
    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public List<SerialInfoDTO> allSerialList() {
        try {
            String str = this.dncOnlineFileClient.serialFileSerialList();
@@ -929,7 +928,7 @@
        }
    }
    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public Integer serialDownloadSend(SerialSendVO vo) {
        log.info("远程地址: {}", vo);
        try {
@@ -946,7 +945,7 @@
        }
    }
    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public SendScheduleVO sendSchedule() {
        try {
            String str = this.dncOnlineFileClient.sendSchedule();
@@ -963,7 +962,7 @@
        }
    }
    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public boolean serialReceive(SerialSetting serialSetting) {
        try {
            String str = this.dncOnlineFileClient.serialReceive(serialSetting);
@@ -979,7 +978,7 @@
        }
    }
    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public ReceiveScheduleVO receiveSchedule(String encodingType) {
        try {
            String str = this.dncOnlineFileClient.receiveSchedule(encodingType);
@@ -996,7 +995,7 @@
        }
    }
    @Override // org.springblade.modules.dnc.service.ITransferDirectoryFileService
    @Override
    public boolean transportCancel() {
        try {
            String str = this.dncOnlineFileClient.transportCancel();
@@ -1011,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();