Industrial Data Acquisition Platform

/*======================= RF Variables ======================*/
#include <SPI.h>
#include <nRF24L01.h>
#include <RF24.h>
RF24 radio(15, 14); // CE, CSN
const byte addresses[][6] = {"00001", "00002"};

/*===================== Values ========================*/

int val1, val2, val3, val4, val5, val6, val7, val8 = 0;

/*=========================== SIM800L =======================*/
#include <Sim800l.h>
#include <SoftwareSerial.h> //is necesary for the library!! 
Sim800l Sim800l;  //to declare the library
String textSms, numberSms,MyString;
char* text;
char* number = "0773357892";
uint8_t index1;
bool error;




/*======================= Totaliser =======================*/
volatile int counter = 0;

void setup() {
  // put your setup code here, to run once:
  Serial.begin(9600);
  //sim800setup();
  nrfsetup();
}

void loop() {
  master_request();
  //checkforsmsreq();
  sendtopc();
  //warn();
}

void nrfsetup() {
  radio.begin();
  radio.openWritingPipe(addresses[0]); // 00001
  radio.openReadingPipe(1, addresses[1]); // 00002
  radio.setPALevel(RF24_PA_MIN);
}


void requestvalue(char val) {

  for (int i = 0; i < 5; i++) {

    sendchar(val);
    for (int i = 0; i < 50; i++) {
      radio.startListening();
      if (radio.available()) {
        int rmessage;
        radio.read(&rmessage, sizeof(rmessage));
        if (val == 'a'){//flowrate
          //Serial.println(rmessage);
          val1 =rmessage; //pH
        }else if(val == 'b'){
          val2 =rmessage; //
        }else if(val == 'c'){//Chlorine
          val3 = rmessage;
        }else if(val == 'd'){//Conductivity
          val4 = rmessage;
        }else if(val == 'e'){//Totaliser
          val5 = rmessage;
        }else if(val == 'f'){//kWh
          val6 = rmessage;
        }
        break;
      }
    }
  }
}


void sendchar(char message) {

  radio.stopListening();
  radio.write(&message, sizeof(message));
  //Serial.println("SENT");

}
void sendvalue(int message) {

  radio.stopListening();
  radio.write(&message, sizeof(message));
  //Serial.println("SENT");
  //delay(100);

}



void waitforack() {

  while (1) {
    radio.startListening();
    if (radio.available()) {
      char rmessage;
      radio.read(&rmessage, sizeof(rmessage));
      Serial.println(rmessage);
      break;
    }

  }
}

void master_request(){
  requestvalue('a');
  delay(100);
  requestvalue('b');
  delay(100);
  requestvalue('c');
  delay(100);
  requestvalue('d');
  delay(100);
  requestvalue('e');
  delay(100);
//  requestvalue('f');
//  delay(100);
}

void sendtopc(){

  Serial.print((val4*(4.8/402.0)-2.1));//Flowrate (val4*(4.79/402)-2.1447f)
  Serial.print(",");
  Serial.print(val1*(0.7f/134.0)+4.991f);//pH val1*(1.6f/322.0)+5.1f
  Serial.print(",");
  Serial.print(val2*(3.11/479.00)-1.233f);//Chlorine val2*(4.97/404)-2.214
  Serial.print(",");
  Serial.print((val3)*(221.1f/571.00f)-73.92f);//Conductivity ((val3)*(0.15f/125.00f))-0.216f
  Serial.print(",");
  Serial.print(val5/1000.000f);
  Serial.println(",");
}


void sim800setup() {
  Sim800l.begin(); // initializate the library.
  //error = Sim800l.delAllSms(); //clean memory of sms;
}


void checkforsmsreq() {
  textSms = Sim800l.readSms(1); //read the first sms

  if (textSms.indexOf("OK") != -1) //first we need to know if the messege is correct. NOT an ERROR
  {
    if (textSms.length() > 1)  // optional you can avoid SMS empty
    {

      numberSms = Sim800l.getNumberSms(1); // Here you have the number
      //for debugin
      //Serial.println(numberSms);
      textSms.toUpperCase();  // set all char to mayus ;)

      if (textSms.indexOf("FLOW") != -1) {
        
        MyString = String((val4*(4.8/402.0)-2.1), 1); //Convert float to String
        MyString = (MyString + " m3/h");
        // convert string to char starts here
        // Length (with one extra character for the null terminator)
        int str_len = MyString.length() + 1;
        // Prepare the character array (the buffer)
        char char_array[str_len];
        // Copy it over
        MyString.toCharArray(char_array, str_len);
        error = Sim800l.sendSms(number, char_array);
      }
      else if (textSms.indexOf("PH") != -1) {
        
        MyString = String(val1*(0.7f/134.0)+4.991f, 1); //Convert float to String
        MyString = (MyString + " pH");
        // convert string to char starts here
        // Length (with one extra character for the null terminator)
        int str_len = MyString.length() + 1;
        // Prepare the character array (the buffer)
        char char_array[str_len];
        // Copy it over
        MyString.toCharArray(char_array, str_len);
        error = Sim800l.sendSms(number, char_array);
      } else if (textSms.indexOf("CL") != -1) {
        
        MyString = String(val2*(3.11/479.00)-1.233f,1); //Convert float to String
        MyString = (MyString + " mg/l");
        // convert string to char starts here
        // Length (with one extra character for the null terminator)
        int str_len = MyString.length() + 1;
        // Prepare the character array (the buffer)
        char char_array[str_len];
        // Copy it over
        MyString.toCharArray(char_array, str_len);
        error = Sim800l.sendSms(number, char_array);
      }else if (textSms.indexOf("COND") != -1) {
        
        MyString = String((val3)*(221.1f/571.00f)-73.92f, 1); //Convert float to String
        MyString = (MyString + " uS/cm");
        // convert string to char starts here
        // Length (with one extra character for the null terminator)
        int str_len = MyString.length() + 1;
        // Prepare the character array (the buffer)
        char char_array[str_len];
        // Copy it over
        MyString.toCharArray(char_array, str_len);
        error = Sim800l.sendSms(number, char_array);
      }else if (textSms.indexOf("TOT") != -1) {
        
        MyString = String(val5/1000.000f, 4); //Convert float to String
        MyString = (MyString + " kg");
        // convert string to char starts here
        // Length (with one extra character for the null terminator)
        int str_len = MyString.length() + 1;
        // Prepare the character array (the buffer)
        char char_array[str_len];
        // Copy it over
        MyString.toCharArray(char_array, str_len);
        error = Sim800l.sendSms(number, char_array);
      }
      else {
        //Serial.println("Not Compatible");
      }


      Sim800l.delAllSms(); //do only if the message is not empty,in other case is not necesary
      //delete all sms..so when receive a new sms always will be in first position
    }



  }
}

void warn(){
  if(val1 > 900){
    error = Sim800l.sendSms(number, "WARNING");
  }
}