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/job-board.corals.io/Corals/modules/Jobs/Http/Controllers/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

<?php

namespace Corals\Modules\Jobs\Http\Controllers;

use Corals\Foundation\Http\Controllers\BaseController;
use Corals\Modules\Jobs\Http\Requests\JobsImportRequest;
use Corals\Modules\Jobs\Jobs\HandleJobsImportFile;
use Illuminate\Contracts\Foundation\Application;
use Illuminate\Contracts\View\Factory;
use Illuminate\Support\Str;
use Illuminate\View\View;
use League\Csv\CannotInsertRecord;
use League\Csv\Reader;
use League\Csv\Writer;


class JobsImportController extends BaseController
{
    protected $importHeaders;
    protected $importTarget;

    public function __construct()
    {
        $segments = request()->segments();

        $target = $segments[2] ?? "";

        if (!$target) {
            return;
        }

        $target = Str::singular($target);

        $this->importTarget = $target;

        $this->resource_url = config("jobs.models.$target.resource_url");

        $this->importHeaders = trans("Jobs::import.$target-headers");

        $this->middleware(function ($request, \Closure $next) use ($target) {
            $model = 'Corals\\Modules\Jobs\\Models\\' . ucfirst($target);

            abort_if(user()->cannot('create', $model), 403, 'Unauthorized');

            return $next($request);
        });

        parent::__construct();
    }

    /**
     * @param JobsImportRequest $request
     * @return Application|Factory|View
     */
    public function getImportModal(JobsImportRequest $request)
    {
        $headers = $this->importHeaders;
        $target = $this->importTarget;


        return view('Jobs::jobs.import.import_modal')
            ->with(compact('headers', 'target'));
    }

    /**
     * @param JobsImportRequest $request
     * @throws CannotInsertRecord
     */
    public function downloadImportSample(JobsImportRequest $request)
    {
        $csv = Writer::createFromFileObject(new \SplTempFileObject())
            ->setDelimiter(config('corals.csv_delimiter', ','));

        //we insert the CSV header
        $csv->insertOne(array_keys($this->importHeaders));

        $target = Str::plural($this->importTarget, 0);

        $csv->output(sprintf('user_%s_%s.csv', $target, now()->format('Y-m-d-H-i')));

        die;
    }

    /**
     * @param JobsImportRequest $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function uploadImportFile(JobsImportRequest $request)
    {
        try {
            // store file in temp folder
            $file = $request->file('file');

            $importsPath = storage_path('jobs/import/job');

            $fileName = sprintf("%s_%s", Str::random(), $file->getClientOriginalName());

            $fileFullPath = $importsPath . '/' . $fileName;
            $file->move($importsPath, $fileName);

            $reader = Reader::createFromPath($fileFullPath, 'r')
                ->setDelimiter(config('corals.csv_delimiter', ','))
                ->setHeaderOffset(0);

            $header = $reader->getHeader();

            // validate file headers
            if (count(array_diff(array_keys($this->importHeaders), $header))) {
                unset($reader);
                @unlink($fileFullPath);
                throw new \Exception(trans('Jobs::import.exceptions.invalid_headers'));
            }

            switch ($this->importTarget) {
                case 'job':
                    $this->dispatch(

                        new HandleJobsImportFile($fileFullPath, user())
                    );
                    break;
            }

            return response()->json([
                'level' => 'success',
                'action' => 'closeModal',
                'message' => trans('Jobs::import.messages.file_uploaded')
            ]);
        } catch (\Exception $exception) {
            return response()->json([
                'level' => 'error',
                'message' => $exception->getMessage()
            ], 400);
        }
    }


}