diff --git a/app/Classes/Modules/PackingLists/ControllersLogic/DeletePackingListByPackageIdLogic.php b/app/Classes/Modules/PackingLists/ControllersLogic/DeletePackingListByPackageIdLogic.php index 9f6949e0..5ee1a008 100644 --- a/app/Classes/Modules/PackingLists/ControllersLogic/DeletePackingListByPackageIdLogic.php +++ b/app/Classes/Modules/PackingLists/ControllersLogic/DeletePackingListByPackageIdLogic.php @@ -4,6 +4,7 @@ namespace App\Classes\Modules\PackingLists\ControllersLogic; use App\Classes\General\Abstracts\AbstractControllerLogic; +use App\Classes\Jobs\Commands\V2\YD\FetchPackingListsFromYdPortalV2CommandJob; use App\Classes\Modules\PackingLists\Services\DeletesPackingList; use App\Classes\Modules\PackingLists\Services\FetchesPackingList; use App\Classes\Modules\PackingLists\Services\Packages\FetchesPackage; @@ -11,6 +12,7 @@ use App\Classes\Modules\PackingLists\Standards\Rules\CanDeletePackingList; use App\Classes\ValueObjects\Constants\PackingListType; use App\Classes\ValueObjects\Constants\TransactionType; use App\Models\PackingList; +use Carbon\Carbon; use ErrorException; use Illuminate\Http\JsonResponse; use Illuminate\Http\Request; @@ -84,7 +86,35 @@ class DeletePackingListByPackageIdLogic extends AbstractControllerLogic $childPackingList->each->delete(); + $jobs1 = $this->fetchPackingListsFromYdPortalV2CommandJobs(); + foreach ($jobs1 as $index => $job) { + dispatch($job)->delay(now()->addSeconds($index * 2)); + } + return $this->response([]); } + + private function fetchPackingListsFromYdPortalV2CommandJobs() + { + $jobs = []; + $count = 0; + + // Always take last 10 days INCLUDING today + for ($x = 0; $x < 10; $x++) { + + $startDate = Carbon::today()->subDays($x)->startOfDay(); + $endDate = Carbon::today()->subDays($x - 1)->startOfDay(); + + $jobs[] = new FetchPackingListsFromYdPortalV2CommandJob($startDate, $endDate); + + Log::info('Dispatched FetchPackingListsFromYdPortalV2CommandJob for start date: ' . $startDate . ', end date: ' . $endDate); + $count++; + } + + Log::info('Total FetchPackingListsFromYdPortalV2CommandJob dispatched: ' . $count); + + return $jobs; + } + } diff --git a/app/Classes/Modules/PackingLists/Processors/V2/FetchPackingListsFromYdPortalV2Processor.php b/app/Classes/Modules/PackingLists/Processors/V2/FetchPackingListsFromYdPortalV2Processor.php index 53c9db9a..548a5d21 100644 --- a/app/Classes/Modules/PackingLists/Processors/V2/FetchPackingListsFromYdPortalV2Processor.php +++ b/app/Classes/Modules/PackingLists/Processors/V2/FetchPackingListsFromYdPortalV2Processor.php @@ -158,6 +158,7 @@ class FetchPackingListsFromYdPortalV2Processor $packingListReference = $row->expressno; try{ + Log::info('Fetch SHIPPING_PACKING_LIST expressno: ' . $row->expressno); $packingList = $this->fetchesPackingList->execute(['reference' => $row->expressno, 'type' => PackingListType::SHIPPING_PACKING_LIST]); Log::info('Fetch SHIPPING_PACKING_LIST id: ' . $packingList->id);