FlightLog\Application\Damage\Command\CreateDamageCommandHandler

Complexity

Total Complexity

8

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	__invoke()	0	12	2
A	linkSupplierInvoice()	0	8	2
A	linkFlight()	0	4	1
A	insertLinks()	0	21	2

<?php


namespace FlightLog\Application\Damage\Command;


use FlightLog\Domain\Damage\AuthorId;
use FlightLog\Domain\Damage\DamageAmount;
use FlightLog\Domain\Damage\FlightDamage;
use FlightLog\Domain\Damage\FlightId;
use FlightLog\Infrastructure\Damage\Repository\FlightDamageRepository;

final class CreateDamageCommandHandler
{
    /**
     * @var FlightDamageRepository
     */
    private $damageRepository;

    /**
     * @var \DoliDB
     */
    private $db;

    /**
     * @param \DoliDB $db
     * @param FlightDamageRepository $damageRepository
     */
    public function __construct(\DoliDB $db, FlightDamageRepository $damageRepository)
    {
        $this->damageRepository = $damageRepository;
        $this->db = $db;
    }


    /**
     * @param CreateDamageCommand $command
     *
     * @throws \Exception
     */
    public function __invoke(CreateDamageCommand $command)
    {
        $damage = FlightDamage::waiting(new DamageAmount($command->getAmount()), AuthorId::create($command->getAuthorId()));
        if(null !== $command->getFlightId()){
            $damage = FlightDamage::damage(FlightId::create($command->getFlightId()), new DamageAmount($command->getAmount()), AuthorId::create($command->getAuthorId()));
        }

        $id = $this->damageRepository->save($damage);

        $this->linkSupplierInvoice($id, $command->getBillId());
        $this->linkFlight($id, $command->getFlightId());
    }

    /**
     * @param int $damageId
     * @param int $invoiceId
     *
     * @throws \Exception
     */
    private function linkSupplierInvoice($damageId, $invoiceId)
    {
        if($invoiceId <= 0){
            return;
        }

        $this->insertLinks($damageId, $invoiceId, 'invoice_supplier');
    }

    /**
     * @param int $damageId
     * @param int $flightId
     */
    private function linkFlight($damageId, $flightId)
    {
        $this->insertLinks($damageId, $flightId, 'flightlog_bbcvols');
    }

    /**
     * @param int $damageId
     * @param int $targetId
     * @param string $targetType
     */
    private function insertLinks($damageId, $targetId, $targetType){
        $sql = "INSERT INTO ".MAIN_DB_PREFIX."element_element (";
        $sql .= "fk_source";
        $sql .= ", sourcetype";
        $sql .= ", fk_target";
        $sql .= ", targettype";
        $sql .= ") VALUES (";
        $sql .= $damageId;
        $sql .= ", 'flightlog_damage'";
        $sql .= ", ".$targetId;
        $sql .= ", '".$targetType."'";
        $sql .= ")";

        if ($this->db->query($sql))
        {
            $this->db->commit();
            return;
        }

        $this->db->rollback();
    }

}