Manejo de excepciones

app/src/Repository/Venta/Propiedad.php

@@ -1,6 +1,8 @@
 <?php
 namespace Incoviba\Repository\Venta;
 
+use PDO;
+use PDOException;
 use Incoviba\Common\Ideal;
 use Incoviba\Common\Define;
 use Incoviba\Common\Implement;
@@ -17,14 +19,7 @@ class Propiedad extends Ideal\Repository
 
     public function create(?array $data = null): Model\Venta\Propiedad
     {
-        $map = (new Implement\Repository\MapperParser())
-            ->register('unidad_principal', (new Implement\Repository\Mapper())
-                ->setProperty('unidades')
-                ->setDefault([])
-                ->setFunction(function($data) {
-                    return [$this->unidadService->getById($data['unidad_principal'])];
-                })
-            )
+        $map = (new Implement\Repository\MapperParser(['unidad_principal', 'estacionamientos', 'bodegas', 'estado']))
             ->register('estado', new Implement\Repository\Mapper\Boolean('estado'));
         return $this->parseData(new Model\Venta\Propiedad(), $data, $map);
     }
@@ -67,7 +62,10 @@ class Propiedad extends Ideal\Repository
      */
     public function fetchVigenteByUnidad(int $unidad_id): Model\Venta\Propiedad
     {
-        $query = "SELECT * FROM `{$this->getTable()}` WHERE `unidad_principal` = ?";
+        $query = $this->connection->getQueryBuilder()
+            ->select()
+            ->from($this->getTable())
+            ->where('`unidad_principal` = ? AND `estado` = 1');
         return $this->fetchOne($query, [$unidad_id]);
     }
 }

app/src/Repository/Venta/PropiedadUnidad.php

@@ -1,6 +1,7 @@
 <?php
 namespace Incoviba\Repository\Venta;
 
+use PDOException;
 use Incoviba\Common\Ideal;
 use Incoviba\Common\Define;
 use Incoviba\Common\Implement;
@@ -57,7 +58,12 @@ class PropiedadUnidad extends Ideal\Repository
         return $this->update($model, ['propiedad', 'unidad', 'valor'], $new_data);
     }
 
-    public function fetchById(int $id): Define\Model
+    /**
+     * @param int $id
+     * @return Model\Venta\PropiedadUnidad
+     * @throws Implement\Exception\EmptyResult
+     */
+    public function fetchById(int $id): Model\Venta\PropiedadUnidad
     {
         $query = $this->connection->getQueryBuilder()
             ->select()
@@ -66,16 +72,27 @@ class PropiedadUnidad extends Ideal\Repository
         return $this->fetchOne($query, [$id]);
     }
 
+    /**
+     * @param int $venta_id
+     * @return array
+     * @throws Implement\Exception\EmptyResult
+     */
     public function fetchByVenta(int $venta_id): array
     {
         $query = $this->connection->getQueryBuilder()
             ->select('a.*')
             ->from("{$this->getTable()} a")
-            ->joined('JOIN unidad ON a.unidad = unidad.id
-    JOIN venta ON venta.propiedad = a.propiedad')
+            ->joined('INNER JOIN unidad ON a.unidad = unidad.id')
+            ->joined('INNER JOIN venta ON venta.propiedad = a.propiedad')
             ->where('venta.id = ?');
         return $this->fetchMany($query, [$venta_id]);
     }
+
+    /**
+     * @param int $propiedad_id
+     * @return array
+     * @throws Implement\Exception\EmptyResult
+     */
     public function fetchByPropiedad(int $propiedad_id): array
     {
         $query = $this->connection->getQueryBuilder()
@@ -86,6 +103,12 @@ class PropiedadUnidad extends Ideal\Repository
             ->group('`unidad`.`id`');
         return $this->fetchMany($query, [$propiedad_id]);
     }
+
+    /**
+     * @param Define\Model $model
+     * @return void
+     * @throws PDOException
+     */
     public function remove(Define\Model $model): void
     {
         $query = $this->connection->getQueryBuilder()
@@ -94,7 +117,15 @@ class PropiedadUnidad extends Ideal\Repository
         $this->connection->execute($query, [$model->pu_id]);
     }
 
-    protected function update(Define\Model $model, array $columns, array $data): Define\Model
+    /**
+     * @param Define\Model $model
+     * @param array $columns
+     * @param array $data
+     * @return Model\Venta\PropiedadUnidad
+     * @throws Implement\Exception\EmptyResult
+     * @throws PDOException
+     */
+    protected function update(Define\Model $model, array $columns, array $data): Model\Venta\PropiedadUnidad
     {
         $changes = [];
         $values = [];