App\Jobs\ImportVocabulary::handle()

Complexity

Conditions	16
Paths	16

Size

Total Lines	112
Code Lines	77

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function handle()
    {
        $timer           = new \DateTime();
        $this->setFormproperties();
        $this->setLanguage();
        $this->userId    = $this->import->user_id;
        $vocabId         = $this->isElementSet() ? $this->import->schema_id : $this->import->vocabulary_id;
        $changeset       = $this->import->instructions;
        $total_processed = 0;
        $added           = 0;
        $updated         = 0;
        $deleted         = 0;
        //each item in the main array is a row. Each item in the statements array is a statement
        foreach ($changeset['update'] as $reg_id => $row) {
            $this->updatedStatements = [];
            //start a transaction
            DB::transaction(function () use ($reg_id, $row, &$updated) {
                $statements = $this->getStatements($reg_id);
                $dirty = false;
                foreach ($row as $statement) {
                    $old = $statements->find($statement['statement_id']);
                    if ($old) {
                        if ($statement['new value']) {
                            $old->update([
                                'object'         => $statement['new value'],
                                'last_import_id' => $this->import->id,
                                'is_generated'   => false,
                            ]);
                            $this->addUpdateStatement($statement);
                            $dirty = true;
                        } else {
                            $old->delete();
                            $this->addUpdateStatement($statement);
                            $dirty = true;
                        }
                    } else {
                        //make a new one
                        $existingStatement = $statements->filter(function ($item) use ($statement) {
                            /* @var Model $item */
                            return $item->profile_property_id == $statement['property_id'] &&
                                $item->object == $statement['new value'] &&
                                $item->getOriginal('language') === $statement['language'];
                        });
                        if ($existingStatement->count() === 0) {
                            $newStatement = $this->makeStatement($statement);
                            $this->resource->statements()->save($newStatement);

The method statements() does not exist on null.

                            $this->addUpdateStatement($statement);
                            $dirty = true;
                        }
                    }
                }
                if (\count($this->updatedStatements)) {
                    try {
                        $this->resource->updated_user_id = $this->userId;
                        $this->resource->updateFromStatements($this->updatedStatements);
                    } catch (Exception $e) {
                        //log the error
                        $this->makeErrorLogEntry($row['*uri']['new value'], $e->getMessage());
                        //cancel the transaction
                        return false;
                    }
                }
                if ($dirty) {
                    $updated++;
                }
            });
            $total_processed++;
        }
        foreach ($changeset['add'] as $row) {
            DB::transaction(function () use ($row, $vocabId, &$added) {
                $allStatements = [];
                foreach ($row as $statement) {
                    $this->addUpdateStatement($statement);
                    $allStatements[] = $this->makeStatement($statement);
                }
                try {
                    //this will make a resource with insufficient values...
                    $resource = $this->makeResource($vocabId);
                    //this will update the resource from the statements and save it...
                    $resource->updateFromStatements($this->updatedStatements);
                    //this will add the statements...
                    $resource->statements()->saveMany($allStatements);
                    $this->UpdatePrefLabelId($resource);
                } catch (Exception $e) {
                    //log the error
                    $this->makeErrorLogEntry($row['*uri']['new value'], $e->getMessage());
                    //cancel the transaction
                    return false;
                }

                $added++;
            });
            $total_processed++;
        }
        foreach ($changeset['delete'] as $row) {
            //TODO implement this...
            //delete the resource
            //cascade delete the statements, which should cascade delete the reciprocals
            $total_processed++;
            $deleted++;
        }
        $this->setResults('timer', $timer->diff(new \DateTime())->format('%h hours; %i minutes; %s seconds'));
        $this->import->results = $this->results;
        //$this->import->batch->increment('handled_count');
        $this->import->total_processed_count = $total_processed;
        $this->import->added_count           = $added;
        $this->import->updated_count         = $updated;
        $this->import->deleted_count         = $deleted;
        $this->import->imported_at           = new \DateTime();
        $this->import->save();

        event(new ImportFinished($this->import));
    }