diff --git a/app/Jobs/ProcessStmtNarrParamDataJob.php b/app/Jobs/ProcessStmtNarrParamDataJob.php
new file mode 100644
index 0000000..72a4419
--- /dev/null
+++ b/app/Jobs/ProcessStmtNarrParamDataJob.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\TempStmtNarrParam;
+
+    class ProcessStmtNarrParamDataJob 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.PARAM.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 TempStmtNarrParam())->getFillable();
+                    while (($row = fgetcsv($handle, 0, ";")) !== false) {
+                        if (count($headers) === count($row)) {
+                            $data = array_combine($headers, $row);
+
+                            try {
+                                TempStmtNarrParam::updateOrCreate(['_id' => $data['_id']], $data);
+                            } catch (Exception $e) {
+                                Log::error('Error processing stmt narr param: ' . $e->getMessage());
+                            }
+                        }
+                    }
+                    fclose($handle);
+                } else {
+                    throw new Exception("Unable to open file: {$filePath}");
+                }
+            } catch (Exception $e) {
+                Log::error('Error in ProcessStmtNarrParamDataJob: ' . $e->getMessage());
+                throw $e;
+            }
+        }
+    }
diff --git a/app/Models/TempStmtNarrParam.php b/app/Models/TempStmtNarrParam.php
new file mode 100644
index 0000000..7e5721c
--- /dev/null
+++ b/app/Models/TempStmtNarrParam.php
@@ -0,0 +1,23 @@
+<?php
+
+namespace Modules\Webstatement\Models;
+
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Factories\HasFactory;
+// use Modules\Webstatement\Database\Factories\TempStmtNarrParamFactory;
+
+class TempStmtNarrParam extends Model
+{
+    use HasFactory;
+    protected $table = 'temp_stmt_narr_param';
+
+    /**
+     * The attributes that are mass assignable.
+     */
+    protected $fillable = ['_id','date_time','system_id','field_name','field_operand','field_value','narr_format','record_status','curr_no','inputter','authoriser','co_code','dept_code','auditor_code','audit_date_time','nr_prm_id','k_file','file'];
+
+    // protected static function newFactory(): TempStmtNarrParamFactory
+    // {
+    //     // return TempStmtNarrParamFactory::new();
+    // }
+}
diff --git a/database/migrations/2025_01_28_051630_create_temp_stmt_narr_param_table.php b/database/migrations/2025_01_28_051630_create_temp_stmt_narr_param_table.php
new file mode 100644
index 0000000..299043e
--- /dev/null
+++ b/database/migrations/2025_01_28_051630_create_temp_stmt_narr_param_table.php
@@ -0,0 +1,34 @@
+<?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,date_time,system_id,field_name,field_operand,field_value,narr_format,record_status,curr_no,inputter,authoriser,co_code,dept_code,auditor_code,audit_date_time,nr_prm_id,k_file,file';
+        $fieldsArray = explode(',', $fields);
+
+        Schema::create('temp_stmt_narr_param', 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_param');
+    }
+};