Skip to content

Instantly share code, notes, and snippets.

@pinitsaya pinitsaya/SOIL.ino Secret
Last active Aug 29, 2015

Embed
What would you like to do?
// 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) {
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.