// Libraries

#include <ESP8266WiFi.h>

#include <PubSubClient.h>

#include "DHT.h"

 

int value;

String pumpstate = "";

// Credentials

String deviceId     = "xxxxxxxxxxxxxxxxx";             // * set your device id (will be the MQTT client username)

String deviceSecret = "xxxxxxxxxxxxxxxxxxxxxxxxxx";         // * set your device secret (will be the MQTT client password)

String clientId     = "soil moisture sensor";             // * set a random string (max 23 chars, will be the MQTT client id)

 

// WiFi name & password

const char* ssid = "HOM"; //NAME WIFI

const char* password = "Gravitech2014"; //PASSWORD WIFI

 

// Topics

String outTopic     = "devices/" + deviceId + "/set"; // * MQTT channel where physical updates are published

String inTopic      = "devices/" + deviceId + "/get"; // * MQTT channel where lelylan updates are received

 

// WiFi client

WiFiClient wifiClient;

 

// Pin & type

#define PIN_VCC 16

#define PIN_GND 13

#define DHTPIN  14

#define DHTTYPE DHT22

 

// Initialize DHT sensor

DHT *dht;

 

// MQTT server address

IPAddress server(178, 62, 108, 47);

 

// MQTT

PubSubClient client(server);

 

 

void setup() {

  Serial.begin(115200);

  delay(500);

  pinMode(4,OUTPUT);

  

  pinMode(PIN_VCC, OUTPUT);

  pinMode(PIN_GND, OUTPUT);

  digitalWrite( PIN_VCC, HIGH );

  digitalWrite( PIN_GND, LOW );

 

  dht = new DHT( DHTPIN, DHTTYPE, 15 );

  dht->begin();

 

  // Connect to WiFi

  Serial.println();

  Serial.println();

  Serial.print("Connecting to ");

  Serial.println(ssid);

  

  WiFi.begin(ssid, password);

  

  while (WiFi.status() != WL_CONNECTED) {

    delay(500);

    Serial.print(".");

  }

  Serial.println("");

  Serial.println("WiFi connected");  

  Serial.println("IP address: ");

  Serial.println(WiFi.localIP());

 

  lelylanConnection();      // MQTT server connection

}

 

void loop() {

 

  // Keep connection open

  lelylanConnection();

  

  // Reading temperature and humidity

 // int h = dht->readHumidity();

  

  // Read temperature as Celsius

 int t = dht->readTemperature();

   

   value = analogRead(A0); //Read analog signal

  Serial.println(value); //Print value to Serial Port

  delay(1000); //delay for 1 second

 

 if (value > 800) // ถ้าค่าอุณหภูมิมากกว่า 800 ให้สั่งการไปยัง RELAY เปิด

 { digitalWrite(4, LOW);

   pumpstate = "open";

  }

 

 else { digitalWrite(4, HIGH); //ถ้าค่าอุณหภูมิน้อยกว่า 800 ให้สั่งการไปยัง RELAY ปิด

  pumpstate = "close";

  }

 

  // Messages for MQTT

  String humidity = "{\"properties\":[{\"id\":\"559ccfc7b4f3840925000009\",\"value\":\"" + String(t) + "\"}]}";

  String temperature = "{\"properties\":[{\"id\":\"55a0ea7f68969a79af000008\",\"value\":\"" + String(value) + "\"}]}";

   String pump = "{\"properties\":[{\"id\":\"55a0ea9368969a81a6000004\",\"value\":\"" + pumpstate + "\"}]}"; //ส่งค่าสถานะ RELAY แปลงเป็น STRING ขึ้นเว็บ LELYLAN

 

  // Publish temperature

  client.publish(outTopic, (char *) temperature.c_str());

  delay(1000);

  

  // Publish humidity

  client.publish(outTopic, (char *) humidity.c_str());

  delay(1000);

 

   client.publish(outTopic, (char *) pump.c_str());

  delay(1000);

 

  

  

}

 

/* MQTT server connection */

void lelylanConnection() {

  // add reconnection logics

  if (!client.connected()) {

    // connection to MQTT server

    if (client.connect(MQTT::Connect(clientId)

               .set_auth(deviceId, deviceSecret))) {

      Serial.println("[PHYSICAL] Successfully connected with MQTT");

      lelylanSubscribe(); // topic subscription

    }

  }

  client.loop();

}

 

/* MQTT subscribe */

void lelylanSubscribe() {

  client.subscribe(inTopic);

}

 

/* Receive Lelylan message and confirm the physical change */

void callback(char* topic, byte* payload, unsigned int length) {

 

}