jandl-taskmanager-app/be/app/Services/Karat/KaratService.php

<?php

namespace App\Services\Karat;

use App\Models\User;
use Carbon\Carbon;
use Illuminate\Support\Arr;
use Illuminate\Support\Collection;

class KaratService
{
    private Api $api;

    public function __construct()
    {
        $this->api = new Api();
    }

    public function syncUsers()
    {
        $karatUsers = \App\Services\Karat\User::all();
        $dbUsers =  User::all();

        $this->insertUsersFromKarat($karatUsers, $dbUsers);

        $this->removeUsersThatAreNotInKaratAnymore($karatUsers, $dbUsers);
    }

    private function insertUsersFromKarat(Collection $karatUsers, Collection $dbUsers)
    {
        $emailsToSkip = $dbUsers->pluck('email' )->intersect( $karatUsers->pluck('email'));

        $karatUsersToInsert = $karatUsers->reject(function ($item) use ($emailsToSkip) {
            return $emailsToSkip->contains($item->email);
        })->map(function ($item) {
            $arrayToInsert =  $item->toArray();

            $arrayToInsert['created_at'] = Carbon::now()->toDateTimeString();
            $arrayToInsert['updated_at'] = Carbon::now()->toDateTimeString();

            return $arrayToInsert;
        });

        User::insert($karatUsersToInsert->toArray());
    }

    private function removeUsersThatAreNotInKaratAnymore( Collection $karatUsers, Collection $dbUsers )
    {
        $emailsInDbThatAreNotInKaratAnymore = $dbUsers->pluck('email' )->diff( $karatUsers->pluck('email'));

        User::whereIn('email', $emailsInDbThatAreNotInKaratAnymore)->delete();

    }

    public function syncClients()
    {
        $karatClients = Client::all();
        $dbClients =  \App\Models\Client::all();

        $this->insertClientsFromKarat($karatClients, $dbClients);

        $this->removeClientsThatAreNotInKaratAnymore($karatClients, $dbClients);
    }

    private function insertClientsFromKarat( Collection $karatClients, Collection $dbClients )
    {
        $clientsToSkip = $dbClients->pluck('code' )->intersect( $karatClients->pluck('code'));

        $karatClientsToInsert = $karatClients->reject(function ($item) use ($clientsToSkip) {
            return $clientsToSkip->contains($item->code);
        })->map(function ($item) {
            $arrayToInsert =  $item->toArray();

            $arrayToInsert['created_at'] = Carbon::now()->toDateTimeString();
            $arrayToInsert['updated_at'] = Carbon::now()->toDateTimeString();

            return $arrayToInsert;
        });

        \App\Models\Client::insert($karatClientsToInsert->toArray());
    }

    private function removeClientsThatAreNotInKaratAnymore( Collection $karatClients, Collection $dbClients )
    {
        $codesInDbThatAreNotInKaratAnymore = $dbClients->pluck('code' )->diff( $karatClients->pluck('code'));

        \App\Models\Client::whereIn('code', $codesInDbThatAreNotInKaratAnymore)->delete();
    }

    public function syncProjects()
    {
        $karatProjects = Project::all();

        $array = [];
        foreach ( $karatProjects as $project ) {
            $array[$project->code][] = $project->code;
        }

        foreach ( $array as $key => $item ) {
            if ( count($item) > 1 ) echo ($key) . PHP_EOL;
        }

        dd('here');

        $dbProjects =  \App\Models\Project::all();

        $this->insertProjectsFromKarat($karatProjects->take(200), $dbProjects);
        dd('here');

        $this->removeProjectsThatAreNotInKaratAnymore($karatProjects, $dbProjects);
    }

    private function insertProjectsFromKarat( Collection $karatProjects, Collection $dbProjects )
    {
        $projectsToSkip = $dbProjects->pluck('code' )->intersect( $karatProjects->pluck('code'));

        $karatProjectsToInsert = $karatProjects->reject(function ($item) use ($projectsToSkip) {
            return $projectsToSkip->contains($item->code);
        })->map(function ($item) {
            $arrayToInsert =  $item->toArray();

            $dbClient = \App\Models\Client::where('code', $item->client_id)->first();

            $arrayToInsert['created_at'] = Carbon::now()->toDateTimeString();
            $arrayToInsert['updated_at'] = Carbon::now()->toDateTimeString();
            $arrayToInsert['client_id'] = ($dbClient) ? $dbClient->id : null;
//            $arrayToInsert['client_id'] = 12;

            return $arrayToInsert;
        });

        \App\Models\Project::insert($karatProjectsToInsert->toArray());
    }


}