mirror of
https://gitlab.com/CIEFWorldwideSdnBhd/exchange-2.0.git
synced 2026-08-24 15:04:19 +00:00
update bulk download invoice
This commit is contained in:
+56
-31
@@ -8,62 +8,87 @@ use ZipArchive;
|
||||
use Illuminate\Http\Request;
|
||||
use Illuminate\Support\Facades\Storage;
|
||||
use App\Classes\Exceptions\MalformedRequestException;
|
||||
use Illuminate\Support\Facades\File;
|
||||
use App\Classes\ValueObjects\Constants\ApprovalStatus;
|
||||
use App\Classes\ValueObjects\Constants\DocumentType;
|
||||
use App\Models\Company;
|
||||
use Carbon\Carbon;
|
||||
use Illuminate\Support\Facades\Session;
|
||||
use Illuminate\Support\Facades\Log;
|
||||
|
||||
class BulkDownloadCustomerInvoicesLogic
|
||||
{
|
||||
/**
|
||||
* @param Request $request
|
||||
* @return void
|
||||
* @throws MalformedRequestException
|
||||
* @return \Illuminate\Http\JsonResponse|\Symfony\Component\HttpFoundation\BinaryFileResponse
|
||||
*/
|
||||
public function execute(Request $request)
|
||||
{
|
||||
$company = Company::where('reference', $request->input('marking'))->first();
|
||||
try {
|
||||
$company = Company::where('reference', $request->input('marking'))->first();
|
||||
|
||||
$startDate = Carbon::createFromFormat('d-m-Y', $request->input('startDate'))->startOfDay();
|
||||
$endDate = Carbon::createFromFormat('d-m-Y', $request->input('endDate'))->endOfDay();
|
||||
if (!$company) {
|
||||
return response()->json([
|
||||
'status' => 'Failed',
|
||||
'message' => 'Customer not found.',
|
||||
]);
|
||||
}
|
||||
|
||||
if ($company) {
|
||||
$invoicebookings = $company->bookings()->whereDate('created_at', '>=', $startDate)
|
||||
$startDate = Carbon::createFromFormat('d-m-Y', $request->input('startDate'))->startOfDay();
|
||||
$endDate = Carbon::createFromFormat('d-m-Y', $request->input('endDate'))->endOfDay();
|
||||
|
||||
$invoicebookings = $company->bookings()
|
||||
->whereDate('created_at', '>=', $startDate)
|
||||
->whereDate('created_at', '<=', $endDate)
|
||||
->whereHas('transactions', function ($query) {
|
||||
$query->where('transactions.type', TransactionType::INVOICE)
|
||||
->whereIn('transactions.status', [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED]);
|
||||
})->orderBy('created_at')->get();
|
||||
->whereIn('transactions.status', [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED]);
|
||||
})
|
||||
->orderBy('created_at')
|
||||
->get();
|
||||
|
||||
if (count($invoicebookings) > 0) {
|
||||
$zip_file = "invoices_{$request->input('startDate')}_to_{$request->input('endDate')}_{$company->reference}.zip";
|
||||
|
||||
$zip = new ZipArchive();
|
||||
if ($zip->open($zip_file, ZIPARCHIVE::CREATE | ZipArchive::OVERWRITE)) {
|
||||
foreach($invoicebookings as $booking) {
|
||||
$invoice_file = $booking->documents()->where('document_type', DocumentType::INVOICE)->whereNull('deleted_at')->first()->files()->first();
|
||||
$zip->addFile(Storage::disk('documents')->path($invoice_file->file->file_info->original->file), 'invoice-' . $booking->created_at->format('d_m_Y') . '_' . $booking->marking . '.pdf');
|
||||
}
|
||||
|
||||
$zip->close();
|
||||
while (ob_get_level()) {
|
||||
ob_end_clean();
|
||||
}
|
||||
|
||||
return response()->download($zip_file);
|
||||
}
|
||||
} else {
|
||||
if ($invoicebookings->isEmpty()) {
|
||||
return response()->json([
|
||||
'status' => 'Failed',
|
||||
'message' => 'No invoices found for this customer in the given date range.',
|
||||
]);
|
||||
}
|
||||
} else {
|
||||
|
||||
$zipDirectory = storage_path('app/bulk_invoice'); // Update this with the actual directory path
|
||||
|
||||
if (!file_exists($zipDirectory)) {
|
||||
mkdir($zipDirectory, 0755, true);
|
||||
}
|
||||
|
||||
$zip_file = "{$zipDirectory}/invoices_{$request->input('startDate')}_to_{$request->input('endDate')}_{$company->reference}.zip";
|
||||
|
||||
$zip = new ZipArchive();
|
||||
if ($zip->open($zip_file, ZipArchive::CREATE | ZipArchive::OVERWRITE)) {
|
||||
foreach ($invoicebookings as $booking) {
|
||||
$invoice_file = $booking->documents()->where('document_type', DocumentType::INVOICE)->whereNull('deleted_at')->first()->files()->first();
|
||||
$zip->addFile(Storage::disk('documents')->path($invoice_file->file->file_info->original->file), 'invoice-' . $booking->created_at->format('d_m_Y') . '_' . $booking->marking . '.pdf');
|
||||
}
|
||||
|
||||
$zip->close();
|
||||
|
||||
while (ob_get_level()) {
|
||||
ob_end_clean();
|
||||
}
|
||||
|
||||
return response()->download($zip_file);
|
||||
} else {
|
||||
return response()->json([
|
||||
'status' => 'Failed',
|
||||
'message' => 'Failed to create the Zip archive.',
|
||||
]);
|
||||
}
|
||||
} catch (\Exception $e) {
|
||||
// Log the exception for debugging
|
||||
Log::error('Error in BulkDownloadCustomerInvoicesLogic: ' . $e->getMessage());
|
||||
|
||||
return response()->json([
|
||||
'status' => 'Failed',
|
||||
'message' => 'Customer not found.',
|
||||
'message' => 'An error occurred while processing the request.',
|
||||
]);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -0,0 +1,52 @@
|
||||
<?php
|
||||
|
||||
namespace App\Console\Commands;
|
||||
|
||||
use Carbon\Carbon;
|
||||
use Illuminate\Console\Command;
|
||||
use Illuminate\Support\Facades\File;
|
||||
|
||||
class DeleteBulkInvoiceFiles extends Command
|
||||
{
|
||||
protected $signature = 'delete:bulk-invoice-files';
|
||||
|
||||
protected $description = 'Delete all files in the storage/app/bulk_invoice directory';
|
||||
|
||||
public function __construct()
|
||||
{
|
||||
parent::__construct();
|
||||
}
|
||||
|
||||
public function handle()
|
||||
{
|
||||
$start = new Carbon();
|
||||
$this->logOutput('Process started');
|
||||
|
||||
$directory = storage_path('app/bulk_invoice');
|
||||
|
||||
if (File::isDirectory($directory)) {
|
||||
File::cleanDirectory($directory);
|
||||
$this->info('All files in the bulk_invoice directory have been deleted.');
|
||||
} else {
|
||||
$this->error('The bulk_invoice directory does not exist.');
|
||||
}
|
||||
|
||||
$end = new Carbon();
|
||||
$elapsedTime = $start->diff($end)->format('%H:%I:%S');
|
||||
|
||||
$this->logOutput('Process ended. ElapsedTime: ' . $elapsedTime);
|
||||
}
|
||||
|
||||
public function logOutput($text)
|
||||
{
|
||||
if (is_array($text)) {
|
||||
$text = implode(', ', $text);
|
||||
}
|
||||
|
||||
$this->info(Carbon::now() . ' : ' . $text);
|
||||
|
||||
$filePath = storage_path('logs/delete-orders.log');
|
||||
$textToAppend = Carbon::now()->format('[Y-m-d H:i:s]') . ' ' . $text . PHP_EOL;
|
||||
file_put_contents($filePath, $textToAppend, FILE_APPEND);
|
||||
}
|
||||
}
|
||||
@@ -43,6 +43,11 @@ class Kernel extends ConsoleKernel
|
||||
->everyMinute()
|
||||
->appendOutputTo(storage_path().'/logs/regenerateInvoice.log')
|
||||
->withoutOverlapping();
|
||||
|
||||
$schedule->command('delete:bulk-invoice-files')
|
||||
->dailyAt('00:00')
|
||||
->appendOutputTo(storage_path().'/logs/delete-bulk-invoice-files.log')
|
||||
->withoutOverlapping();
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
Reference in New Issue
Block a user