#include <WiFi.h>
#include "PubSubClient.h"
const char * MQTTServer = "broker.emqx.io";
const char* leds = "dengiaothong";
// Tạo ID ngẫu nhiên tại: https://www.guidgen.com/
const char * MQTT_ID = "f331fd64-15b6-4e57-a847-074b1bfa061f";
int Port = 1883;
WiFiClient espClient;
PubSubClient client(espClient);
const int ledPins[] = {5,17,16};
unsigned long timeLed[] = {0, 0, 0};
unsigned long nextLedChange = 0; // Thời điểm tiếp theo cần thay đổi đèn
int ledIndex = 0; // Chỉ số của đèn hiện tại
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(leds);
Serial.println(" connected");
client.subscribe(leds);
Serial.println("");
} 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: ");
char strMessage[length + 1];
for (int i = 0; i < length; i++) {
strMessage[i] = (char)message[i];
}
strMessage[length] = '\0';
String strPayload = String(strMessage);
Serial.println(strPayload);
int firstSemiColon = strPayload.indexOf(';');
int secondSemiColon = strPayload.indexOf(';', firstSemiColon + 1);
// Cập nhật thời gian hoạt động cho mỗi đèn
timeLed[0] = strPayload.substring(0, firstSemiColon).toInt();
timeLed[1] = strPayload.substring(firstSemiColon + 1, secondSemiColon).toInt();
timeLed[2] = strPayload.substring(secondSemiColon + 1).toInt();
// Send back a confirmation message to the web application
String confirmation = String("LED1: ") + timeLed[0] + "s, LED2: " + timeLed[1] + "s, LED3: " + timeLed[2] + "s";
client.publish(leds, confirmation.c_str());
}
void setup() {
// put your setup code here, to run once:
Serial.begin(115200);
WIFIConnect();
client.setServer(MQTTServer, Port);
client.setCallback(callback);
for (int i = 0; i < 3; i++) {
pinMode(ledPins[i], OUTPUT);
}
}
void loop() {
if (!client.connected()) {
MQTT_Reconnect();
}
client.loop();
// Kiểm tra nếu có thời gian cho đèn được cập nhật
if (timeLed[0] > 0 || timeLed[1] > 0 || timeLed[2] > 0) {
for (int i = 0; i < 3; i++) {
digitalWrite(ledPins[i], HIGH); // Bật đèn hiện tại
delay(timeLed[i] * 1000); // Chờ thời gian cài đặt cho đèn hiện tại
digitalWrite(ledPins[i], LOW); // Tắt đèn hiện tại
// Reset thời gian cho đèn sau khi đã sử dụng
timeLed[i] = 0;
}
}
}
/*
<!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">
<title>Led</title>
</head>
<body>
<div class="container">
<div class="group">
<h2>Thời gian đèn xanh bật (đơn vị giây)</h2>
<input type="number" id="led1">
</div>
<div class="group">
<h2>Thời gian đèn vàng bật (đơn vị giây)</h2>
<input type="number" id="led2">
</div>
<div class="group">
<h2>Thời gian đèn đỏ bật (đơn vị giây)</h2>
<input type="number" id="led3">
</div>
<button type="submit" id="btnLed" style="background-color: red; color: white; width:100px; margin-top:50px;">Lưu</button>
<div id="statusMessage" style="margin-top: 50px ;"></div>
</div>
<script src="https://unpkg.com/mqtt/dist/mqtt.min.js"></script>
<script>
const client = mqtt.connect('ws://broker.emqx.io:8083/mqtt');
client.on('connect', function() {
console.log('Connected to MQTT broker');
});
document.getElementById('btnLed').addEventListener('click', function() {
let led1 = document.getElementById('led1').value || 0;
let led2 = document.getElementById('led2').value || 0;
let led3 = document.getElementById('led3').value || 0;
let mess = `${led1};${led2};${led3}`;
client.publish('IoT/leds',mess);
document.getElementById('statusMessage').innerHTML = 'Thao tác thành công';
});
</script>
</body>
</html>
*/
/*
import mysql.connector
import paho.mqtt.client as mqtt
# Kết nối tới cơ sở dữ liệu MySQL
mydb = mysql.connector.connect(
host="localhost",
user="root",
password="", # Thay bằng mật khẩu của bạn
database="ptiot6"
)
def maintain_table_limit(table_name):
try:
mycursor = mydb.cursor()
mycursor.execute(f"SELECT COUNT(*) FROM {table_name}")
row_count = mycursor.fetchone()[0]
if row_count > 20:
num_rows_to_delete = row_count - 20
mycursor.execute(f"DELETE FROM {table_name} ORDER BY id LIMIT {num_rows_to_delete}")
mydb.commit()
print(f"{num_rows_to_delete} old rows deleted from {table_name}.")
except mysql.connector.Error as err:
print("Error: {}".format(err))
mydb.rollback()
# Hàm được gọi khi kết nối tới MQTT broker
def on_connect(client, userdata, flags, rc):
print("Connected with result code " + str(rc))
# Đăng ký MQTT topic
client.subscribe("DHTSQL") # Đăng ký topic dữ liệu cảm biến
# Hàm được gọi khi nhận được tin nhắn từ MQTT topic
def on_message(client, userdata, msg):
mess = str(msg.payload.decode("utf-8"))
print(msg.topic + " " + mess)
mycursor = mydb.cursor()
# Xử lý dữ liệu từ topic DHTSQL
if msg.topic == "DHTSQL":
try:
# Giả sử dữ liệu gửi về theo định dạng "NhietDo|DoAm"
data = mess.split("|")
nhietdo = float(data[0]) # Nhiệt độ
doam = float(data[1]) # Độ ẩm
# Chèn dữ liệu vào bảng `cambien`
sql = "INSERT INTO cambien (NhietDo, DoAm) VALUES (%s, %s)"
val = (nhietdo, doam)
maintain_table_limit("cambien") # Giữ giới hạn 20 hàng
mycursor.execute(sql, val)
mydb.commit()
print("NhietDo và DoAm đã được lưu vào bảng cambien.")
except (ValueError, IndexError) as parse_err:
print(f"Lỗi phân tích dữ liệu: {parse_err}")
except mysql.connector.Error as db_err:
print(f"Lỗi MySQL: {db_err}")
mydb.rollback()
if msg.topic == "LED/Status":
try:
# Giả sử dữ liệu gửi về theo định dạng "NhietDo|DoAm"
data = mess.split("|")
battat = float(data[0]) # Nhiệt độ
# Độ ẩm
# Chèn dữ liệu vào bảng `cambien`
sql = "INSERT INTO cambien (battat) VALUES (%s)"
val = (battat)
maintain_table_limit("cambien") # Giữ giới hạn 20 hàng
mycursor.execute(sql, val)
mydb.commit()
print("battat đã được lưu vào bảng cambien.")
except (ValueError, IndexError) as parse_err:
print(f"Lỗi phân tích dữ liệu: {parse_err}")
except mysql.connector.Error as db_err:
print(f"Lỗi MySQL: {db_err}")
mydb.rollback()
# Tạo MQTT client
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
# Kết nối tới MQTT broker
client.connect("broker.emqx.io", 1883, 60)
# Lắng nghe dữ liệu từ MQTT broker
client.loop_forever()
https://wokwi.com/makers/baothanngg
tuanlam01
khanhduytran2012
haiquan22
minhtri27
khoahocmaytinh
[email protected]
thanhvinh!115:42/-strong/-heart:>:o:-((:-h T6 06/12/2024
https://wokwi.com/makers/huuthocse*/
/*
https://github.com/HuuThoCSE/PTIoT/blob/main/PTIoT_Midterm/INDEX.md
*/