FlightLog\Infrastructure\Damage\Repository\FlightDamageRepository

Complexity

Total Complexity

5

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	6

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	save()	0	16	2
A	getById()	0	15	2

<?php


namespace FlightLog\Infrastructure\Damage\Repository;

use FlightLog\Domain\Damage\AuthorId;
use FlightLog\Domain\Damage\DamageAmount;
use FlightLog\Domain\Damage\DamageId;
use FlightLog\Domain\Damage\FlightDamage;
use FlightLog\Domain\Damage\FlightId;
use FlightLog\Infrastructure\Common\Repository\AbstractDomainRepository;

final class FlightDamageRepository extends AbstractDomainRepository
{

    /**
     * @param \DoliDB $db
     */
    public function __construct(\DoliDB $db)
    {
        parent::__construct($db, 'bbc_flight_damages');
    }

    /**
     * @param FlightDamage $flightDamage
     *
     * @throws \Exception
     */
    public function save(FlightDamage $flightDamage)
    {
        $fields = [
            'flight_id' => $flightDamage->getFlightId()->getId(),
            'billed' => $flightDamage->isBilled(),
            'amount' => $flightDamage->amount()->getValue(),
            'author_id' => $flightDamage->getAuthor()->getId()
        ];

        if($flightDamage->getId()){
            $this->update($flightDamage->getId()->getId(), $fields);
            return;
        }

        $this->write($fields);
    }

    /**
     * @param DamageId $id
     *
     * @return FlightDamage
     *
     * @throws \Exception
     */
    public function getById(DamageId $id){
        $damage = $this->get($id->getId());

        if(null === $damage){
            throw new \Exception('Damage not found');
        }

        return FlightDamage::load(
            FlightId::create($damage['flight_id']),
            new DamageAmount($damage['amount']),
            $damage['billed'],
            AuthorId::create($damage['author_id']),
            DamageId::create($damage['rowid'])
        );
    }
}