View difference between Paste ID: TAiNykt3 and ULzTKicJ

 #include "esp_wifi.h"
 #include "driver/adc.h"
 
 
 #include <WiFi.h>
 #include "nvs_flash.h"
 #include <SimplePgSQL.h>
 #include "time.h"
 //#include <ESP32Time.h>
 #include "SPI.h"
 
 
 #include <Adafruit_BMP280.h>
 #include <Adafruit_AHTX0.h>
 
 #include <Adafruit_GFX.h>
 #include <Adafruit_PCD8544.h>
 #include <ADS1115_WE.h>
 #include <Wire.h>
 bool isSetNtp = false;                                 // flag to indicate if we had a successful NTP call
             // test variable in RTC memory
 
 // callback to check if NTP was called
 #include "esp_sntp.h"
 void cbSyncTime(struct timeval *tv) { // callback function to show when NTP was synchronized
   Serial.println("NTP time synched");
   isSetNtp = true;
 }
 
 #define I2C_ADDRESS 0x48
 
 ADS1115_WE adc = ADS1115_WE(I2C_ADDRESS);
 
  Adafruit_PCD8544 display = Adafruit_PCD8544(0, 1, 2);
 
 
 Adafruit_AHTX0 aht;
 Adafruit_BMP280 bmp;
 
 //ESP32Time rtc(0);  // offset in seconds
 
 int16_t adc0, adc1, adc2, adc3;
 float volts0, volts1, volts2, volts3;
 float abshum;
 
 
 
 #include <Preferences.h>
 Preferences prefs;
   struct tm timeinfo;
 
 RTC_DATA_ATTR int readingCnt = -1;
 RTC_DATA_ATTR int arrayCnt = 0;
 
 int i;
 
 typedef struct {
   float temp1;
   float temp2;
   unsigned long   time;
   float volts;
   float pres;
 } sensorReadings;
 
 #define maximumReadings 360 // The maximum number of readings that can be stored in the available space
 #define sleeptimeSecs   30
 #define WIFI_TIMEOUT 20000
 #define TIME_TIMEOUT 20000
 
 RTC_DATA_ATTR sensorReadings Readings[maximumReadings];
 
 const char* ntpServer = "pool.ntp.org";
 const long gmtOffset_sec = -18000;  //Replace with your GMT offset (secs)
 const int daylightOffset_sec = 3600;   //Replace with your daylight offset (secs)
 int hours, mins, secs;
 float tempC;
 bool sent = false;
 
 
-IPAddress PGIP(216,110,224,105);
+IPAddress PGIP(x,x,x,x);
 
 const char ssid[] = "xxxx";      //  your network SSID (name)
 const char pass[] = "xxxx";      // your network password
 
 const char user[] = "xxxx";       // your database user
 const char password[] = "xxxx";   // your database password
 const char dbname[] = "xxxx";         // your database name
 
 
 int WiFiStatus;
 WiFiClient client;
 
 
 
 
 
 /////////////////////////
 //POSTGRESQL CODE BEGIN//
 /////////////////////////
 
 
 
 
 
 
 char buffer[1024];
 PGconnection conn(&client, 0, 1024, buffer);
 
 char tosend[192];
 String tosendstr;
 
 
 #ifndef USE_ARDUINO_ETHERNET
 void checkConnection()
 {
     int status = WiFi.status();
     if (status != WL_CONNECTED) {
         if (WiFiStatus == WL_CONNECTED) {
             Serial.println("Connection lost");
             WiFiStatus = status;
         }
     }
     else {
         if (WiFiStatus != WL_CONNECTED) {
             Serial.println("Connected");
             WiFiStatus = status;
         }
     }
 }
 
 #endif
 
 static PROGMEM const char query_rel[] = "\
 SELECT a.attname \"Column\",\
   pg_catalog.format_type(a.atttypid, a.atttypmod) \"Type\",\
   case when a.attnotnull then 'not null ' else 'null' end as \"null\",\
   (SELECT substring(pg_catalog.pg_get_expr(d.adbin, d.adrelid) for 128)\
    FROM pg_catalog.pg_attrdef d\
    WHERE d.adrelid = a.attrelid AND d.adnum = a.attnum AND a.atthasdef) \"Extras\"\
  FROM pg_catalog.pg_attribute a, pg_catalog.pg_class c\
  WHERE a.attrelid = c.oid AND c.relkind = 'r' AND\
  c.relname = %s AND\
  pg_catalog.pg_table_is_visible(c.oid)\
  AND a.attnum > 0 AND NOT a.attisdropped\
     ORDER BY a.attnum";
 
 static PROGMEM const char query_tables[] = "\
 SELECT n.nspname as \"Schema\",\
   c.relname as \"Name\",\
   CASE c.relkind WHEN 'r' THEN 'table' WHEN 'v' THEN 'view' WHEN 'm' THEN 'materialized view' WHEN 'i' THEN 'index' WHEN 'S' THEN 'sequence' WHEN 's' THEN 'special' WHEN 'f' THEN 'foreign table' END as \"Type\",\
   pg_catalog.pg_get_userbyid(c.relowner) as \"Owner\"\
  FROM pg_catalog.pg_class c\
      LEFT JOIN pg_catalog.pg_namespace n ON n.oid = c.relnamespace\
  WHERE c.relkind IN ('r','v','m','S','f','')\
       AND n.nspname <> 'pg_catalog'\
       AND n.nspname <> 'information_schema'\
       AND n.nspname !~ '^pg_toast'\
   AND pg_catalog.pg_table_is_visible(c.oid)\
  ORDER BY 1,2";
 
 int pg_status = 0;
 
 void doPg(void)
 {
     char *msg;
     int rc;
     if (!pg_status) {
         conn.setDbLogin(PGIP,
             user,
             password,
             dbname,
             "utf8");
         pg_status = 1;
         return;
     }
 
     if (pg_status == 1) {
         rc = conn.status();
         if (rc == CONNECTION_BAD || rc == CONNECTION_NEEDED) {
             char *c=conn.getMessage();
             if (c) Serial.println(c);
             pg_status = -1;
         }
         else if (rc == CONNECTION_OK) {
             pg_status = 2;
             Serial.println("Enter query");
         }
         return;
     }
     if (pg_status == 2) {
         if (!Serial.available()) return;
         char inbuf[192];
         int n = Serial.readBytesUntil('\n',inbuf,191);
         while (n > 0) {
             if (isspace(inbuf[n-1])) n--;
             else break;
         }
         inbuf[n] = 0;
 
         if (!strcmp(inbuf,"\\d")) {
             if (conn.execute(query_tables, true)) goto error;
             Serial.println("Working...");
             pg_status = 3;
             return;
         }
         if (!strncmp(inbuf,"\\d",2) && isspace(inbuf[2])) {
             char *c=inbuf+3;
             while (*c && isspace(*c)) c++;
             if (!*c) {
                 if (conn.execute(query_tables, true)) goto error;
                 Serial.println("Working...");
                 pg_status = 3;
                 return;
             }
             if (conn.executeFormat(true, query_rel, c)) goto error;
             Serial.println("Working...");
             pg_status = 3;
             return;
         }
 
         if (!strncmp(inbuf,"exit",4)) {
             conn.close();
             Serial.println("Thank you");
             pg_status = -1;
             return;
         }
         if (conn.execute(inbuf)) goto error;
         Serial.println("Working...");
         pg_status = 3;
     }
     if (pg_status == 3) {
         rc=conn.getData();
         if (rc < 0) goto error;
         if (!rc) return;
         if (rc & PG_RSTAT_HAVE_COLUMNS) {
             for (i=0; i < conn.nfields(); i++) {
                 if (i) Serial.print(" | ");
                 Serial.print(conn.getColumn(i));
             }
             Serial.println("\n==========");
         }
         else if (rc & PG_RSTAT_HAVE_ROW) {
             for (i=0; i < conn.nfields(); i++) {
                 if (i) Serial.print(" | ");
                 msg = conn.getValue(i);
                 if (!msg) msg=(char *)"NULL";
                 Serial.print(msg);
             }
             Serial.println();
         }
         else if (rc & PG_RSTAT_HAVE_SUMMARY) {
             Serial.print("Rows affected: ");
             Serial.println(conn.ntuples());
         }
         else if (rc & PG_RSTAT_HAVE_MESSAGE) {
             msg = conn.getMessage();
             if (msg) Serial.println(msg);
         }
         if (rc & PG_RSTAT_READY) {
             pg_status = 2;
             Serial.println("Enter query");
         }
     }
     return;
 error:
     msg = conn.getMessage();
     if (msg) Serial.println(msg);
     else Serial.println("UNKNOWN ERROR");
     if (conn.status() == CONNECTION_BAD) {
         Serial.println("Connection is bad");
         pg_status = -1;
     }
 }
 
 
 
 
 
 
 
 
 /////////////////////////
 //POSTGRESQL CODE END  //
 /////////////////////////
 
 
 
 
 
 
 
 
 
 void gotosleep() {
       //WiFi.disconnect();
       delay(1);
       esp_sleep_enable_timer_wakeup(sleeptimeSecs * 1000000ULL);
       delay(1);
       esp_deep_sleep_start();
       delay(1000);
 }
 
 
 void killwifi() {
             WiFi.disconnect();
 }
 
 void transmitReadings() {
   i=0;
           while (i<maximumReadings) {
             doPg();
             display.clearDisplay();   // clears the screen and buffer
             display.setCursor(0,0);
             display.print("TXing #");
             display.print(i);
             display.print(",");
             display.println(arrayCnt);
             display.display();
 
             if ((pg_status == 2) && (i<maximumReadings)){
               tosendstr = "insert into burst values (42,1," + String(Readings[i].time) + "," + String(Readings[i].temp1,3) + "), (42,2," + String(Readings[i].time) + "," + String(Readings[i].volts,4) + "), (42,3," + String(Readings[i].time) + "," + String(Readings[i].temp2,3) + "), (42,4," + String(Readings[i].time) + "," + String(Readings[i].pres,3) + ")";
               conn.execute(tosendstr.c_str());
               pg_status = 3;
               delay(10);
               i++;
             }
             delay(10);
 
           }
 
 }
 
 
 float readChannel(ADS1115_MUX channel) {
   float voltage = 0.0;
   adc.setCompareChannels(channel);
   adc.startSingleMeasurement();
   while(adc.isBusy()){}
   voltage = adc.getResult_V(); // alternative: getResult_mV for Millivolt
   return voltage;
 }
 
 
 
 void initTime(String timezone){
   configTzTime(timezone.c_str(), "time.cloudflare.com", "pool.ntp.org", "time.nist.gov");
 
   while ((!isSetNtp) && (millis() < TIME_TIMEOUT)) {
         delay(250);
         display.print(".");
         display.display();
         }
 
 }
 
 
 void setup(void)
 {
   sntp_set_time_sync_notification_cb(cbSyncTime);
   display.begin(20, 7);
 
 
   display.display(); // show splashscreen
   display.clearDisplay();   // clears the screen and buffer
   display.setTextSize(1);
   display.setTextColor(BLACK);
   display.setCursor(0,0);
   display.setTextWrap(true);
   if ((readingCnt == -1)) {
 
       WiFi.mode(WIFI_STA);
       WiFi.begin((char *)ssid, pass);
       display.print("Connecting to get time...");
       display.display();
       while ((WiFi.status() != WL_CONNECTED) && (millis() < WIFI_TIMEOUT)) {
         delay(250);
         display.print(".");
         display.display();
       }
           display.clearDisplay();   // clears the screen and buffer
           display.setCursor(0,0);
           if (WiFi.status() == WL_CONNECTED) {
             display.print("Connected. Getting time...");
           }
           else
           {
             display.print("Connection timed out. :(");
           }
           display.display();
           initTime("EST5EDT,M3.2.0,M11.1.0");
           //rtc.setTimeStruct(timeinfo);
           killwifi();
           readingCnt = 0;
           delay(1);
           readingCnt = 0;
           delay(1);
 
           esp_sleep_enable_timer_wakeup(1 * 1000000);
           esp_deep_sleep_start();
           delay(1000);
   }
 
   Wire.begin();
   adc.init();
   adc.setVoltageRange_mV(ADS1115_RANGE_4096);
 
   float volts0 = 2.0 * readChannel(ADS1115_COMP_3_GND);
 
 
   bmp.begin();
   bmp.setSampling(Adafruit_BMP280::MODE_FORCED,     /* Operating Mode. */
                   Adafruit_BMP280::SAMPLING_X2,     /* Temp. oversampling */
                   Adafruit_BMP280::SAMPLING_X16,    /* Pressure oversampling */
                   Adafruit_BMP280::FILTER_X16,      /* Filtering. */
                   Adafruit_BMP280::STANDBY_MS_500);
   bmp.takeForcedMeasurement();
   float presread = bmp.readPressure() / 100.0;
   aht.begin();
   sensors_event_t humidity, temp;
   aht.getEvent(&humidity, &temp);
   abshum = (6.112 * pow(2.71828, ((17.67 * temp.temperature)/(temp.temperature + 243.5))) * humidity.relative_humidity * 2.1674)/(273.15 + temp.temperature); //calculate absolute humidity
   display.print("Time: ");
   setenv("TZ","EST5EDT,M3.2.0,M11.1.0",1);  //  Now adjust the TZ.  Clock settings are adjusted to show the new local time
   tzset();
   getLocalTime(&timeinfo);
   int hr12 = timeinfo.tm_hour;
   String AMPM;
   if (hr12 > 12) {
     hr12 -= 12;
     AMPM = "PM";
   }
   else {AMPM = "AM";}
 
   display.print(hr12);
   if (timeinfo.tm_min < 10) {display.print(":0");}
   else {display.print(":");}
 
   display.print(timeinfo.tm_min);
   display.println(AMPM);
 
   display.print(temp.temperature, 2);
   display.print("C ");
   display.print(humidity.relative_humidity, 1);
   display.println("%");
 
   display.print("Abs: ");
   display.print(abshum, 2);
   display.println("g");
 
   display.print("Batt: ");
   display.print(volts0, 4);
   display.println("v");
 
   display.print("Pres: ");
   display.print(presread, 2);
   display.println("m");
 
   display.print("R");
   display.print(readingCnt);
   display.print("/");
   display.print(maximumReadings);
   display.print(" A");
   display.print(arrayCnt);
   display.display();
 
   //Store the sensor readings in the struct we declared earlier, using the RTC-ram integer "readingCnt" to increment the array index by one each reading
   Readings[readingCnt].temp1 = temp.temperature;    // Units °C
   Readings[readingCnt].temp2 = abshum; //humidity is temp2
   Readings[readingCnt].time = mktime(&timeinfo);
   Readings[readingCnt].volts = volts0;
   Readings[readingCnt].pres = presread;
 
 
 
   ++readingCnt;
   delay(1);
 
   if (readingCnt >= maximumReadings) {
 
       prefs.begin("stuff", false, "nvs2"); //open up a prefs on the custom NVS2 partition
       WiFi.mode(WIFI_STA);
       WiFi.begin((char *)ssid, pass);
       display.clearDisplay();   // clears the screen and buffer
       display.setCursor(0,0);
       display.print("Connecting to transmit...");
       display.display();
       while ((WiFi.status() != WL_CONNECTED) && (millis() < WIFI_TIMEOUT)) {
         delay(250);
         display.print(".");
         display.display();
       }
 
       if ((WiFi.status() != WL_CONNECTED) && (millis() >= WIFI_TIMEOUT)) {
 
         delay(1);
         ++arrayCnt;
         delay(1);
         prefs.putBytes(String(arrayCnt).c_str(), &Readings, sizeof(Readings));
         readingCnt = 0;
         killwifi();
         esp_sleep_enable_timer_wakeup(1 * 1000000);
         esp_deep_sleep_start();
         delay(1000);
       }
       display.clearDisplay();   // clears the screen and buffer
       display.setCursor(0,0);
       display.print("Connected. Transmitting #0");
       display.display();
       transmitReadings();
       while (arrayCnt > 0) {
         display.clearDisplay();   // clears the screen and buffer
         display.setCursor(0,0);
         display.print("Transmitting #");
         display.print(arrayCnt);
         display.display();
         delay(50);
         prefs.getBytes(String(arrayCnt).c_str(), &Readings, sizeof(Readings));
         arrayCnt--;
         transmitReadings();
       }
       arrayCnt = 0;
       readingCnt = -1;
       delay(1);
       arrayCnt = 0;
       readingCnt = -1;
       delay(1);
       display.clearDisplay();   // clears the screen and buffer
       display.setCursor(0,0);
       display.print("Done.  Closing connection...");
       display.display();
       conn.close();
 
       killwifi();
 
       ESP.restart();
   }
 
 
         gotosleep();
 
 }
 
 
 void loop()
 {
 gotosleep();
 }