IOT Project: Integrated Sprinker System

// This #include statement was automatically added by the Particle IDE.
#include <Adafruit_DHT.h>

// This #include statement was automatically added by the Particle IDE.
#include <ThingSpeak.h>

// This example assumes the sensor to be plugged into CONN2
#define DHTPIN D6     // what pin we're connected to

// Here we define the type of sensor used
#define DHTTYPE DHT11        // DHT 11 

DHT dht(DHTPIN, DHTTYPE);

bool humid = false;

int waterSens = A0; //define water sensor analog input
int waterVal; //define the water sensor raw input value
float waterInch; //define the water sensor output value in inches
float rawlevel; //define the water sensor raw output value
int Switchstate = 0; //A variable that holds the current state of the sprinkler relay
int Laststate = 0; //A variable that holds the last state of the sprinkler relay
int led1 = D7; //A variable for the LED output

TCPClient client;

unsigned long myChannelNumber =2031349;
const char * myWriteAPIKey ="IHTJSGLV24XX4MEL";
const char * myReadAPIKey ="XZP2TVGFZSTAJO1Z";

void setup() {
    
    Serial.begin(19200); //Start Serial output at 19200 baudrate
    dht.begin(); //Start DHT11 Sensor
    pinMode(waterSens, INPUT);//set water sensor as an input
    ThingSpeak.begin(client); //Start Thinkgspeak client
    
    pinMode(led1, OUTPUT);

    Particle.subscribe("Card detected", Activation, MY_DEVICES); //When "Card detected" is published, run the relayon function. Triggered from Argon 1
    Particle.subscribe("Relay", Relay, MY_DEVICES); //When "Relay" is published, run the relayon function. Data from Argon 3

}

void loop() {
    
    // Reading temperature or humidity takes about 250 milliseconds
    // Sensor readings may also be up to 2 seconds 
    // Read humidity
    float h1 = dht.getHumidity();
    // Read temperature as Farenheit
    float f1 = dht.getTempFarenheit();

    Serial.print(dht.getHumidity());
    Serial.println("h1");
    Serial.print(dht.getTempFarenheit());
    Serial.println("f1");
    
     if (isnan(h1) || isnan(f1)) {
         Serial.println("Failed to read from DHT sensor!");
        return;
    }

    Particle.publish("Temp", String(f1), ALL_DEVICES);
    Particle.publish("Humidity",String(h1), ALL_DEVICES);

    waterVal = analogRead(waterSens); //read the water sensor

    waterInch = 0.00039139*waterVal; //Calculate water level in inches from analog value

    Serial.println("waterInch");
    String level = String(waterInch);
    String rawlevel = String(waterVal);
    Particle.publish("Water", level, ALL_DEVICES);
    Particle.publish("RawWater", rawlevel, ALL_DEVICES);

    ThingSpeak.setField(1,f1); //Primes Temperature data for ThingSpeak
    ThingSpeak.setField(2,h1); //Primes Humidity data for ThingSpeak
    ThingSpeak.setField(3,waterInch); //Primes Water Level data for ThingSpeak
    ThingSpeak.writeFields(myChannelNumber, myWriteAPIKey); //sends my data to thingspeak
    
    delay(1800000);

}

//Declare functions here

void Activation(const char *topic, const char *data) //subscribe data retreival for Card detected from Argon 1
{
    Serial.println("Activation Requested");
    Particle.publish("Activation Requested");
}

void Relay(const char *topic, const char *data) //subscribe data retreival for Sprinkler Relay State from Argon 3
{ 
   Switchstate = String(data).toInt(); //convert subscribe data to int
    if (Switchstate == 1 && Laststate == 0)
    {
        digitalWrite(led1, HIGH);
        Laststate = Switchstate;
        Serial.println(Switchstate);
        Serial.println(Laststate);
        Serial.println("Its on!");
    }
    else if (Switchstate == 0 && Laststate == 1)
    {
        digitalWrite(led1, LOW);
        Laststate = Switchstate;
        Serial.println(Switchstate);
        Serial.println(Laststate);
        Serial.println("Its off!");
    }
}

// This #include statement was automatically added by the Particle IDE.
#include <ThingSpeak.h>

//Enable code to start running before connecting to the web
SYSTEM_THREAD(ENABLED);

//Declare variables here
int led1 = D7;
int Relay = D0; //Valve trigger
int Relay2 = D1; //Valve reset
int Relay3 = D2; //Power supply
int Switchstate = 0; //a variable that will hold the current switch state
int tempdata = 0;
int waterdata = 0;

TCPClient client;

unsigned long myChannelNumber =2031349;
const char * myWriteAPIKey ="IHTJSGLV24XX4MEL";
const char * myReadAPIKey ="XZP2TVGFZSTAJO1Z";

void setup ()
{
//Start Serial Coms
Serial.begin(19200);

//Start Thinkgspeak client
ThingSpeak.begin(client); 

//Declare variables inputs, outputs
pinMode(led1, OUTPUT);
pinMode(Relay, OUTPUT);
pinMode(Relay2, OUTPUT);
pinMode(Relay3, OUTPUT);

//Declare subscription and function
Particle.subscribe("Card detected", Relayon, MY_DEVICES); //When "Card detected" is published, run the relayon function. Triggered from Argon 1
Particle.subscribe("Temp", f1, MY_DEVICES); //When "Temp" is published, run the relayon function. Data sent from Argon 2.
Particle.subscribe("RawWater", level, MY_DEVICES); //When "Water" is published, run the relayon function. Data sent from Argon 2.


}

void loop()
{

    Serial.println(tempdata);
    Particle.publish("tempdata", String(tempdata), ALL_DEVICES);
    Particle.publish("waterdata", String(waterdata), ALL_DEVICES);
    
    delay(600000);
    
}

//Declare functions here
void Relayon(const char *topic, const char *data)
{
   if (tempdata >= 20 && waterdata <= 2400)
   {
    Particle.publish("Relay On");
    Switchstate = 1;
    Particle.publish("Relay", String(Switchstate), ALL_DEVICES);
    ThingSpeak.setField(4,Switchstate); //Primes Sprinkler data for ThingSpeak
    ThingSpeak.writeFields(myChannelNumber, myWriteAPIKey); //sends my data to thingspeak
    digitalWrite(led1, HIGH); //Turns on LED to indicate the sprinkler output is triggered
    digitalWrite(Relay3, HIGH); //Turn on Power for the sprinkler output
    delay(5000); //Pause for 5 second
    digitalWrite(Relay3, LOW); //Power relay off
    digitalWrite(Relay, HIGH); //Flip solenoid wire polarity
    digitalWrite(Relay2, HIGH); //Flip solenoid wire polarity
    delay(1000); //Pause for 1 second
    digitalWrite(Relay3, HIGH); //Turn on Power for the sprinkler output
    delay(1000); //Pause for 1 second
    digitalWrite(Relay3, LOW); //Power relay off
    digitalWrite(Relay, LOW); //Flip solenoid wire polarity
    digitalWrite(Relay2, LOW); //Flip solenoid wire polarity
    Particle.publish("Relay Off");
    Switchstate = 0;
    Particle.publish("Relay", String(Switchstate), ALL_DEVICES);
    ThingSpeak.setField(4,Switchstate); //Primes Sprinkler data for ThingSpeak
    ThingSpeak.writeFields(myChannelNumber, myWriteAPIKey); //sends my data to thingspeak
    
    return;
   }
   else if (waterdata > 2400)
   {
     Particle.publish("Water level too high for sprinkler!");  
   }
   else
   {
     Particle.publish("Too cold for sprinkler!");  
   }
   
   

}

void f1(const char *topic, const char *data) //subscribe data retreival for temperature from Argon 2
{ 
    
    tempdata = String(data).toInt(); //convert subscribe data to int
    Serial.println(tempdata);
    
    }
    
void level(const char *topic, const char *data) //subscribe data retreival for water level from Argon 2
{ 
    
    waterdata = String(data).toInt(); //convert subscribe data to int
    Serial.println(waterdata);
    
    }