cief/exchange-2.0
1
0
Fork 0
mirror of https://gitlab.com/CIEFWorldwideSdnBhd/exchange-2.0.git synced 2026-08-19 12:33:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Laravel Vapor - sync code for download files in bulk from S3 to more files

Browse Source
This commit is contained in:
Dillon Ngo
2024-04-27 10:36:56 +08:00
parent e240bdd2b4
commit 4ec4ecbb7a
1 changed files with 34 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/Classes/Jobs/Commands/V2/DeleteBulkInvoiceFilesV2CommandJob.php
+34 -10
View File
@@ -11,6 +11,7 @@ use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\File;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Storage;
class DeleteBulkInvoiceFilesV2CommandJob implements ShouldQueue
{
@@ -23,25 +24,48 @@ class DeleteBulkInvoiceFilesV2CommandJob implements ShouldQueue
$start = new Carbon();
$directories = [
storage_path('app/bulk_invoice'), //cief todo: should map to the equivalent in AWS S3 bucket
storage_path('app/bulk_whiteform'), //cief todo: should map to the equivalent in AWS S3 bucket
storage_path('app/bulk_invoice'),
storage_path('app/bulk_whiteform'),
];
foreach ($directories as $directory) {
$start = new Carbon();
Log::info(Carbon::now() . ' Start cleaning - ' . $directory);
$startInner = new Carbon();
Log::info(Carbon::now() . ' [Local] Start cleaning - ' . $directory);
if (File::isDirectory($directory)) { //cief todo: should map to the equivalent in AWS S3 bucket
if (File::isDirectory($directory)) {
File::cleanDirectory($directory);
Log::info('All files have been deleted.');
Log::info('[Local] All files have been deleted.');
} else {
Log::info('Directory does not exist.');
Log::info('[Local] Directory does not exist.');
}
$end = new Carbon();
$elapsedTime = $start->diff($end)->format('%H:%I:%S');
$endInner = new Carbon();
$elapsedTime = $startInner->diff($endInner)->format('%H:%I:%S');
Log::info(Carbon::now() . ' Process ended. ElapsedTime: ' . $elapsedTime);
Log::info(Carbon::now() . ' [Local] Process ended. ElapsedTime: ' . $elapsedTime);
}
$s3 = Storage::disk('s3');
$directories = [
'bulk_invoice',
'bulk_whiteform',
];
foreach ($directories as $directory) {
$startInner = Carbon::now();
Log::info(Carbon::now() . ' [S3] Start cleaning - ' . $directory);
$objects = $s3->allFiles($directory);
foreach ($objects as $object) {
$s3->delete($object);
Log::info('[S3] Deleted object: ' . $object);
}
Log::info('[S3] All files have been deleted.');
$endInner = Carbon::now();
$elapsedTime = $startInner->diff($endInner)->format('%H:%I:%S');
Log::info(Carbon::now() . ' [S3] Process ended. ElapsedTime: ' . $elapsedTime);
}
$end = new Carbon();