<?php

require_once(dirname(__FILE__)."/../../../../../modules3/db.mysqli.php");

$db = DB();
$tahun = 0;

function API_SalingBantu() {
    $curl_array = array(
        CURLOPT_URL => "https://salingbantu.mempawahkab.go.id/api/api_bansos?api_key=6a8f0d2e3f47b53c5e687d9b45f10a98b2e33c9a7d4e6f5a3c2d1e0b8765f4c3",
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_ENCODING => "",
        CURLOPT_MAXREDIRS => 10,
        CURLOPT_TIMEOUT => 0,
        CURLOPT_FOLLOWLOCATION => true,
        CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
        CURLOPT_HTTPHEADER => array(
            "Accept: application/json",
            "Content-Type: application/json",
        ),
        CURLOPT_SSL_VERIFYHOST => false,
        CURLOPT_SSL_VERIFYPEER => false
    );

    $curl = curl_init();
    curl_setopt_array($curl, $curl_array);
    $response = curl_exec($curl);
    $err = curl_error($curl);
    curl_close($curl);
    if ($err) {
        $aresult[] = $err;
    } else {
        $aresult = json_decode($response, true);
    }
    return $aresult;
}

$adata = API_SalingBantu();

echo count($adata)." record<br>";
$db->Query("TRUNCATE i_salingbantu");
foreach ($adata as $arec) {
    $arec['nama_pengaju'] = $db->SafeSQL($arec['nama_pengaju']);
    $arec['judul'] = $db->SafeSQL($arec['judul']);
    $arec['latar_belakang'] = $db->SafeSQL($arec['latar_belakang']);
    $arec['maksud_tujuan'] = $db->SafeSQL($arec['maksud_tujuan']);
    $arec['alamat'] = $db->SafeSQL($arec['alamat']);

    $db->Query("INSERT INTO i_salingbantu (Tahun,Kode,Organisasi,Judul,Latar,Maksud,Alamat,Rupiah,Tipe,Level_Tahap,Tahapan,N_OPD,DateStamp) VALUES ('".$arec['tahun']."','".$arec['id']."','".$arec['nama_pengaju']."','".$arec['judul']."','".$arec['latar_belakang']."','".$arec['maksud_tujuan']."','".$arec['alamat']."','".$arec['nilai']."','".$arec['type']."','".$arec['level_tahap']."','".$arec['tahapan']."','".$arec['opd']."',NOW())");
    $tahun = $arec['tahun'];
}
//$db->Query("update i_salingbantu a,para90_opd b set a.opdid=b.opdid where a.n_opd=b.n_opd");

$db->Query("INSERT INTO pok_salingbantu (Tahun,Kode,Organisasi,Judul,Latar,Maksud,Alamat,Rupiah,Tipe,Level_Tahap,Tahapan,DateStamp) SELECT Tahun,Kode,Organisasi,Judul,Latar,Maksud,Alamat,Rupiah,Tipe,Level_Tahap,Tahapan,DateStamp FROM i_salingbantu WHERE Tahun='".$tahun."' AND Kode NOT IN (SELECT Kode FROM pok_salingbantu WHERE Tahun='".$tahun."')");

echo "import done.";
?>