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

- Menambahkan kelas ProcessStmtNarrFormatDataJob untuk memproses file CSV.
- Menambahkan model TempStmtNarrFormat untuk menyimpan data format narasi.
- Membuat migrasi untuk tabel temp_stmt_narr_format dengan atribut yang diperlukan.
---
 app/Jobs/ProcessStmtNarrFormatDataJob.php     | 67 +++++++++++++++++++
 app/Models/TempStmtNarrFormat.php             | 24 +++++++
 ...956_create_temp_stmt_narr_format_table.php | 35 ++++++++++
 3 files changed, 126 insertions(+)
 create mode 100644 app/Jobs/ProcessStmtNarrFormatDataJob.php
 create mode 100644 app/Models/TempStmtNarrFormat.php
 create mode 100644 database/migrations/2025_01_28_053956_create_temp_stmt_narr_format_table.php

diff --git a/app/Jobs/ProcessStmtNarrFormatDataJob.php b/app/Jobs/ProcessStmtNarrFormatDataJob.php
new file mode 100644
index 0000000..b8885a3
--- /dev/null
+++ b/app/Jobs/ProcessStmtNarrFormatDataJob.php
@@ -0,0 +1,67 @@
+<?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\TempStmtNarrFormat;
+
+    class ProcessStmtNarrFormatDataJob 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.STMT.NARR.FORMAT.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 TempStmtNarrFormat())->getFillable();
+                    while (($row = fgetcsv($handle, 0, ";")) !== false) {
+                        if (count($headers) === count($row)) {
+                            $data = array_combine($headers, $row);
+                            try {
+                                TempStmtNarrFormat::updateOrCreate(['_id' => $data['_id']], $data);
+                            } catch (Exception $e) {
+                                Log::error('Error processing stmt narr format: ' . $e->getMessage());
+                            }
+                        }
+                    }
+                    fclose($handle);
+                } else {
+                    throw new Exception("Unable to open file: {$filePath}");
+                }
+            } catch (Exception $e) {
+                Log::error('Error in ProcessStmtNarrFormatDataJob: ' . $e->getMessage());
+                throw $e;
+            }
+        }
+    }
diff --git a/app/Models/TempStmtNarrFormat.php b/app/Models/TempStmtNarrFormat.php
new file mode 100644
index 0000000..8fbeec8
--- /dev/null
+++ b/app/Models/TempStmtNarrFormat.php
@@ -0,0 +1,24 @@
+<?php
+
+namespace Modules\Webstatement\Models;
+
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Factories\HasFactory;
+// use Modules\Webstatement\Database\Factories\TempStmtNarrFormatFactory;
+
+class TempStmtNarrFormat extends Model
+{
+    use HasFactory;
+
+    protected $table = 'temp_stmt_narr_format';
+
+    /**
+     * The attributes that are mass assignable.
+     */
+    protected $fillable = ['_id','narr_format_id','description','text_data','line_length','max_lines','wrap_truncate','record_status','curr_no','inputter','date_time','authoriser','co_code','dept_code','auditor_code','audit_date_time','k_file','k_format','file','format'];
+
+    // protected static function newFactory(): TempStmtNarrFormatFactory
+    // {
+    //     // return TempStmtNarrFormatFactory::new();
+    // }
+}
diff --git a/database/migrations/2025_01_28_053956_create_temp_stmt_narr_format_table.php b/database/migrations/2025_01_28_053956_create_temp_stmt_narr_format_table.php
new file mode 100644
index 0000000..fe5d147
--- /dev/null
+++ b/database/migrations/2025_01_28_053956_create_temp_stmt_narr_format_table.php
@@ -0,0 +1,35 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     */
+    public function up(): void
+    {
+        $fields = '_id,narr_format_id,description,text_data,line_length,max_lines,wrap_truncate,record_status,curr_no,inputter,date_time,authoriser,co_code,dept_code,auditor_code,audit_date_time,k_file,k_format,file,format';
+
+        $fieldsArray = explode(',', $fields);
+
+        Schema::create('temp_stmt_narr_format', function (Blueprint $table) use ($fieldsArray) {
+            $table->id();
+            foreach ($fieldsArray as $field) {
+                $field = trim($field);
+                $table->string($field)->nullable();
+            }
+            $table->timestamps();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     */
+    public function down(): void
+    {
+        Schema::dropIfExists('temp_stmt_narr_format');
+    }
+};