#include <DHT.h>
#include <WiFi.h>
#include "PubSubClient.h"
#include <LiquidCrystal_I2C.h>
LiquidCrystal_I2C lcd(0x27, 16, 2);
DHT dht(16, DHT22);
float temperature;
float humidity;
float temperatures[3];
int currentIndex = 0; // Chỉ số hiện tại trong mảng
float Max_ht = temperatures[0], Min_ht = temperatures[0];
const char * MQTTServer = "broker.hivemq.com";
const char * MQTT_Topic = "pt/nhietdo";
const char * MQTT_Topic1 = "pt/doam";
const char * MQTT_ID = "mqttx_7e7c4ab4";
int Port = 1883;
WiFiClient espClient;
PubSubClient client(espClient);
void WIFIConnect() {
Serial.println("Connecting to SSID: Wokwi-GUEST");
WiFi.begin("Wokwi-GUEST", "");
while (WiFi.status() != WL_CONNECTED) {
delay(500);
// Serial.print(".");
}
Serial.println("");
Serial.print("WiFi connected");
Serial.print(", IP address: ");
Serial.println(WiFi.localIP());
}
void MQTT_Reconnect() {
while (!client.connected()) {
if (client.connect(MQTT_ID)) {
Serial.print("MQTT Topic: ");
Serial.print(MQTT_Topic);
Serial.println(" connected");
//để nhận dữ liệu từ web
} else {
Serial.print("failed, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
delay(5000);
}
}
}
void callback(char* topic, byte* message, unsigned int length) {
Serial.print("Message arrived on topic: ");
Serial.println(topic);
Serial.print("Message: ");
String stMessage;
for (int i = 0; i < length; i++) {
Serial.print((char)message[i]);
stMessage += (char)message[i];
}
Serial.println();
}
void setup() {
Serial.begin(9600);
pinMode(18, OUTPUT);
dht.begin();
WIFIConnect();
lcd.init();
lcd.backlight();
client.setServer(MQTTServer, Port);
client.setCallback(callback);
}
void loop() {
temperature = dht.readTemperature(true);
humidity = dht.readHumidity();
if (!client.connected()) {
MQTT_Reconnect();
}
client.loop();
String a = String(temperature);
String b = String(humidity);
Serial.println("Nhiệt độ: ");
Serial.println(temperature);
Serial.println("Độ ẩm: ");
Serial.println(humidity);
lcd.setCursor(0, 0);
lcd.print("ND");
lcd.setCursor(5, 0);
lcd.print(temperature);
lcd.setCursor(0, 1);
lcd.print("DA");
lcd.setCursor(5, 1);
lcd.print(humidity);
// Lưu giá trị vào mảng
temperatures[currentIndex] = temperature;
currentIndex = (currentIndex + 1) % 3; // Quay lại 0 sau khi đạt 3
Max_ht = temperatures[0];
Min_ht = temperatures[0];
// Tính trung bình nhiệt độ
float avg_temp = 0;
for (int i = 0; i < 3; i++) {
avg_temp += temperatures[i];
if (Max_ht < temperatures[i]) {
Max_ht = temperatures[i];
}
if (Min_ht > temperatures[i]) {
Min_ht = temperatures[i];
}
}
avg_temp /= 3;
Serial.print("Max: ");
Serial.println(Max_ht);
Serial.print("Min: ");
Serial.println(Min_ht);
Serial.print("Trung binh: ");
Serial.println(avg_temp);
delay(200);
client.publish(MQTT_Topic, a.c_str());
client.publish(MQTT_Topic1, b.c_str());
delay(1000);
}
// <!DOCTYPE html>
// <html lang="en">
// <head>
// <meta charset="UTF-8">
// <meta http-equiv="X-UA-Compatible" content="IE=edge">
// <meta name="viewport" content="width=device-width, initial-scale=1.0">
// <script src="https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.min.js" type="text/javascript"></script>
// <script src="https://code.jquery.com/jquery-3.6.1.min.js" type="text/javascript"></script>
// <title>DHT22 Sensor Data</title>
// <style>
// body {
// font-family: Arial, sans-serif;
// text-align: left;
// }
// #data {
// margin-top: 20px;
// }
// .value {
// font-size: 2em;
// }
// .row {
// display: flex;
// align-items: center;
// }
// .alert {
// color: red;
// margin-left: 10px;
// font-size: 1em;
// }
// </style>
// </head>
// <body>
// <h1>DHT22 Sensor Data</h1>
// <div id="data">
// <p class="row">Temperature: <span id="temperature" class="value">Loading...</span> °C</p>
// <p class="row">Humidity: <span id="humidity" class="value">Loading...</span> % <span id="humidityAlert" class="alert"></span></p>
// <p class="row">Avg: <span id="trungbinh" class="value">Loading...</span> % <span id="avgAlert" class="alert"></span></p>
// <p class="row">Max: <span id="max" class="value">Loading...</span> % <span id="MAX" class="alert"></span></p>
// <p class="row">Min: <span id="min" class="value">Loading...</span> % <span id="MIN" class="alert"></span></p>
// <p>Nhiệt độ lớn hơn: <input type="number" id="setTemp" value="200"><sup>o</sup>C</p>
// </div>
// <div id="time"></div>
// <script>
// var client = new Paho.MQTT.Client("broker.hivemq.com", 8000, "clientId-" + Math.random().toString(36).substring(2, 15));
// client.onConnectionLost = function (responseObject) {
// if (responseObject.errorCode !== 0) {
// console.log("onConnectionLost:" + responseObject.errorMessage);
// }
// };
// client.onMessageArrived = function (message) {
// console.log("onMessageArrived:" + message.destinationName + " - " + message.payloadString);
// if (message.destinationName === "pt/nhietdo") {
// $('#temperature').text(message.payloadString);
// var currentTemp = parseFloat(message.payloadString);
// var setTemp = parseFloat($('#setTemp').val());
// updateLEDStatus(currentTemp, setTemp);
// } else if (message.destinationName === "pt/doam") {
// $('#humidity').text(message.payloadString);
// if (parseFloat(message.payloadString) > 85) {
// $('#humidityAlert').text("Độ ẩm cao!");
// } else {
// $('#humidityAlert').text("");
// }
// }
// else if (message.destinationName === "pt/trungbinh") {
// $('#trungbinh').text(message.payloadString);
// }
// else if (message.destinationName === "pt/max") {
// $('#max').text(message.payloadString);
// }
// else if (message.destinationName === "pt/min") {
// $('#min').text(message.payloadString);
// }
// };
// client.connect({
// onSuccess: function () {
// console.log("Connected to MQTT broker");
// client.subscribe("pt/nhietdo");
// client.subscribe("pt/doam");
// client.subscribe("pt/trungbinh");
// client.subscribe("pt/max");
// client.subscribe("pt/min");
// client.subscribe("VLUTE/LED"); // Thêm chủ đề này để nhận phản hồi từ thiết bị
// },
// useSSL: false,
// timeout: 3,
// onFailure: function (message) {
// console.error("Connection failed: " + message.errorMessage);
// }
// });
// function updateLEDStatus(currentTemp, setTemp) {
// if (currentTemp > setTemp) {
// $('#temperature').addClass('alert');
// var ledOnMessage = new Paho.MQTT.Message("LED_ON");
// ledOnMessage.destinationName = "VLUTE/LED";
// client.send(ledOnMessage);
// } else {
// $('#temperature').removeClass('alert');
// var ledOffMessage = new Paho.MQTT.Message("LED_OFF");
// ledOffMessage.destinationName = "VLUTE/LED";
// client.send(ledOffMessage);
// }
// }
// // Real-time clock
// setInterval(function() {
// var now = new Date();
// document.getElementById("time").innerHTML = "Dữ liệu được cập nhật vào: " + now.toLocaleString();
// }, 1000);
// // Recheck the temperature set point every time the input changes
// $('#setTemp').on('input', function() {
// var currentTemp = parseFloat($('#temperature').text());
// var setTemp = parseFloat($(this).val());
// updateLEDStatus(currentTemp, setTemp);
// });
// // Gửi kèm thông điệp nhiệt độ ngưỡng
// var setTempMessage = new Paho.MQTT.Message("Set Temperature: " + setTemp);
// setTempMessage.destinationName = "VLUTE/SetTemp";
// client.send(setTempMessage);
// </script>
// </body>
// </html>