<?php
namespace Incoviba\Service\Contabilidad;

use DateTimeInterface;
use Psr\Log\LoggerInterface;
use Incoviba\Common\Ideal\Service;
use Incoviba\Common\Implement;
use Incoviba\Model;
use Incoviba\Repository;

class Movimiento extends Service
{
    public function __construct(LoggerInterface                         $logger,
                                protected Repository\Contabilidad\Movimiento $movimientoRepository,
                                protected Repository\Movimiento\Detalle $detalleRepository)
    {
        parent::__construct($logger);
    }

    public function getAll(null|string|array $ordering = null): array
    {
        return array_map([$this, 'process'], $this->movimientoRepository->fetchAll($ordering));
    }
    public function getById(int $movimiento_id): Model\Contabilidad\Movimiento
    {
        return $this->process($this->movimientoRepository->fetchById($movimiento_id));
    }
    public function getAmountStartingFrom(int $start, int $amount): array
    {
        return array_map([$this, 'process'], $this->movimientoRepository->fetchAmountStartingFrom($start, $amount));
    }
    public function getAmountBySociedadAndMes(int $sociedad_rut, DateTimeInterface $mes, ?int $amount): array
    {
        return array_map([$this, 'process'], $this->movimientoRepository->fetchAmountBySociedadAndMes($sociedad_rut, $mes, $amount));
    }
    public function setDetalles(Model\Contabilidad\Movimiento $movimiento, array $data): Model\Contabilidad\Movimiento
    {
        try {
            $detalles = $this->detalleRepository->fetchByMovimiento($movimiento->id);
            $this->detalleRepository->edit($detalles, $data);
        } catch (Implement\Exception\EmptyResult) {
            $data['movimiento_id'] = $movimiento->id;
            $detalles = $this->detalleRepository->create($data);
            $this->detalleRepository->save($detalles);
        }
        return $movimiento;
    }

    public function process(Model\Contabilidad\Movimiento $movimiento): Model\Contabilidad\Movimiento
    {
        $movimiento->addFactory('detalles', (new Implement\Repository\Factory())->setCallable(function(int $movimiento_id) {
            return $this->detalleRepository->fetchByMovimiento($movimiento_id);
        })->setArgs(['movimiento_id' => $movimiento->id]));
        return $movimiento;
    }
}