源文件夹路径 : D:/upload/
目标文件夹路径 : D:/backup/
File directory = new File(bdcImportConfig.getSourceDirectory());
if(!directory.exists()){
log.error("目录不存在:{}" + bdcImportConfig.getSourceDirectory());
return;
}
if(!directory.isDirectory()){
log.error("不是一个目录:{}" + bdcImportConfig.getSourceDirectory());
return;
}
File[] fileList = directory .listFiles();
for(File file : fileList){
if(!file.getName().endsWith(".rtf")){
log.error("文件类型不正确:{}", file.getName());
continue;
}
if(file.getName().split("_").length < 3){
log.error("文件名称不符合命名规范:{}", file.getName());
continue;
}
try {
this.importRtfData(file);
} catch (Exception e) {
log.error("{} 文件数据导入出现异常:{}", file.getName(), e.getMessage());
continue;
}
if(bdcImportConfig.isDeleteFile()){
file.delete();
log.info("{} 文件导入成功,根据配置删除文件", file.getAbsolutePath());
}else {
File targetFile = new File(bdcImportConfig.getTargetDirectory(), file.getName());
if(targetFile.exists()){
targetFile = new File(bdcImportConfig.getTargetDirectory(), file.getName()+IdWorker.getIdStr());
log.info("目标文件已存在{},重命名:{}", file.getName(), targetFile.getName());
}
try {
FileUtils.moveFile(file, targetFile);
log.info("{} 文件导入成功,根据配置讲文件移动到目录:{}", file.getName(), targetFile.getAbsolutePath());
}catch (IOException e) {
file.delete();
log.info("{} 文件移动出现异常:{}", file.getName(), e.getMessage());
}
}
|