101 lines
4.0 KiB
PHP
101 lines
4.0 KiB
PHP
<?php
|
|
|
|
namespace App\Jobs;
|
|
|
|
use App\Models\Activity;
|
|
use App\Models\Contract;
|
|
use App\Models\FieldJob;
|
|
use App\Models\FieldJobSetting;
|
|
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\DB;
|
|
|
|
class EndFieldJob implements ShouldQueue
|
|
{
|
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
|
|
|
public function __construct(
|
|
public int $activityId,
|
|
public ?int $contractId = null,
|
|
public array $config = []
|
|
) {}
|
|
|
|
public function handle(): void
|
|
{
|
|
$activity = Activity::query()->find($this->activityId);
|
|
|
|
// Determine target contract ID
|
|
$contractId = $this->contractId;
|
|
if (! $contractId && $activity) {
|
|
$contractId = $activity->contract_id;
|
|
}
|
|
if (! $contractId) {
|
|
\Log::warning('EndFieldJob: missing contract id', ['activity_id' => $this->activityId]);
|
|
|
|
return;
|
|
}
|
|
|
|
// Use latest FieldJobSetting as the source of action/decision/segments
|
|
$setting = FieldJobSetting::query()->latest('id')->first();
|
|
|
|
$triggeredByEvent = (bool) $activity; // this job is invoked from a decision event when an Activity exists
|
|
|
|
DB::transaction(function () use ($contractId, $setting, $triggeredByEvent): void {
|
|
// Find active field job for this contract
|
|
$job = FieldJob::query()
|
|
->where('contract_id', $contractId)
|
|
->whereNull('completed_at')
|
|
->whereNull('cancelled_at')
|
|
->latest('id')
|
|
->first();
|
|
|
|
if ($job) {
|
|
// Complete the job (updated hook moves segment appropriately)
|
|
$job->completed_at = now();
|
|
$job->save();
|
|
|
|
// Optionally log a completion activity.
|
|
// By default, we SKIP creating an extra activity when triggered by a decision event (to avoid duplicates).
|
|
// To force creation from an event, set config['create_activity_from_event'] = true on the decision event.
|
|
// For non-event triggers, set config['create_activity'] = true to allow creation.
|
|
$shouldCreateActivity = $triggeredByEvent
|
|
? (bool) ($this->config['create_activity_from_event'] ?? false)
|
|
: (bool) ($this->config['create_activity'] ?? false);
|
|
|
|
if ($shouldCreateActivity) {
|
|
$job->loadMissing('contract');
|
|
$actionId = optional($job->setting)->action_id ?? optional($setting)->action_id;
|
|
$decisionId = optional($job->setting)->complete_decision_id ?? optional($setting)->complete_decision_id;
|
|
if ($actionId && $decisionId && $job->contract) {
|
|
Activity::create([
|
|
'due_date' => null,
|
|
'amount' => null,
|
|
'note' => 'Terensko opravilo zaključeno',
|
|
'action_id' => $actionId,
|
|
'decision_id' => $decisionId,
|
|
'client_case_id' => $job->contract->client_case_id,
|
|
'contract_id' => $job->contract_id,
|
|
]);
|
|
}
|
|
}
|
|
} else {
|
|
// No active job: still move contract to the configured return segment if available
|
|
if ($setting && $setting->return_segment_id) {
|
|
$tmp = new FieldJob;
|
|
$tmp->contract_id = $contractId;
|
|
$tmp->moveContractToSegment($setting->return_segment_id);
|
|
}
|
|
}
|
|
});
|
|
|
|
\Log::info('EndFieldJob executed', [
|
|
'activity_id' => $this->activityId,
|
|
'contract_id' => $contractId,
|
|
'config' => $this->config,
|
|
]);
|
|
}
|
|
}
|