From 495581de8f7287ec4bb68b60774225ffb1f87b1e Mon Sep 17 00:00:00 2001
From: Juan Pablo Vial <jpvialb@incoviba.cl>
Date: Thu, 3 Jul 2025 16:59:41 -0400
Subject: [PATCH] Update subscriptions

---
 app/src/Service/Venta/MediosPago/Toku.php     |  9 ------
 .../Venta/MediosPago/Toku/Subscription.php    | 28 +++++++++----------
 2 files changed, 14 insertions(+), 23 deletions(-)

diff --git a/app/src/Service/Venta/MediosPago/Toku.php b/app/src/Service/Venta/MediosPago/Toku.php
index 05423b6..ebd7414 100644
--- a/app/src/Service/Venta/MediosPago/Toku.php
+++ b/app/src/Service/Venta/MediosPago/Toku.php
@@ -318,18 +318,9 @@ class Toku extends Ideal\Service
         }
         $results = [];
         switch ($type) {
-            case 'customers':
-                try {
-                    $results['subscription'] = $this->subscription->updateByCustomer($ids);
-                    $results['invoice'] = $this->invoice->updateByCustomer($ids);
-                } catch (EmptyResult $exception) {
-                    $this->logger->error($exception);
-                }
-                break;
             case 'subscriptions':
                 try {
                     $results['subscription'] = $this->subscription->update($ids);
-                    $results['invoice'] = $this->invoice->updateBySubscription($ids);
                 } catch (EmptyResult | EmptyResponse $exception) {
                     $this->logger->error($exception);
                 }
diff --git a/app/src/Service/Venta/MediosPago/Toku/Subscription.php b/app/src/Service/Venta/MediosPago/Toku/Subscription.php
index 602ec2c..8b55050 100644
--- a/app/src/Service/Venta/MediosPago/Toku/Subscription.php
+++ b/app/src/Service/Venta/MediosPago/Toku/Subscription.php
@@ -120,10 +120,10 @@ class Subscription extends AbstractEndPoint
      */
     public function update(array $idsData): array
     {
-        $toku_ids = array_column($idsData, 'toku_id');
-        $old_pids = array_column($idsData, 'product_id');
+        $tokuIds = array_column($idsData, 'toku_id');
+        $oldPids = array_column($idsData, 'product_id');
 
-        $placeholders = array_map(fn($id) => "id{$id}", array_keys($old_pids));
+        $placeholders = array_map(fn($id) => "id{$id}", array_keys($oldPids));
         $placeholdersString = implode(', ', array_map(fn($id) => ":{$id}", $placeholders));
         $query = $this->ventaService->getRepository()->getConnection()->getQueryBuilder()
             ->select('venta.id, CONCAT_WS("-", unidad.descripcion, CONCAT_WS("-", propietario.rut, propietario.dv)) AS old_pid')
@@ -132,7 +132,7 @@ class Subscription extends AbstractEndPoint
             ->joined('JOIN propiedad_unidad pu ON pu.propiedad = venta.propiedad')
             ->joined('JOIN unidad ON pu.unidad = unidad.id')
             ->having("old_pid IN ({$placeholdersString})");
-        $values = array_combine($placeholders, $old_pids);
+        $values = array_combine($placeholders, $oldPids);
         try {
             $statement = $this->ventaService->getRepository()->getConnection()->execute($query, $values);
             $results = $statement->fetchAll(PDO::FETCH_ASSOC);
@@ -143,30 +143,30 @@ class Subscription extends AbstractEndPoint
 
         $accountKeys = $this->getAccountKey(array_column($results, 'id'));
 
-        $new_pids = [];
+        $newPids = [];
         $keys = [];
         foreach ($results as $result) {
-            $idx = array_search($result['old_pid'], $old_pids);
-            $new_pids[$idx] = $result['id'];
+            $idx = array_search($result['old_pid'], $oldPids);
+            $newPids[$idx] = $result['id'];
             if (array_key_exists($result['id'], $accountKeys)) {
                 $keys[$idx] = $accountKeys[$result['id']];
             }
         }
         $output = [];
-        foreach ($toku_ids as $idx => $toku_id) {
-            if (!isset($new_pids[$idx])) {
+        foreach ($tokuIds as $idx => $tokuId) {
+            if (!isset($newPids[$idx])) {
                 continue;
             }
             $data = [
-                'product_id' => $new_pids[$idx],
+                'product_id' => $newPids[$idx],
             ];
-            if (!$this->edit($toku_id, $data, array_key_exists($idx, $keys) ? $keys[$idx] : null)) {
+            if (!$this->edit($tokuId, $data, array_key_exists($idx, $keys) ? $keys[$idx] : null)) {
                 continue;
             }
             $output[] = [
-                'toku_id' => $toku_id,
-                'old_pid' => $old_pids[$idx],
-                'product_id' => $new_pids[$idx],
+                'toku_id' => $tokuId,
+                'old_pid' => $oldPids[$idx],
+                'product_id' => $newPids[$idx],
                 'account_key' => array_key_exists($idx, $keys) ? $keys[$idx] : null
             ];
         }