From 48bfe5d8ab72439cc55e332421e790553439a70b Mon Sep 17 00:00:00 2001 From: Juan Pablo Vial Date: Wed, 28 Feb 2024 21:44:37 -0300 Subject: [PATCH] Mejora en velocidad de busqueda --- app/resources/routes/api/search.php | 10 +- app/resources/views/search.blade.php | 94 ++++++++++------ app/src/Controller/API/Search.php | 155 ++++++++++++++++++++++++++- app/src/Repository/Venta.php | 22 +++- app/src/Repository/Venta/Unidad.php | 18 ++++ app/src/Service/Venta.php | 4 + app/src/Service/Venta/Unidad.php | 4 + 7 files changed, 269 insertions(+), 38 deletions(-) diff --git a/app/resources/routes/api/search.php b/app/resources/routes/api/search.php index e81221f..9a7890b 100644 --- a/app/resources/routes/api/search.php +++ b/app/resources/routes/api/search.php @@ -1,4 +1,12 @@ post('/search', [Search::class, 'query']); +$app->group('/search', function($app) { + $app->group('/ventas', function($app) { + $app->post('/unidades', [Search::class, 'unidades']); + $app->get('/unidad/{unidad_id}', [Search::class, 'unidad']); + $app->post('[/]', [Search::class, 'ventas']); + }); + $app->get('/venta/{venta_id}', [Search::class, 'venta']); + $app->post('[/]', [Search::class, 'query']); +}); diff --git a/app/resources/views/search.blade.php b/app/resources/views/search.blade.php index 0da8710..9464141 100644 --- a/app/resources/views/search.blade.php +++ b/app/resources/views/search.blade.php @@ -96,6 +96,10 @@ id: '', data: [], table: null, + queues: { + unidades: [], + ventas: [] + }, get: function() { return { results: () => { @@ -122,34 +126,33 @@ } const progress = this.draw().progress(data.results.length) const promises = [] - data.results.forEach(row => { - if (row.tipo === 'venta') { - return promises.push(this.get().venta(row.id).then(json => { - if (json.venta === null) { - console.debug(json) - return - } - const venta = json.venta + this.queues.ventas = data.results.filter(row => row.tipo === 'venta').map(row => row.id) + this.queues.unidades = data.results.filter(row => row.tipo !== 'venta').map(row => row.id) + promises.push(this.get().ventas().then(arrays => { + arrays.forEach(json => { + if (json.ventas.length === 0) { + console.debug(json) + return + } + json.ventas.forEach(venta => { progress.progress('increment') const r = new Row({unidad: venta.propiedad.unidades[0], proyecto: venta.proyecto}) r.venta = venta this.data.push(r) - }).catch(error => { + }) + }) + })) + promises.push(this.get().unidades().then(arrays => { + arrays.forEach(json => { + if (json.unidades.length === 0) { + return + } + json.unidades.forEach(unidad => { progress.progress('increment') - console.error(row) - console.error(error) - })) - } - promises.push(this.get().unidad(row.id).then(json => { - const unidad = json.unidad - progress.progress('increment') - this.data.push(new Row({unidad: unidad, proyecto: unidad.proyecto_tipo_unidad.proyecto})) - }).catch(error => { - progress.progress('increment') - console.error(row) - console.error(error) - })) - }) + this.data.push(new Row({unidad: unidad, proyecto: unidad.proyecto_tipo_unidad.proyecto})) + }) + }) + })) Promise.all(promises).then(() => { this.sort() this.draw().clear() @@ -157,22 +160,43 @@ }) }) }, - unidad: id => { - const url = '{{$urls->api}}/ventas/unidad/' + id - return fetchAPI(url).then(response => { - if (response.ok) { + unidades: () => { + const url = '{{$urls->api}}/search/ventas/unidades' + const chunks = [] + for (let i = 0; i < this.queues.unidades.length; i += 100) { + chunks.push(this.queues.unidades.slice(i, i + 100)) + } + const promises = [] + chunks.forEach(ids => { + const body = new FormData() + body.set('unidades', ids) + promises.push(fetchAPI(url, {method: 'post', body}).then(response => { + if (!response) { + return + } return response.json() - } + })) }) + return Promise.all(promises) }, - venta: id => { - const url = '{{$urls->api}}/venta/' + id - return fetchAPI(url).then(response => { - if (!response) { - return - } - return response.json() + ventas: () => { + const url = '{{$urls->api}}/search/ventas' + const chunks = [] + for (let i = 0; i < this.queues.ventas.length; i += 100) { + chunks.push(this.queues.ventas.slice(i, i + 100)) + } + const promises = [] + chunks.forEach(ids => { + const body = new FormData() + body.set('ventas', ids) + promises.push(fetchAPI(url, {method: 'post', body}).then(response => { + if (!response) { + return + } + return response.json() + })) }) + return Promise.all(promises) } } }, diff --git a/app/src/Controller/API/Search.php b/app/src/Controller/API/Search.php index 7770215..ae76f3b 100644 --- a/app/src/Controller/API/Search.php +++ b/app/src/Controller/API/Search.php @@ -3,11 +3,13 @@ namespace Incoviba\Controller\API; use Psr\Http\Message\ResponseInterface; use Psr\Http\Message\ServerRequestInterface; +use Incoviba\Controller\withRedis; +use Incoviba\Common\Implement\Exception; use Incoviba\Service; class Search { - use withJson; + use withJson, withRedis; public function query(ServerRequestInterface $request, ResponseInterface $response, Service\Search $service): ResponseInterface @@ -17,4 +19,155 @@ class Search $output = compact('results'); return $this->withJson($response, $output); } + public function unidad(ServerRequestInterface $request, ResponseInterface $response, Service\Redis $redisService, + Service\Venta\Unidad $unidadService, int $unidad_id): ResponseInterface + { + $output = [ + 'unidad_id' => $unidad_id, + 'unidad' => null + ]; + $redisKey = "search:unidad:{$unidad_id}"; + try { + $output['unidad'] = $this->fetchRedis($redisService, $redisKey); + } catch (Exception\EmptyRedis) { + try { + $unidad = $unidadService->getByIdForSearch($unidad_id); + $output['unidad'] = [ + 'id' => $unidad['id'], + 'descripcion' => $unidad['descripcion'], + 'proyecto_tipo_unidad' => [ + 'proyecto' => [ + 'id' => $unidad['proyecto_id'], + 'descripcion' => $unidad['proyecto_descripcion'] + ], + 'tipo_unidad' => [ + 'descripcion' => $unidad['tipo_unidad_descripcion'] + ], + 'superficie' => $unidad['superficie'] + ], + 'current_precio' => [ + 'valor' => $unidad['precio'] + ] + ]; + $this->saveRedis($redisService, $redisKey, $output['unidad']); + } catch (Exception\EmptyResult) {} + } + return $this->withJson($response, $output); + } + public function unidades(ServerRequestInterface $request, ResponseInterface $response, Service\Redis $redisService, + Service\Venta\Unidad $unidadService): ResponseInterface + { + $body = $request->getParsedBody(); + $output = [ + 'input' => $body, + 'unidades' => [] + ]; + $unidades = explode(',', $body['unidades']); + foreach ($unidades as $unidad_id) { + $redisKey = "search:unidad:{$unidad_id}"; + try { + $output['unidades'] []= $this->fetchRedis($redisService, $redisKey); + } catch (Exception\EmptyRedis) { + try { + $unidad = $unidadService->getByIdForSearch($unidad_id); + $unidad = [ + 'id' => $unidad['id'], + 'descripcion' => $unidad['descripcion'], + 'proyecto_tipo_unidad' => [ + 'proyecto' => [ + 'id' => $unidad['proyecto_id'], + 'descripcion' => $unidad['proyecto_descripcion'] + ], + 'tipo_unidad' => [ + 'descripcion' => $unidad['tipo_unidad_descripcion'] + ], + 'superficie' => $unidad['superficie'] + ], + 'current_precio' => [ + 'valor' => $unidad['precio'] + ] + ]; + $output['unidades'] []= $unidad; + $this->saveRedis($redisService, $redisKey, $unidad); + } catch (Exception\EmptyResult) {} + } + } + return $this->withJson($response, $output); + } + public function venta(ServerRequestInterface $request, ResponseInterface $response, Service\Redis $redisService, + Service\Venta $ventaService, int $venta_id): ResponseInterface + { + $output = [ + 'venta_id' => $venta_id, + 'venta' => null + ]; + $redisKey = "search:venta:{$venta_id}"; + try { + $output['venta'] = $this->fetchRedis($redisService, $redisKey); + } catch (Exception\EmptyRedis) { + try { + $venta = $ventaService->getById($venta_id); + /*$output['venta'] = [ + 'id' => $venta->id, + '' + ];*/ + $output['venta'] = $venta; + $this->saveRedis($redisService, $redisKey, $output['venta']); + } catch (Exception\EmptyResult) {} + } + return $this->withJson($response, $output); + } + public function ventas(ServerRequestInterface $request, ResponseInterface $response, Service\Redis $redisService, + Service\Venta $ventaService): ResponseInterface + { + $body = $request->getParsedBody(); + $output = [ + 'input' => $body, + 'ventas' => [] + ]; + $ventas = explode(',', $body['ventas']); + foreach ($ventas as $venta_id) { + $redisKey = "search:venta:{$venta_id}"; + try { + $output['ventas'] []= $this->fetchRedis($redisService, $redisKey); + } catch (Exception\EmptyRedis) { + try { + $venta = $ventaService->getByIdForSearch($venta_id); + $venta = [ + 'id' => $venta['id'], + 'proyecto' => [ + 'id' => $venta['proyecto_id'], + 'descripcion' => $venta['proyecto_descripcion'] + ], + 'propietario' => [ + 'nombre_completo' => $venta['propietario'] + ], + 'propiedad' => [ + 'unidades' => [ + [ + 'descripcion' => $venta['unidad_descripcion'], + 'proyecto_tipo_unidad' => [ + 'tipo_unidad' => [ + 'descripcion' => $venta['tipo_unidad_descripcion'] + ], + 'superficie' => $venta['superficie'] + ] + ] + ] + ], + 'fecha' => $venta['fecha'], + 'current_estado' => [ + 'tipo_estado_venta' => [ + 'activa' => $venta['activa'] + ] + ], + 'valor' => $venta['valor'] + ]; + $output['ventas'] []= $venta; + $this->saveRedis($redisService, $redisKey, json_encode($venta)); + } catch (Exception\EmptyResult) {} + } + } + return $this->withJson($response, $output); + } } diff --git a/app/src/Repository/Venta.php b/app/src/Repository/Venta.php index c9bb1f0..d1d2f0a 100644 --- a/app/src/Repository/Venta.php +++ b/app/src/Repository/Venta.php @@ -298,7 +298,6 @@ class Venta extends Ideal\Repository OR CONCAT_WS(' ', `propietario`.`nombres`, `propietario`.`apellido_paterno`, `propietario`.`apellido_materno`) LIKE :propietario OR rut = :rut OR CONCAT_WS('-', rut, dv) = :rut"); - error_log($query.PHP_EOL,3,'/logs/debug'); return $this->fetchIds($query, [':propietario' => "%{$propietario}%", ':rut' => $propietario]); } public function fetchByPropietarioNombreCompleto(string $propietario): array @@ -356,6 +355,27 @@ class Venta extends Ideal\Repository ->where('bono_pie = ?'); return $this->fetchId($query, [$bono_id]); } + public function fetchByIdForSearch(int $venta_id): array + { + $query = $this->connection->getQueryBuilder() + ->select('venta.id AS id, venta.fecha AS fecha, venta.valor_uf AS valor') + ->columns('proyecto.id AS proyecto_id, proyecto.descripcion AS proyecto_descripcion') + ->columns('CONCAT_WS(" ", propietario.nombres, propietario.apellido_paterno, propietario.apellido_materno) AS propietario') + ->columns('unidad.descripcion AS unidad_descripcion, tu.descripcion AS tipo_unidad_descripcion, ptu.m2 + ptu.logia + ptu.terraza AS superficie') + ->columns('tev.activa') + ->from($this->getTable()) + ->joined('JOIN propietario ON propietario.rut = venta.propietario') + ->joined('JOIN propiedad_unidad pu ON pu.propiedad = venta.propiedad') + ->joined('JOIN unidad ON unidad.id = pu.unidad') + ->joined('JOIN proyecto_tipo_unidad ptu ON unidad.pt = ptu.id') + ->joined('JOIN proyecto ON proyecto.id = ptu.proyecto') + ->joined('JOIN tipo_unidad tu ON tu.id = ptu.tipo') + ->joined('JOIN (SELECT ev1.* FROM estado_venta ev1 JOIN (SELECT MAX(id) AS id, venta FROM estado_venta GROUP BY venta) ev0 ON ev0.id = ev1.id) ev ON ev.venta = venta.id') + ->joined('JOIN tipo_estado_venta tev ON ev.estado = tev.id') + ->where('venta.id = ? AND tu.descripcion = "departamento"') + ->group('venta.id'); + return $this->connection->execute($query, [$venta_id])->fetch(PDO::FETCH_ASSOC); + } protected function fetchIds(string $query, ?array $data = null): array { diff --git a/app/src/Repository/Venta/Unidad.php b/app/src/Repository/Venta/Unidad.php index 21fe4be..cdefc57 100644 --- a/app/src/Repository/Venta/Unidad.php +++ b/app/src/Repository/Venta/Unidad.php @@ -177,6 +177,24 @@ class Unidad extends Ideal\Repository ->where("a.`descripcion` LIKE ? AND tu.`descripcion` = ? AND (pu.`id` IS NULL OR `venta`.`id` IS NULL OR tev.`activa` = 0)"); return $this->connection->execute($query, [$descripcion, $tipo])->fetchAll(PDO::FETCH_ASSOC); } + public function fetchByIdForSearch(int $unidad_id): array + { + $query = $this->connection->getQueryBuilder() + ->select('unidad.id AS id, unidad.descripcion AS descripcion') + ->columns('proyecto.id AS proyecto_id, proyecto.descripcion AS proyecto_descripcion') + ->columns('tu.descripcion AS tipo_unidad_descripcion') + ->columns('ptu.m2 + ptu.logia + ptu.terraza AS superficie') + ->columns('precio.valor AS precio') + ->from($this->getTable()) + ->joined('JOIN proyecto_tipo_unidad ptu ON ptu.id = unidad.pt') + ->joined('JOIN proyecto ON proyecto.id = ptu.proyecto') + ->joined('JOIN tipo_unidad tu ON tu.id = ptu.tipo') + ->joined('JOIN precio ON precio.unidad = unidad.id') + ->joined('JOIN (SELECT ep1.* FROM estado_precio ep1 JOIN (SELECT MAX(id) AS id, precio FROM estado_precio GROUP BY precio) ep0 ON ep0.id = ep1.id) ep ON ep.precio = precio.id') + ->where('unidad.id = ?') + ->group('unidad.id'); + return $this->connection->execute($query, [$unidad_id])->fetch(PDO::FETCH_ASSOC); + } protected function joinProrrateo(): string { diff --git a/app/src/Service/Venta.php b/app/src/Service/Venta.php index d694ad6..60a7edd 100644 --- a/app/src/Service/Venta.php +++ b/app/src/Service/Venta.php @@ -75,6 +75,10 @@ class Venta extends Service $ventas = $this->ventaRepository->fetchEscriturasByProyecto($proyecto_id); return array_map([$this, 'process'], $ventas); } + public function getByIdForSearch(int $venta_id): array + { + return $this->ventaRepository->fetchByIdForSearch($venta_id); + } protected function process(Model\Venta $venta): Model\Venta { diff --git a/app/src/Service/Venta/Unidad.php b/app/src/Service/Venta/Unidad.php index 1fc6f6e..1f5276f 100644 --- a/app/src/Service/Venta/Unidad.php +++ b/app/src/Service/Venta/Unidad.php @@ -33,6 +33,10 @@ class Unidad { return $this->unidadRepository->fetchDisponiblesByProyecto($proyecto_id); } + public function getByIdForSearch(int $unidad_id): array + { + return $this->unidadRepository->fetchByIdForSearch($unidad_id); + } protected function process($unidad): Model\Venta\Unidad {