index.php

Go to the documentation of this file.

<?php
        
   ###########################################################################################
    # Set the username and password to use. The read_user should only be allowed to read data #
    # from the database, while the write_user will probably need to read and write.           #  
    ###########################################################################################
        include '/usr/local/share/brigadoon/apache/db_passwords.php';    
 
 
    function DbConnect( $DbFunction, $ConnectionType = 'mysqli' )
    {
        global $db_password; global $db_username; global $log_file;
        
    /* Set the host as the localhost. The username and password for the database should be set only for localhost in the database
           to lessen the chance of someone outside this system attempting to use them to access the database.
    */
        $host = 'localhost';
 
    /* Set the name of the local database to connect to. */
        $db   = 'WeatherStation';
 
    /* Attempt to open the connection based on the selected library.
    */    
        if ( $ConnectionType == 'mysqli' )
        {
               // file_put_contents( $log_file, "mysqli Connection Attempt\n",  FILE_APPEND );
            return new mysqli( $host, $db_username, $db_password, $db ) or die ( 'Cannot Open Database' );
        }
        elseif ( $ConnectionType == 'pdo' )
        {
                // file_put_contents( $log_file, "pdo Connection Attempt\n",  FILE_APPEND );
            try
            {
                return new PDO( "mysql::host=$host;dbname=$db;", $db_username, $db_password );   
            }
            catch (Exception $e)
            {
                header("HTTP/1.0 400 Unable to Open Database");
                exit;
            }
        }   
        else
        {
             // file_put_contents( $log_file, "Unrecognised Driver",  FILE_APPEND );
           header("HTTP/1.0 400 Unrecognised Driver Type");                     
           exit;
        } 
    }    
 
   function SaveObservation()
    {
        global $db_password; global $db_username; global $log_file; 
    ##################################################################################################################
    # Used to Determine the Parameters being Passed to This Program                      #
    ##################################################################################################################
    $parameters = json_encode($_POST);
    
    ###############################
    # Used for Debugging Purposes   #
    ############################### 
    // file_put_contents( $log_file, $parameters );
 
    ##################################################################################################################
    # Read the Weather Station's Username and Password, the action to be carried out and the Date of the Observation #
    # as these are mandatory parameters required to save the readings. This not determine if this is a valid message #
    # but it does determine if it at least has the minimum parameters required.                  #
    ##################################################################################################################  
    $readings = json_decode( $parameters, true );
 
    if ( $readings['PASSKEY'] )
    {   
      $passkey  = $readings['PASSKEY'];
    }
 
    if ( $readings['dateutc'] )
    {
      $date_utc = $readings['dateutc'];
    }
 
    ###################################################################
    # If the Two (2) Mandatory Fields Are There, Process the Reading  #
    ###################################################################
    if ( $passkey && $date_utc )
    {
 
        ##########################################################
        # Create a Database Connection                           #
        ##########################################################
       // file_put_contents( $log_file, "Attempt Open",  FILE_APPEND );
            
        $connection = DbConnect( 'WRITE', 'pdo' );
        
        // file_put_contents( $log_file, "Opened",  FILE_APPEND );
        ##########################################################
        # Extract Readings from the Parameters passed in POST    #
        ##########################################################
        if ( $readings['stationtype'] != '' )
        {       
          $software_type = $readings['stationtype'];  
        }
 
        if ( $readings['model'] != '' )
        {       
          $model = $readings['model'];  
        }
 
        if ( $readings['freq'] != '' )
        {       
          $freq = $readings['freq'];  
        }
 
        ##########################################################
        # Extract the Indoor Temperature                         #
        ##########################################################
        if ( $readings['tempinf'] )
        {
          $indoor_temp = ($readings['tempinf'] - 32.0) * 0.555555556;
        }
 
        ##########################################################
        # Extract the Outdoor Temperature                        #
        ##########################################################
        if ($readings['tempf'] )
        {
          $outdoor_temp = ($readings['tempf'] - 32.0) * 0.555555556;
        }
 
        ##########################################################
        # Extract the Dew Point Temperature                      #
        ##########################################################
        if ($readings['dewptf'] )
        {
          $dew_point = ($readings['dewptf'] - 32.0) * 0.555555556;
        }
 
        ##########################################################
        # Extract the Wind Chill Temperature                      #
        ##########################################################
        if ( $readings['windchillf'] )
        {
          $windchill = ($readings['windchillf'] - 32.0) * 0.555555556;
        }
 
        ##########################################################
        # Extract the Indoor Relative Humidity                   #
        ##########################################################
        if ( $readings['humidityin'] )
        {
          $indoor_humidity = $readings['humidityin'];
        }
 
        ##########################################################
        # Extract the Outdoor Relative Humidity                  #
        ##########################################################
        if ( $readings['humidity'] )
        {
          $outdoor_humidity = $readings['humidity'];
        }
 
        ##########################################################
        # Extract the Wind Speed                         #
        ##########################################################
        if ( $readings['windspeedmph'] )
        {
          $wind_speed = $readings['windspeedmph'] * 1.609344;
        }
 
        ##########################################################
        # Extract the Wind Speed                         #
        ##########################################################
        if ( $readings['windspdmph_avg10m'] )
        {
          $wind_speed_avg10m = $readings['windspdmph_avg10m'] * 1.609344;
        }
 
        ##########################################################
        # Extract the Wind Gust Speed                        #
        ##########################################################
        if ( $readings['windgustmph'] )
        {
          $wind_gust = $readings['windgustmph'] * 1.609344;
        }
 
        ##########################################################
        # Extract the Max Daily Wind Gust Speed                      #
        ##########################################################
        if ( $readings['maxdailygust'] )
        {
          $wind_gust_max_daily = $readings['maxdailygust'] * 1.609344;
        }
 
        ##########################################################
        # Extract the Wind Direction                         #
        ##########################################################
        if ( $readings['winddir'] )
        {
          $wind_direction = $readings['winddir'];
        }
 
        ##########################################################
        # Extract the Wind Direction                         #
        ##########################################################
        if ( $readings['windspdmph_avg10m'] )
        {
          $wind_direction_avg10m = $readings['windspdmph_avg10m'];
        }
 
        ##########################################################
        # Extract the Local Barometric Pressure              #
        ##########################################################
        if ( $readings['baromabsin'] )
        {
          $absolute_barometer = $readings['baromabsin'] * 33.8639;
        }
 
        ##########################################################
        # Extract the MSL Barometric Pressure                #
        ##########################################################
        if ( $readings['baromrelin'] )
        {
          $relative_barometer = $readings['baromrelin'] * 33.8639;
        }
 
        ##########################################################
        # Extract the Rainfall Rate                  #
        ##########################################################
 
        if ( $readings['rainratein'] )
        {
          $rain_rate = $readings['rainratein'] * 25.4;
        }
 
        ##########################################################
        # Extract the Rainfall Event                     #
        ##########################################################
        if( $readings['eventrainin'] )
        {
          $rain_event = $readings['eventrainin'] * 25.4;
        }
 
        ##########################################################
        # Extract the Hourly Rainfall                    #
        ##########################################################
        if ( $readings['hourlyrainin'] )
        {
          $rain_hourly = $readings['hourlyrainin'] * 25.4;
        }
 
        ##########################################################
        # Extract the Daily Rainfall                     #
        ##########################################################
        if ( $readings['dailyrainin'] )
        {
          $rain_daily = $readings['dailyrainin'] * 25.4;
        }
 
        ##########################################################
        # Extract the Weekly Rainfall                    #
        ##########################################################
        if ( $readings['weeklyrainin'] )
        {
          $rain_weekly = $readings['weeklyrainin'] * 25.4;
        }
 
        ##########################################################
        # Extract the Monthly Rainfall                   #
        ##########################################################
        if ( $readings['monthlyrainin'] )
        {
          $rain_monthly = $readings['monthlyrainin'] * 25.4;
        }
 
        ##########################################################
        # Extract the Yearly Rainfall                    #
        ##########################################################
        if ( $readings['yearlyrainin'] )
        {
          $rain_yearly = $readings['yearlyrainin'] * 25.4;
        }
 
        ##########################################################
        # Extract the Solar Radiation                    #
        ##########################################################
        if ( $readings['solarradiation'] )
        {
          $power = $readings['solarradiation'];
        }
 
        ##########################################################
        # Extract the UV Index                       #
        ##########################################################
        if ( $readings['uv'] != '' )
        {       
          $uv_index = $readings['uv'];
        }
 
        ##########################################################
        # Extract the Extra Temp/Humidity Sensors        #
        ##########################################################
        
        if ( $readings['temp1f'] )
        {
          $temperature1 = ($readings['temp1f'] - 32.0) * 0.555555556;
        }          
 
        if ( $readings['temp2f'] )
        {
          $temperature2 = ($readings['temp2f'] - 32.0) * 0.555555556;
        }          
 
        if ( $readings['temp3f'] )
        {
          $temperature3 = ($readings['temp3f'] - 32.0) * 0.555555556;
        }          
 
        if ( $readings['temp4f'] )
        {
          $temperature4 = ($readings['temp4f'] - 32.0) * 0.555555556;
        }          
 
        if ( $readings['temp5f'] )
        {
          $temperature5 = ($readings['temp5f'] - 32.0) * 0.555555556;
        }          
 
        if ( $readings['temp6f'] )
        {
          $temperature6 = ($readings['temp6f'] - 32.0) * 0.555555556;
        }          
 
        if ( $readings['temp7f'] )
        {
          $temperature7 = ($readings['temp7f'] - 32.0) * 0.555555556;
        }          
 
        if ( $readings['temp8f'] )
        {
          $temperature8 = ($readings['temp8f'] - 32.0) * 0.555555556;
        }
 
        if ( $readings['humidity1'] )
        {
          $humidity1 = $readings['humidity1'];
        }
        
        if ( $readings['humidity2'] )
        {
          $humidity2 = $readings['humidity2'];
        }
        
        if ( $readings['humidity3'] )
        {
          $humidity3 = $readings['humidity3'];
        }
        
        if ( $readings['humidity4'] )
        {
          $humidity4 = $readings['humidity4'];
        }
        
        if ( $readings['humidity5'] )
        {
          $humidity5 = $readings['humidity5'];
        }
        
        if ( $readings['humidity6'] )
        {
          $humidity6 = $readings['humidity6'];
        }
        
        if ( $readings['humidity7'] )
        {
          $humidity7 = $readings['humidity7'];
        }
        
        if ( $readings['humidity8'] )
        {
          $humidity1 = $readings['humidity8'];
        }
 
        ##########################################################
        # Extract the Soil Moisture Readings                          #
        ##########################################################
 
        if ( $readings['soilmoisture1']  )
        {
          $moisture_soil_1 = $readings['soilmoisture1'];
        }
 
        if ( $readings['soilmoisture2'] )
        {
          $moisture_soil_2 = $readings['soilmoisture2'];
        }
 
        if ( $readings['soilmoisture3'] )
        {
          $moisture_soil_3 = $readings['soilmoisture3'];
        }
 
        if ( $readings['soilmoisture4'] )
        {
          $moisture_soil_4 = $readings['soilmoisture4'];
        }
 
        if ( $readings['soilmoisture5'] )
        {
          $moisture_soil_5 = $readings['soilmoisture5'];
        }
 
        if ( $readings['soilmoisture6'] )
        {
          $moisture_soil_6 = $readings['soilmoisture6'];
        }
 
        if ( $readings['soilmoisture7'] )
        {
          $moisture_soil_7 = $readings['soilmoisture7'];
        }
 
        if ( $readings['soilmoisture8'] )
        {
          $moisture_soil_8 = $readings['soilmoisture8'];
        }
 
        ##########################################################
        # Extract the Battery States                             #
        ##########################################################
        
        if ( $readings['wh65batt'] )
        {
          $battery_wh65 = $readings['wh65batt'];
        }
 
        if ( $readings['wh25batt'] )
        {
          $battery_wh25 = $readings['wh25batt'];
        }
 
        if ( $readings['batt1'] )
        {
          $battery_1 = $readings['batt1'];
        }
 
        if ( $readings['batt2']  )
        {
          $battery_2 = $readings['batt2'];
        }
 
        if ( $readings['batt3'] )
        {
          $battery_3 = $readings['batt3'];
        }
 
        if ( $readings['batt4'] )
        {
          $battery_4 = $readings['batt4'];
        }
 
        if ( $readings['batt5'] )
        {
          $battery_5 = $readings['batt5'];
        }
 
        if ( $readings['batt6'] )
        {
          $battery_6 = $readings['batt6'];
        }
 
        if ( $readings['batt7'] )
        {
          $battery_7 = $readings['batt7'];
        }
 
        if ( $readings['batt8'] )
        {
          $battery_8 = $readings['batt8'];
        }
        
        ############################################################
        # Old versions of the firmware may use "Siolbatt", while   #
        # later versions will use "soilbatt", so include both         #
        # just in case. There are so many models and versions that #
        # it is simpler to try anything based on model numbers.   #
        ############################################################
        
        if ( $readings['Siolbatt1'] != '' )
        {
          $battery_moisture_soil_1 = $readings['Siolbatt1'];
        }
 
        if ( $readings['Siolbatt2'] != '' )
        {
          $battery_moisture_soil_2 = $readings['Siolbatt2'];
        }
 
        if ( $readings['Siolbatt3'] != '' )
        {
          $battery_moisture_soil_3 = $readings['Siolbatt3'];
        }
 
        if ( $readings['Siolbatt4'] != '' )
        {
          $battery_moisture_soil_4 = $readings['Siolbatt4'];
        }
 
        if ( $readings['Siolbatt5'] != '' )
        {
          $battery_moisture_soil_5 = $readings['Siolbatt5'];
        }
 
        if ( $readings['Siolbatt6'] != '' )
        {
          $battery_moisture_soil_6 = $readings['Siolbatt6'];
        }
 
        if ( $readings['Siolbatt7'] != '' )
        {
          $battery_moisture_soil_7 = $readings['Siolbatt7'];
        }
 
        if ( $readings['Siolbatt8'] != '' )
        {
          $battery_moisture_soil_8 = $readings['Siolbatt8'];
        }
        
        if ( $readings['soilbatt1'] != '' )
        {
          $battery_moisture_soil_1 = $readings['soilbatt1'];
        }
 
        if ( $readings['soilbatt2'] != '' )
        {
          $battery_moisture_soil_2 = $readings['soilbatt2'];
        }
 
        if ( $readings['soilbatt3'] != '' )
        {
          $battery_moisture_soil_3 = $readings['soilbatt3'];
        }
 
        if ( $readings['soilbatt4'] != '' )
        {
          $battery_moisture_soil_4 = $readings['soilbatt4'];
        }
 
        if ( $readings['soilbatt5'] != '' )
        {
          $battery_moisture_soil_5 = $readings['soilbatt5'];
        }
 
        if ( $readings['soilbatt6'] != '' )
        {
          $battery_moisture_soil_6 = $readings['soilbatt6'];
        }
 
        if ( $readings['soilbatt7'] != '' )
        {
          $battery_moisture_soil_7 = $readings['soilbatt7'];
        }
 
        if ( $readings['soilbatt8'] != '' )
        {
          $battery_moisture_soil_8 = $readings['soilbatt8'];
        }
 
        if ( $readings['pm25batt1'] != '' )
        {
          $option_pm25_battery_1 = $readings['pm25batt1'];
        }
 
        if ( $readings['pm25batt2'] != '' )
        {
          $option_pm25_battery_2 = $readings['pm25batt2'];
        }
 
        if ( $readings['pm25batt3'] != '' )
        {
          $option_pm25_battery_3 = $readings['pm25batt3'];
        }
 
        if ( $readings['pm25batt4'] != '' )
        {
          $option_pm25_battery_4 = $readings['pm25batt4'];
        }
 
        #########################################################################
        # Process any PM2.5 Sensors that are connected to the weather station   #
        # (by radio).                                                           #
        #########################################################################
 
        if ( $readings['pm25_ch1'] != '' )
        {
          $option_pm25_ch1 = $readings['pm25_ch1'];
        }
 
        if ( $readings['pm25_avg_24h_ch1'] != '' )
        {
          $option_pm25_avg_24h_ch1 = $readings['pm25_avg_24h_ch1'];
        }
 
        if ( $readings['pm25_ch2'] != '' )
        {
          $option_pm25_ch2 = $readings['pm25_ch2'];
        }
 
        if ( $readings['pm25_avg_24h_ch2'] != '' )
        {
          $option_pm25_avg_24h_ch2 = $readings['pm25_avg_24h_ch2'];
        }
 
        if ( $readings['pm25_ch3'] != '' )
        {
          $option_pm25_ch3 = $readings['pm25_ch3'];
        }
 
        if ( $readings['pm25_avg_24h_ch3'] != '' )
        {
          $option_pm25_avg_24h_ch3 = $readings['pm25_avg_24h_ch3'];
        }
 
        if ( $readings['pm25_ch4'] != '' )
        {
          $option_pm25_ch4 = $readings['pm25_ch4'];
        }
 
        if ( $readings['pm25_avg_24h_ch4'] != '' )
        {
          $option_pm25_avg_24h_ch4 = $readings['pm25_avg_24h_ch4'];
        }
 
        #########################################################################
        # If Dew Point is not provided, estimate the Dew Point using the method #
        # by Arden Buck in Journal of Applied Meteorology and Climatology. This #
        # method is accurate for the temperature range -40C to +50C.            #
        #########################################################################
        if ( !isset( $dewpoint ) )
        {
          if ( $outdoor_temp >= 0.0 )
          {
            $a = 6.1121; $b = 17.368; $c = 238.88; $d = 234.5;
          }
          else
          {
            $a = 6.1121; $b = 17.966; $c = 247.15; $d = 234.5;
          }
          $ym = log( ($outdoor_humidity/100.0) * exp( ($b-$outdoor_temp/$d)*($outdoor_temp/($c+$outdoor_temp) ) ) );
          $dew_point = $c*$ym/($b-$ym);
        }
 
        #########################################################################
        # If Windchill Temperature is not provided, estimate the Windchill Temp #
        # using the Australian Bureau Of Meteorology Apparent Temperature (AT)  #
        # method calculated for an adult walking outdoors in the shade. #
        #########################################################################
        if ( !isset( $windchill ) )
        {
          $v = $wind_speed * 0.2777778; $e = ($outdoor_humidity/100.0)*6.105*exp( (17.27*$outdoor_temp)/(237.7+$outdoor_temp) );
          $windchill = $outdoor_temp + 0.33*$e - 0.7*$v - 4.0; 
        }
 
        ########################################################################
        # Find the Station Index From the Ecowitt Passkey                       #
        # The station index is the key identifying the station in all records. #
        # Also determine if non-essential fields like the battery states and      #
        # the identification strings are required. If they are not required,   #
        # those fields are not sent, reducing the database storage required.   #
        # If the fields are not defined in the database are sent, it will         #
        # result in the entire observation being discarded. If the fields      #
        # exist in the database, but are not sent, they will be recorded as a  #
        # NULL in the database, but the other readings will be recorded as     #
        # normal.                                                              #
        ########################################################################
        // file_put_contents( $log_file, "Start Query",  FILE_APPEND );
        
        $station_query = "select station_index, trim_readings from station where ecowitt_passkey= '$passkey';";
        $result        = $connection->query($station_query);
        $row_count     = $result->rowCount();
        if ( $row_count != 1)
        {
        // file_put_contents( $log_file, "No matching passkey",  FILE_APPEND ); 
          exit;
        }
        foreach ($connection->query($station_query) as $row )
        {
            $station_index = $row['station_index'];
            $trim_readings = $row['trim_readings'];
        }
 
        ###############################################################
        # Create the SQL INSERT Statement based on readings provided. #
        ###############################################################
        
        $field_string = "station_index, date_utc";
        $value_string = $station_index . ',\'' . $date_utc . '\'';
 
        $field_string_battery = "station_index, date_utc";
        $value_string_battery = $station_index . ',\'' . $date_utc . '\'';
 
        $field_string_version = "station_index, date_utc";
        $value_string_version = $station_index . ',\'' . $date_utc . '\'';
 
            
        if ( isset($indoor_temp) )
        {
            $field_string .= ", temperature_internal";
            $value_string .= ", " . $indoor_temp;
        }
         
        if ( isset($outdoor_temp) )
        {
            $field_string .= ", temperature_external";
            $value_string .= ", " . $outdoor_temp;
        }
         
        if ( isset($dew_point) )
        {
            $field_string .= ", dew_point";
            $value_string .= ", " . $dew_point;
        }
          
        if ( isset($windchill) )
        {
            $field_string .= ", wind_chill_temp";
            $value_string .= ", " . $windchill;
        }
         
         if ( isset($outdoor_humidity) )
        {
            $field_string .= ", humidity_external";
            $value_string .= ", " . $outdoor_humidity;
        }
            
        if ( isset($indoor_humidity) )
        {
            $field_string .= ", humidity_internal";
            $value_string .= ", " . $indoor_humidity;
        }
           
        if ( isset($wind_speed) )
        {
            $field_string .= ", wind_speed";
            $value_string .= ", " . $wind_speed;
        }
            
        if ( isset($wind_speed_avg10m) )
        {
            $field_string .= ", wind_speed_avg10m";
            $value_string .= ", " . $wind_speed_avg10m;
        }
            
        if ( isset($wind_gust) )
        {
            $field_string .= ", wind_gust";
            $value_string .= ", " . $wind_gust;
        }
           
        if ( isset($wind_gust_max_daily) )
        {
            $field_string .= ", wind_gust_max_daily";
            $value_string .= ", " . $wind_gust_max_daily;
        }
           
        if ( isset($wind_direction) )
        {
            $field_string .= ", wind_direction";
            $value_string .= ", " . $wind_direction;
        }
            
        if ( isset($wind_direction_avg10m) )
        {
            $field_string .= ", wind_direction_avg10m";
            $value_string .= ", " . $wind_direction_avg10m;
        }
            
        if ( isset($absolute_barometer) )
        {
            $field_string .= ", barometer_absolute";
            $value_string .= ", " . $absolute_barometer;
        }
 
        if ( isset($relative_barometer) )
        {
            $field_string .= ", barometer_relative";
            $value_string .= ", " . $relative_barometer;
        }
 
        if ( isset($rain_rate) )
        {
            $field_string .= ", rainfall_rate";
            $value_string .= ", " . $rain_rate;
        }
 
        if ( isset($rain_event) )
        {
            $field_string .= ", rainfall_event";
            $value_string .= ", " . $rain_event;
        }
 
        if ( isset($rain_hourly) )
        {
            $field_string .= ", rainfall_hour";
            $value_string .= ", " . $rain_hourly;
        }
 
        if ( isset($rain_daily) )
        {
            $field_string .= ", rainfall_day";
            $value_string .= ", " . $rain_daily;
        }
 
        if ( isset($rain_weekly) )
        {
            $field_string .= ", rainfall_week";
            $value_string .= ", " . $rain_weekly;
        }
 
        if ( isset($rain_monthly) )
        {
            $field_string .= ", rainfall_month";
            $value_string .= ", " . $rain_monthly;
        }
 
        if ( isset($rain_yearly) )
        {
            $field_string .= ", rainfall_year";
            $value_string .= ", " . $rain_yearly;
        }
 
        if ( isset($power) )
        {
            $field_string .= ", power";
            $value_string .= ", " . $power;
        }
 
        if ( isset($uv_index) )
        {
            $field_string .= ", uv_index";
            $value_string .= ", " . $uv_index;
        }
 
        if ( isset($temperature1) )
        {
            $field_string .= ", temperature_1";
            $value_string .= ", " . $temperature1;
        }
 
        if ( isset($temperature2) )
        {
            $field_string .= ", temperature_2";
            $value_string .= ", " . $temperature2;
        }
 
        if ( isset($temperature3) )
        {
            $field_string .= ", temperature_3";
            $value_string .= ", " . $temperature3;
        }
 
        if ( isset($temperature4) )
        {
            $field_string .= ", temperature_4";
            $value_string .= ", " . $temperature4;
        }
 
        if ( isset($temperature5) )
        {
            $field_string .= ", temperature_5";
            $value_string .= ", " . $temperature5;
        }
 
        if ( isset($temperature6) )
        {
            $field_string .= ", temperature_6";
            $value_string .= ", " . $temperature6;
        }
 
        if ( isset($temperature7) )
        {
            $field_string .= ", temperature_7";
            $value_string .= ", " . $temperature7;
        }
 
        if ( isset($temperature8) )
        {
            $field_string .= ", temperature_8";
            $value_string .= ", " . $temperature8;
        }
 
        if ( isset($humidity1) )
        {
            $field_string .= ", humidity_1";
            $value_string .= ", " . $humidity1;
        }
 
        if ( isset($humidity2) )
        {
            $field_string .= ", humidity_2";
            $value_string .= ", " . $humidity2;
        }
 
        if ( isset($humidity3) )
        {
            $field_string .= ", humidity_3";
            $value_string .= ", " . $humidity3;
        }
 
        if ( isset($humidity4) )
        {
            $field_string .= ", humidity_4";
            $value_string .= ", " . $humidity4;
        }
 
        if ( isset($humidity5) )
        {
            $field_string .= ", humidity_5";
            $value_string .= ", " . $humidity5;
        }
 
        if ( isset($humidity6) )
        {
            $field_string .= ", humidity_6";
            $value_string .= ", " . $humidity6;
        }
 
        if ( isset($humidity7) )
        {
            $field_string .= ", humidity_7";
            $value_string .= ", " . $humidity7;
        }
 
        if ( isset($humidity8) )
        {
            $field_string .= ", humidity_8";
            $value_string .= ", " . $humidity8;
        }
 
        if ( isset( $moisture_soil_1 ) )
        {
            $field_string .= ", moisture_soil_1";
            $value_string .= ", " . $moisture_soil_1;
        }
 
        if ( isset( $moisture_soil_2 ) )
        {
            $field_string .= ", moisture_soil_2";
            $value_string .= ", " . $moisture_soil_2;
        }
 
        if ( isset( $moisture_soil_3 ) )
        {
            $field_string .= ", moisture_soil_3";
            $value_string .= ", " . $soil_moisture3;
        }
 
        if ( isset( $moisture_soil_4 ) )
        {
            $field_string .= ", moisture_soil_4";
            $value_string .= ", " . $soil_moisture4;
        }
 
        if ( isset( $moisture_soil_5 ) )
        {
            $field_string .= ", moisture_soil_5";
            $value_string .= ", " . $soil_moisture5;
        }
 
        if ( isset( $moisture_soil_6 ) )
        {
            $field_string .= ", moisture_soil_6";
            $value_string .= ", " . $soil_moisture6;
        }
 
        if ( isset( $moisture_soil_7 ) )
        {
            $field_string .= ", moisture_soil_7";
            $value_string .= ", " . $soil_moisture7;
        }
 
        if ( isset( $moisture_soil_8 ) )
        {
            $field_string .= ", moisture_soil_8";
            $value_string .= ", " . $soil_moisture8;
        }
 
        if ( $option_pm25_ch1 != '' )   
        {
            $field_string .= ", air_quality_P25_1";
            $value_string .= ", " . $option_pm25_ch1;
        }
 
        if ( $option_pm25_avg_24h_ch1 != '' )   
        {
            $field_string .= ", air_quality_AQI_1";
            $value_string .= ", " . $option_pm25_avg_24h_ch1;
        }
 
        if ( $option_pm25_ch2 != '' )   
        {
            $field_string .= ", air_quality_P25_2";
            $value_string .= ", " . $option_pm25_ch2;
        }
 
        if ( $option_pm25_avg_24h_ch2 != '' )   
        {
            $field_string .= ", air_quality_AQI_2";
            $value_string .= ", " . $option_pm25_avg_24h_ch2;
        }
 
        if ( $option_pm25_ch3 != '' )   
        {
            $field_string .= ", air_quality_P25_3";
            $value_string .= ", " . $option_pm25_ch3;
        }
 
        if ( $option_pm25_avg_24h_ch3 != '' )   
        {
            $field_string .= ", air_quality_AQI_3";
            $value_string .= ", " . $option_pm25_avg_24h_ch3;
        }
 
        if ( $option_pm25_ch4 != '' )   
        {
            $field_string .= ", air_quality_P25_4";
            $value_string .= ", " . $option_pm25_ch4;
        }
 
        if ( $option_pm25_avg_24h_ch4 != '' )   
        {
            $field_string .= ", air_quality_AQI_4";
            $value_string .= ", " . $option_pm25_avg_24h_ch4;
        }
 
        // file_put_contents( $log_file, "Trim_Readings = $trim_readings",  FILE_APPEND );
        if ( $trim_readings != 1 )
        {
 
            if ( $battery_1 != '' )
            {
                $field_string_battery .= ", battery_temp_humidity_1";
                $value_string_battery .= ", " . $battery_1;
            }
 
            if ( isset($battery_2) )
            {
                $field_string_battery .= ", battery_temp_humidity_2";
                $value_string_battery .= ", " . $battery_2;
            }
 
            if ( isset($battery_3) )
            {
                $field_string_battery .= ", battery_temp_humidity_3";
                $value_string_battery .= ", " . $battery_3;
            }
 
            if ( isset($battery_4) )
            {
                $field_string_battery .= ", battery_temp_humidity_4";
                $value_string_battery .= ", " . $battery_4;
            }
 
            if ( isset($battery_5) )
            {
                $field_string_battery .= ", battery_temp_humidity_5";
                $value_string_battery .= ", " . $battery_5;
            }
 
            if ( isset($battery_6) )
            {
            $field_string_battery .= ", battery_temp_humidity_6";
            $value_string_battery .= ", " . $battery_6;
            }
 
            if ( isset($battery_7) )
            {
                $field_string_battery .= ", battery_temp_humidity_7";
                $value_string_battery .= ", " . $battery_7;
            }   
 
            if ( isset($battery_8) )
            {
                $field_string_battery .= ", battery_temp_humidity_8";
                $value_string_battery .= ", " . $battery_8;
            }
 
            if ( isset($battery_moisture_soil_1 ) )
            {
                $field_string_battery .= ", battery_moisture_soil_1";
                $value_string_battery .= ", " . $battery_moisture_soil_1;
            }
 
            if ( isset($battery_moisture_soil_2 ) )
            {
                $field_string_battery .= ", battery_moisture_soil_2";
                $value_string_battery .= ", " . $battery_moisture_soil_2;
            }
 
            if ( isset($battery_moisture_soil_3 ) )
            {
                $field_string_battery .= ", battery_moisture_soil_3";
                $value_string_battery .= ", " . $battery_moisture_soil_3;
            }
 
            if ( isset($battery_moisture_soil_4 ) )
            {
                $field_string_battery .= ", battery_moisture_soil_4";
                $value_string_battery .= ", " . $battery_moisture_soil_4;
            }
 
            if ( isset($battery_moisture_soil_5 ) )
            {
                $field_string_battery .= ", battery_moisture_soil_5";
                $value_string_battery .= ", " . $battery_moisture_soil_5;
            }
 
            if ( isset($battery_moisture_soil_6 ) )
            {
                $field_string_battery .= ", battery_moisture_soil_6";
                $value_string_battery .= ", " . $battery_moisture_soil_6;
            }
 
            if ( isset($battery_moisture_soil_7 ) )
            {
                $field_string_battery .= ", battery_moisture_soil_6";
                $value_string_battery .= ", " . $battery_moisture_soil_7;
            }
 
            if ( isset($battery_moisture_soil_8 ) )
            {
                $field_string_battery .= ", battery_moisture_soil_8";
                $value_string_battery .= ", " . $battery_moisture_soil_8;
            }
 
            if ( isset($option_pm25_battery_1 ) )
            {
                $field_string_battery .= ", option_pm25_battery_1";
                $value_string_battery .= ", " . $option_pm25_battery_1;
            }
 
            if ( isset($option_pm25_battery_2 ) )
            {
                $field_string_battery .= ", option_pm25_battery_2";
                $value_string_battery .= ", " . $option_pm25_battery_2;
            }
 
            if ( isset($option_pm25_battery_3 ) )
            {
            $field_string_battery .= ", option_pm25_battery_3";
                $value_string_battery .= ", " . $option_pm25_battery_3;
            }
 
            if ( isset($option_pm25_battery_4 ) )
            {
                $field_string_battery .= ", option_pm25_battery_4";
                $value_string_battery .= ", " . $option_pm25_battery_4;
            }
 
            if ( isset($battery_wh65) )
            {
                $field_string_battery .= ", battery_wh65";
                $value_string_battery .= ", " . $battery_wh65;
            }
 
            if ( isset($battery_wh25) )
            {
                $field_string_battery  .= ", battery_wh25";
                $value_string_battery .= ", " . $battery_wh25;
            }
 
            if ( isset($software_type ) )
            {
            $field_string_version .= ", software_type";
                $value_string_version .= ", '" . $software_type . "'";
            }
 
            if ( isset( $model ) )
            {
                $field_string_version .= ", station_model";
                $value_string_version .= ", '" . $model . "'";
            }
 
            if ( isset( $freq ) )
            {
                $field_string_version .= ", frequency";
                $value_string_version .= ", '" . $freq . "'";
            }
        }
        $insert_query         = "insert into WeatherStation.ws_obs( " . $field_string . " ) values( " . $value_string . " );";
        $insert_query_battery = "insert into WeatherStation.ws_battery( " . $field_string_battery . " ) values( " . $value_string_battery . " );";
        $insert_query_option  = "insert into WeatherStation.ws_version( " . $field_string_version . " ) values( " . $value_string_version . " );";
 
        ###############################
        # Used for Debugging Purposes   #
        ############################### 
        $query = "\n\n$insert_query";       
        // file_put_contents( $log_file, $query,  FILE_APPEND );
 
        # Insert the Observation Into the database
        $statement = $connection->prepare( $insert_query );
        $statement->execute();
 
 
        if ( $trim_readings != 1 )
        {
            $statement_battery = $connection->prepare( $insert_query_battery );
            $statement_battery->execute();
            
            ###############################
            # Used for Debugging Purposes   #
            ############################### 
            $query_option = "\n\n$insert_query_battery";        
            // file_put_contents( $log_file, $query_option,  FILE_APPEND );
            
            ###############################
            # Used for Debugging Purposes   #
            ############################### 
            $query_option = "\n\n$insert_query_option";     
            // file_put_contents( $log_file, $query_option,  FILE_APPEND );
        
            $statement_option = $connection->prepare( $insert_query_option );
            $statement_option->execute();
        }
        
        $connection->commit();
        header( "HTTP/1.0 200 Success" );
      }
    }
 
 
 
    SaveObservation();
?>