xiaoguangbin/AnalysisSystemForRadionuclide
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix：from file 读取ftp功能改为直接访问ftp文件夹目录获取文件

Browse Source
This commit is contained in:
xiaoguangbin 2024-07-16 14:30:36 +08:00
parent f4b05e2da1
commit 5a8f20362a
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/SpectrumFileServiceImpl.java
View File

@ -181,12 +181,13 @@ public class SpectrumFileServiceImpl implements ISpectrumFileService {
List<FileDto> fileDtos = new ArrayList<>();
Page<FileDto> page = new Page<>(pageNo, pageSize);
try {
ftpClient = ftpUtil.LoginFTP();
if (ObjectUtil.isNull(ftpClient))
return Result.error(Prompt.FTP_ERR);
boolean exist = ftpClient.changeWorkingDirectory(filePath);
if (!exist) return Result.OK(page);
List<FTPFile> ftpFiles = ListUtil.toList(ftpClient.listFiles());
File folder = new File(filePath);
// ftpClient = ftpUtil.LoginFTP();
// if (ObjectUtil.isNull(ftpClient))
// return Result.error(Prompt.FTP_ERR);
// boolean exist = ftpClient.changeWorkingDirectory(filePath);
// if (!exist) return Result.OK(page);
List<File> ftpFiles = ListUtil.toList(folder.listFiles());
// 根据文件名进行过滤
String name = fileVo.getName();
if (StrUtil.isNotBlank(name)){
@ -195,11 +196,10 @@ public class SpectrumFileServiceImpl implements ISpectrumFileService {
.filter(file -> containsAllIgnoreCase(file.getName(),names))
.collect(Collectors.toList());
}
for (FTPFile ftpFile : ftpFiles) {
for (File ftpFile : ftpFiles) {
String fileName = ftpFile.getName();
Calendar calendar = ftpFile.getTimestamp();
Date updateDate = calendar.getTime();
long size = ftpFile.getSize();
Date updateDate = new Date(ftpFile.lastModified());
long size = ftpFile.length();
FileDto fileDto = new FileDto();
fileDto.setName(fileName);
fileDto.setUpdateDate(updateDate);
@ -212,7 +212,7 @@ public class SpectrumFileServiceImpl implements ISpectrumFileService {
List<FileDto> records = PageUtil.page(pageNo, pageSize, fileDtos);
page.setRecords(records).setTotal(fileDtos.size());
return Result.OK(page);
} catch (IOException e) {
} catch (Exception e) {
e.printStackTrace();
return Result.error(e.getMessage());
}finally {