chenxudong
/
electromagnetic-data-new
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

增加详细日志输出。

This commit is contained in:
chenxudong 2025-03-18 14:08:01 +08:00
parent dca641d664
commit 617d005e0d
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/tasks/BackupTask.java
View File

@ -159,6 +159,7 @@ public class BackupTask {
.setParentId("") .setParentId("")
.setResponse(""); .setResponse("");
userAccessLogMapper.insert(userAccessLog); userAccessLogMapper.insert(userAccessLog);
log.info("删除文件成功，路径 {}", file.getAbsolutePath());
} }
} }
@ -169,11 +170,13 @@ public class BackupTask {
String sqlDirs = elePropertyConfig.getSqlDirs(); String sqlDirs = elePropertyConfig.getSqlDirs();
File[] files = new File(sqlDirs).listFiles((file, name) -> name.endsWith(".sql")); File[] files = new File(sqlDirs).listFiles((file, name) -> name.endsWith(".sql"));
if (ArrayUtil.isEmpty(files)) { if (ArrayUtil.isEmpty(files)) {
log.info("SQL文件没有找到。");
return; return;
} }
File maxModifyTimeFile = Arrays.stream(files).filter(File::isFile).filter(File::exists).max(Comparator.comparingLong(File::lastModified)).orElse(null); File maxModifyTimeFile = Arrays.stream(files).filter(File::isFile).filter(File::exists).max(Comparator.comparingLong(File::lastModified)).orElse(null);
if (maxModifyTimeFile == null) { if (maxModifyTimeFile == null) {
log.info("没有找到最新的SQL文件");
return; return;
} }
String fileName = maxModifyTimeFile.getName(); String fileName = maxModifyTimeFile.getName();
@ -182,6 +185,7 @@ public class BackupTask {
.eq(FileBackupLog::getSource, FileBackupSource.SQL.code)); .eq(FileBackupLog::getSource, FileBackupSource.SQL.code));
List<FileBackupLog> successBacks = fileBackupLogs.stream().filter(FileBackupLog::isBackupSuccess).collect(Collectors.toList()); List<FileBackupLog> successBacks = fileBackupLogs.stream().filter(FileBackupLog::isBackupSuccess).collect(Collectors.toList());
if (CollUtil.isNotEmpty(successBacks)) { if (CollUtil.isNotEmpty(successBacks)) {
log.info("最新的SQL文件已经备份过。");
return; return;
} }
@ -212,6 +216,7 @@ public class BackupTask {
.set(FileBackupLog::getFailInfoDetail, resLog.getFailInfoDetail()) .set(FileBackupLog::getFailInfoDetail, resLog.getFailInfoDetail())
.set(FileBackupLog::isBackupSuccess, resLog.getBackupSuccess())); .set(FileBackupLog::isBackupSuccess, resLog.getBackupSuccess()));
} }
log.info("备份SQL文件成功，文件路径 {}", maxModifyTimeFile.getAbsolutePath());
} catch (Exception e) { } catch (Exception e) {
log.error("备份SQL文件异常，原因 {}", e.getMessage(), e); log.error("备份SQL文件异常，原因 {}", e.getMessage(), e);
} }