internal(summary calculation): use previous closed amounts as opened …

…amounts
KennethTrecy · May 11, 2024 · c59d51a · c59d51a
1 parent f8a5ca3
commit c59d51a
Showing 1 changed file with 53 additions and 13 deletions.
diff --git a/app/Database/Migrations/2024-05-11-044230_ExpandSummaryCalculations.php b/app/Database/Migrations/2024-05-11-044230_ExpandSummaryCalculations.php
@@ -3,24 +3,64 @@
 namespace App\Database\Migrations;
 
 use CodeIgniter\Database\Migration;
+use CodeIgniter\Database\Exceptions\DatabaseException;
+use App\Models\FrozenPeriodModel;
+use App\Models\SummaryCalculationModel;
 
 class ExpandSummaryCalculations extends Migration
 {
     public function up()
     {
-        $new_fields = [
-            "opened_debit_amount" => [
-                "type" => "TEXT",
-                "null" => false,
-                "default" => "0"
-            ],
-            "opened_credit_amount" => [
-                "type" => "TEXT",
-                "null" => false,
-                "default" => "0"
-            ]
-        ];
-        $this->forge->addColumn("summary_calculations", $new_fields);
+        try {
+            $new_fields = [
+                "opened_debit_amount" => [
+                    "type" => "TEXT",
+                    "null" => false,
+                    "default" => "0"
+                ],
+                "opened_credit_amount" => [
+                    "type" => "TEXT",
+                    "null" => false,
+                    "default" => "0"
+                ]
+            ];
+            $this->forge->addColumn("summary_calculations", $new_fields);
+
+            $frozen_periods = model(FrozenPeriodModel::class)->findAll();
+            $previous_keyed_summary_calculations = [];
+            foreach ($frozen_periods as $index => $frozen_period) {
+                $summary_calculations = model(SummaryCalculationModel::class)
+                    ->where("frozen_period_id", $frozen_period->id)
+                    ->findAll();
+
+                $keyed_summary_calculations = [];
+                foreach ($summary_calculations as $summary_calculation) {
+                    $account_id = $summary_calculation->account_id;
+
+                    $previous_calculation = $previous_keyed_summary_calculations[$account_id] ?? [];
+
+                    $summary_calculation->opened_debit_amount
+                        = $previous_calculation["closed_debit_amount"] ?? "0";
+                    $summary_calculation->opened_credit_amount
+                        = $previous_calculation["closed_credit_amount"] ?? "0";
+                    $keyed_summary_calculations[$account_id] = $summary_calculation->toArray();
+                }
+
+                model(SummaryCalculationModel::class)
+                    ->updateBatch(array_values($keyed_summary_calculations), "id");
+
+                $previous_keyed_summary_calculations = $keyed_summary_calculations;
+            }
+        } catch (DatabaseException $error) {
+            $this->down();
+            throw $error;
+        } catch (\TypeError $error) {
+            $this->down();
+            throw $error;
+        } catch (\ErrorException $error) {
+            $this->down();
+            throw $error;
+        }
     }
 
     public function down()