payment/backend
1
0
Fork 0
Code Issues Pull Requests 3 Actions Packages Projects Releases Wiki Activity

refactor the job

Browse Source
This commit is contained in:
amirghasempoor
2025-03-10 11:24:14 +03:30
parent 0d33693383
commit 3291eba66e
4 changed files with 15 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
app/Console/Commands/SendRoadObservationToNikarayanCommand.php
View File

@@ -32,15 +32,14 @@ class SendRoadObservationToNikarayanCommand extends Command
$count = 0;
$this->info("Dispatching jobs with a delay between each...");
DB::transaction(function () use ($count) {
DB::transaction(function () use (&$count) {
$delay = 0;
RoadObserved::query()
->whereBetween('StartTime_DateTime_fa', ['1403-01-01 00:00:00', '1403-07-13 23:59:59'])
->where('rms_status', '=', 0)
->chunkById(50, function ($roads) use ($delay, $count) {
->chunkById(50, function ($roads) use (&$delay, &$count) {
foreach ($roads as $road) {
$road->update(['rms_status' => 1]);
SendRoadObservationToNikarayan::dispatch($road)->delay(now()->addMinutes(10)->addSeconds($delay));
$road->update(['status' => 1]);
SendRoadObservationToNikarayan::dispatch($road)->delay(now()->addSeconds($delay));
Log::channel('road_observation_problem')->info("Job for Road Observed ID {$road->id} scheduled with a {$delay} seconds delay.");
$this->info("Scheduled job for Road ID: {$road->id} {$delay}s");
$delay += 3;