lkddi/nexusphp
1
0
Fork 0
mirror of https://github.com/lkddi/nexusphp.git synced 2026-04-24 12:07:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

improve backup cronjob cleanup

Browse Source
This commit is contained in:
xiaomlove
2025-10-29 15:28:52 +07:00
parent 61f4de8868
commit 907cca7a40
1 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/Repositories/ToolRepository.php
+13 -5
View File
@@ -153,6 +153,8 @@ class ToolRepository extends BaseRepository
$result_code = 0; $result_code = 0;
do_log("No tar command, use zip."); do_log("No tar command, use zip.");
} }
File::delete($backupWeb['filename']);
File::delete($backupDatabase['filename']);
if (!$transfer) { if (!$transfer) {
return compact('result_code', 'filename'); return compact('result_code', 'filename');
} }
@@ -216,7 +218,7 @@ class ToolRepository extends BaseRepository
$transferResult = $this->transfer($backupResult['filename'], $backupResult['result_code'], $setting); $transferResult = $this->transfer($backupResult['filename'], $backupResult['result_code'], $setting);
$backupResult['transfer_result'] = $transferResult; $backupResult['transfer_result'] = $transferResult;
do_log("[BACKUP_ALL_DONE]: " . json_encode($backupResult)); do_log("[BACKUP_ALL_DONE]: " . json_encode($backupResult));
$this->cleanupBackupFiles(); $this->cleanupBackupFiles(basename($backupResult['filename']));
return $backupResult; return $backupResult;
} }
@@ -336,20 +338,26 @@ class ToolRepository extends BaseRepository
} }
} }
private function cleanupBackupFiles(): void private function cleanupBackupFiles($basename): void
{ {
$nameParts = explode('.', $basename);
$firstPart = $nameParts[0];
$lastPart = $nameParts[count($nameParts) - 1];
$retentionCount = Setting::getBackupRetentionCount(); $retentionCount = Setting::getBackupRetentionCount();
if ($retentionCount <= 0) { if ($retentionCount <= 0) {
$retentionCount = self::BACKUP_RETENTION_COUNT_DEFAULT; $retentionCount = self::BACKUP_RETENTION_COUNT_DEFAULT;
} }
$path = self::getBackupExportPath(); $path = self::getBackupExportPath();
$allFiles = collect(File::allFiles($path)); $allFiles = collect(File::allFiles($path))->filter(function (\Symfony\Component\Finder\SplFileInfo $file) use ($firstPart, $lastPart) {
$name = basename($file->getRealPath());
return str_starts_with($name, $firstPart) && str_ends_with($name, $lastPart);
});
// 按创建时间降序排序 // 按创建时间降序排序
$allFiles = $allFiles->sortByDesc(fn (\Symfony\Component\Finder\SplFileInfo $file) => $file->getCTime()); $allFiles = $allFiles->sortByDesc(fn (\Symfony\Component\Finder\SplFileInfo $file) => $file->getCTime());
$filesToDelete = $allFiles->slice($retentionCount); $filesToDelete = $allFiles->slice($retentionCount);
do_log(sprintf( do_log(sprintf(
"retentionCount: %s, path: %s, fileCount: %s, toDeleteCount: %s", "retentionCount: %s, path: %s, fileCount: %s",
$retentionCount, $path, $allFiles->count(), $filesToDelete->count() $retentionCount, $path, $allFiles->count()
)); ));
foreach ($filesToDelete as $file) { foreach ($filesToDelete as $file) {
$realPath = $file->getRealPath(); $realPath = $file->getRealPath();