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

1688 PO Automation Project

Browse Source
This commit is contained in:
Dillon Ngo
2026-01-15 03:04:11 +08:00
parent 4fb2366fab
commit cae2f1f082
2 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/Classes/Jobs/Commands/V2/ETLPurchaseOrderTransactionV2CommandJob.php
+8
View File
@@ -3,12 +3,14 @@
namespace App\Classes\Jobs\Commands\V2;
use App\Classes\Modules\Transactions\Processors\ETLPDFPurchaseOrderClaudeProcessor;
use App\Events\ETLPurchaseOrderTransactionCompleteEvent;
use Carbon\Carbon;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Log;
class ETLPurchaseOrderTransactionV2CommandJob implements ShouldQueue
@@ -75,6 +77,12 @@ class ETLPurchaseOrderTransactionV2CommandJob implements ShouldQueue
(App()->make(ETLPDFPurchaseOrderClaudeProcessor::class))->execute($this->files, $this->bookingId, $this->batchIndex !== 1, $this->isLast);
$finished = Cache::increment('etl_finished_jobs_' . $this->groupId);
if ($finished >= $this->totalBatches) {
Log::info('All ETL jobs finished for group ' . $this->groupId . '. Last job finished at ' . now());
event(new ETLPurchaseOrderTransactionCompleteEvent(true, $this->bookingId));
}
$end = new Carbon();
$elapsedTime = $start->diff($end)->format('%H:%I:%S');
Log::info(Carbon::now() . ': End job - ETL Purchase Order Transaction. ElapsedTime: ' . $elapsedTime . '.');
app/Classes/Modules/Transactions/Processors/ETLPDFPurchaseOrderClaudeProcessor.php
+3 -3
View File
@@ -155,9 +155,9 @@ class ETLPDFPurchaseOrderClaudeProcessor
$this->createPurchaseOrderTransactionProcessor->execute($booking, $object, $append);
if($broadcast){
ETLPurchaseOrderTransactionCompleteV2CommandJob::dispatch(true, $bookingId)->delay(now()->addSeconds(20));
}
// if($broadcast){
// ETLPurchaseOrderTransactionCompleteV2CommandJob::dispatch(true, $bookingId)->delay(now()->addSeconds(20));
// }
}
return $data;