collect_from_api.php

<?php

include_once ('config/database.php');

/**
 *
 */
class DustData
{

  public function getCurrTime(){
    $api_url = "http://openapi.airkorea.or.kr/openapi/services/rest/ArpltnInforInqireSvc/getCtprvnMesureLIst?itemCode=PM10&dataGubun=HOUR&searchCondition=MONTH&pageNo=1&numOfRows=".$req_data."&ServiceKey=5rngHQO75rpCVULQ4UNMIXpRWSMzzTduA%2F2N47nrYL3Tc4sHHCAJ3F0k61NC05iQLdrR20%2Bur41a9nEPmpVhtQ%3D%3D";

    $xmlstring = simplexml_load_file($api_url);

    //$xml = simplexml_load_string($xmlstring);
    $json = json_encode($xmlstring);
    $array = json_decode($json,TRUE);

    //reformat the time
    $array['body']['items']['item']['0']['dataTime'] = str_replace('-', '.', $array['body']['items']['item']['0']['dataTime']);
    $array['body']['items']['item']['0']['dataTime'] = str_replace(' ', '.', $array['body']['items']['item']['0']['dataTime']);
    return($array['body']['items']['item']['0']['dataTime']);
  }

  public function NeedUpdate($first_data){

    $enc = urlencode($first_data['NAME_DUST']);
    $api_url = "http://openapi.airkorea.or.kr/openapi/services/rest/ArpltnInforInqireSvc/getCtprvnRltmMesureDnsty?sidoName=".$enc."&pageNo=1&numOfRows=200&ServiceKey=5rngHQO75rpCVULQ4UNMIXpRWSMzzTduA%2F2N47nrYL3Tc4sHHCAJ3F0k61NC05iQLdrR20%2Bur41a9nEPmpVhtQ%3D%3D&&ver=1.3";

    $xmlstring = simplexml_load_file($api_url);

    $json = json_encode($xmlstring);
    $array = json_decode($json,TRUE);

    $res['dataTime'] = $array['body']['items']['item'][0]['dataTime'];

    $db = new Database();
    $conn = $db->getConnection();

    $sql ="SELECT `IDX` FROM `tbl_dust_data` WHERE `IDX_DATETIME` = '".$res['dataTime']."'";

    $result = mysqli_query($conn, $sql);
    if (!$result) {
        printf("Error: %s\n", mysqli_error($this->conn));
        exit();
    }

    mysqli_close($conn);

    $row = $result->fetch_assoc();
    if($row > 0)
      return FALSE;
    else
      return TRUE;
  }

  public function insertDustDataNew($theData, $prov_name){
    $db = new Database();
    $conn = $db->getConnection();
    //var_dump($theData);

    for($i=0; $i<sizeof($theData)-1; $i++){
      //find the key
      $sql = "SELECT `IDX` FROM `tbl_full_location` WHERE `Phase_3` LIKE '%".$theData[$i]['city']."%'";

      $result = mysqli_query($conn, $sql);
      if (!$result) {
          printf("Error: %s\n", mysqli_error($this->conn));
          exit();
      }

      $row = $result->fetch_assoc();
      if(!$row){
        continue;
      }
      //var_dump($row);

      $sql ="INSERT INTO `tbl_dust_data`(`IDX_DATETIME`, `ITEMCODE`, `LOCATION`, `VALUE_1`)
      VALUES ('".$theData['dataTime']."','PM10','".$row['IDX']."',".$theData[$i]['val'].")";
      //var_dump($sql);

      $result = mysqli_query($conn, $sql);
      if (!$result) {
          printf("Error: %s\n", mysqli_error($this->conn));
          exit();
      }
      //var_dump($sql);
    }

    mysqli_close($conn);
  }

  public function getDustName(){
    //fetch the table names
    $db = new Database();
    $conn = $db->getConnection();

    //$sql = "SELECT * FROM tbl_dust_data;";
    //more readable
    $sql ="SELECT `NAME_HGL`, `NAME_DUST` FROM `province`";

    $result = mysqli_query($conn, $sql);
    if (!$result) {
        printf("Error: %s\n", mysqli_error($this->conn));
        exit();
    }

    $row = $result->fetch_assoc();
    if($row > 0){
      while($row = $result->fetch_assoc())
       {
           $data[] = $row;
       }
    }
    //$row = array_pop($row[]);
    //print_r($row);
    mysqli_close($conn);

    return($data);
  }

  public function getSingleProvince($single_province_name){
    //print_r($single_province_name['NAME_DUST']);
    $enc = urlencode($single_province_name['NAME_DUST']);
    //$api_url = "http://openapi.airkorea.or.kr/openapi/services/rest/ArpltnInforInqireSvc/getCtprvnRltmMesureDnsty?sidoName=%EB%B6%80%EC%82%B0&pageNo=1&numOfRows=10&ServiceKey=5rngHQO75rpCVULQ4UNMIXpRWSMzzTduA%2F2N47nrYL3Tc4sHHCAJ3F0k61NC05iQLdrR20%2Bur41a9nEPmpVhtQ%3D%3D&&ver=1.3";
    //$api_url = "http://openapi.airkorea.or.kr/openapi/services/rest/ArpltnInforInqireSvc/getCtprvnRltmMesureDnsty?sidoName=서울&pageNo=1&numOfRows=10&ServiceKey=5rngHQO75rpCVULQ4UNMIXpRWSMzzTduA%2F2N47nrYL3Tc4sHHCAJ3F0k61NC05iQLdrR20%2Bur41a9nEPmpVhtQ%3D%3D&&ver=1.3";
    $api_url = "http://openapi.airkorea.or.kr/openapi/services/rest/ArpltnInforInqireSvc/getCtprvnRltmMesureDnsty?sidoName=".$enc."&pageNo=1&numOfRows=200&ServiceKey=5rngHQO75rpCVULQ4UNMIXpRWSMzzTduA%2F2N47nrYL3Tc4sHHCAJ3F0k61NC05iQLdrR20%2Bur41a9nEPmpVhtQ%3D%3D&&ver=1.3";

    $xmlstring = simplexml_load_file($api_url);

    $json = json_encode($xmlstring);
    $array = json_decode($json,TRUE);

    //print_r($enc);
    //print_r($api_url);
    //print_r(sizeof($array['body']['items']['item']));

    //single time
    //if($first == TRUE){
    $res['dataTime'] = $array['body']['items']['item'][0]['dataTime'];
    //}
    for($i=0 ; $i < sizeof($array['body']['items']['item']); $i++){
      $res[$i]['city'] = $array['body']['items']['item'][$i]['stationName'];
      $res[$i]['val'] = $array['body']['items']['item'][$i]['pm10Value'];
    }

    return ($res);
  }

  public function getResult($req_data)
  {
    //print_r($req_data);
    $api_url = "http://openapi.airkorea.or.kr/openapi/services/rest/ArpltnInforInqireSvc/getCtprvnMesureLIst?itemCode=PM10&dataGubun=HOUR&searchCondition=MONTH&pageNo=1&numOfRows=".$req_data."&ServiceKey=5rngHQO75rpCVULQ4UNMIXpRWSMzzTduA%2F2N47nrYL3Tc4sHHCAJ3F0k61NC05iQLdrR20%2Bur41a9nEPmpVhtQ%3D%3D&ver=1.3";

    $xmlstring = simplexml_load_file($api_url);

    //$xml = simplexml_load_string($xmlstring);
    $json = json_encode($xmlstring);
    $array = json_decode($json,TRUE);

    //single time
    $res = $array['body']['items']['item']['0'];

    return ($res);
  }
}

 ?>