add files and folders

2026-06-10 17:28:32 +07:00
parent 52f4cf86ab
commit 61f4fb2e71
80 changed files with 17551 additions and 0 deletions
@@ -0,0 +1,127 @@
+<?php
+header('Content-Type: application/json; charset=utf-8');
+require_once 'koneksi.php';
+
+function haversine_m($lat1, $lon1, $lat2, $lon2) {
+  $R = 6371000.0;
+  $phi1 = deg2rad((float)$lat1);
+  $phi2 = deg2rad((float)$lat2);
+  $dphi = deg2rad((float)$lat2 - (float)$lat1);
+  $dlambda = deg2rad((float)$lon2 - (float)$lon1);
+  $a = sin($dphi/2) * sin($dphi/2) + cos($phi1) * cos($phi2) * sin($dlambda/2) * sin($dlambda/2);
+  $c = 2 * atan2(sqrt($a), sqrt(1-$a));
+  return $R * $c;
+}
+
+function compute_nearest_ibadah(array $ibadahRows, $lat, $lng) {
+  $best = null;
+  foreach ($ibadahRows as $r) {
+    $rLat = (float)($r['latitude'] ?? 0);
+    $rLng = (float)($r['longitude'] ?? 0);
+    $radius = (float)($r['radius_meter'] ?? 0);
+    if ($radius <= 0) continue;
+    $d = haversine_m($lat, $lng, $rLat, $rLng);
+    if ($d <= $radius) {
+      if ($best === null || $d < $best['jarak_meter']) {
+        $best = [
+          'rumah_ibadah_id' => (int)($r['id'] ?? 0),
+          'jarak_meter' => $d,
+          'row' => $r
+        ];
+      }
+    }
+  }
+  return $best;
+}
+
+// Prefer new schema; fall back to old schema if needed.
+$cols = $pdo->query("SHOW COLUMNS FROM pemukiman_miskin_points")->fetchAll(PDO::FETCH_COLUMN, 0);
+$hasNew = in_array('kk_nama', $cols, true);
+
+$hasJarak = in_array('jarak_meter', $cols, true);
+$hasRumahIbadahId = in_array('rumah_ibadah_id', $cols, true);
+
+// Fetch rumah ibadah once; used for real-time coverage computation server-side.
+$ibadah = [];
+try {
+  $stmtI = $pdo->query("SELECT id, nama, jenis, kontak, radius_meter, latitude, longitude FROM rumah_ibadah_points");
+  $ibadah = $stmtI->fetchAll();
+} catch (Exception $e) {
+  $ibadah = [];
+}
+
+// Load pemukiman rows
+$rows = [];
+try {
+  if ($hasNew) {
+    $stmt = $pdo->query("
+      SELECT p.*,
+             (
+               SELECT COUNT(*) FROM anggota_keluarga a WHERE a.penduduk_id = p.id
+             ) AS anggota_count
+      FROM pemukiman_miskin_points p
+      ORDER BY p.id ASC
+    ");
+    $rows = $stmt->fetchAll();
+  } else {
+    $stmt = $pdo->query("SELECT p.* FROM pemukiman_miskin_points p ORDER BY p.id ASC");
+    $rows = $stmt->fetchAll();
+  }
+} catch (Exception $e) {
+  $rows = [];
+}
+
+// Best-effort: keep stored rumah_ibadah_id/jarak_meter in sync with latest radius rules.
+$upd = null;
+try {
+  if ($hasRumahIbadahId && $hasJarak) {
+    $upd = $pdo->prepare("UPDATE pemukiman_miskin_points SET rumah_ibadah_id = :rid, jarak_meter = :jarak WHERE id = :id");
+  } elseif ($hasRumahIbadahId) {
+    $upd = $pdo->prepare("UPDATE pemukiman_miskin_points SET rumah_ibadah_id = :rid WHERE id = :id");
+  }
+} catch (Exception $e) {
+  $upd = null;
+}
+
+foreach ($rows as &$p) {
+  $lat = isset($p['latitude']) ? (float)$p['latitude'] : null;
+  $lng = isset($p['longitude']) ? (float)$p['longitude'] : null;
+  if ($lat === null || $lng === null) continue;
+
+  $best = compute_nearest_ibadah($ibadah, $lat, $lng);
+  $rid = $best ? (int)$best['rumah_ibadah_id'] : null;
+  $jarak = $best ? (float)$best['jarak_meter'] : null;
+  $storedRid = isset($p['rumah_ibadah_id']) ? (int)$p['rumah_ibadah_id'] : null;
+
+  // overwrite output with authoritative computed coverage
+  $p['rumah_ibadah_id'] = $rid;
+  if ($hasJarak) $p['jarak_meter'] = $jarak;
+
+  if ($best && isset($best['row']) && is_array($best['row'])) {
+    $p['rumah_ibadah_nama'] = $best['row']['nama'] ?? null;
+    $p['rumah_ibadah_jenis'] = $best['row']['jenis'] ?? null;
+    $p['rumah_ibadah_kontak'] = $best['row']['kontak'] ?? null;
+    $p['rumah_ibadah_radius'] = $best['row']['radius_meter'] ?? null;
+  } else {
+    $p['rumah_ibadah_nama'] = null;
+    $p['rumah_ibadah_jenis'] = null;
+    $p['rumah_ibadah_kontak'] = null;
+    $p['rumah_ibadah_radius'] = null;
+  }
+
+  // best-effort DB sync
+  try {
+    if ($upd && ((string)$storedRid !== (string)$rid)) {
+      if ($hasRumahIbadahId && $hasJarak) {
+        $upd->execute([':rid' => $rid, ':jarak' => $jarak, ':id' => (int)$p['id']]);
+      } elseif ($hasRumahIbadahId) {
+        $upd->execute([':rid' => $rid, ':id' => (int)$p['id']]);
+      }
+    }
+  } catch (Exception $e) {
+    // ignore
+  }
+}
+unset($p);
+
+echo json_encode($rows, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);