#include <DHT.h>
#include <WiFi.h>
#include "PubSubClient.h"
DHT dht(4, DHT22);
float temperature;
float humidity;
float temperatures[3]; // Mảng để lưu trữ 3 lần đo nhiệt độ
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 = "nhietdo";
const char * MQTT_Topic1 ="doam";
const char * MQTT_Topic2 ="trungbinh";
const char * MQTT_Topic_Max ="max";
const char * MQTT_Topic_Min ="min";
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.print(" connected");
} else {
Serial.println("failed, rc=");
Serial.println(client.state());
Serial.println(" try again in 5 seconds");
delay(5000);
}
}
}
void setup() {
Serial.begin(9600);
pinMode(32,OUTPUT);
dht.begin();
WIFIConnect();
client.setServer(MQTTServer, Port);
}
void loop() {
temperature = dht.readTemperature();
humidity = dht.readHumidity();
if (!client.connected()) {
MQTT_Reconnect();
}
client.loop();
// Gửi nhiệt độ & độ ẩm lên MQTT Broker
String a = String(temperature);
String b = String(humidity);
Serial.println("Nhiệt độ: ");
Serial.println(temperature);
Serial.println("Độ ẩm: ");
Serial.println(humidity);
// Lưu giá trị vào mảng
temperatures[currentIndex] = temperature;
// 0 -1 2
// max_ht = i[0] =0
// Tăng chỉ số
currentIndex = (currentIndex + 1) % 3; // Quay lại 0 sau khi đạt 3
Max_ht = temperatures[0];
Min_ht = temperatures[0];
// Max_ht = temperatures[0];
// nếu tính max min từ đầu không bỏ trong mảng 3 thì bỏ dòng này
// Tính trung bình nhiệt độ
float avg_temp = 0;
for (int i = 0; i < 3; i++) {
avg_temp += temperatures[i];
}
for (int i = 0; i < 3; i++) {
if(Max_ht < temperatures[i])
{
Max_ht = temperatures[i];
}
}
for (int i = 0; i < 3; i++) {
if(Min_ht > temperatures[i])
{
Min_ht = temperatures[i];
}
}
Serial.print("Max: ");
Serial.println(Max_ht);
Serial.print("Min: ");
Serial.println(Min_ht);
avg_temp /= 3;
Serial.print("Trung binh: ");
Serial.println(avg_temp);
delay(200);
if (avg_temp >40 )
{
digitalWrite(32, HIGH);
delay(500);
digitalWrite(32, LOW);
delay(500);
digitalWrite(32, HIGH);
}
else
{
digitalWrite(32, LOW);
}
String c = String(avg_temp);
String maxx = String(Max_ht);
String minn = String(Min_ht);
client.publish(MQTT_Topic, a.c_str());
client.publish(MQTT_Topic1, b.c_str());
client.publish(MQTT_Topic2, c.c_str());
client.publish(MQTT_Topic_Max, maxx.c_str());
client.publish(MQTT_Topic_Min, minn.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>
// </div>
// <div id="time"></div>
// <div id="trungbinh">
// <!-- <p>NHIỆT ĐỘ TRUNG BÌNH: <span id ="tb" class ="value">Loading...</span></p> -->
// </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 === "nhietdo") {
// $('#temperature').text(message.payloadString);
// } else if (message.destinationName === "doam") {
// $('#humidity').text(message.payloadString);
// if (parseFloat(message.payloadString) > 85) {
// $('#humidityAlert').text("Độ ẩm cao!");
// } else {
// $('#humidityAlert').text("");
// }
// }
// else if (message.destinationName === "trungbinh")
// {
// $('#trungbinh').text(message.payloadString);
// }
// else if (message.destinationName === "max")
// {
// $('#max').text(message.payloadString);
// }else if (message.destinationName === "min")
// {
// $('#min').text(message.payloadString);
// }
// };
// client.connect({
// onSuccess: function () {
// console.log("Connected to MQTT broker");
// client.subscribe("nhietdo");
// client.subscribe("doam");
// client.subscribe("trungbinh");
// client.subscribe("max");
// client.subscribe("min");
// },
// useSSL: false,
// timeout: 3,
// onFailure: function (message) {
// console.error("Connection failed: " + message.errorMessage);
// }
// });
// //THOIGIAN THUC
// var now = new Date();
// document.getElementById("time").innerHTML = "DỮ LIỆU ĐƯỢC CẬP NHÂT VÀO: " + now.toLocaleString();
// </script>
// </body>
// </html>