-
Notifications
You must be signed in to change notification settings - Fork 1
/
NodeMCU_LEDwithDHT11.cpp
165 lines (160 loc) · 4.83 KB
/
NodeMCU_LEDwithDHT11.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
#include <Arduino.h>
#include <ArduinoJson.h>
#include <DHT.h>
#include <DHT_U.h>
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#define DHTTYPE DHT11 // DHT 11
#define dht_dpin 0
DHT dht(dht_dpin, DHTTYPE);
/* define port */
WiFiClient espClient;
PubSubClient client(espClient);
/* WIFI settings */
const char* ssid = "WifiName";
const char* password = "WifiPassword";
String DEVICE_SERIAL = "DeviceSerialNo";
//Backend credentials
const char* mqtt_server = "MQTT Serevername"; //mqtt.exampledomain.com
char* EVENT_TOPIC = "lolinnodemcuv3v5/common";
String SUB_TOPIC_STRING = "+/" + DEVICE_SERIAL + "/SUBTOPIC/sub";
String PUB_TOPIC_STRING = "/" + DEVICE_SERIAL + "/PUBTOPIC/pub";
char msg[1024];
String data = "";
String actionData = "";
int actionParameter1;
int actionParameter2;
//====================================================Connecting to Wifi
void setup_wifi() {
delay(10);
// We start by connecting to a WiFi network
Serial.println();
Serial.print("Connecting to ");
Serial.println(ssid);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
randomSeed(micros());
Serial.println("");
Serial.println("WiFi connected");
Serial.println("IP address: ");
Serial.println(WiFi.localIP());
//=====================================================MQTT
}
//receiving a message
void callback(char* topic, byte* payload, long length) {
yield();
delay(300);
for (int i = 0; i < length; i++) {
msg[i] = NULL;
}
Serial.print("Message arrived [");
Serial.print(SUB_TOPIC_STRING);
Serial.print("] ");
//NodeMCU.print("L1:");
for (int i = 0; i < length; i++) {
msg[i] = (char)payload[i];
Serial.print(msg[i]);
//NodeMCU.print(msg[i]);
}
// NodeMCU.println();
// delay(3000);
StaticJsonBuffer<800> jsonBuffer;
JsonObject& root = jsonBuffer.parseObject(msg);
if (strcmp(root["action"], "turnOn") == 0) {
actionParameter1 = (int)root["param"]["intensity"];
analogWrite(D1, actionParameter1);
}
else if (strcmp(root["action"], "turnOff") == 0) {
analogWrite(D1, 0);
//actionParameter2 = root["param"]["msg"].as<String>();
}
else if(strcmp(root["action"], "deviceStatus") == 0) {
//OK action is success. Let's report this to backend
//Let's derive the unique ID of the received action message
String topicStr(topic);
String uniqueID = topicStr.substring(0, topicStr.indexOf('/'));
//Let's add this unique ID to pub topic of the device
String pubtopic = uniqueID + PUB_TOPIC_STRING;
//Publish the response message to backend
char* pubmsg = "{\"deviceStatus\":\"OK\"}\"";
client.publish(pubtopic.c_str(), pubmsg);
Serial.println("");
Serial.println("Response published to:");
Serial.print(pubtopic);
}
Serial.println(data);
Serial.println();
yield();
}
void reconnect() {
// Loop until we're reconnected
while (!client.connected()) {
Serial.print("Attempting MQTT connection...");
// Create a random client ID
String clientId = "ESP8266Client-";
clientId += String(random(0xffff), HEX);
// Attempt to connect
if (client.connect(clientId.c_str(), "MQTTUSERNAME", "MQTTPASSWORD")) {
Serial.println("connected");
//subscribe to the topic
const char* SUB_TOPIC = SUB_TOPIC_STRING.c_str();
client.subscribe(SUB_TOPIC);
} else {
Serial.print("failed, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
// Wait 5 seconds before retrying
delay(5000);
}
}
}
void publish_message(const char* message) {
Serial.println(message);
client.publish(EVENT_TOPIC, message);
}
void readSensorValues(){
float h = dht.readHumidity();
float t = dht.readTemperature();
String message = "{\"eventName\":\"getInfo\",\"status\":\"none\",\"eventparams\":{\"humidity\":\"" + String(h) + "\",\"temperature\":\"" + String(t) + "\"},\"id\":\""+ DEVICE_SERIAL +"\"}";
char* msg = (char*)message.c_str();
publish_message(msg); //send the event to backend
//Serial.println(message);
}
void send_event() {
//Should call publish_message() function to send events. Pass your message as parameter
publish_message(msg);
}
void setup() {
// put your setup code here, to run once:
Serial.begin(9600);
pinMode(D1, OUTPUT);
setup_wifi();
client.setServer(mqtt_server, 1883);
client.setCallback(callback);
dht.begin();
Serial.println("Humidity and temperature\n\n");
}
void loop() {
// put your main code here, to run repeatedly:
if (WiFi.status() != WL_CONNECTED) {
setup_wifi();
}
if (WiFi.status() == WL_CONNECTED && !client.connected()) {
reconnect();
}
/*float h = dht.readHumidity();
float t = dht.readTemperature();
Serial.print("Current humidity = ");
Serial.print(h);
Serial.print("% ");
Serial.print("temperature = ");
Serial.print(t);
Serial.println("C ");
delay(800);*/
readSensorValues();
delay(10000);
client.loop();
}