1. Install a Raspberry Pi Operating System image on SD card
2. First RPI RUN with the new SDCard
3. System Update & required packages install

Published November 14, 2018 © CC BY-NC-ND

Smart Communicating Irrigation System

Automatic and controled plant irrigation system with data monitoring through internet, locally or via SMS + alerts.

AdvancedShowcase (no instructions)24 hours4,314

Things used in this project

Hardware components

Arduino Mega 2560

SparkFun Soil Moisture Sensor (with Screw Terminals)

DHT22 Temperature Sensor

Arduino Mega 2560

GSM sim800l

MicroSD Module (Generic)

Digilent Pmod RTCC

Adafruit Standard LCD - 16x2 White on Blue

keypad

Raspberry Pi 3 Model B

Espressif ESP8266 ESP-01

Software apps and online services

Arduino IDE

Story

We live in an era where the human being wants to control everything, and he wants to do that the easiest way possible, so this project lets you do that with your plants, most of the time i'm too busy and forget to water my plants. To solve this problem, I am building a portable irrigation system that waters my plants depending on the soil moisture, and sends the plant's temperature and humidity and soil's humidity to an internet plateform and i've chosen thingspeak, and also it sends those data by sms to my phone and alerts me when the humidity of the air is too high

why did I chose thingspeak

thingspeak has so many features

Some of ThingSpeak Features

Real-time data collection and storage
MATLAB® analytics and visualizations
Alerts
Scheduling
Device communication
Open API
Geolocation data
Available on GitHub®

Personally I especially like ThingSpeak because it's so easy to send data to it and it helps so much with analytics as it works with MATLAB ; Last couple months I had many problems with ESP8266 "ESP01" which is the wifi module i used; as it works with AT commands ( basic comands to send data) thus it's somehow difficult to send data with these commands , you can still flash your ESP-01 but I found that too complicated as i've been uploading firmwares or testing tools and IDEs. I have spend many times hours on small problems . And here I found ThingSpeak which I wanted to test. And you know what? In just 10minutes (really) I have created a new account ,I have added a new channel (device) and I have learned basic API examples

Next thing, i made a calculation on the temperature data ,I have tried to create a basic Matlab programe, which was calculating average temperature. or the correlation between temperture and humidity, you can find all of these codes examples in there website

https://thingspeak.com

thingspeak uses applications, one of its application is called talkback it uses the same API protocol as to send or get data from thingspeak but this time to control your IOT, i've used that to control the plants irrigation, so that my system wouldn't only be automatic, now I have full control etither I want it to work in the manual mode where I can command the pump from internet or I want it automatic where it will irrigat according to the soil humidity

But now what if we dont have internet, does the system stop sending data ?

there are many solutions and I have made some of them, thingspeak is an open plateform so I thought if I cant go to thingspeak I will make thingspeak come to me, I installed it in a raspberry pi 3, no probleme if you don't have a raspberry you can just install it in your pc, the only condition is that you have to install the rasbian distribution of linux ; another solution for saving your data in case the thingspeak server stops, i've put an SD card reader for the arduino so that the data is stocked localy in it

INSTALLATION OF THINGSPEAK PROCESS:

1. Install a Raspberry Pi Operating System image on SD card

Download the Raspbian image from RPI website
Write image to SDCard

For more details please read RPI Install Guide

I was using the Win32DiskImager utility under W7Pro for that, worked like a charm.

2. First RPI RUN with the new SDCard:

Inset card in RPI2
Boot
From raspi-config:

– Set to use entire SDcard space– Set hostname: RPIMON1– Enable SSH Server– Write down your new RPI IP: 192.168.2.xx

Reboot for apply new hostname & settings

pi@RPIMON1~$ sudo reboot

3. System Update & required packages install

Switch over to SSH remote access with Putty – accept new key

Change “pi” account password:

pi@RPIMON1~$passwd

Set ROOT password, so you can then use root

pi@RPIMON1~$sudo passwd root

System Update & upgrade :
pi@RPIMON1~$sudo apt-get updatepi@RPIMON1~$sudo apt-get upgradepi@RPIMON1~$sudo apt-get dist-upgradepi@RPIMON1~$sudo sync
Reboot:

pi@RPIMON1~$ sudo reboot

Required packages:

pi@RPIMON1~$sudo apt-get -y install build-essential git mysql-server mysql-client libmysqlclient-dev libxml2-dev libxslt-dev libssl-dev libsqlite3-dev

4. MySQL Database configuration

pi@RPIMON1~$mysql –user=root mysql -p useyourpasswd here

pi@RPIMON1~$mysql> CREATE USER ‘thing’@’localhost’ IDENTIFIED BY ‘speak’;

pi@RPIMON1~$mysql> GRANT ALL PRIVILEGES ON *.* TO ‘thing’@’localhost’ WITH GRANT OPTION;

pi@RPIMON1~$mysql> commit;

pi@RPIMON1~$mysql> exit;

5. Ruby & Rails install

pi@RPIMON1~$wget http://cache.ruby-lang.org/pub/ruby/2.1/ruby-2.1.5.tar.gzpi@RPIMON1~$tar xvzf ruby-2.1.5.tar.gz

pi@RPIMON1~$cd ruby-2.1.5

pi@RPIMON1~$./configure

pi@RPIMON1~$make

pi@RPIMON1~$sudo make install

pi@RPIMON1~$cd..

pi@RPIMON1~$echo “gem: –no-rdoc –no-ri” >> ${HOME}/.gemrc

pi@RPIMON1~$sudo gem install rails

6. THINGSPEAK SERVER INSTALL

pi@RPIMON1~$git clone https://github.com/iobridge/thingspeak.git

pi@RPIMON1~$cd thingspeak/config/database.yml.example thingspeak/config/database.yml

pi@RPIMON1~$cd thingspeak

pi@RPIMON1~$bundle install

pi@RPIMON1~$bundle exec rake db:create

pi@RPIMON1~$mysql –user=root mysql -p

pi@RPIMON1~$mysql> show databases;

pi@RPIMON1~$mysql> exit;

IF all OK continue with loading Thingspeak DB configuration

pi@RPIMON1~$bundle exec rake db:schema:load

RUN the THINGSPEAK SERVER:

pi@RPIMON1 ~/yourthingspeak $ rails server webrick

Running Thingspeak on RPI Board

in the Browser type : http://"raspberry ip adress":3000

And the result :

and that's already a big solution for the internet probleme after this you have your computer that works as a server

now all you have to do is set up the you arduino as it would send the data to the plateform and I chose the http protocol as my ESP01 works with AT commands :

https://www.sparkfun.com/datasheets/Cellular%20Modules/AT_Commands_Reference_Guide_r0.pdf

you just have to follow the code i've posted and change it following your parametres

for the wifi the raspberry and the arduino must be conected to the same router same network , change the apikey with your api key either you're sending data to the thingspeak website or localy ,or both ; and the hostname and password by your acces point's hostname and password

edit these

and you have to change this ip adress and put the raspberry adress

and also to make the code work you have to install these libraries

install !

change the number in the SIM fonction

follow all the pins as in the schematic

or change the code according to your setting

- for the keypad pins

- for esp01 (wifi) pins

for the GSM you have to follow the schematic RX --->11, TX----->10

for other componants I recomand doing as the schematic because i've made many digital pins work as VCC or GND because there isn't much power pins for all the componants and as I wanted to put the system in a box that was one solution ; but as I always say there's always another solution so if you dont want to do that you can follow what pin i've set as VCC and which one GND and you just have to change them as you want

for the talkback, tyou have to change these following you API and comand id in thingspeak

if you follow that and the schematic everything should work great

now once you change the code, and upload it in your arduino and set up your raspberry and everything works ;

you have to start the server in the raspberry but then you dont want to plug your raspbberry to a screen everytime you want to start the server, so you can get your raspberry screen in your phone, all you have to do is install XRDP in your raspberry

and an XRDP app in your phone

conect to the raspberry with XRDP ;

and do as follow on your phone after pluging your raspberry without screen :

start the system , it should tell you enter the password, the password is "1234" (if didn't changed in the code)

and then it displays " press 0 for help " as follow

there is a menu for the keypad

"0" for help

"1" for diplaying temperature and time

"2" for diplaying humidity and time

"3" for diplaying the soil humidity and time

"5" for switching to the internet mode ( if the arduino is conected to internet if not do not enable that)

"D" for diplaying the date

A for the automatique mode

""B" for the manual mode, (this works with internet, if there's no internet do not enable it)

"#" to send data to the the local thingspeak

"5" + "#" send data to the local thingspeak and internet thingspeak

"C" to display the data that is saved in the sd card

here are some pictures

and here are some plots I have made with the internet singspeak

and here is the link to view my public chanel if you want to check the result

https://thingspeak.com/channels/416097

Code

project's code

#include "DHT.h"
#define DHTPIN 32                       // Digital Pin 32
#define DHTTYPE DHT22    // We are Using DHT22
#include <string.h>
#include <Keypad.h>
#include <SoftwareSerial.h>
#include <Sim800l.h>
#include <SD.h>//SD Card Library
Sim800l Sim800l;  //to declare the library
#include <DS3231.h>
DS3231  rtc(SDA, SCL);





//String Host_Name = "ANON0NOSSe";         // Edit Host_Name  
//String Password = "nassim"; // Edit Password
String apiKey = "5Z1WCK3CVIASN5TW";    // Edit this API key according to your Account
String apiKey1 = "WQNEJ9CE6V2U25EX"; // API LOCAL-------------------
String Host_Name = "USTHB";         // Edit Host_Name  
String Password = "telecom2018"; // Edit Password

const int pompe=8; 
const byte inter=38;
String temp;
String MyString;
String mystring;

int c=0;
int n =0;
int i=0;
int p=0;
int m=0;
//String text;     // to storage the text of the sms
uint8_t index;   // to indicate the message to read.
char* text;
char* number;
char* password ="1234"; //create a password
int posision = 0;
int ledV =40;
int ledR = 42;
int ledB = 46;
  int CS_pin = 53;
SoftwareSerial ser(12, 9);// RX, TX
DHT dht(DHTPIN, DHTTYPE);              // Initialising Pin and Type of DHT

#include <LiquidCrystal.h>
LiquidCrystal lcd(47, 45, 43, 41, 39, 37);


 char keys[4][4] = {
 {'1','2','3','A'},
{'4','5','6','B'},
{'7','8','9','C'},
{'*','0','#','D'}
};

byte rowPins[4] = {29,28,27,26};  //connect to the row pinouts of the keypad
byte colPins[4] = {25,24,23,22}; //connect to the column pinouts of the keypad

Keypad keypad = Keypad( makeKeymap(keys), rowPins, colPins, 4, 4 );

char key = keypad.getKey();
int pinpower= 48;
int pinpower1=49;
int pinpower2=6;
int GND=7;
int gnD=4;
 int gnd= 36 ;
 int GnD=35;
 int VCC=44;

long id = 1;  


void setup() {  
 
  
///////////////////////////////ALIMENTATION//////////////////////////////
pinMode(VCC,OUTPUT);
digitalWrite(VCC,1);
pinMode(GnD,OUTPUT);
digitalWrite(GnD,0);
pinMode(pinpower,OUTPUT);
digitalWrite(pinpower,1);
pinMode(pinpower1,OUTPUT);
digitalWrite(pinpower1,1);
pinMode(pinpower2,OUTPUT);
digitalWrite(pinpower2,1);
pinMode(gnd,OUTPUT);
digitalWrite(gnd,0);
pinMode(GND,OUTPUT);
digitalWrite(GND,0);
pinMode(gnD,OUTPUT);
digitalWrite(gnD,0);
pinMode(inter,OUTPUT);
digitalWrite(inter,1);

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

lcd.begin(16, 2);   

Serial.begin(9600);
 
 pinMode(CS_pin, OUTPUT);
  
 // Serial.begin(9600); // only for debug the results . 
 if (!SD.begin(CS_pin))
  {
     Serial.println("Card Failure");
    
      return;
  }
  Serial.println("Card Ready");
 
  File logFile = SD.open("LOG.csv", FILE_WRITE);
  if (logFile)
  {
    logFile.println(", , , ,"); //Just a leading blank line, incase there was previous data
    String header = "ID, humidity, Temp, time, humid terre, day, date ";
    logFile.println(header);
    logFile.close();
    Serial.println(header);
  }
  else
  {
    Serial.println("Couldn't open log file");
  }
             
    ser.begin(115200);
    //ser.println("AT+RST"); 
      ser.println("AT+CIOBAUD=9600");
      delay(4000);
 // enable software serial
  ser.begin(9600); 
 pinMode(ledV, OUTPUT);
   pinMode(ledB, OUTPUT);
 pinMode(ledR, OUTPUT);

dht.begin();
  
  rtc.begin();
  /////////////////////////////////REGLAGE RTC //////////////////////////////////////
  //rtc.setDOW(SUNDAY);     // Set Day-of-Week to SUNDAY                          //  
 //rtc.setTime(14, 20, 00);     // Set the time to 12:00:00 (24hr format)        //
 // rtc.setDate(29, 3, 2018);   // Set the date to January 1st, 2014            //
 ////////////////////////////////////////////////////////////////////////////////


 char inv ='"';
 String cmd1 = "AT+CWJAP";
       cmd1+= "=";
       cmd1+= inv;
       cmd1+= Host_Name;
       cmd1+= inv;
       cmd1+= ",";
       cmd1+= inv;
       cmd1+= Password;
       cmd1+= inv;
ser.println(cmd1);                // Connecting ESP8266 to your WiFi Router                                   
                                  // AT+CWJAP="Host_Name","Password"

pinMode(ledV,OUTPUT);
pinMode(ledB,OUTPUT);
pinMode(ledR,OUTPUT);



}



void loop() {
  
  char key = keypad.getKey();
  attachInterrupt(digitalPinToInterrupt(3), interrupt,HIGH);
//////////////////////////////////////////////////////////////////Security/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
while (n!=1)
{

char key = keypad.getKey();
//lcd.clear();
lcd.setCursor(0, 0);
  lcd.print("   Welcome");
  lcd.setCursor(0, 1);
  lcd.print(" Enter Password");
  delay(100);

  if(key == '*' || key == '#' || key == 'A' ||       //define invalid keys
  key == 'B' || key == 'C' || key == 'D'){

    posision=0;
  
    lcd.clear();
    lcd.setCursor(0, 0);
    lcd.print("  Invalid Key!");
digitalWrite(ledV, 0);
digitalWrite(ledR, 1);
digitalWrite(ledB, 0);
    delay(1000);
 
 digitalWrite(ledV, 0);
digitalWrite(ledR, 0);
digitalWrite(ledB, 0);
    
    lcd.clear();
    
  }
  if(key == password [posision]){

    posision ++;
  }

  if(posision == 4){
  
    lcd.clear();
    lcd.setCursor(0, 0);
    lcd.print("*** Verified ***");
   n=1;
   digitalWrite(ledV, 1);
digitalWrite(ledR, 0);

digitalWrite(ledB, 0);
    delay(2000);
  lcd.clear();
  lcd.setCursor(0,0);
 
    lcd.print("press 0 for help");
  delay(50); 
}

}

 
 /////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////   
    
   if(n==1)
  {
  float h =  dht.readHumidity();             // Reading Humidity Value
 float t = dht.readTemperature(); 
   int sensorValue = analogRead(A15);
   //Serial.println(sensorValue);
    sensorValue= map(sensorValue,200,1024,100,0);
 delay(200);
 String dataString = String(id) + ", " + String(h) + ", " + String(t)+ ", " + String(sensorValue)+", " + String (rtc.getTimeStr())+ ", " + String (rtc.getDOWStr())+ ", " + String (rtc.getDateStr());
 

   //Open a file to write to
  //Only one file can be open at a time
  File logFile = SD.open("LOG.csv", FILE_WRITE);
  if (logFile)
  {
    logFile.println(dataString);
    logFile.close();
    Serial.println(dataString); 
     }
  else
  {
    Serial.println("Couldn't open log file");
  }
  // Wait one second before repeating :)
  delay (50); 
  //Increment ID number
  id++;
  
 digitalWrite(ledV, 0);
digitalWrite(ledR, 0);
digitalWrite(ledB, 0);
   
  /////////////////////////////////////////
   rtc.getDOWStr();
 // Send date
  rtc.getDateStr();
 // Send time
rtc.getTimeStr(); 


//int index=1; // first position in the prefered memory storage. 
 //String text;
  //text=Sim800l.readSms(index);    
  //lcd.print(text);
 //delay(5000);
//lcd.clear();
 

   char key = keypad.getKey();
   
  ////Parti____lcd///////
  

 if (key=='0'){
    i=8;
      lcd.clear();
    }
   if (i==8)
    {
    
    
    digitalWrite(ledV, 1);
digitalWrite(ledR, 0);

digitalWrite(ledB, 0);  

  lcd.setCursor(2, 0);
  lcd.print("1-humidite");
  lcd.setCursor(2, 1);
  lcd.print("2-temperature");

  
 
  lcd.setCursor(16, 0);
  lcd.print("3-humid terre");  
  lcd.setCursor(16, 1);
  lcd.print("D-date");


lcd.setCursor(30, 0);
  lcd.print("#-send sms ");
  lcd.setCursor(29, 1);
  lcd.print("*-send wifi ");
  lcd.scrollDisplayLeft();
  
  delay(400);
  
 
    
    }
    digitalWrite(ledV, 0);
digitalWrite(ledR, 0);

digitalWrite(ledB, 0); 

 if (key=='1'){
    i=1;
     lcd.clear();
    }
    if(i==1){
    
  
      lcd.setCursor(0,0);
  lcd.print("Humidity:");
  lcd.print(h);
     lcd.print("%");
     lcd.setCursor(0,1);
      lcd.print(rtc.getTimeStr()); 
     
    
    }
    
  if (key =='2'){
  i=2;
      lcd.clear(); }
      if(i==2){
      
        lcd.setCursor(0,0);
      lcd.print("temp :");
      lcd.print(t);
      lcd.setCursor(0,1);
      lcd.print(rtc.getTimeStr());
      }
    
    if (key =='C'){
  i=10;
  lcd.clear();
       }
    if(i==10){
      lcd.setCursor(0,0);
     lcd.print (dataString);
    lcd.scrollDisplayLeft();
    delay(400);
    }
     

    
     if (key=='3'){
      i=3;
       lcd.clear();
     }
     if(i==3){
     lcd.setCursor(0,0);
      lcd.print("humid terre:");
      lcd.print(sensorValue);
      lcd.print("%");
      lcd.setCursor(0,1);
      lcd.print(rtc.getTimeStr());
     }
 
   if(key=='D')
         {
          i=6;
         lcd.clear();
         }
         if(i==6){
       lcd.setCursor(33,0);
       lcd.print( "Date:");
    lcd.setCursor(4,0);
       lcd.print( rtc.getDOWStr());
        

    lcd.setCursor(2,1);
lcd.print(rtc.getDateStr())  ;
         lcd.setCursor(18,0);
   lcd.print( "TIME ");
     
      
      lcd.setCursor(20,1);
  lcd.print(rtc.getTimeStr());
    lcd.print(" ");
   
    lcd.scrollDisplayLeft();
    delay(500);
     
         }

         if (key=='#'){
          i=7;
         }
         if (i==7)
         {
          char key = keypad.getKey();
         
 lcd.clear();
      lcd.print("sending SMS");
      mystring = String (h,0);
     MyString= String (t,0);
   temp= (rtc.getTimeStr());
     MyString = ("temperature: "+MyString +"*C "+ "humidity: "+ mystring+" %"+"  ---  " "time :"+ temp);
     
     int str_len = MyString.length() + 1;
     char char_array[str_len];
     

   
     MyString.toCharArray(char_array,str_len); 
   
 Sim800l.begin(); // initializate the library.  
  number="0658564816"; //change to a valid number.
  //text=TEXT;
 //



Sim800l.sendSms(number,char_array);
delay(3000);
        
         }

if(key=='B')
   {p=1;
   lcd.clear();
   lcd.print("mode manuel");
     pinMode(pompe,OUTPUT);
    digitalWrite(pompe,0);
    delay(1000);
   } 
   if(key=='A'){
    p=2;
    lcd.clear();
     lcd.print("mode auto");
     delay(1000);
   }
 if(p==1)
      {
       i=5;
       key='5';
      }
  
   if(p==2){
  if(sensorValue<40)
  {
          digitalWrite(ledV, 1);
digitalWrite(ledR, 0);
digitalWrite(ledB, 0);
    
     pinMode(pompe,OUTPUT);
    digitalWrite(pompe,1);
    lcd.clear();
    lcd.setCursor(5,0);
  lcd.print("Arrosage");
  lcd.setCursor(5,1);
   lcd.print("en cours");
   
 
         digitalWrite(ledV, 0);
digitalWrite(ledR, 0);
digitalWrite(ledB, 0);
  }
    else 
    {
       pinMode(pompe,OUTPUT);
    digitalWrite(pompe,0);
    }
   }
if (key=='5') 
{
  lcd.clear(); 
  lcd.print("mode internet");
  m=1;
}
  //////////////////////////
//////////
if (key=='*')

{

  i=5;
   lcd.clear();
  lcd.setCursor(0,0);
  lcd.print("wifi send");
  lcd.setCursor(0,1);
  lcd.print ("temp and humid");
  delay(3000);
}
if(i==5){

    digitalWrite(ledV, 0);
digitalWrite(ledR, 0);
digitalWrite(ledB, 1);


  lcd.clear();
lcd.setCursor(0,0);
lcd.print("Humidite: "); 
 lcd.print(h);
  lcd.print("%");
  lcd.setCursor(0,1);
  lcd.print("Temperature:"); 
  lcd.print(t);
  lcd.print("*C");
  
  
  ser.begin(115200);
    //ser.println("AT+RST"); 
      ser.println("AT+CIOBAUD=9600");
      delay(20);
 // enable software serial
  ser.begin(9600); 
  
  
  
  
  
  String state1=String(t);                 // Converting them to string 
  String state2=String(h);              // as to send it through URL
 String state3=String(sensorValue);
  String cmd = "AT+CIPSTART=\"TCP\",\"";          // Establishing TCP connection
if(m==0){
  c=0;
}
  if (m==1,c==1){
//  ------------------------------------------------------------------------------------------------
  cmd += "184.106.153.149";   // api.thingspeak.com
  cmd += "\",80";                                 // port 80
 
  }
   
   
   else{
   //---------------------------------------------------------------------------------------------
    cmd += "192.168.43.111"; // api.THINGSPEAKSTANDALONE--------------
  cmd += "\",3000";  //--------------port local
 // ------------------------------------------------------------------------------------------------
  
   }
 
  ser.println(cmd);
  
                             // AT+CIPSTART="TCP",184.106.153.149,"80"
  
 //enleve par  moi
 if(ser.find("Error")){
    ser.println("AT+CIPSTART error");
   return;
  }
  
  String getStr = "GET /update?api_key=";    // prepare GET string
  if (m==1,c==1){
  getStr += apiKey;
     c--;
     }
  else {
    getStr += apiKey1;
    c++;
  }

  getStr +="&field1=";
  getStr += String(state1);                       // Temperature Data
  getStr +="&field2=";
  getStr += String(state2);                       // Humidity Data
  //getStr += "\r\n\r\n";
////////////essai//////////
  getStr +="&field3=";
  getStr += String(state3);                       // Humidity terre Data
  getStr += "\r\n\r\n";
  //////////////
  cmd = "AT+CIPSEND=";
  cmd += String(getStr.length());                // Total Length of data
  ser.println(cmd);
 
  if (ser.find(">"))
   {
    ser.println(getStr);
   }
  else{
    ser.println("AT+CIPCLOSE");                  // closing connection
    // alert user
     delay(20);
      }
      if(p==1)
      {
talkback();
      }
           digitalWrite(ledV, 0);
digitalWrite(ledR, 0);
digitalWrite(ledB, 0);
  

}
 

 //String dataString = String(id) + ", " + String(h) + ", " + String(t)+ ", " + String (rtc.getTimeStr()); 
  
    ////////////////////////////////////// 
    
    if(h>=95)
    {
      lcd.clear();
      digitalWrite(ledV, 0);
digitalWrite(ledR, 1);
digitalWrite(ledB, 0);
 lcd.print("alert");
     
  Sim800l.begin(); // initializate the library. 
 text="ALERTE HUMIDITE";  //text for the message. 
  number="0658564..."; //change to a valid number.
   Sim800l.sendSms(number,text);
lcd.clear();
 lcd.print(text);
delay(5000);
      }
      
  }

} 


void interrupt()
{
i=1;
    
}

 
   void talkback()
  {
    //////////////////////// START: POMPE_ON TALKBAK ////////////////////////////
    ser.println("AT+CIPMUX=0\r\n");    // Set MUX=0
    delay(200);                          
      
    // TCP connection 
    String cmd = "AT+CIPSTART=\"TCP\",\"";   // TCP connection with https://thingspeak.com server
    cmd += "184.106.153.149";                // api.thingspeak.com 
    cmd += "\",80\r\n\r\n";                  // Port No. = 80
  
    ser.println(cmd);                    // Send above command to Rx1, Tx1
  
    delay(200);                  
  
    if(ser.find("ERROR"))                // If returns error in TCP Connection
    { 
      Serial.println("AT+CIPSTART error");   // Display error msg to PC
      return; 
    }
  
    // prepare GET string 
    // Replace <TalkBack_ID>, <Command_ID> and <API_Key> by actual values here
    String getStr = "GET /talkbacks/24264/commands/12511276?api_key=CX8DMME15ZE4QP3R\r\n\r\n";  //POMPE_ON Get a TalkBack Command  
  
    // send data length 
    cmd = "AT+CIPSEND="; 
    cmd += String(getStr.length());
    cmd+="\r\n";
  
    ser.println(cmd);                   // Send Data length command to Tx, Rx
  
    delay(100);                             // wait for 0.1 Sec
  
    if(ser.find(">"))                   // If prompt opens //verify connection with cloud
    {
      Serial.println("Request Sent");       // Display confirmation msg to PC
      ser.print(getStr);                // Send GET String to Rx, Tx
    }
    else
    { 
      ser.println("AT+CIPCLOSE");       // Send Close Connection command to Rx1, Tx1
      // alert user 
      Serial.println("Closing Connection"); // Display Connection closed command on PC
    } 
    delay(300);                           
  
  
    String recd="";                         // Received String
  
    if(ser.available()>0)               // Check Buffer
    {
      delay(200);                          // wait for 1 Sec
      while(ser.available())            // Till Buffer is not Empty
      {
        recd+=(char(ser.read()));       // Read the Buffer 
      }
      Serial.println("____________");       // Display msg to PC
      Serial.println("Response: ");         // Display msg to PC
    
      Serial.print(recd);    // Display Received msg to PC
     
    }
    
    if(find_text("POMPE_ON",recd)==1)         // Check if POMPE_ON msg received
      digitalWrite(pompe,HIGH);               // POMPE ON
   if(find_text("POMPE_ON",recd)==1) {
  lcd.clear();
    lcd.print("pompe on");}

 
    //////////////////////// END: POMPE_ON TALKBAK ////////////////////////////
    
    //////////////////////// START: POMPE_OFF TALKBACK ////////////////////////////
    ser.println("AT+CIPMUX=0\r\n");    // Set MUX=0
    delay(200);                         
      
    // TCP connection 
    cmd = "AT+CIPSTART=\"TCP\",\"";          // TCP connection with https://thingspeak.com server
    cmd += "184.106.153.149";                // api.thingspeak.com 
    cmd += "\",80\r\n\r\n";                  // Port No. = 80
  
    ser.println(cmd);                    // Send above command to Rx, Tx
  
    delay(200);                             
  
    if(ser.find("ERROR"))                // If returns error in TCP Connection
    { 
      Serial.println("AT+CIPSTART error");   // Display error msg to PC
      return; 
    }
  
    // prepare GET string 
    // Replace <TalkBack_ID>, <Command_ID> and <API_Key> by actual values here
    getStr = "GET /talkbacks/24264/commands/12430486?api_key=CX8DMME15ZE4QP3R\r\n\r\n";   //POMPE_OFF Get a TalkBack Command  
  
    // send data length 
    cmd = "AT+CIPSEND="; 
    cmd += String(getStr.length());
    cmd+="\r\n";
  
    ser.println(cmd);                   // Send Data length command to Tx1, Rx1
  
    delay(100);                             // wait for 0.1 Sec
  
    if(ser.find(">"))                   // If prompt opens //verify connection with cloud
    {
      Serial.println("Request Sent");       // Display confirmation msg to PC
      ser.print(getStr);                // Send GET String to Rx1, Tx1
    }
    else
    { 
      ser.println("AT+CIPCLOSE");       // Send Close Connection command to Rx1, Tx1
      // alert user 
      Serial.println("Closing Connection"); // Display Connection closed command on PC
    } 
    delay(300);                        
  
  
    recd="";                                // Received String
  
    if(ser.available()>0)               // Check Buffer
    {
      delay(200);                          // wait for 1 Sec
      while(ser.available())            // Till Buffer is not Empty
      {
        recd+=(char(ser.read()));       // Read the Buffer 
      }
      Serial.println("____________");       // Display msg to PC
      Serial.println("Response: ");         // Display msg to PC
    
      Serial.print(recd);                   // Display Received msg to PC
   
    }
    
          
    if(find_text("POMPE_OFF",recd)==1)        // Check if POMPE_OFF msg received
      digitalWrite(pompe,LOW);                // POMPE OFF
if(find_text("POMPE_OFF",recd)==1){
  lcd.clear();
    lcd.print("pompe off");}
    //////////////////////// END: POMPE_OFF TALKBAK ////////////////////////////
      
    delay(200);  
 }
  
  int find_text(String sr, String recd)      //function to serach a Substring in Received msg
  {
    int foundpos = -1;
    for (int i = 0; (i < recd.length() - sr.length()); i++) 
    {
      if (recd.substring(i,sr.length()+i) == sr) 
      {
        foundpos = 1;
      }
    }
    return foundpos;
  }

Credits

nassim sehad

1 project • 6 followers

I'am a Network and telecom student

Thanks to SEHAD_NASSIM_USTHB.

Smart Communicating Irrigation System