diff --git a/app/Jobs/ProcessAccountDataJob.php b/app/Jobs/ProcessAccountDataJob.php index 04137a6..439cfcf 100644 --- a/app/Jobs/ProcessAccountDataJob.php +++ b/app/Jobs/ProcessAccountDataJob.php @@ -11,6 +11,7 @@ use Illuminate\Support\Facades\Log; use Illuminate\Support\Facades\Storage; use Modules\Webstatement\Models\Account; + use Modules\Webstatement\Models\AccountBalance; class ProcessAccountDataJob implements ShouldQueue { @@ -92,6 +93,27 @@ $account = Account::firstOrNew(['account_number' => $data['account_number']]); $account->fill($data); $account->save(); + + // Store the opening balances in the AccountBalance model for this period + if (isset($data['open_actual_bal']) || isset($data['open_cleared_bal'])) { + $accountBalance = AccountBalance::firstOrNew([ + 'account_number' => $data['account_number'], + 'period' => $period + ]); + + // Set the balances + if (isset($data['open_actual_bal'])) { + $accountBalance->actual_balance = $data['open_actual_bal']; + } + + if (isset($data['open_cleared_bal'])) { + $accountBalance->cleared_balance = $data['open_cleared_bal']; + } + + $accountBalance->save(); + Log::info("Saved balance for account {$data['account_number']} for period $period"); + } + $processedCount++; } } catch (Exception $e) {