Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory :  /home/corals/dceprojects.corals.io/Corals/core/User/Jobs/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

<?php

namespace Corals\User\Jobs;

use Corals\User\Http\Requests\{UserRequest};
use Corals\User\Models\{User};
use Corals\User\Services\{UserService};
use Corals\User\Traits\ImportTrait;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\{InteractsWithQueue, SerializesModels};
use League\Csv\{Exception as CSVException};

class HandleUsersImportFile implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels, ImportTrait;

    protected $importFilePath;

    /**
     * @var array
     */
    protected $importHeaders;
    protected $user;
    protected $roles;
    /**
     * @var mixed
     */
    private $rolesListForLoggedInUser;

    /**
     * HandleBrandsImportFile constructor.
     * @param $importFilePath
     * @param $user
     */
    public function __construct($importFilePath, $user, $roles, $rolesListForLoggedInUser)
    {
        $this->user = $user;
        $this->roles = $roles;
        $this->importFilePath = $importFilePath;
        $this->importHeaders = array_keys(trans('User::import.user-headers'));
        $this->rolesListForLoggedInUser = $rolesListForLoggedInUser;
    }


    /**
     * @throws CSVException
     */
    public function handle()
    {
        $this->doImport();
    }

    /**
     * @param $record
     * @throws \Exception
     */
    protected function handleImportRecord($record)
    {
        $record = array_map('trim', $record);

        //prepare user data
        $userData = $this->getUserData($record);

        $this->validateRecord($userData);

        $userModel = $this->gerUserModel($userData['email']);

        $userRequest = new UserRequest();


        if ($userModel) {
            // in case the importer can't manage all imported user roles
            $userRoles = $userModel->roles->pluck('label', 'id');
            $rolesToInsert = array_merge(array_keys(($userRoles->diff($this->rolesListForLoggedInUser))->toArray()), $this->roles);

            $userData['roles'] = $rolesToInsert;
        }

        $userRequest->replace($userData);

        $userService = new UserService();

        if ($userModel) {
            $userService->update($userRequest, $userModel, ['roles_for_logged_in_user' => $this->rolesListForLoggedInUser]);
        } else {
            $userService->store($userRequest, User::class, ['roles_for_logged_in_user' => $this->rolesListForLoggedInUser]);
        }
    }

    protected function gerUserModel($email)
    {
        return User::query()->where('email', $email)->first();
    }

    /**
     * @param $record
     * @return array
     * @throws \Exception
     */
    protected function getUserData($record)
    {
        return array_filter([
            'name' => data_get($record, 'name'),
            'last_name' => data_get($record, 'last_name'),
            'email' => data_get($record, 'email'),
            'roles' => $this->roles,
            'positions' => explode('|', data_get($record, 'positions')),
            'rate' => data_get($record, 'rate'),
            'phone_number' => data_get($record, 'phone_number'),
            'classification' => data_get($record, 'classification'),
            'properties' => [
                'about' => data_get($record, 'about'),
            ],
        ]);
    }

    protected function initHandler()
    {
    }

    protected function getValidationRules($data): array
    {
        return [
            'name' => 'required|max:191',
            'last_name' => 'required|max:191',
            'email' => 'required',
            'roles' => 'required|array',
            'positions' => 'required|array',
            'positions.*' => 'exists:utility_list_of_values,code',
            'rate' => 'nullable',
            'phone_number' => 'nullable',
            'classification' => 'nullable',
            'about' => 'nullable',
        ];
    }
}