push_mhs.php

<?php
//include "inc/config.php";
include "../../lib/nusoap/nusoap.php";

include "../../inc/config.php";

include "../../lib/prosesupdate/ProgressUpdater.php";


$config = $db->fetch_single_row('config_user','id',1);

if ($config->live=='Y') {
	$url = 'http://'.$config->url.':'.$config->port.'/ws/live.php?wsdl'; // gunakan live
} else {
	$url = 'http://'.$config->url.':'.$config->port.'/ws/sandbox.php?wsdl'; // gunakan sandbox
}
//untuk coba-coba
// $url = 'http://pddikti.uinsgd.ac.id:8082/ws/live.php?wsdl'; // gunakan live bila

$client = new nusoap_client($url, true);
$proxy = $client->getProxy();



# MENDAPATKAN TOKEN
$username = $config->username;
$password = $config->password;
$result = $proxy->GetToken($username, $password);
$token = $result;

//$token = 'acdbbc82c3b29f99e9096dab1d5eafb4';


	$id_sms = '';
	$id_mk = '';
	$id_reg_ptk = '';
	$nidn = '';
	$id_ptk = '';
	$sks_mk = '';
	$sks_tm = '';
	$sks_prak = '';
	$sks_prak_lap = '';
	$sks_sim = '';
	$temp_data = array();
	$sukses_count = 0;
	$id_pd = "";
	$sukses_msg = '';
	$error_count = 0;
	$error_msg = array();
	$temp_result = array();

	//get id npsn
	$filter_sp = "npsn='".$config->id_sp."'";
	$get_id_sp = $proxy->GetRecord($token,'satuan_pendidikan',$filter_sp);

	$id_sp = $get_id_sp['result']['id_sp'];

$table1 = 'kelas_kuliah';

	$arr_data = $db->fetch_custom("select mhs.*,mhs_pt.nipd from mhs inner join mhs_pt on mhs.id=mhs_pt.id_mhs where kode_jurusan='".$_GET['jurusan']."' and mulai_smt='".$_GET['sem']."' and status_error!=1");

$options = array(
    'filename' => $_GET['jurusan'].'_progress.json',
    'autoCalc' => true,
    'totalStages' => 1
);
$pu = new Manticorp\ProgressUpdater($options);



$stageOptions = array(
    'name' => 'This AJAX process takes a long time',
    'message' => 'But this will keep the user updated on it\'s actual progress!',
    'totalItems' => $arr_data->rowCount(),
);


$pu->nextStage($stageOptions);



$i=1;

		function myFilter($var){
			  return ($var !== NULL && $var !== FALSE && $var !== '');
			}



	foreach ($arr_data as $value) {

		$data_mhs_pt = $db->fetch_single_row('mhs_pt','id_mhs',$value->id);

		$filter_nipd = "nipd like '%".$value->nipd."%'";
        $temp_nipd = $proxy->GetRecord($token,'mahasiswa_pt',$filter_nipd);


        if ($temp_nipd['result']) {
           ++$error_count;
           $db->update('mhs_pt',array('status_error' => 2, 'keterangan'=>"Error ".$value->nipd." ".$value->nm_pd." Sudah ada"),'id',$data_mhs_pt->id);
			$error_msg[] = "<b>Error ".$value->nipd." ".$value->nm_pd." Sudah ada di Feeder";

        } else {

        	$data_mhs = $db->convert_obj_to_array($value);
        	unset($data_mhs['id']);
        	unset($data_mhs['nipd']);


			$data_mhs = array_filter($data_mhs, 'myFilter');

			$sp = array('id_sp' => $id_sp);

			$data_mhs = array_merge($data_mhs,$sp);

        	  $temp_result = $proxy->InsertRecord($token, 'mahasiswa', json_encode($data_mhs));


        	  if ($temp_result['result']) {

        	  	$kode_prodi = trim($data_mhs_pt->kode_jurusan);

        	  	$id_pd = $temp_result['result']['id_pd'];
        	  	$filter_sms = "id_sp='".$id_sp."' and kode_prodi ilike '%".$kode_prodi."%'";
				$temp_sms = $proxy->GetRecord($token,'sms',$filter_sms);
				if ($temp_sms['result']) {
					$id_sms = $temp_sms['result']['id_sms'];
				}

				$data_insert_mhs_pt = array(
				  'id_sms' => $id_sms,
                  'id_pd' => $id_pd,
                  'id_sp' => $id_sp,
                  'id_jns_daftar' => $data_mhs_pt->id_jns_daftar,
                  'nipd' => $data_mhs_pt->nipd,
                  'tgl_masuk_sp' => $data_mhs_pt->tgl_masuk_sp,
                  'a_pernah_paud' => '1',
                  'a_pernah_tk' => '1',
                  'mulai_smt' => $data_mhs_pt->mulai_smt
                );



         $insert_mhs_pt =  $proxy->InsertRecord($token, 'mahasiswa_pt', json_encode($data_insert_mhs_pt));


		if ($insert_mhs_pt['result']['error_desc']==NULL) {
									++$sukses_count;
									$db->update('mhs_pt',array('status_error'=>1,'keterangan'=>''),'id',$data_mhs_pt->id);
								} else {
									++$error_count;
									$db->update('mhs_pt',array('status_error' => 2, 'keterangan'=>"Error".$insert_mhs_pt['result']['error_desc']),'id',$data_mhs_pt->id);
									$error_msg[] = "<b>Error </b>".$insert_mhs_pt['result']['error_desc'];
								}


        	  } else {
        	  	++$error_count;
									$db->update('mhs_pt',array('status_error' => 2, 'keterangan'=>"Error".$temp_result['result']['error_desc']),'id',$data_mhs_pt->id);
									$error_msg[] = "<b>Error </b>".$temp_result['result']['error_desc'];
        	  }



        }

$i++;
 $pu->incrementStageItems(1, true);

		}



$msg = '';
	$msg =  "<div class=\"alert alert-warning\" role=\"alert\">
			<font color=\"#3c763d\">".$sukses_count." data Mahasiswa baru berhasil ditambah</font><br />
			<font color=\"#ce4844\" >".$error_count." data tidak bisa ditambahkan </font>";
			if (!$error_count==0) {
				$msg .= "<a data-toggle=\"collapse\" href=\"#collapseExample\" aria-expanded=\"false\" aria-controls=\"collapseExample\">Detail error</a>";
			}
			//echo "<br />Total: ".$i." baris data";
			$msg .= "<div class=\"collapse\" id=\"collapseExample\">";
					$i=1;
					foreach ($error_msg as $pesan) {
							$msg .= "<div class=\"bs-callout bs-callout-danger\">".$i.". ".$pesan."</div><br />";
						$i++;
						}
			$msg .= "</div>
		</div>";


//echo $msg;

$pu->totallyComplete($msg);