App\Jobs\UpdateRelatedIds

Complexity

Total Complexity

10

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
B	handle()	0	27	9

<?php

namespace App\Jobs;

use App\Models\Batch;
use App\Models\Concept;
use App\Models\ConceptAttribute;
use App\Models\Element;
use Exception;
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\Log;

class UpdateRelatedIds implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

The trait Illuminate\Queue\SerializesModels requires some properties which are not provided by App\Jobs\UpdateRelatedIds: $id, $class

    /**
     * @var Batch
     */
    private $batch;

    /**
     * Create a new job instance.
     *
     * @param Batch $batch
     */
    public function __construct(Batch $batch)
    {
        //
        $this->batch = $batch;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        try {
            foreach ($this->batch->imports as $import) {
                $statements = $import->conceptResourceStatements()->where('related_concept_id', null);
                /** @var ConceptAttribute[] $statements */
                if ($statements->count()) {
                    foreach ($statements as $statement) {
                        $concept = Concept::where('uri', $statement->object)->first();
                        if ($concept) {
                            $statement->update(['related_concept_id' => $concept->id]);
                        }
                    }
                }
                $statements = $import->elementResourceStatements()->where('related_schema_property_id', null);
                /** @var ConceptAttribute[] $statements */
                if ($statements->count()) {
                    foreach ($statements as $statement) {
                        $element = Element::where('uri', $statement->object)->first();
                        if ($element) {
                            $statement->update(['related_schema_property_id' => $element->id]);
                        }
                    }
                }
            }
        } catch (Exception $e) {
            Log::error($e->getMessage());
        }
    }
}