#include <WiFi.h>
#include <ArduinoJson.h>
#include "PubSubClient.h"
const char * MQTTServer = "broker.emqx.io";
const char * MQTT_Topic1 = "ontap/xanh";
const char * MQTT_Topic2 = "ontap/vang";
const char * MQTT_Topic3 = "ontap/do";
const char * MQTT_ID = "77fb8fe3-bc81-44ef-ac7b-44db8b837617";
int Port = 1883;
WiFiClient espClient;
PubSubClient client(espClient);
String stMessage;
String pass = "";
const int l_xanh = 13;
const int l_vang = 26;
const int l_do = 32;
String tg_xanh="";
String tg_vang="";
String tg_do="";
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_Topic1);
Serial.print(" connected");
client.subscribe(MQTT_Topic1);
client.subscribe(MQTT_Topic2);
client.subscribe(MQTT_Topic3);
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: ");
stMessage = "";
for (int i = 0; i < length; i++) {
Serial.print((char)message[i]);
stMessage += (char)message[i];
}
if (strcmp(topic, MQTT_Topic1) == 0) {
Serial.print("xanh: ");
Serial.println(stMessage);
tg_xanh = stMessage;
}
if (strcmp(topic, MQTT_Topic2) == 0) {
Serial.print("vang: ");
Serial.println(stMessage);
tg_vang = stMessage;
}
if (strcmp(topic, MQTT_Topic3) == 0) {
Serial.print("do: ");
Serial.println(stMessage);
tg_do = stMessage;
}
}
void setup() {
Serial.begin(115200);
WIFIConnect();
client.setServer(MQTTServer, Port);
client.setCallback(callback);
pinMode(l_xanh, OUTPUT);
pinMode(l_vang, OUTPUT);
pinMode(l_do, OUTPUT);
}
void pushPass(){
// JsonDocument doc;
// doc["pass"] = pass;
// String payload = "";
// serializeJson(doc, payload);
// // String payload = "{\"pass\":" + pass + "}";
// client.publish(MQTT_Topic1, payload.c_str());
// pass = "";
}
void loop() {
delay(10);
if (!client.connected()) {
MQTT_Reconnect();
}
int tt_xanh = digitalRead(l_xanh);
int tt_vang = digitalRead(l_vang);
int tt_do = digitalRead(l_do);
float tg_xanh_g = tg_xanh.toFloat() *1000;
float tg_vang_g = tg_vang.toFloat() *1000;
float tg_do_g = tg_do.toFloat() *1000;
digitalWrite(l_xanh, HIGH);
delay(tg_xanh_g);
digitalWrite(l_xanh, LOW);
digitalWrite(l_vang, HIGH);
delay(tg_vang_g);
digitalWrite(l_vang, LOW);
digitalWrite(l_do, HIGH);
delay(tg_do_g);
digitalWrite(l_do, LOW);
client.loop();
}
/*
<!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>
</head>
<body>
<div>
<label for="">Thời gian đèn xanh bật (đơn vị là giây)</label>
<br>
<input type="text" id="led_xanh" name="led_xanh" required>
<br>
<label for="">Thời gian đèn vàng bật (đơn vị là giây)</label>
<br>
<input type="text" id="led_vang" name="led_vang" required>
<br>
<label for="">Thời gian đèn đỏ bật (đơn vị là giây)</label>
<br>
<input type="text" id="led_do" name="led_do" required>
<br>
<br>
<label for=""><p id="tb"></p></label>
<br>
<button class="btn">Lưu</button>
<br>
<label for=""><p id="tb"></p></label>
</div>
<script>
$(".btn").click(function () {
var ledxanh = $('#led_xanh').val();
var ledvang = $('#led_vang').val();
var leddo = $('#led_do').val();
console.log(ledxanh);
if (ledxanh) {
var message = new Paho.MQTT.Message(ledxanh);
message.destinationName = "ontap/xanh";
client.send(message);
}
if (ledvang) {
var message = new Paho.MQTT.Message(ledvang);
message.destinationName = "ontap/vang";
client.send(message);
}
if (leddo) {
var message = new Paho.MQTT.Message(leddo);
message.destinationName = "ontap/do";
client.send(message);
}
});
client = new Paho.MQTT.Client("broker.emqx.io", Number(8083), "21004274");
client.onConnectionLost = onConnectionLost;
client.onMessageArrived = onMessageArrived;
client.connect({ onSuccess: onConnect });
function onConnect() {
console.log("onConnect");
client.subscribe("ontap/xanh");
client.subscribe("ontap/vang");
client.subscribe("ontap/do");
}
function onConnectionLost(responseObject) {
if (responseObject.errorCode !== 0) {
console.log("onConnectionLost:" + responseObject.errorMessage);
}
}
function onMessageArrived(message) {
// let pass, mkht, Message;
// try {
// let payload = JSON.parse(message.payloadString);
// pass = payload.pass;
// } catch (e) {
// return;
// }
// mkht = $(".mkht").text();
// if (pass && pass.toString() === mkht) {
// $("#tb").text("Thao tác thành công, ESP32 đã nhận dữ liệu");
// Message = new Paho.MQTT.Message("thanhcong");
// } else {
// $("#tb").text("Thao tác thất bại");
// Message = new Paho.MQTT.Message("thatbai");
// }
// Message.destinationName = "Nghi/keypad";
// client.send(Message);
}
</script>
</body>
</html>
*/