tree-sensor-v6.6.ino

/*
  Moisture sensor 
  
  Kit Wallace

  see  https://kitwallace.tumblr.com/tagged/moisture

  20/2/22 This version does a few fast reports to the testing log on startup
  it also uses the treecarers domain name 

  v6.5 - air/soil distinguished in server config
  v6.6 - use this runtime to set  sleeptime
  
*/
// Script version
const char version[] = "V6.6";

// Pin assignment
// GPIO sensor power 
#define TEMPPOWER 13
#define MOISTUREPOWER 25

// moisture sensor on an analog pin
#define moisture_A2D A0   

// Data wire is  on Pin 14 (I/O pin) with added 4.7K pullup)
#define ONE_WIRE_BUS 14

// battery monitoring
#define battery_ADC 35


// GPRS credentials
#define ThingsMobile
 
#ifdef ThingsMobile
const char apn[]      = "TM"; 
const char gprsUser[] = ""; 
const char gprsPass[] = ""; 
#endif

#ifdef GiffGaff
const char apn[]      = "giffgaff.com"; 
const char gprsUser[] = "giffgaff"; 
const char gprsPass[] = ""; 

#endif

// Server details
const char host[] = "treecarers.org.uk"; 
const char resource[] = "/log-data.xq";         
const int  httpPort = 80;                           

String appid = "1418";   

// initial warmup reporting
#define WARMUP_COUNT 6
#define WARMUP_TIME_TO_SLEEP 30

// refresh interval
#define uS_TO_S_FACTOR  1000000ULL     /* Conversion factor for seconds to microseconds - cast as ULL to allow long sleeps  */        
#define REPORTING_TIME_TO_SLEEP 60*60*2  /* Time ESP32 will go to sleep (in seconds)  */

/////////////////////////////////////////////


#include <WiFi.h>  // to get MAC address

#define SerialMon Serial

// voltage
float get_battery_voltage() {
   return analogRead(battery_ADC) *2.0 / 1135;
}

// Moisture sensor

const int nReadings=7;  // must be odd
int readings[nReadings];
int reading_delay=10;

int get_moisture_reading() {
   for (int i=0;i < nReadings; i++) {
    int reading = analogRead(moisture_A2D);
    readings[i]=reading;
    delay(reading_delay);
   }
   printArray(readings,nReadings);
   int moisture_reading = median(readings,nReadings);
   return moisture_reading; 
}

//Bubble sort 
void bubbleSort(int *a, int n)
{
 for (int i = 1; i < n; ++i)
 {
   int j = a[i];
   int k;
   for (k = i - 1; (k >= 0) && (j < a[k]); k--)
   {
     a[k + 1] = a[k];
   }
   a[k + 1] = j;
 }
}

int median (int *a,int n) {
// n odd
  int mid = n/2;
  bubbleSort(a,n);
  return a[mid];
}

void printArray(int *a, int n)
{
 for (int i = 0; i < n; i++)
 {
   SerialMon.print(a[i]);
   SerialMon.print(' ');
 }
 SerialMon.println();
}

// temperature sensor
#include <OneWire.h>
#include <DallasTemperature.h>

// Setup a oneWire instance to communicate with any OneWire devices
OneWire oneWire(ONE_WIRE_BUS);

// Pass our oneWire reference to Dallas Temperature sensor 
DallasTemperature sensors(&oneWire);


// performance monitoring

RTC_DATA_ATTR int run_ms = 0;
RTC_DATA_ATTR int boot_no = 0;


// TTGO T-Call pins
#define MODEM_RST            5
#define MODEM_PWKEY          4
#define MODEM_POWER_ON       23
#define MODEM_TX             27
#define MODEM_RX             26
#define I2C_SDA              21
#define I2C_SCL              22


// Set serial for AT commands (to SIM800 module)
#define SerialAT Serial1

// Configure TinyGSM library
#define TINY_GSM_MODEM_SIM800      // Modem is SIM800
#define TINY_GSM_RX_BUFFER  1024  // Set RX buffer to 1Kb

// Define the serial console for debug prints, if needed
//#define DUMP_AT_COMMANDS

#include <Wire.h>
#include <TinyGsmClient.h>
TinyGsm modem(SerialAT);


// I2C for SIM800 (to keep it running when powered from battery)
TwoWire I2CPower = TwoWire(0);

// TinyGSM Client for Internet connection
TinyGsmClient client(modem);

#define IP5306_ADDR          0x75
#define IP5306_REG_SYS_CTL0  0x00

bool setPowerBoostKeepOn(int en){
  I2CPower.beginTransmission(IP5306_ADDR);
  I2CPower.write(IP5306_REG_SYS_CTL0);
  if (en) {
    I2CPower.write(0x37); // Set bit1: 1 enable 0 disable boost keep on
  } else {
    I2CPower.write(0x35); // 0x37 is default reg value
  }
  return I2CPower.endTransmission() == 0;
}
bool GSM_start() {
    // Start I2C communication
  I2CPower.begin(I2C_SDA, I2C_SCL, 400000);
   // Keep power when running from battery

  bool isOk = setPowerBoostKeepOn(1);
  Serial.println(String("IP5306 KeepOn ") + (isOk ? "OK" : "FAIL"));

  // Set modem reset, enable, power pins
  pinMode(MODEM_PWKEY, OUTPUT);
  pinMode(MODEM_RST, OUTPUT);
  pinMode(MODEM_POWER_ON, OUTPUT);
  digitalWrite(MODEM_PWKEY, LOW);
  digitalWrite(MODEM_RST, HIGH);
  digitalWrite(MODEM_POWER_ON, HIGH);

  // Set GSM module baud rate and UART pins
  SerialAT.begin(115200, SERIAL_8N1, MODEM_RX, MODEM_TX);
  delay(1000);

  // Restart SIM800 module, it takes quite some time
  SerialMon.println("Initializing modem...");
  if (!modem.restart()) {
        SerialMon.println("Failed to restart");
        return false;
    }
  
  SerialMon.print("Connecting to APN: ");
  SerialMon.println(apn);
  if (!modem.gprsConnect(apn, gprsUser, gprsPass)) {
      return false;
  }
  SerialMon.println("GSM started");
  return true;
}

void GSM_end() {
   modem.gprsDisconnect();
   SerialMon.println("GSM disconnected");
}

void HTTP_POST(String httpData) { 
    httpData.replace(" ", "+");
    int tries = 0;
    while (tries < 10) {
      if (client.connect(host, httpPort)) break;
      SerialMon.print(".");
      tries+=1;
      delay(100);
   }

   int signal_quality = modem.getSignalQuality();          
   httpData = httpData + "&signal-quality="+signal_quality;  
   
//  construct http request
    String http = String("POST ") + resource + " HTTP/1.1\r\n" +
               "Host: " + host + "\r\n" + 
               "Connection: close\r\n" +
               "Content-Type: application/x-www-form-urlencoded\r\n" +
               "Content-Length: " + httpData.length() + "\r\n\r\n" +
               httpData;
   SerialMon.println(http);
   client.print(http);
  
// Read all the lines of the reply from server and print them to Serial
  uint32_t timeout = millis();
  while (client.connected() && millis() - timeout < 10000L) {
    // Print available data
    while (client.available()) {
      char c = client.read();
      SerialMon.print(c);
      timeout = millis();
    }
  }
  SerialMon.println();

 
//  SerialMon.println();
   SerialMon.println("closing connection");
   client.stop();
}

void get_sensor_data(String& str) {
  // temperatures
  
  digitalWrite(TEMPPOWER,HIGH); // power on the temp sensors
 
  //one wire begin
   sensors.begin();
   delay(500);

// get temperatures - need to test and mark to find which is which
      sensors.requestTemperatures();
      float temp_C_0 = sensors.getTempCByIndex(0);
      SerialMon.print("Temp_C_0 "); SerialMon.println(temp_C_0);
      float temp_C_1 = sensors.getTempCByIndex(1);
      SerialMon.print("Temp_C_1 "); SerialMon.println(temp_C_1);
     

   digitalWrite(TEMPPOWER,LOW); // power off the temp sensors
  
 // get moisture reading
   digitalWrite(MOISTUREPOWER,HIGH); // power on the moisture sensors
   delay(500);
    int moisture_reading = get_moisture_reading();
     SerialMon.print("Moisture Reading ");SerialMon.println(moisture_reading);

    digitalWrite(MOISTUREPOWER,LOW); // power off the moisture sensors


 // get battery level
     float battery_voltage = get_battery_voltage();
     SerialMon.print("Battery voltage "); SerialMon.println(battery_voltage);

 // construct data
   str += "moisture="+ String(moisture_reading) +"&battery-voltage="+ String(battery_voltage) + "&temp-C-0="+ String(temp_C_0) + "&temp-C-1="+ String(temp_C_1) ;

 }

void get_system_data(String& str) {// get MAC id 
   SerialMon.print("Version "); SerialMon.println(version);
  
   String macAddr = WiFi.macAddress();
   SerialMon.print("MAC address "); SerialMon.println(macAddr);

   str += "&_appid=" + appid + "&version="+version+"&_MAC="+ macAddr +"&run_ms="+String(run_ms)+"&boot-no="+String(boot_no); 
   if (boot_no < WARMUP_COUNT)
     str +="&_test=test";
     
   SerialMon.println(str);
}

void setup() {
  SerialMon.begin(115200);
  
  pinMode(TEMPPOWER,OUTPUT);
  pinMode(MOISTUREPOWER,OUTPUT);
  bool GSMok;
  int start = millis();
  GSMok = GSM_start();
  if (GSMok) {
          String params; 
          get_sensor_data(params);
          get_system_data(params);
          HTTP_POST(params);
          GSM_end();
      }
   else SerialMon.println("GSM not started"); 
 
  
 // set the sleep time depending on the phase of operation 
    
    int sleep_time = REPORTING_TIME_TO_SLEEP;
    if( boot_no < WARMUP_COUNT ||  ! GSMok )  
      sleep_time  = WARMUP_TIME_TO_SLEEP;
      
  // save the elapsed time to report next time
    run_ms = millis() - start;   
    boot_no += 1;
    sleep_time = sleep_time - round(run_ms / 1000);
    SerialMon.println(sleep_time);

    esp_sleep_enable_timer_wakeup(sleep_time * uS_TO_S_FACTOR);
    SerialMon.print("sleep enabled "); 

    esp_deep_sleep_start();
}

void loop() {
}