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

- Membuat kelas ProcessArrangementDataJob untuk memproses file CSV data arrangement.
- Menangani pembacaan file dan pembaruan data menggunakan model TempArrangement.
- Menangani kesalahan dengan logging untuk memudahkan debugging.
---
 app/Jobs/ProcessArrangementDataJob.php | 68 ++++++++++++++++++++++++++
 1 file changed, 68 insertions(+)
 create mode 100644 app/Jobs/ProcessArrangementDataJob.php

diff --git a/app/Jobs/ProcessArrangementDataJob.php b/app/Jobs/ProcessArrangementDataJob.php
new file mode 100644
index 0000000..cb03da7
--- /dev/null
+++ b/app/Jobs/ProcessArrangementDataJob.php
@@ -0,0 +1,68 @@
+<?php
+
+    namespace Modules\Webstatement\Jobs;
+
+    use Exception;
+    use Illuminate\Bus\Queueable;
+    use Illuminate\Contracts\Queue\ShouldQueue;
+    use Illuminate\Foundation\Bus\Dispatchable;
+    use Illuminate\Queue\InteractsWithQueue;
+    use Illuminate\Queue\SerializesModels;
+    use Log;
+    use Modules\Webstatement\Models\TempArrangement;
+
+    class ProcessArrangementDataJob implements ShouldQueue
+    {
+        use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+        /**
+         * Create a new job instance.
+         */
+        public function __construct()
+        {
+            //
+        }
+
+        /**
+         * Execute the job.
+         */
+        public function handle()
+        : void
+        {
+            $filePath = storage_path('app/20240901.ST.AA.ARRANGEMENT.csv'); // Adjust this path as needed
+            try {
+                if (!file_exists($filePath)) {
+                    throw new Exception("File not found: $filePath");
+                }
+
+                set_time_limit(24 * 60 * 60);
+
+                if (!file_exists($filePath)) {
+                    throw new Exception("File not found: {$filePath}");
+                }
+
+                $handle = fopen($filePath, "r");
+
+                if ($handle !== false) {
+                    $headers = (new TempArrangement())->getFillable();
+
+                    while (($row = fgetcsv($handle, 0, ";")) !== false) {
+                        unset($row[0]); // Remove the first empty column if present
+                        if (count($headers) === count($row)) {
+                            $data = array_combine($headers, $row);
+                            TempArrangement::updateOrCreate(
+                                ['arrangement_id' => $data['arrangement_id']], // key to find existing record
+                                $data                                          // data to update or create
+                            );
+                        }
+                    }
+                    fclose($handle);
+                } else {
+                    throw new Exception("Unable to open file: {$filePath}");
+                }
+            } catch (Exception $e) {
+                Log::error('Error in ProcessArrangementDataJob: ' . $e->getMessage());
+                throw $e;
+            }
+        }
+    }