- Implement automated synchronization of employees via Arcadia API (EmployeeSyncService, SynchronizeEmployeesWithArcadiaApi, FetchAndUpsertArcadiaEmployees) - Add Back-Office application settings for employee sites (Setting singleton, GetSettingsQuery, UpdateSettings, SettingsController, EmployeeSitesInputComponent.vue) - Strongly type Employee attributes using Domain Value Objects (ShopperEstablishmentCode, ShopperSiteCode, ShopperServiceCode) and Eloquent Casts - Migrate pagination from Domain to Shared\Pagination namespace across queries and inputs - Remove legacy and dead CSV employee import/export code - Restore Domain\Ports\Services\CsvGenerator interface for Regate order generation - Add comprehensive Pest unit, integration, and feature test coverage
102 lines
2.7 KiB
PHP
102 lines
2.7 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace App\Repositories;
|
|
|
|
use App\Contracts\Repositories\EmployeeRepository;
|
|
use App\Models\Employee;
|
|
use Domain\Models\ValueObjects\Code;
|
|
use Domain\Models\ValueObjects\Matricule;
|
|
use Illuminate\Support\Collection;
|
|
use Ramsey\Uuid\UuidInterface;
|
|
|
|
class EloquentEmployeeRepository implements EmployeeRepository
|
|
{
|
|
/** @return array<int, Employee> */
|
|
public function getAll(): array
|
|
{
|
|
return Employee::query()
|
|
->get()
|
|
->all();
|
|
}
|
|
|
|
public function find(UuidInterface $id): ?Employee
|
|
{
|
|
return Employee::query()
|
|
->where('id', $id->toString())
|
|
->first();
|
|
}
|
|
|
|
public function persist(Employee $employee): void
|
|
{
|
|
$employee->save();
|
|
}
|
|
|
|
public function delete(Employee $employee): void
|
|
{
|
|
$employee->delete();
|
|
}
|
|
|
|
public function findByMatriculeAndCode(Matricule $matricule, Code $code): ?Employee
|
|
{
|
|
return Employee::query()
|
|
->where('matricule', $matricule->value)
|
|
->where('code', $code->value)
|
|
->first();
|
|
}
|
|
|
|
public function findByMatricule(Matricule $matricule): ?Employee
|
|
{
|
|
return Employee::query()
|
|
->where('matricule', $matricule->value)
|
|
->first();
|
|
}
|
|
|
|
/**
|
|
* @param array<array-key, Matricule>|Collection<array-key, Matricule> $matricules
|
|
* @return array<int, Employee>
|
|
*/
|
|
public function getWhereMatriculeIn(array | Collection $matricules): array
|
|
{
|
|
return Employee::query()
|
|
->whereIn('matricule', $matricules)
|
|
->get()
|
|
->all();
|
|
}
|
|
|
|
/**
|
|
* @param array<array-key, Matricule>|Collection<array-key, Matricule> $matricules
|
|
* @return array<string, Employee>
|
|
*/
|
|
public function getWithCustomerWhereMatriculeIn(array | Collection $matricules): array
|
|
{
|
|
return Employee::query()
|
|
->with('customer')
|
|
->whereIn('matricule', $matricules)
|
|
->get()
|
|
->keyBy('matricule')
|
|
->all();
|
|
}
|
|
|
|
/**
|
|
* @param array<array-key, Matricule>|Collection<array-key, Matricule> $excludedMatricules
|
|
* @return array<int, Employee>
|
|
*/
|
|
public function getWithCustomerWhereMatriculeNotIn(array | Collection $excludedMatricules): array
|
|
{
|
|
return Employee::query()
|
|
->with('customer')
|
|
->whereNotIn('matricule', $excludedMatricules)
|
|
->get()
|
|
->all();
|
|
}
|
|
|
|
public function getMostRecentSyncDate(): ?\DateTimeInterface
|
|
{
|
|
return Employee::query()
|
|
->orderBy('last_sync', 'desc')
|
|
->limit(1)
|
|
->first('last_sync')?->last_sync;
|
|
}
|
|
}
|