From aee13fcba91af89f59d7612df4e1c866a54fe78f Mon Sep 17 00:00:00 2001
From: Daeng Deni Mardaeni <ddeni05@gmail.com>
Date: Wed, 29 Jan 2025 19:43:36 +0700
Subject: [PATCH] feat(jobs): tambahkan job untuk memproses data detail tagihan

- Membuat kelas ProcessBillDetailDataJob untuk memproses file CSV detail tagihan.
- Menangani pembacaan file dan pemrosesan data dengan penanganan kesalahan.
- Menggunakan model TempBillDetail untuk menyimpan data yang diproses.
---
 app/Jobs/ProcessBillDetailDataJob.php | 61 +++++++++++++++++++++++++++
 1 file changed, 61 insertions(+)
 create mode 100644 app/Jobs/ProcessBillDetailDataJob.php

diff --git a/app/Jobs/ProcessBillDetailDataJob.php b/app/Jobs/ProcessBillDetailDataJob.php
new file mode 100644
index 0000000..2770fd7
--- /dev/null
+++ b/app/Jobs/ProcessBillDetailDataJob.php
@@ -0,0 +1,61 @@
+<?php
+
+namespace Modules\Webstatement\Jobs;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Modules\Webstatement\Models\TempBillDetail;
+use Exception;
+class ProcessBillDetailDataJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    /**
+     * Create a new job instance.
+     */
+    public function __construct()
+    {
+        //
+    }
+
+    /**
+     * Execute the job.
+     */
+    public function handle()
+    {
+        $filePath = storage_path('app/20240901.ST.AA.BILL.DETAILS.csv');
+        try {
+            if (!file_exists($filePath)) {
+                throw new Exception("File not found: $filePath");
+            }
+
+            set_time_limit(24 * 60 * 60);
+
+            $handle = fopen($filePath, "r");
+
+            if ($handle !== false) {
+                $headers = (new TempBillDetail())->getFillable();
+                while (($row = fgetcsv($handle, 0, ";")) !== false) {
+                    if (count($headers) === count($row)) {
+                        $data = array_combine($headers, $row);
+
+                        try {
+                            TempBillDetail::upadteOrCreate(['_id',$data['_id']],$data);
+                        } catch (Exception $e) {
+                            \Log::error('Error processing bill detail: ' . $e->getMessage());
+                        }
+                    }
+                }
+                fclose($handle);
+            } else {
+                throw new Exception("Unable to open file: {$filePath}");
+            }
+        } catch (Exception $e) {
+            \Log::error('Error in ProcessBillDetailDataJob: ' . $e->getMessage());
+            throw $e;
+        }
+    }
+}