<?php
    $FName = "20141127001900.awsd";
    $file = fopen($FName,"r");
    $DateTime = substr($FName, 0,4)."-".substr($FName, 4,2)."-".substr($FName, 6,2)." ".substr($FName, 8,2).":".substr($FName, 10,2).":".substr($FName, 12,2);
    $row=0;
    $LastID=0;
    $values = [];
    while(!feof($file)) {
            $row++;
            $value = fgetcsv($file);
            if(count($value)==3){
                $values[dataType($value[1])] = $value[2];
                if($LastID!=$value[0]&&$row>1){
                    if($LastID!=0){
                                 $query = "INSERT INTO dpaws_13 (Station_ID,DateTime,";
                        $query = $query . join(array_keys($values),"," );
                        $query = $query . ") VALUES ('{$value[0]}','{$DateTime}','".join($values,"', '");
                        $query = $query . "')";
                        echo $query ."<br>";
                        // query($query);
                        $values= array();;
                    }
                    $LastID = $value[0];
                }
            }
    }

fclose($file);

function query($qry){
    $username = "root";
    $password = "";
    $pdo = new PDO('mysql:host=localhost;dbname=dpaws_db', $username, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    $query = $pdo->prepare($qry);
    $query->execute();
}

function dataType($id){
    switch ($id) {
        case '10':
                return "Temperature";
                break;
        case '11':
                return "TemperatureMin";
                break;
        case '12':
                return "TemperatureMax";
                break;
        case '13':
                return "DewTemperature";
                break;
        case '20':
                return "Relative_Humidity";
                break;
        case '21':
                return "RelativeHumidity_Min";
                break;
        case '22':
                return "RelativeHumidity_Max";
                break;
        case '30':
                return "Barometric_Pressure";
                break;
        case '31':
                return "BarometricPressureMin";
                break;
        case '32':
                return "BarometricPressureMax";
                break;
        case '40':
                return "Wind_Speed";
                break;
        case '41':
                return "WindSpeedMax";
                break;
        case '42':
                return "WindSpeedMaxTime";
                break;
        case '43':
                return "WindSpeedMaxDirection";
                break;
        case '44':
                return "Wind_Direction";
                break;
        case '50':
                return "Solar_Radiation";
                break;
        case '51':
                return "SolarRadMin";
                break;
        case '52':
                return "SolarRadMax";
                break;
        case '60':
                return "Hourly_Rain";
                break;
        case '61':
                return "Rain15";
                break;
        case '62':
                return "Rain30";
                break;
        case '63':
                return "Rain45";
                break;
        case '64':
                return "Rain00";
                break;
        case '70':
                return "Water_Level";
                break;
        case '80':
                return "Soil_Moisture";
                break;
        case '81':
                return "Soil_Temperature";
                break;
        case '82':
                return "Soil_Electric Conductivity";
                break;
        case '90':
                return "Battery_Voltage";
                break;
        default:
                return "Not Found";
            break;
    }

}