feat: add CSV import for ibadah and miskin (admin-only, round-trip format)

2026-06-03 21:00:28 +07:00
parent 6d157a17c9
commit 2d4533683d
3 changed files with 174 additions and 0 deletions
@@ -0,0 +1,101 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Models\ActivityLog;
+use App\Models\RumahIbadah;
+use App\Models\RumahMiskin;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\DB;
+
+class ImportController extends Controller
+{
+    public function ibadah(Request $request)
+    {
+        $request->validate(['file' => 'required|file|mimes:csv,txt|max:5120']);
+
+        $rows = $this->parseCsv($request->file('file')->getRealPath());
+        $imported = 0; $failed = 0;
+
+        DB::beginTransaction();
+        try {
+            foreach ($rows as $r) {
+                // [0]=ID(diabaikan) [1]=Nama [2]=Jenis [3]=Alamat [4]=Radius [5]=Jemaah [6]=Pengurus [7]=Telepon [8]=Lat [9]=Lon
+                if (count($r) < 10 || trim($r[1]) === '' || !is_numeric($r[8]) || !is_numeric($r[9])) { $failed++; continue; }
+                RumahIbadah::create([
+                    'user_id'       => auth()->id(),
+                    'nama'          => $r[1],
+                    'jenis'         => $r[2] ?: null,
+                    'alamat'        => $r[3] ?: null,
+                    'radius'        => is_numeric($r[4]) ? (int) $r[4] : 500,
+                    'jumlah_jemaah' => is_numeric($r[5]) ? (int) $r[5] : null,
+                    'pengurus'      => $r[6] ?: null,
+                    'telepon'       => $r[7] ?: null,
+                    'latitude'      => (float) $r[8],
+                    'longitude'     => (float) $r[9],
+                ]);
+                $imported++;
+            }
+            DB::commit();
+        } catch (\Throwable $e) {
+            DB::rollBack();
+            return response()->json(['message' => 'Import gagal: ' . $e->getMessage()], 422);
+        }
+
+        ActivityLog::record('import', "Import CSV rumah ibadah: {$imported} berhasil, {$failed} gagal", 'ibadah');
+        return response()->json(['success' => true, 'imported' => $imported, 'failed' => $failed]);
+    }
+
+    public function miskin(Request $request)
+    {
+        $request->validate(['file' => 'required|file|mimes:csv,txt|max:5120']);
+
+        $rows = $this->parseCsv($request->file('file')->getRealPath());
+        $imported = 0; $failed = 0;
+
+        DB::beginTransaction();
+        try {
+            foreach ($rows as $r) {
+                // [0]=ID Rumah [1]=Nama KK [2]=Alamat [3]=KK [4]=Jiwa [5]=Pekerjaan [6]=Pendapatan [7]=Kondisi [8]=Lat [9]=Lon
+                if (count($r) < 10 || trim($r[0]) === '' || !is_numeric($r[8]) || !is_numeric($r[9])) { $failed++; continue; }
+                RumahMiskin::updateOrCreate(
+                    ['id_rumah' => $r[0]],
+                    [
+                        'nama_kk'       => $r[1] ?: null,
+                        'alamat'        => $r[2] ?: null,
+                        'jumlah_kk'     => is_numeric($r[3]) ? (int) $r[3] : 1,
+                        'jumlah_orang'  => is_numeric($r[4]) ? (int) $r[4] : 1,
+                        'pekerjaan'     => $r[5] ?: null,
+                        'pendapatan'    => is_numeric($r[6]) ? (int) $r[6] : null,
+                        'kondisi_rumah' => $r[7] ?: null,
+                        'latitude'      => (float) $r[8],
+                        'longitude'     => (float) $r[9],
+                    ]
+                );
+                $imported++;
+            }
+            DB::commit();
+        } catch (\Throwable $e) {
+            DB::rollBack();
+            return response()->json(['message' => 'Import gagal: ' . $e->getMessage()], 422);
+        }
+
+        ActivityLog::record('import', "Import CSV keluarga miskin: {$imported} berhasil, {$failed} gagal", 'miskin');
+        return response()->json(['success' => true, 'imported' => $imported, 'failed' => $failed]);
+    }
+
+    /** Baca CSV, lewati baris header, kembalikan array baris data. */
+    private function parseCsv(string $path): array
+    {
+        $rows   = [];
+        $handle = fopen($path, 'r');
+        $first  = true;
+        while (($data = fgetcsv($handle)) !== false) {
+            if ($first) { $first = false; continue; } // skip header
+            if (count($data) === 1 && trim((string) $data[0]) === '') continue; // skip blank
+            $rows[] = $data;
+        }
+        fclose($handle);
+        return $rows;
+    }
+}