package com.qianwen.smartman.modules.dnc.service.impl;
|
|
import java.io.File;
|
import java.io.IOException;
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
import java.util.Optional;
|
import java.util.stream.Collectors;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.apache.commons.io.FileUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.google.common.collect.Lists;
|
import com.qianwen.core.excel.util.ExcelUtil;
|
import com.qianwen.core.log.exception.ServiceException;
|
import com.qianwen.core.oss.OssTemplate;
|
import com.qianwen.core.oss.model.BladeFile;
|
import com.qianwen.core.oss.model.OssFile;
|
import com.qianwen.core.secure.utils.AuthUtil;
|
import com.qianwen.core.tool.api.ResultCode;
|
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.LocalDateTimeUtils;
|
import com.qianwen.smartman.common.utils.MessageUtils;
|
import com.qianwen.smartman.modules.cps.service.IWorkstationService;
|
import com.qianwen.smartman.modules.cps.vo.WorkstationVO;
|
import com.qianwen.smartman.modules.dnc.context.DncFileNameProcessRuleContext;
|
import com.qianwen.smartman.modules.dnc.context.DncFileNameProcessRuleFactory;
|
import com.qianwen.smartman.modules.dnc.dto.ArtFileInformationDTO;
|
import com.qianwen.smartman.modules.dnc.dto.DncOperationLogDto;
|
import com.qianwen.smartman.modules.dnc.entity.DncArtBag;
|
import com.qianwen.smartman.modules.dnc.entity.DncFixedSpace;
|
import com.qianwen.smartman.modules.dnc.entity.DncWsRelationTd;
|
import com.qianwen.smartman.modules.dnc.entity.TransferDirectory;
|
import com.qianwen.smartman.modules.dnc.entity.TransferDirectoryFile;
|
import com.qianwen.smartman.modules.dnc.enums.DncEnums;
|
import com.qianwen.smartman.modules.dnc.service.IDncFixedSpaceService;
|
import com.qianwen.smartman.modules.dnc.service.IDncOperationLogService;
|
import com.qianwen.smartman.modules.dnc.service.IDncWsRelationTdService;
|
import com.qianwen.smartman.modules.dnc.service.IDockingFtpService;
|
import com.qianwen.smartman.modules.dnc.service.ITransferDirectoryFileService;
|
import com.qianwen.smartman.modules.dnc.service.ITransferDirectoryService;
|
import com.qianwen.smartman.modules.dnc.vo.DncFixSpaceVO;
|
import com.qianwen.smartman.modules.dnc.vo.EntityInfoVO;
|
import com.qianwen.smartman.modules.dnc.vo.FtpDirectoryVO;
|
import com.qianwen.smartman.modules.resource.builder.oss.OssBuilder;
|
|
import cn.hutool.core.date.DateTime;
|
import cn.hutool.core.util.StrUtil;
|
|
@Service
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/dnc/service/impl/DockingFtpServiceImpl.class */
|
public class DockingFtpServiceImpl implements IDockingFtpService {
|
private static final Logger log = LoggerFactory.getLogger(DockingFtpServiceImpl.class);
|
private final ITransferDirectoryService transferDirectoryService;
|
private final ITransferDirectoryFileService transferDirectoryFileService;
|
private final IWorkstationService workstationService;
|
private final OssBuilder ossBuilder;
|
private final IDncOperationLogService logService;
|
private final IDncFixedSpaceService fixedSpaceService;
|
private final IDncWsRelationTdService wsRelationTdService;
|
|
public DockingFtpServiceImpl(final ITransferDirectoryService transferDirectoryService, final ITransferDirectoryFileService transferDirectoryFileService, final IWorkstationService workstationService, final OssBuilder ossBuilder, final IDncOperationLogService logService, final IDncFixedSpaceService fixedSpaceService, final IDncWsRelationTdService wsRelationTdService) {
|
this.transferDirectoryService = transferDirectoryService;
|
this.transferDirectoryFileService = transferDirectoryFileService;
|
this.workstationService = workstationService;
|
this.ossBuilder = ossBuilder;
|
this.logService = logService;
|
this.fixedSpaceService = fixedSpaceService;
|
this.wsRelationTdService = wsRelationTdService;
|
}
|
|
@Override // org.springblade.modules.dnc.service.IDockingFtpService
|
public FtpDirectoryVO readDirectory(String path) {
|
List<EntityInfoVO> list = findByDirectoryPath(path);
|
return FtpDirectoryVO.builder().path(path).list(list).build();
|
}
|
|
@Override // org.springblade.modules.dnc.service.IDockingFtpService
|
public String readFile(String path) {
|
Long workstationId = getWorkstationByPath();
|
TransferDirectory transferDirectory = getTransferDirectoryByPath(workstationId);
|
if (Objects.isNull(transferDirectory)) {
|
throw new ServiceException(MessageUtils.message("dnc.transfer.directory.no", new Object[0]));
|
}
|
String fileName = fileName(path);
|
if (Func.isNotBlank(fileName)) {
|
DncFixedSpace dncFixedSpace = getDirectoryName(path, workstationId);
|
if (dncFixedSpace == null) {
|
throw new ServiceException(MessageUtils.message("dnc.ftp.relation.workstation.normal.use", new Object[0]));
|
}
|
TransferDirectoryFile transferDirectoryFile = this.transferDirectoryFileService.getOne(new QueryWrapper<TransferDirectoryFile>().lambda()
|
.eq(TransferDirectoryFile::getTransferDirectoryId, transferDirectory.getId())
|
.eq(TransferDirectoryFile::getOriginalFilename, fileName)
|
.eq(TransferDirectoryFile::getFileType, 1)
|
.eq(Func.isNotEmpty(dncFixedSpace), TransferDirectoryFile::getStorageSpaceId, dncFixedSpace.getId())
|
.eq(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode()));
|
/*
|
TransferDirectoryFile transferDirectoryFile = (TransferDirectoryFile) this.transferDirectoryFileService.getOne((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) new QueryWrapper().lambda().eq((v0) -> {
|
return v0.getTransferDirectoryId();
|
}, transferDirectory.getId())).eq((v0) -> {
|
return v0.getOriginalFilename();
|
}, fileName)).eq((v0) -> {
|
return v0.getFileType();
|
}, 1)).eq(Func.isNotEmpty(dncFixedSpace), (v0) -> {
|
return v0.getStorageSpaceId();
|
}, dncFixedSpace.getId()).eq((v0) -> {
|
return v0.getIsCurrent();
|
}, DncEnums.CurrentVersion.YES.getCode()));*/
|
if (transferDirectoryFile == null) {
|
throw new ServiceException(MessageUtils.message("dnc.file.is.not.exists", new Object[0]));
|
}
|
String link = transferDirectoryFile.getLink();
|
WorkstationVO workstationVO = this.workstationService.getDetail(transferDirectoryFile.getWorkstationId());
|
this.logService.insertLog(new DncOperationLogDto().setLink(link).setWorkstationId(transferDirectoryFile.getWorkstationId()).setTargetPathName(workstationVO.getGroupName() + "/" + workstationVO.getName() + "/" + transferDirectoryFile.getOriginalFilename()).setTargetPathId(transferDirectory.getGroupAllPath()).setTargetType(DncEnums.LogFileSourceType.PROCESSING_PROGRAM.getCode()).setOperationTime(DateTime.now()).setSourceType(DncEnums.LogFileSourceType.FTP.getCode()).setOperationResponse(1).setSourcePathName(DncConstant.FTP_PATH).setOperatorName("机床回传").setOperationType(DncEnums.LogOperationType.DOWNLOAD.getCode()).setSuffix(transferDirectoryFile.getSuffix()).setObjectKey(transferDirectoryFile.getObjectKey()).setFileName(transferDirectoryFile.getFilename()).setVersion(transferDirectoryFile.getVersion()).setFileId(transferDirectoryFile.getId()));
|
return link;
|
}
|
return "";
|
}
|
|
@Override // org.springblade.modules.dnc.service.IDockingFtpService
|
public EntityInfoVO getByPath(String path) {
|
TransferDirectoryFile transferDirectoryFile = getTransferDirectoryFileByPath(path);
|
return (EntityInfoVO) Optional.ofNullable(transferDirectoryFile.getId()).map(c -> {
|
return EntityInfoVO.builder().id(String.valueOf(transferDirectoryFile.getId())).objectKey(transferDirectoryFile.getObjectKey()).isDirectory(Boolean.FALSE).canWrite(Boolean.FALSE).name(transferDirectoryFile.getFilename()).size(transferDirectoryFile.getContentLength()).creationTime(transferDirectoryFile.getCreateTime() != null ? LocalDateTimeUtils.DateToLocalDateTime(transferDirectoryFile.getCreateTime()) : LocalDateTime.now()).updateTime(transferDirectoryFile.getLastModified() == null ? LocalDateTime.now() : LocalDateTimeUtils.DateToLocalDateTime(transferDirectoryFile.getLastModified())).owner(String.valueOf(transferDirectoryFile.getCreateUser())).hash(transferDirectoryFile.getContentMd5()).build();
|
}).orElse(new EntityInfoVO());
|
}
|
|
@Override // org.springblade.modules.dnc.service.IDockingFtpService
|
public EntityInfoVO createFile(String path, HttpServletRequest request) {
|
Long workstationId = getWorkstationByPath();
|
if (Func.isBlank(path)) {
|
return new EntityInfoVO();
|
}
|
log.info("path:{}", path);
|
DncFixedSpace dncFixedSpace = getDirectoryName(path, workstationId);
|
if (dncFixedSpace == null) {
|
throw new ServiceException(MessageUtils.message("dnc.ftp.relation.workstation.normal.use", new Object[0]));
|
}
|
log.info("storageSpace:{}", dncFixedSpace);
|
String fileName = fileName(path);
|
log.info("fileName:{}", fileName);
|
Long workStationId = getWorkstationByPath();
|
TransferDirectory transferDirectory = getTransferDirectoryByPath(workstationId);
|
if (Objects.isNull(transferDirectory)) {
|
throw new ServiceException(MessageUtils.message("dnc.transfer.directory.no", new Object[0]));
|
}
|
OssTemplate template = this.ossBuilder.template();
|
BladeFile bladeFile = null;
|
try {
|
File file = new File(System.getProperty("java.io.tmpdir") + "/" + fileName);
|
FileUtils.copyToFile(request.getInputStream(), file);
|
MultipartFile multipartFile = ExcelUtil.fileToMultipartFile(file);
|
log.info("multipartFile:{}", Boolean.valueOf(multipartFile.isEmpty()));
|
bladeFile = template.putFile(multipartFile.getOriginalFilename(), multipartFile);
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
log.info("BladeFile:{}", bladeFile);
|
OssFile ossFile = template.statFile(((BladeFile) Objects.requireNonNull(bladeFile)).getName());
|
log.info("OssFile:{}", ossFile);
|
String hash = ossFile.getHash();
|
TransferDirectoryFile currentFile = this.transferDirectoryFileService.getOne(Wrappers.<TransferDirectoryFile>lambdaQuery()
|
.eq(TransferDirectoryFile::getTransferDirectoryId, transferDirectory.getId())
|
.eq(TransferDirectoryFile::getFilename, fileName)
|
.eq(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode())
|
.eq(TransferDirectoryFile::getFileType, DncEnums.FileType.PROCESSING_PROGRAM.getCode())
|
.eq(TransferDirectoryFile::getStorageSpaceId, dncFixedSpace.getId()));
|
/*
|
TransferDirectoryFile currentFile = (TransferDirectoryFile) this.transferDirectoryFileService.getOne((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getTransferDirectoryId();
|
}, transferDirectory.getId())).eq((v0) -> {
|
return v0.getFilename();
|
}, fileName)).eq((v0) -> {
|
return v0.getIsCurrent();
|
}, DncEnums.CurrentVersion.YES.getCode())).eq((v0) -> {
|
return v0.getFileType();
|
}, DncEnums.FileType.PROCESSING_PROGRAM.getCode())).eq((v0) -> {
|
return v0.getStorageSpaceId();
|
}, dncFixedSpace.getId()));*/
|
TransferDirectoryFile directoryFile = TransferDirectoryFile.builder().transferDirectoryId(transferDirectory.getId()).workstationId(workStationId).fileType(1).fileSource(DncEnums.FileSource.FTP.getCode()).filename(fileName).originalFilename(fileName).contentMd5(hash).contentLength(Long.valueOf(ossFile.getLength())).contentType(ossFile.getContentType()).objectKey(bladeFile.getName()).suffix(getFileSuffix(fileName)).storageSpace(dncFixedSpace.getSpaceLocation()).storageSpaceId(dncFixedSpace.getId()).isCurrent(DncEnums.CurrentVersion.YES.getCode()).whetherArchive(DncEnums.WhetherArchive.Archive.getCode()).link(ossFile.getLink()).build();
|
if (Func.isNull(currentFile)) {
|
directoryFile.setVersion(CommonConstant.VERSION_NUM);
|
this.transferDirectoryFileService.save(directoryFile);
|
} else if (!hash.equals(currentFile.getContentMd5())) {
|
currentFile.setIsCurrent(DncEnums.CurrentVersion.NO.getCode());
|
this.transferDirectoryFileService.updateById(currentFile);
|
directoryFile.setVersion(Integer.valueOf(currentFile.getVersion().intValue() + CommonConstant.VERSION_NUM.intValue()));
|
this.transferDirectoryFileService.save(directoryFile);
|
}
|
WorkstationVO workstationVO = this.workstationService.getDetail(workStationId);
|
return (EntityInfoVO) Optional.ofNullable(directoryFile).map(c -> {
|
this.logService.insertLog(new DncOperationLogDto().setLink(directoryFile.getLink()).setWorkstationId(directoryFile.getWorkstationId()).setTargetPathName(workstationVO.getGroupName() + "/" + workstationVO.getName() + "/" + directoryFile.getOriginalFilename()).setTargetPathId(transferDirectory.getGroupAllPath()).setTargetType(DncEnums.LogFileSourceType.PROCESSING_PROGRAM.getCode()).setOperationTime(DateTime.now()).setSourceType(DncEnums.LogFileSourceType.FTP.getCode()).setSourcePathName(DncConstant.FTP_PATH).setOperatorName("机床回传").setVersion(directoryFile.getVersion()).setOperationResponse(1).setOperationType(DncEnums.LogOperationType.UPLOAD.getCode()).setSuffix(directoryFile.getSuffix()).setObjectKey(directoryFile.getObjectKey()).setFileName(directoryFile.getFilename()).setFileId(directoryFile.getId()));
|
return EntityInfoVO.builder().id(String.valueOf(c.getId())).objectKey(c.getObjectKey()).isDirectory(Boolean.FALSE).canWrite(Boolean.FALSE).name(c.getFilename()).size(c.getContentLength()).creationTime(c.getCreateTime() != null ? LocalDateTimeUtils.DateToLocalDateTime(c.getCreateTime()) : LocalDateTime.now()).updateTime(c.getLastModified() == null ? LocalDateTime.now() : LocalDateTimeUtils.DateToLocalDateTime(c.getLastModified())).owner(String.valueOf(c.getCreateUser())).hash(c.getContentMd5()).build();
|
}).orElse(new EntityInfoVO());
|
}
|
|
private String getFileSuffix(String name) {
|
int i = name.lastIndexOf(DncConstant.POINT) + CommonConstant.VERSION_NUM.intValue();
|
if (i == CommonConstant.NOT_SEALED_ID.intValue()) {
|
return "";
|
}
|
return name.substring(i);
|
}
|
|
private void coverFile(String path, Long workStationId) {
|
this.transferDirectoryFileService.update(Wrappers.<TransferDirectoryFile>lambdaUpdate()
|
.set(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.NO.getCode())
|
.set(TransferDirectoryFile::getCovertTime, DateTime.now())
|
.eq(TransferDirectoryFile::getFileType, DncEnums.FileType.PROCESSING_PROGRAM.getCode())
|
.eq(TransferDirectoryFile::getOriginalFilename, path)
|
.eq(TransferDirectoryFile::getWorkstationId, workStationId)
|
.eq(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode()));
|
|
/*
|
this.transferDirectoryFileService.update((Wrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate().set((v0) -> {
|
return v0.getIsCurrent();
|
}, DncEnums.CurrentVersion.NO.getCode())).set((v0) -> {
|
return v0.getCovertTime();
|
}, DateTime.now())).eq((v0) -> {
|
return v0.getFileType();
|
}, DncEnums.FileType.PROCESSING_PROGRAM.getCode())).eq((v0) -> {
|
return v0.getOriginalFilename();
|
}, path)).eq((v0) -> {
|
return v0.getWorkstationId();
|
}, workStationId)).eq((v0) -> {
|
return v0.getIsCurrent();
|
}, DncEnums.CurrentVersion.YES.getCode()));*/
|
}
|
|
@Override // org.springblade.modules.dnc.service.IDockingFtpService
|
@Transactional(rollbackFor = {Exception.class})
|
public boolean renameFile(String oldFileName, String newFileName) {
|
Long workstationId = getWorkstationByPath();
|
DncFixedSpace dncFixedSpace = getDirectoryName(oldFileName, workstationId);
|
if (dncFixedSpace == null) {
|
throw new ServiceException(MessageUtils.message("dnc.ftp.relation.workstation.normal.use", new Object[0]));
|
}
|
Long storageSpaceId = dncFixedSpace.getId();
|
String oldName = fileName(oldFileName);
|
String newName = fileName(newFileName);
|
|
Long count = Long.valueOf(this.transferDirectoryFileService.count(Wrappers.<TransferDirectoryFile>lambdaQuery()
|
.eq(TransferDirectoryFile::getWorkstationId, workstationId)
|
.eq(TransferDirectoryFile::getStorageSpaceId, storageSpaceId)
|
.eq(TransferDirectoryFile::getFileType, DncEnums.FileType.PROCESSING_PROGRAM.getCode())
|
.eq(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode())
|
.eq(TransferDirectoryFile::getOriginalFilename, newName)));
|
|
/*
|
Long count = Long.valueOf(this.transferDirectoryFileService.count((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getWorkstationId();
|
}, workstationId)).eq((v0) -> {
|
return v0.getStorageSpaceId();
|
}, storageSpaceId)).eq((v0) -> {
|
return v0.getFileType();
|
}, DncEnums.FileType.PROCESSING_PROGRAM.getCode())).eq((v0) -> {
|
return v0.getIsCurrent();
|
}, DncEnums.CurrentVersion.YES.getCode())).eq((v0) -> {
|
return v0.getOriginalFilename();
|
}, newName)));*/
|
if (count.longValue() > 0) {
|
throw new ServiceException(MessageUtils.message("dnc.file.name.exist", new Object[0]));
|
}
|
TransferDirectoryFile directoryFile = getTransferDirectoryFile(storageSpaceId, oldName, workstationId);
|
TransferDirectory directory = (TransferDirectory) this.transferDirectoryService.getById(directoryFile.getTransferDirectoryId());
|
WorkstationVO workstationVO = this.workstationService.getDetail(workstationId);
|
this.logService.insertLog(new DncOperationLogDto().setLink(directoryFile.getLink()).setWorkstationId(directoryFile.getWorkstationId()).setTargetPathName(workstationVO.getGroupName() + "/" + workstationVO.getName() + "/" + directoryFile.getOriginalFilename()).setTargetPathId(directory.getGroupAllPath()).setTargetType(DncEnums.LogFileSourceType.PROCESSING_PROGRAM.getCode()).setOperationTime(DateTime.now()).setSourceType(DncEnums.LogFileSourceType.FTP.getCode()).setOperationResponse(1).setOperationType(DncEnums.LogOperationType.TO_UPDATE.getCode()).setSuffix(directoryFile.getSuffix()).setObjectKey(directoryFile.getObjectKey()).setFileName(directoryFile.getFilename()).setVersion(directoryFile.getVersion()).setSourcePathName(DncConstant.FTP_PATH).setOperatorName("机床回传").setFileId(directoryFile.getId()));
|
|
return this.transferDirectoryFileService.update(Wrappers.<TransferDirectoryFile>lambdaUpdate()
|
.set(TransferDirectoryFile::getOriginalFilename, newName)
|
.set(TransferDirectoryFile::getFilename, newName)
|
.eq(TransferDirectoryFile::getFileType, DncEnums.FileType.PROCESSING_PROGRAM.getCode())
|
.eq(TransferDirectoryFile::getWorkstationId, workstationId)
|
.eq(TransferDirectoryFile::getStorageSpaceId, storageSpaceId)
|
.eq(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode())
|
.and(i -> i.eq(TransferDirectoryFile::getOriginalFilename, oldName).or().eq(TransferDirectoryFile::getFilename, oldName)));
|
/*
|
return this.transferDirectoryFileService.update((Wrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate().set((v0) -> {
|
return v0.getOriginalFilename();
|
}, newName)).set((v0) -> {
|
return v0.getFilename();
|
}, newName)).eq((v0) -> {
|
return v0.getFileType();
|
}, DncEnums.FileType.PROCESSING_PROGRAM.getCode())).eq((v0) -> {
|
return v0.getWorkstationId();
|
}, workstationId)).eq((v0) -> {
|
return v0.getStorageSpaceId();
|
}, storageSpaceId)).eq((v0) -> {
|
return v0.getIsCurrent();
|
}, DncEnums.CurrentVersion.YES.getCode())).and(i -> {
|
LambdaUpdateWrapper lambdaUpdateWrapper = (LambdaUpdateWrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) i.eq((v0) -> {
|
return v0.getOriginalFilename();
|
}, oldName)).or()).eq((v0) -> {
|
return v0.getFilename();
|
}, oldName);
|
}));*/
|
}
|
|
private TransferDirectoryFile getTransferDirectoryFile(Long storageSpaceId, String oldFileName, Long workstationId) {
|
return (TransferDirectoryFile)this.transferDirectoryFileService.getOne(Wrappers.<TransferDirectoryFile>lambdaQuery()
|
.eq(TransferDirectoryFile::getWorkstationId, workstationId)
|
.eq(TransferDirectoryFile::getFileType, DncEnums.FileType.PROCESSING_PROGRAM.getCode())
|
.eq(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode())
|
.eq(TransferDirectoryFile::getStorageSpaceId, storageSpaceId)
|
.and(i -> i.eq(TransferDirectoryFile::getOriginalFilename, oldFileName).or().eq(TransferDirectoryFile::getFilename, oldFileName)));
|
/*
|
return (TransferDirectoryFile) this.transferDirectoryFileService.getOne((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getWorkstationId();
|
}, workstationId)).eq((v0) -> {
|
return v0.getFileType();
|
}, DncEnums.FileType.PROCESSING_PROGRAM.getCode())).eq((v0) -> {
|
return v0.getIsCurrent();
|
}, DncEnums.CurrentVersion.YES.getCode())).eq((v0) -> {
|
return v0.getStorageSpaceId();
|
}, storageSpaceId)).and(i -> {
|
LambdaQueryWrapper lambdaQueryWrapper = (LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) i.eq((v0) -> {
|
return v0.getOriginalFilename();
|
}, oldFileName)).or()).eq((v0) -> {
|
return v0.getFilename();
|
}, oldFileName);
|
}));*/
|
}
|
|
@Override // org.springblade.modules.dnc.service.IDockingFtpService
|
public boolean deleteFile(String filename) {
|
Long workstationId = getWorkstationByPath();
|
DncFixedSpace dncFixedSpace = getDirectoryName(filename, workstationId);
|
if (dncFixedSpace == null) {
|
throw new ServiceException(MessageUtils.message("dnc.ftp.relation.workstation.normal.use", new Object[0]));
|
}
|
Long storageSpaceId = dncFixedSpace.getId();
|
String name = fileName(filename);
|
TransferDirectoryFile directoryFile = getTransferDirectoryFile(storageSpaceId, name, workstationId);
|
TransferDirectory directory = (TransferDirectory) this.transferDirectoryService.getById(directoryFile.getTransferDirectoryId());
|
WorkstationVO workstationVO = this.workstationService.getDetail(workstationId);
|
this.logService.insertLog(new DncOperationLogDto().setLink(directoryFile.getLink()).setWorkstationId(directoryFile.getWorkstationId()).setTargetPathName(workstationVO.getGroupName() + "/" + workstationVO.getName() + "/" + directoryFile.getOriginalFilename()).setTargetPathId(directory.getGroupAllPath()).setTargetType(DncEnums.LogFileSourceType.PROCESSING_PROGRAM.getCode()).setOperationTime(DateTime.now()).setSourceType(DncEnums.LogFileSourceType.FTP.getCode()).setOperationResponse(1).setOperationType(DncEnums.LogOperationType.DELETE.getCode()).setSuffix(directoryFile.getSuffix()).setObjectKey(directoryFile.getObjectKey()).setFileName(directoryFile.getFilename()).setSourcePathName(DncConstant.FTP_PATH).setOperatorName("机床回传").setVersion(directoryFile.getVersion()).setFileId(directoryFile.getId()));
|
return this.transferDirectoryFileService.removeById(directoryFile);
|
}
|
|
@Override // org.springblade.modules.dnc.service.IDockingFtpService
|
public Integer getOrderCwd(String path) {
|
Long workstationId = getWorkstationByPath();
|
Long ftpNodeParentId = getFtpNodeParentId(path, workstationId);
|
if (Func.isBlank(path) || ftpNodeParentId.longValue() > 0) {
|
return Integer.valueOf(ResultCode.SUCCESS.getCode());
|
}
|
return Integer.valueOf(ResultCode.NOT_FOUND.getCode());
|
}
|
|
private TransferDirectoryFile getTransferDirectoryFileByPath(String path) {
|
Long workstationId = getWorkstationByPath();
|
DncFixedSpace dncFixedSpace = getDirectoryName(path, workstationId);
|
if (dncFixedSpace == null) {
|
throw new ServiceException(MessageUtils.message("dnc.ftp.relation.workstation.normal.use", new Object[0]));
|
}
|
TransferDirectory transferDirectory = getTransferDirectoryByPath(workstationId);
|
if (Objects.isNull(transferDirectory)) {
|
throw new ServiceException(MessageUtils.message("dnc.transfer.directory.no", new Object[0]));
|
}
|
String fileName = fileName(path);
|
|
return Optional.<TransferDirectoryFile>ofNullable(this.transferDirectoryFileService.getOne(new QueryWrapper<TransferDirectoryFile>().lambda()
|
.eq(TransferDirectoryFile::getTransferDirectoryId, transferDirectory.getId())
|
.eq(TransferDirectoryFile::getOriginalFilename, fileName)
|
.eq(TransferDirectoryFile::getFileType, Integer.valueOf(1))
|
.eq(TransferDirectoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode())
|
.eq(Func.isNotEmpty(dncFixedSpace), TransferDirectoryFile::getStorageSpaceId, dncFixedSpace.getId()))
|
)
|
|
.orElse(new TransferDirectoryFile());
|
|
/*
|
return (TransferDirectoryFile) Optional.ofNullable(this.transferDirectoryFileService.getOne(((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) new QueryWrapper().lambda().eq((v0) -> {
|
return v0.getTransferDirectoryId();
|
}, transferDirectory.getId())).eq((v0) -> {
|
return v0.getOriginalFilename();
|
}, fileName)).eq((v0) -> {
|
return v0.getFileType();
|
}, 1)).eq((v0) -> {
|
return v0.getIsCurrent();
|
}, DncEnums.CurrentVersion.YES.getCode())).eq(Func.isNotEmpty(dncFixedSpace), (v0) -> {
|
return v0.getStorageSpaceId();
|
}, dncFixedSpace.getId()))).orElse(new TransferDirectoryFile());
|
*/
|
}
|
|
private DncFixedSpace getDirectoryName(String path, Long workstationId) {
|
|
DncFixedSpace dncFixedSpace2;
|
DncFixedSpace fixedSpace = null;
|
String[] split = StrUtil.split(path, "/");
|
if (Func.isNotEmpty(split)) {
|
int len = split.length;
|
if (len < 2) {
|
Long rootNodeId = this.fixedSpaceService.getRootNodeId(String.valueOf(workstationId)).getRootNodeId();
|
if (Func.isNotEmpty(rootNodeId)) {
|
DncFixedSpace dncFixedSpace = (DncFixedSpace)this.fixedSpaceService.getById(rootNodeId);
|
if (dncFixedSpace != null) {
|
fixedSpace = dncFixedSpace;
|
}
|
}
|
/*
|
if (Func.isNotEmpty(rootNodeId) && (dncFixedSpace2 = (DncFixedSpace) this.fixedSpaceService.getById(rootNodeId)) != null) {
|
fixedSpace = dncFixedSpace2;
|
}*/
|
}
|
if (len >= 2) {
|
String substr = path.substring(0, path.lastIndexOf("/"));
|
Long parentId = getFtpNodeParentId(substr, workstationId);
|
String directoryName = substr.substring(substr.lastIndexOf("/") + 1);
|
DncWsRelationTd wsRelationTd = this.wsRelationTdService.getOne(Wrappers.<DncWsRelationTd>lambdaQuery().eq(DncWsRelationTd::getWorkstationId, workstationId));
|
|
if (wsRelationTd != null) {
|
DncFixedSpace dncFixedSpace = this.fixedSpaceService.getOne(Wrappers.<DncFixedSpace>lambdaQuery()
|
.eq(DncFixedSpace::getTdId, wsRelationTd.getTransferDirectorId())
|
.eq(DncFixedSpace::getParentId, parentId)
|
.eq(DncFixedSpace::getName, directoryName));
|
if (dncFixedSpace != null) {
|
fixedSpace = dncFixedSpace;
|
}
|
}
|
|
/*
|
DncWsRelationTd wsRelationTd = (DncWsRelationTd) this.wsRelationTdService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getWorkstationId();
|
}, workstationId));*/
|
/*
|
if (wsRelationTd != null) && (dncFixedSpace = (DncFixedSpace) this.fixedSpaceService.getOne((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getTdId();
|
}, wsRelationTd.getTransferDirectorId())).eq((v0) -> {
|
return v0.getParentId();
|
}, parentId)).eq((v0) -> {
|
return v0.getName();
|
}, directoryName))) != null) {
|
fixedSpace = dncFixedSpace;
|
}*/
|
}
|
}
|
return fixedSpace;
|
}
|
|
private Integer getStorageSpace(String path) {
|
Integer storageSpace = null;
|
String[] split = StrUtil.split(path, "/");
|
if (Func.isNotEmpty(split)) {
|
int len = split.length;
|
if (len < 2) {
|
storageSpace = DncEnums.StorageSpace.ROUTINE.getCode();
|
}
|
if (len == 2) {
|
String fixedSpace = split[split.length - 2];
|
if (CommonConstant.FIXED_SPACE.equals(fixedSpace)) {
|
storageSpace = DncEnums.StorageSpace.FIXED.getCode();
|
} else {
|
storageSpace = DncEnums.StorageSpace.ROUTINE.getCode();
|
}
|
}
|
}
|
return storageSpace;
|
}
|
|
private TransferDirectory getTransferDirectoryByPath(Long workstationId) {
|
DncWsRelationTd dncWsRelationTd = this.wsRelationTdService.getOne(Wrappers.<DncWsRelationTd>lambdaQuery().eq(DncWsRelationTd::getWorkstationId, workstationId));
|
/*
|
DncWsRelationTd dncWsRelationTd = (DncWsRelationTd) this.wsRelationTdService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getWorkstationId();
|
}, workstationId));*/
|
if (dncWsRelationTd == null) {
|
throw new ServiceException(MessageUtils.message("dnc.workstation.not.binding.ftp.directory", new Object[0]));
|
}
|
TransferDirectory transferDirectory = (TransferDirectory) this.transferDirectoryService.getById(dncWsRelationTd.getTransferDirectorId());
|
if (transferDirectory == null) {
|
throw new ServiceException(MessageUtils.message("dnc.relation.ftp.directory.not.exist", new Object[0]));
|
}
|
return transferDirectory;
|
}
|
|
private String fileName(String path) {
|
String fileName = "";
|
String[] split = StrUtil.split(path, "/");
|
if (Func.isNotEmpty(split)) {
|
int len = split.length;
|
if (len < 2) {
|
fileName = path;
|
}
|
if (len >= 2) {
|
fileName = path.substring(path.lastIndexOf("/") + 1);
|
}
|
}
|
return fileName;
|
}
|
|
private List<EntityInfoVO> findByDirectoryPath(String path) {
|
Long rootNodeId;
|
Long workstationId = getWorkstationByPath();
|
int length = path.split("/").length;
|
DncWsRelationTd dncWsRelationTd = this.wsRelationTdService.getOne(Wrappers.<DncWsRelationTd>lambdaQuery().eq(DncWsRelationTd::getWorkstationId, workstationId));
|
/*
|
DncWsRelationTd dncWsRelationTd = (DncWsRelationTd) this.wsRelationTdService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getWorkstationId();
|
}, workstationId));*/
|
if (dncWsRelationTd == null) {
|
throw new ServiceException(MessageUtils.message("dnc.workstation.not.binding.ftp.directory", new Object[0]));
|
}
|
TransferDirectory transferDirectory = (TransferDirectory) this.transferDirectoryService.getById(dncWsRelationTd.getTransferDirectorId());
|
if (Func.isEmpty(transferDirectory)) {
|
return Lists.newArrayList();
|
}
|
List<TransferDirectoryFile> fileList = this.transferDirectoryFileService.findProgram(transferDirectory.getId());
|
if (Func.isEmpty(fileList)) {
|
return Lists.newArrayList();
|
}
|
List<Long> artFileIds = fileList.stream().filter(s -> {
|
return DncEnums.FileSource.PROCESSING_PROGRAM.getCode().equals(s.getFileSource());
|
}).map((v0) -> {
|
return v0.getCraftFileId();
|
}).collect(Collectors.toList());
|
Map<Long, ArtFileInformationDTO> artFileInformationMap = this.transferDirectoryFileService.artFileInformationMap(artFileIds);
|
if (StrUtil.isBlank(path) && (rootNodeId = this.fixedSpaceService.getRootNodeId(String.valueOf(workstationId)).getRootNodeId()) != null) {
|
List<EntityInfoVO> collect = fileList.stream().filter(s2 -> {
|
return rootNodeId.equals(s2.getStorageSpaceId());
|
}).map(c -> {
|
EntityInfoVO build = EntityInfoVO.builder().id(String.valueOf(c.getId())).objectKey(c.getObjectKey()).isDirectory(Boolean.FALSE).canWrite(Boolean.FALSE).name(c.getOriginalFilename()).size(c.getContentLength()).creationTime(c.getCreateTime() != null ? LocalDateTimeUtils.DateToLocalDateTime(c.getCreateTime()) : LocalDateTime.now()).updateTime(c.getLastModified() == null ? LocalDateTime.now() : LocalDateTimeUtils.DateToLocalDateTime(c.getLastModified())).owner(String.valueOf(c.getCreateUser())).hash(c.getContentMd5()).build();
|
return getEntityInfoVO(artFileInformationMap, c, build);
|
}).collect(Collectors.toList());
|
List<DncFixSpaceVO> fixSpaceTree = this.fixedSpaceService.getFixSpaceTree(String.valueOf(workstationId), String.valueOf(rootNodeId));
|
if (Func.isNotEmpty(fixSpaceTree)) {
|
List<EntityInfoVO> fixSpaceList = getFixSpaceList(fixSpaceTree);
|
collect.addAll(fixSpaceList);
|
}
|
return collect;
|
} else if (length >= CommonConstant.VERSION_NUM.intValue()) {
|
List<EntityInfoVO> collect2 = new ArrayList<>();
|
DncFixedSpace dncFixedSpace = getDirectory(path, workstationId);
|
if (dncFixedSpace == null) {
|
throw new ServiceException(MessageUtils.message("dnc.ftp.relation.workstation.normal.use", new Object[0]));
|
}
|
List<DncFixSpaceVO> fixSpaceVOList = this.fixedSpaceService.getFixSpaceTree(String.valueOf(workstationId), String.valueOf(dncFixedSpace.getId()));
|
if (Func.isNotEmpty(fixSpaceVOList)) {
|
List<EntityInfoVO> fixSpaceList2 = getFixSpaceList(fixSpaceVOList);
|
collect2.addAll(fixSpaceList2);
|
}
|
List<TransferDirectoryFile> files = fileList.stream().filter(s3 -> {
|
return dncFixedSpace.getId().equals(s3.getStorageSpaceId());
|
}).collect(Collectors.toList());
|
if (Func.isNotEmpty(files)) {
|
List<EntityInfoVO> entityInfos = files.stream().map(c2 -> {
|
EntityInfoVO build = EntityInfoVO.builder().id(String.valueOf(c2.getId())).isDirectory(Boolean.FALSE).canWrite(Boolean.FALSE).name(c2.getOriginalFilename()).size(c2.getContentLength()).creationTime(c2.getCreateTime() != null ? LocalDateTimeUtils.DateToLocalDateTime(c2.getCreateTime()) : LocalDateTime.now()).updateTime(c2.getLastModified() == null ? LocalDateTime.now() : LocalDateTimeUtils.DateToLocalDateTime(c2.getLastModified())).owner(String.valueOf(c2.getCreateUser())).hash(c2.getContentMd5()).build();
|
return getEntityInfoVO(artFileInformationMap, c2, build);
|
}).collect(Collectors.toList());
|
collect2.addAll(entityInfos);
|
}
|
return collect2;
|
} else {
|
return new ArrayList<>();
|
}
|
}
|
|
private EntityInfoVO getEntityInfoVO(Map<Long, ArtFileInformationDTO> artFileInformationMap, TransferDirectoryFile c, EntityInfoVO build) {
|
ArtFileInformationDTO fileInformation;
|
if (DncEnums.FileSource.PROCESSING_PROGRAM.getCode().equals(c.getFileSource()) && !artFileInformationMap.isEmpty() && (fileInformation = artFileInformationMap.get(c.getCraftFileId())) != null) {
|
String fileSourceNamePath = fileInformation.getFileSourceNamePath();
|
DncArtBag dncArtBag = fileInformation.getDncArtBag();
|
if (Func.isNotEmpty(dncArtBag) && Func.isNotBlank(fileSourceNamePath)) {
|
DncFileNameProcessRuleContext context = DncFileNameProcessRuleContext.builder().artBag(dncArtBag).directoryPath(fileSourceNamePath).fileName(c.getFilename()).build();
|
String dncFileName = DncFileNameProcessRuleFactory.getDncFileName(context);
|
if (Func.isNotBlank(dncFileName)) {
|
build.setName(dncFileName);
|
}
|
}
|
}
|
return build;
|
}
|
|
private List<EntityInfoVO> getFixSpaceList(List<DncFixSpaceVO> fixSpaceVOList) {
|
List<EntityInfoVO> collect = new ArrayList<>();
|
fixSpaceVOList.forEach(item -> {
|
EntityInfoVO dto = new EntityInfoVO();
|
dto.setCanWrite(Boolean.FALSE);
|
dto.setCreationTime(LocalDateTime.now());
|
dto.setUpdateTime(LocalDateTime.now());
|
dto.setHash("");
|
dto.setSize(0L);
|
dto.setOwner(DncConstant.OWNER);
|
dto.setId("0");
|
dto.setIsDirectory(Boolean.TRUE);
|
dto.setName(item.getName());
|
collect.add(dto);
|
});
|
return collect;
|
}
|
|
private DncFixedSpace getDirectory(String path, Long workstationId) {
|
//DncFixedSpace dncFixedSpace;
|
DncFixedSpace fixedSpace = null;
|
String directoryName = "";
|
String[] split = StrUtil.split(path, "/");
|
if (Func.isNotEmpty(split)) {
|
int len = split.length;
|
if (len < 2) {
|
directoryName = path;
|
}
|
if (len >= 2) {
|
directoryName = path.substring(path.lastIndexOf("/") + 1);
|
}
|
Long parentId = getFtpNodeParentId(path, workstationId);
|
DncWsRelationTd wsRelationTd = this.wsRelationTdService.getOne(Wrappers.<DncWsRelationTd>lambdaQuery().eq(DncWsRelationTd::getWorkstationId, workstationId));
|
if (wsRelationTd != null) {
|
DncFixedSpace dncFixedSpace = this.fixedSpaceService.getOne(Wrappers.<DncFixedSpace>lambdaQuery()
|
.eq(DncFixedSpace::getTdId, wsRelationTd.getTransferDirectorId())
|
.eq(DncFixedSpace::getName, directoryName)
|
.eq(DncFixedSpace::getParentId, parentId)
|
.eq(DncFixedSpace::getSpaceLocation, CommonConstant.CREATE_SAME_DIRECTORY));
|
if (dncFixedSpace != null)
|
fixedSpace = dncFixedSpace;
|
}
|
|
/*
|
DncWsRelationTd wsRelationTd = (DncWsRelationTd) this.wsRelationTdService.getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getWorkstationId();
|
}, workstationId));
|
if (wsRelationTd != null && (dncFixedSpace = (DncFixedSpace) this.fixedSpaceService.getOne((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getTdId();
|
}, wsRelationTd.getTransferDirectorId())).eq((v0) -> {
|
return v0.getName();
|
}, directoryName)).eq((v0) -> {
|
return v0.getParentId();
|
}, parentId)).eq((v0) -> {
|
return v0.getSpaceLocation();
|
}, CommonConstant.CREATE_SAME_DIRECTORY))) != null) {
|
fixedSpace = dncFixedSpace;
|
}*/
|
}
|
return fixedSpace;
|
}
|
|
private Long getFtpNodeParentId(String path, Long workstationId) {
|
String completePathName;
|
Long rootNodeId = this.fixedSpaceService.getRootNodeId(String.valueOf(workstationId)).getRootNodeId();
|
DncFixedSpace rootNode = this.fixedSpaceService.getById(rootNodeId);
|
String rootName = rootNode.getName();
|
if (Func.isNotBlank(path)) {
|
completePathName = rootName + "/" + path;
|
} else {
|
completePathName = rootName;
|
}
|
Map<Long, String> stringMap = this.fixedSpaceService.getFixSpaceLocation(workstationId);
|
String str = completePathName;
|
Long nodeId = (Long) (stringMap.entrySet().stream().filter(kvEntry -> {
|
return Objects.equals(str, kvEntry.getValue());
|
}).map((v0) -> {
|
return v0.getKey();
|
}).collect(Collectors.toList())).get(0);
|
DncFixedSpace node = (DncFixedSpace) this.fixedSpaceService.getById(nodeId);
|
return node.getParentId();
|
}
|
|
private Long getWorkstationByPath() {
|
String machineCode = AuthUtil.getUser().getAccount();
|
List<Long> ids = this.workstationService.findByMachineShortCode(machineCode);
|
if (Func.isEmpty(ids)) {
|
throw new ServiceException(MessageUtils.message("dnc.machine.no.workstation", new Object[0]));
|
}
|
return ids.get(0);
|
}
|
}
|
