alex9ufo 聰明人求知心切

2025年4月16日星期三

作業3 WOKWI + Node-Red + SQlite + Line Developer

1)系統圖

(第一次執行node-red 時要先將資料庫 C:\Users\User\ 2025EX2_RFID.db 建立按圖示 <<建立RFID資料庫>>

2)實驗結果

https://www.youtube.com/watch?v=B08TaYfROi0

3)Wokwi Arduino程式

#include <ArduinoMqttClient.h>

#include <WiFi.h>

//MFRC522 程式庫  模擬mfrc522 送出卡號 PB可以控制

int LED1 = 23;

int LED2 = 22;

int LED3 = 21;

int LED4 = 19;

char ssid[]="Wokwi-GUEST";

char pass[]="";

WiFiClient wifiClient;

MqttClient mqttClient(wifiClient);

//const char broker[] = "test.mosquitto.org";

const char broker[] = "broker.mqttgo.io";

//const char broker[] = "broker.mqtt-dashboard.com";

int        port     = 1883;

const char *SubTopic1 = "alex9ufo/esp32/led";

const char *PubTopic2 = "alex9ufo/esp32/led_status";

const char *PubTopic3 = "alex9ufo/esp32/RFID";

const char willTopic[] = "alex9ufo/esp32/Starting";

int inPin = 12;    // pushbutton connected to digital pin 7

int val = 0;      // variable to store the read value

bool create=false;

bool Send = false;  //true

bool Flash1 = false;  //true

bool Flash2 = false;  //true

bool Flash3 = false;  //true

bool Flash4 = false;  //true

String LEDjson = "";

//===========================================================

void onMqttMessage(int messageSize) {

  // we received a message, print out the topic and contents

  Serial.print("Received a message with topic '");

  Serial.print(mqttClient.messageTopic());

  String Topic= mqttClient.messageTopic();

  Serial.print("', duplicate = ");

  Serial.print(mqttClient.messageDup() ? "true" : "false");

  Serial.print(", QoS = ");

  Serial.print(mqttClient.messageQoS());

  Serial.print(", retained = ");

  Serial.print(mqttClient.messageRetain() ? "true" : "false");

  Serial.print("', length ");

  Serial.print(messageSize);

  Serial.println(" bytes:");

  String message="";

  // use the Stream interface to print the contents

  while (mqttClient.available()) {

    //Serial.print((char)mqttClient.read());

    message += (char)mqttClient.read();

}

  Serial.println(message);

  message.trim();

  Topic.trim();

  if (Topic=="alex9ufo/esp32/led") {

  if (message == "led1on") {

    digitalWrite(LED1, HIGH);  // Turn on the LED

    //ledState = true;  //ledState = ture HIGH

    //設定 各個 旗號

    LEDjson ="LED1ON";

    Flash1 = false;

    Flash2 = false;

    Flash3 = false;

    Flash4 = false;

    Send = true ;

    Serial.println(LEDjson);

}

  if (message == "led2on") {

    digitalWrite(LED2, HIGH);  // Turn on the LED

    //ledState = true;  //ledState = ture HIGH

    //設定 各個 旗號

    LEDjson ="LED2ON";

    Flash1 = false;

    Flash2 = false;

    Flash3 = false;

    Flash4 = false;

    Send = true ;

    Serial.println(LEDjson);

}

  if (message == "led3on") {

    digitalWrite(LED3, HIGH);  // Turn on the LED

    //ledState = true;  //ledState = ture HIGH

    //設定 各個 旗號

    LEDjson ="LED3ON";

    Flash1 = false;

    Flash2 = false;

    Flash3 = false;

    Flash4 = false;

    Send = true ;

    Serial.println(LEDjson);

}

  if (message == "led4on") {

    digitalWrite(LED4, HIGH);  // Turn on the LED

    //ledState = true;  //ledState = ture HIGH

    //設定 各個 旗號

    LEDjson ="LED4ON";

    Flash1 = false;

    Flash2 = false;

    Flash3 = false;

    Flash4 = false;

    Send = true ;

    Serial.println(LEDjson);

}

  if (message == "led1off" ) {

    digitalWrite(LED1, LOW); // Turn off the LED

    //ledState = false; //ledState = false LOW

    LEDjson ="LED1OFF";

    Flash1 = false;

    Flash2 = false;

    Flash3 = false;

    Flash4 = false;

    Send = true ;

    Serial.println(LEDjson);

}

  if (message == "led2off" ) {

    digitalWrite(LED2, LOW); // Turn off the LED

    //ledState = false; //ledState = false LOW

    LEDjson ="LED2OFF";

    Flash1 = false;

    Flash2 = false;

    Flash3 = false;

    Flash4 = false;

    Send = true ;

    Serial.println(LEDjson);

}

  if (message == "led3off" ) {

    digitalWrite(LED3, LOW); // Turn off the LED

    //ledState = false; //ledState = false LOW

    LEDjson ="LED3OFF";

    Flash1 = false;

    Flash2 = false;

    Flash3 = false;

    Flash4 = false;

    Send = true ;

    Serial.println(LEDjson);

}

  if (message == "led4off" ) {

    digitalWrite(LED4, LOW); // Turn off the LED

    //ledState = false; //ledState = false LOW

    LEDjson ="LED4OFF";

    Flash1 = false;

    Flash2 = false;

    Flash3 = false;

    Flash4 = false;

    Send = true ;

    Serial.println(LEDjson);

}

  if (message == "led1flash" ) {

    digitalWrite(LED1, HIGH); // Turn off the LED

    Flash1 = true;

    //Flash2 = false;

    //Flash3 = false;

    //Flash4 = false;

    LEDjson ="LED1FLASH";

    Send = true ;  

    Serial.println(LEDjson);      

}

  if (message == "led2flash" ) {

    digitalWrite(LED2, HIGH); // Turn off the LED

    Flash2 = true;

    //Flash1 = false;

    //Flash3 = false;

    //Flash4 = false;

    LEDjson ="LED2FLASH";

    Send = true ;  

    Serial.println(LEDjson);      

}

  if (message == "led3flash" ) {

    digitalWrite(LED3, HIGH); // Turn off the LED

    Flash3 = true;

    //Flash1 = false;

    //Flash2 = false;

    //Flash4 = false;

    LEDjson ="LED3FLASH";

    Send = true ;  

    Serial.println(LEDjson);      

}

  if (message == "led4flash" ) {

    digitalWrite(LED4, HIGH); // Turn off the LED

    Flash4 = true;

    //Flash1 = false;

    //Flash2 = false;

    //Flash3 = false;

    LEDjson ="LED4FLASH";

    Send = true ;  

    Serial.println(LEDjson);      

}

  if (message == "ledalloff" ) {

    digitalWrite(LED1, LOW); // Turn off the LED

    digitalWrite(LED2, LOW); // Turn off the LED

    digitalWrite(LED3, LOW); // Turn off the LED

    digitalWrite(LED4, LOW); // Turn off the LED

    //ledState = false; //ledState = false LOW

    LEDjson ="LEDALLOFF";

    Flash1 = false;

    Flash2 = false;

    Flash3 = false;

    Flash4 = false;

    Send = true ;

    Serial.println(LEDjson);

}

  if (message == "ledallon") {

    digitalWrite(LED1, HIGH);  // Turn on the LED

    digitalWrite(LED2, HIGH);  // Turn on the LED

    digitalWrite(LED3, HIGH);  // Turn on the LED

    digitalWrite(LED4, HIGH);  // Turn on the LED

    //ledState = true;  //ledState = ture HIGH

    //設定 各個 旗號

    LEDjson ="LEDALLON";

    Flash1 = false;

    Flash2 = false;

    Flash3 = false;

    Flash4 = false;

    Send = true ;

    Serial.println(LEDjson);

}

  Serial.println();

  Serial.println("-----------------------");

}

}

//===========================================================

//===========================================================

//判斷 旗號Flash , Timer 是否為真

void LED_Message() {

  //判斷 旗號 Flash / timer  是否為真 ? 閃爍 定時

  if (Flash1 && Flash2 && Flash3 && Flash4){

      digitalWrite(LED1, !digitalRead(LED1));

      digitalWrite(LED2, !digitalRead(LED2));

      digitalWrite(LED3, !digitalRead(LED3));

      digitalWrite(LED4, !digitalRead(LED4));      

      delay(500);  

}

  if (Flash1) {

    digitalWrite(LED1, !digitalRead(LED1));

    delay(500);

  } //(Flash1)

  if (Flash2){

    digitalWrite(LED2, !digitalRead(LED2));

    delay(500);

  } //(Flash2)

  if (Flash3){

    digitalWrite(LED3, !digitalRead(LED3));

    delay(500);

  } //(Flash3)

  if (Flash4){

    digitalWrite(LED4, !digitalRead(LED4));

    delay(500);

  } //(Flash4)

  ////判斷 旗號 Send 是否為真 回傳MQTT訊息到MQTT Broker　

  if (Send) {

    // Convert JSON string to character array

    Serial.print("Publish message: ");

    Serial.println(LEDjson);

    LEDjson.trim();

    bool retained = false;

    int qos = 1;

    bool dup = false;

    // Publish JSON character array to MQTT topic

    mqttClient.beginMessage(PubTopic2,  LEDjson.length(), retained, qos, dup);  //LED Status

    mqttClient.print(LEDjson);

    mqttClient.endMessage();

    Send = false;    //處理過後 旗號 Send為假

}

}

//=========================================================== 

//===========================================================

//副程式  setup wifi

void setup_wifi() {

  delay(10);

  // We start by connecting to a WiFi network

  Serial.println();

  Serial.print("Connecting to ");

  Serial.println(ssid);     //print ssid

  WiFi.begin(ssid, pass);  //初始化WiFi 函式庫並回傳目前的網路狀態

  while (WiFi.status() != WL_CONNECTED) {

    delay(500);

    Serial.print(".");

  }   //假設 wifi 未連接 show ………

  Serial.println("");

  Serial.println("WiFi connected");

  Serial.println("IP address: ");

  Serial.println(WiFi.localIP());

}

//==================================================================

void setup() {

  Serial.begin(115200); // 初始化序列埠

  pinMode(LED1, OUTPUT);

  digitalWrite(LED1, LOW);  // Turn off the LED initially

  pinMode(LED2, OUTPUT);

  digitalWrite(LED2, LOW);  // Turn off the LED initially

  pinMode(LED3, OUTPUT);

  digitalWrite(LED3, LOW);  // Turn off the LED initially

  pinMode(LED4, OUTPUT);

  digitalWrite(LED4, LOW);  // Turn off the LED initially

  pinMode(inPin, INPUT);    // sets the digital pin 12 as input

  randomSeed(analogRead(0)); // 設定亂數種子，增加亂數的隨機性  

  //Initialize serial and wait for port to open: 

  Serial.begin(115200);   // Initialize serial communications with the PC

  while (!Serial);    // Do nothing if no serial port is opened (added for Arduinos based on ATMEGA32U4)

  setup_wifi();

  Serial.println("You're connected to the network");

  Serial.println();

  String willPayload = "ESP32 Start working....!";

  bool willRetain = true;

  int willQos = 1;

  mqttClient.beginWill(willTopic, willPayload.length(), willRetain, willQos);

  mqttClient.print(willPayload);

  mqttClient.endWill();

  Serial.print("Attempting to connect to the MQTT broker: ");

  Serial.println(broker);

  if (!mqttClient.connect(broker, port)) {

    Serial.print("MQTT connection failed! Error code = ");

    Serial.println(mqttClient.connectError());

    while (1);

}

  Serial.println("You're connected to the MQTT broker!");

  Serial.println();

  // set the message receive callback

  mqttClient.onMessage(onMqttMessage);

  Serial.print("Subscribing to topic: ");

  Serial.println(SubTopic1);

  // subscribe to a topic

  // the second parameter sets the QoS of the subscription,

  // the the library supports subscribing at QoS 0, 1, or 2

  int subscribeQos = 1;

  mqttClient.subscribe(SubTopic1, subscribeQos);

  Serial.println();

  /***

  Init SPI bus

  Init MFRC522

  ***/

}

//==================================================================

void loop() {

  val = digitalRead(inPin);   // read the input pin

  if (val==LOW) create= false;

  if (val==HIGH) create= true; 

  // call poll() regularly to allow the library to receive MQTT messages and

  // send MQTT keep alives which avoids being disconnected by the broker

  mqttClient.poll();

  LED_Message();

  if (create) {

    // 模擬 RFID UID 結構

    struct RFID_UID {

      uint8_t uidByte[10]; // UID 位元組陣列，最大長度為 10

      uint8_t size;        // UID 長度

};

    // 建立一個 RFID UID 物件

    RFID_UID uid;

    // 設定 UID 資料

    uid.size = 4;

    for (int i = 0; i < uid.size; i++) {

      uid.uidByte[i] = random(256); // 生成 0-255 的亂數

}

    // 顯示 UID

    Serial.print("UID: ");

    for (int i = 0; i < uid.size; i++) {

      Serial.print(uid.uidByte[i] < 0x10 ? " 0" : " "); // 補零

      Serial.print(uid.uidByte[i], HEX);             // 以十六進位格式輸出

}

    Serial.println();

    String json = "{ \"uid\": \"";

    for (int i = 0; i < uid.size; i++) {

        json += String(uid.uidByte[i], HEX);

}

    json += "\" }";

    json.trim();

    bool retained = false;

    int qos = 1;

    bool dup = false;

    mqttClient.beginMessage(PubTopic3,  json.length(), retained, qos, dup);

    mqttClient.print(json);

    mqttClient.endMessage();

    Serial.println(json);

    Serial.println();

}

}

電路圖

4) Node-Red程式

LINE Developers 說明

https://steam.oxxostudio.tw/category/python/example/line-developer.html#google_vignette

https://steam.oxxostudio.tw/category/python/example/line-bot.html

Node-Red <<LINE Notify + LINE Developers

https://alex9ufoexploer.blogspot.com/2024/12/node-red-line-notify-line-developers.html

SQLite 資料庫的檢視

https://sqlitebrowser.org/

https://sqlitebrowser.org/dl/ 軟體下載

手機 Line 通知畫面

Node-Red 節點說明

 
  節點圖示

  說明

 

  LED控制 Node-red發行到 WOkWI ESP32 的部分

 

  




  On Payload:  led1on
Off Payload:  led1off
On Payload:  led2on
Off Payload:  led2off
On Payload:  led3on
Off Payload:  led3off
On Payload:  led4on
Off Payload:  led4off

 

  



  Payload : ledallon
 
Payload : ledalloff

 

  



  MQTT out 節點
服務端 : broker.mqttgo.io 埠 : 1883
主題 :alex9ufo/esp32/led

 

  LED接收  Node-red訂閱  WOkWI ESP32發行的 部分

 

  



  MQTT in 節點
服務端 : broker.mqttgo.io 埠 : 1883
主題 : alex9ufo/esp32/led_status
 

 

  




  LED Dispatcher 功能
輸出要設定10個
 
// 建立一個陣列來裝每個輸出的訊息，預設都為 null
let outputs =
  Array(10).fill(null);
 
// 根據 payload 決定要送出的輸出端口 (0~9)
switch
  (msg.payload) {
    case "LED1ON":
        outputs[0] = msg;
        break;
    case "LED1OFF":
        outputs[1] = msg;
        break;
    case "LED2ON":
        outputs[2] = msg;
        break;
    case "LED2OFF":
        outputs[3] = msg;
        break;
    case "LED3ON":
        outputs[4] = msg;
        break;
    case "LED3OFF":
        outputs[5] = msg;
        break;
    case "LED4ON":
        outputs[6] = msg;
        break;
    case "LED4OFF":
        outputs[7] = msg;
        break;
    case "LEDALLON":
        outputs[8] = msg;
        break;
    case "LEDALLOFF":
        outputs[9] = msg;
        break;
    default:
        return null;
}
 
// 回傳包含 10 個輸出的陣列
return outputs;

 

  



  LED1ON 功能內程式
if (msg.payload
  === "LED1ON")
  {
    msg.payload = true;
    return msg;
} else {
    return null;
}
 
 
LED1OFF 功能內程式
 
if (msg.payload
  === "LED1OFF")
  {
    msg.payload = false;
    return msg;
} else {
    return null;
}
 
其餘依此列推
 
if (msg.payload
  === "LEDALLON")
  {
    msg.payload = true;
    return msg;
} else {
    return null;
}
 
if (msg.payload
  === "LEDALLOFF")
  {
    msg.payload = false;
    return msg;
} else {
    return null;
}

 

  



   
設定顏色 
true: green
false: red

 

  RFID 資料庫 與 Line Message API 部分  訂閱WOKWI 模擬RFID送出UID碼 暨 發出Line通知

 

  



  MQTT in 節點
服務端 : broker.mqttgo.io 埠 : 1883
主題 :  alex9ufo/esp32/RFID
 

 

  



  增加 日期 時間 功能程式
var Today = new Date();
var yyyy = Today.getFullYear(); //年
var MM = Today.getMonth()+1;    //月
var dd = Today.getDate();       //日
var h = Today.getHours();       //時
var m = Today.getMinutes();     //分
var s = Today.getSeconds();     //秒
if(MM<10)
{
   MM =
  '0'+MM;
}
if(dd<10)
{
   dd =
  '0'+dd;
}
if(h<10)
{
   h =
  '0'+h;
}
 
if(m<10)
{
  m =
  '0' + m;
}
 
if(s<10)
{
  s =
  '0' + s;
}
var var_date = yyyy+'/'+MM+'/'+dd;
var var_time = h+':'+m+':'+s;
 
var myUID = msg.payload.uid;
 
 
msg.payload="新增一筆:"+ myUID +", 日期:
  "+ var_date +", 時間:"+var_time;
return msg;

 

  



  LINE 
  Messaging API 功能程式
需修成成自己的CHANNEL_ACCESS_TOKEN 與 USER_ID
 
 
//CHANNEL_ACCESS_TOKEN
  = 'Messaging API Token';
CHANNEL_ACCESS_TOKEN
  =
  'E2ElxCQeoDszSHF0N1TJsyytnnae+HF1XZ733YVYj1RQcpjAT1oi2Fa2TScNbOz+q815fFVp4MuFW+UC4PsfKbvtc/o0OM6hchpxuQURZyvizGq+/cAz/TgCwJ9wQ4ebkQyEXEDzaYUZ/Dx3yaaBgwdB04t89/1O/w1cDnyilFU=';
USER_ID =
  'Ua2f646d82a75d31dee884a6fdfa95f76'; //'使用者ID(不是Line ID)';
 
var msg1=msg.payload;
 
message = {
   
  type:'text',
   
  text:'Line Developers傳送的訊息：'+msg1
};
 
 
headers = {
   
  'Content-Type': 'application/json; charset=UTF-8',
   
  'Authorization': 'Bearer ' + CHANNEL_ACCESS_TOKEN,
};
payload = {
   
  'to':  USER_ID,
   
  'messages': [message]
};
msg.headers = headers;
msg.payload = payload;
return msg;
 



 



 

  

  http request節點
 
請求方式 : POST
URL : https://api.line.me/v2/bot/message/push

 

  

  新增一筆資料的INSERT功能程式
 
var Today = new Date();
var yyyy = Today.getFullYear(); //年
var MM = Today.getMonth()+1;    //月
var dd = Today.getDate();       //日
var h = Today.getHours();       //時
var m = Today.getMinutes();     //分
var s = Today.getSeconds();     //秒
if(MM<10)
{
   MM =
  '0'+MM;
}
 
if(dd<10)
{
   dd =
  '0'+dd;
}
 
if(h<10)
{
   h =
  '0'+h;
}
 
if(m<10)
{
  m =
  '0' + m;
}
 
if(s<10)
{
  s =
  '0' + s;
}
var var_date = yyyy+'/'+MM+'/'+dd;
var var_time = h+':'+m+':'+s;
 
var myUID = msg.payload.uid;
 
 
msg.topic = "INSERT INTO RFIDUID ( UID ,
  Date , Time ) VALUES ($myUID, 
  $var_date ,  $var_time ) "
  ;
msg.payload = [myUID, var_date , var_time ]
return msg;
 
 
//INSERT INTO RFIDUID (
//id INTEGER,
//UID TEXT,
//Date DATE,
//Time TIME,
//PRIMARY KEY (id)
//);

 

  

   
名稱　：　 RFID_2025EX2
 Database :　 2025EX2_RFID.db　　<<Read-Write-Create>>
存放位置 : C:\Users\User\ 2025EX2_RFID.db
(第一次執行node-red 時 要先將 資料庫 C:\Users\User\ 2025EX2_RFID.db 建立  按圖示 <<建立RFID資料庫>>

 

   




  檢視資料 節點功能
 
//INSERT INTO RFIDUID (
//id INTEGER,
//UID TEXT,
//Date DATE,
//Time TIME,
//PRIMARY KEY (id)
//);
 
//SELECT * FROM RFIDUID ORDER BY  id DESC LIMIT 50;
 
msg.topic = "SELECT * FROM RFIDUID ORDER
  BY id DESC LIMIT 50";
return msg;

 

  

  CREATE　DATABASE
  功能節點程式
 
//CREATE TABLE RFIDUID (
//id INTEGER,
//UID TEXT,
//Date DATE,
//Time TIME,
//PRIMARY KEY (id)
//);
//CREATE TABLE LEDSTATUS (id INTEGER,UID
  TEXT,Date DATE,Time TIME,PRIMARY KEY (id));
msg.topic = "CREATE TABLE RFIDUID (id
  INTEGER,UID TEXT,Date DATE,Time TIME,PRIMARY KEY (id))";
return msg;

 

  

  DELETE ALL DATA功能節點程式
 
//CREATE TABLE RFIDUID (
//id INTEGER,
//UID TEXT,
//Date DATE,
//Time TIME,
//PRIMARY KEY (id)
//);
//CREATE TABLE LEDSTATUS (id INTEGER,UID
  TEXT,Date DATE,Time TIME,PRIMARY KEY (id));
msg.topic = "DELETE from RFIDUID";
return msg;

 
 

2025年3月8日星期六

作業2 MQTT (Relay + DHT22) 控制 ------- 利用Node-Red

作業2 MQTT (Relay + DHT22) 控制 ------- 利用Node-Red

1) 安裝Node-Red

https://ithelp.ithome.com.tw/articles/10201795

https://www.youtube.com/watch?v=I6jp9X0fhhI

https://alex9ufoexploer.blogspot.com/2023/10/node-red-dashboard_18.html

2) 安裝Dashboard UI 與 LED元件

http://blog.3dgowl.com/node-red-dashboard%E5%84%80%E8%A1%A8%E6%9D%BF/

https://www.gechic.com/tw/rpi-nodered-touchscreen-gui/

https://flows.nodered.org/node/node-red-contrib-ui-led

WokWI程式

#include <WiFi.h>
#include <MQTTPubSubClient.h>
#include <Adafruit_Sensor.h>
#include <DHT_U.h>
extern "C" {
  #include "freertos/FreeRTOS.h"
  #include "freertos/timers.h"
}

#define Relay4            15     //D15 LED-Orangs = Water-1
#define Relay3            2      //D2   LED-Blue  = Water-2
#define Relay2            19     //D19  LED-Blue   = Motor
#define Relay1            23     //D23  LED-RED    = Fan

#define WIFI_SSID "Wokwi-GUEST"
#define WIFI_PASSWORD ""

#define MQTT_HOST "test.mosquitto.org"
//#define MQTT_HOST "broker.mqttgo.io"
#define MQTT_PORT 1883

#define DHTPIN 12
// DHT parameters
#define DHTTYPE    DHT22     // DHT 12
DHT_Unified dht(DHTPIN, DHTTYPE);

WiFiClient client;
MQTTPubSubClient mqtt;
int count;
float temp, hum;
bool Send= false;
String json="";

//=============================================================================
void connect() {
  connect_to_wifi:
    Serial.print("connecting to wifi...");
    while (WiFi.status() != WL_CONNECTED) {
        Serial.print(".");
        delay(1000);
    }
    Serial.println(" connected!");

  connect_to_host:
    Serial.print("connecting to host...");
    client.stop();
    while (!client.connect(MQTT_HOST, 1883)) {//while (!client.connect("public.cloud.shiftr.io", 1883)) {
        Serial.print(".");
        delay(1000);
        if (WiFi.status() != WL_CONNECTED) {
            Serial.println("WiFi disconnected");
            goto connect_to_wifi;
        }
    }
    Serial.println(" connected!");

    Serial.print("connecting to mqtt broker...");
    mqtt.disconnect();
    while (!mqtt.connect("arduino", "", "")) {
        Serial.print(".");
        delay(1000);
        if (WiFi.status() != WL_CONNECTED) {
            Serial.println("WiFi disconnected");
            goto connect_to_wifi;
        }
        if (client.connected() != 1) {
            Serial.println("WiFiClient disconnected");
            goto connect_to_host;
        }
    }
    Serial.println(" connected!");
}
//=============================================================================
void  Publish_message() {
  if (Send){
    mqtt.publish("alex9ufo/esp32/led/status", json);

    Serial.println();  
    Serial.print("publish message to MQTT ---");
    Serial.println(json);
    
    Send= false;
    json="";
  }
}
//=============================================================================
void setup() {

    pinMode(Relay1, OUTPUT);
    pinMode(Relay2, OUTPUT);
    pinMode(Relay3, OUTPUT);
    pinMode(Relay4, OUTPUT);

    Serial.begin(115200);
    dht.begin();
    // Get temperature sensor details.
    sensor_t sensor;
    dht.temperature().getSensor(&sensor);
    dht.humidity().getSensor(&sensor);



    WiFi.begin(WIFI_SSID, WIFI_PASSWORD, 6);
    mqtt.begin(client);
    connect();

    mqtt.subscribe([](const String& topic, const String& payload, const size_t size) {
        Serial.println("mqtt received: " + topic + " - " + payload);
    });

    mqtt.subscribe("alex9ufo/esp32/led/control", [] (const String& payload, const size_t size) {
        Serial.print("alex9ufo/esp32/led/control");
        Serial.println(payload);
       
        String message=payload;
        message.trim();
        Serial.print(message);


        if ( message == "1on" ) {
            digitalWrite(Relay1, HIGH);  // Turn on the LED
            Send = true;
            json="Relay1on";

        }
        if ( message == "1off" ) {
            digitalWrite(Relay1, LOW);  // Turn off the LED
            Send = true;
            json="Relay1off"; 
        }    
        if ( message == "2on" ) {
            digitalWrite(Relay2, HIGH);  // Turn on the LED 
            Send = true;
            json="Relay2on";  
        }
        if ( message == "2off" ) {
            digitalWrite(Relay2, LOW);  // Turn off the LED 
            Send = true;
            json="Relay2off"; 
        }  
        if ( message == "3on" ) {
            digitalWrite(Relay3, HIGH);  // Turn on the LED 
            Send = true;
            json="Relay3on"; 
        }
        if ( message == "3off" ) {
            digitalWrite(Relay3, LOW);  // Turn off the LED 
            Send = true;
            json="Relay3off"; 
        }    
        if ( message == "4on" ) {
            digitalWrite(Relay4, HIGH);  // Turn on the LED 
            Send = true;
            json="Relay4on"; 
        }
        if ( message == "4off" ) {
            digitalWrite(Relay4, LOW);  // Turn off the LED 
            Send = true;
            json="Relay4off"; 
        } 
    });
}

//=============================================================================
void loop() {
    mqtt.update();
    Publish_message();

    if (!mqtt.isConnected()) {
        connect();
    }

    // publish message
    static uint32_t prev_ms = millis();
    if (millis() > prev_ms + 2500) {
        prev_ms = millis();
        sensors_event_t event;
      dht.temperature().getEvent(&event);
      if (isnan(event.temperature)) {
          Serial.println(F("Error reading temperature!"));
      }
      else {
        Serial.print(F("Temperature: "));
        temp = event.temperature;
        Serial.print(temp);
        Serial.println(F("°C"));
      }
      // Get humidity event and print its value
      dht.humidity().getEvent(&event);
      if (isnan(event.relative_humidity)) {
        Serial.println(F("Error reading humidity!"));
      }
      else {
        Serial.print(F("Humidity: "));
        hum = event.relative_humidity;
        Serial.print(hum);
        Serial.println(F("%"));
      }
      String msgStr = String(temp) + "," + String(hum) ;

      //mqtt.publish("alex9ufo/esp32/dht/temp", String(temp));
      //delay(100);
      //mqtt.publish("alex9ufo/esp32/dht/humi", String(hum));
      delay(100);  
      mqtt.publish("alex9ufo/esp32/dht/temphumi", msgStr);
    }
}

Node-Red程式的設定

(發行 Publish) LED控制主題與訊息

	SWITCH : LED1控制
	SWITCH : LED2控制	2on 2off
	SWITCH : LED3控制	3on 3off
	SWITCH : LED4控制	4on 4off

MQTT OUT (LED控制)

接收(訂閱 Subscribe)溫溼度資料

MQTT IN (溫溼度)

Function112

var dataString = msg.payload; // 取得輸入的資料字串

var dataArray = dataString.split(","); // 將字串以逗號分隔成陣列

if (dataArray.length === 2) { // 檢查陣列是否包含兩個元素

var value1 = parseFloat(dataArray[0]); // 將第一個元素轉換為數字

var value2 = parseFloat(dataArray[1]); // 將第二個元素轉換為數字

var newMsg1 = { payload: value1 }; // 建立第一個輸出訊息

var newMsg2 = { payload: value2 }; // 建立第二個輸出訊息

return [newMsg1, newMsg2]; // 將兩個訊息作為陣列傳回

} else {

node.warn("輸入資料格式不正確：" + dataString); // 如果資料格式不正確，發出警告

return null; // 不輸出任何訊息

}

接收(訂閱 Subscribe) LED的狀態亮滅資料

MQTT IN

Function程式

LED1	var temp = msg.payload; // Initialize output array var msg1=null; var msg2=null; var msg3=null; var msg4=null; if (temp=== "Relay1on") { msg1=true; } else if (temp=== "Relay1off") { msg1 = false; } else if (temp== "Relay2on") { msg2 = true; } else if (temp== "Relay2off") { msg2 = false; } else if (temp == "Relay3on") { msg3 = true; } else if (temp == "Relay3off") { msg3 = false; } else if (temp == "Relay4on") { msg4 = true; } else if (temp == "Relay4off") { msg4 = false; } msg.payload=[msg1,msg2,msg3,msg4]; return msg;
LED2	let leds = context.get('leds') \|\| [false, false, false, false]; // 取得或初始化 LED 狀態 if (Array.isArray(msg.payload) && msg.payload.length === 4) { for (let i = 0; i < 4; i++) { if (msg.payload[i] !== null) { leds[i] = !!msg.payload[i]; // 更新 LED 狀態 } } context.set('leds', leds); // 儲存更新後的 LED 狀態 } msg.payload = leds; // 將 LED 狀態陣列傳遞給輸出 return msg;
LED31	var a=msg.payload[0]; msg.payload=a; return msg;
LED32	var a=msg.payload[1]; msg.payload=a; return msg;
LED33	var a=msg.payload[2]; msg.payload=a; return msg;
LED34	var a=msg.payload[3]; msg.payload=a; return msg;

LED

Node-Red程式

訂閱：文章 (Atom)

節點圖示	說明
LED控制 Node-red發行到 WOkWI ESP32 的部分
	On Payload: led1on Off Payload: led1off On Payload: led2on Off Payload: led2off On Payload: led3on Off Payload: led3off On Payload: led4on Off Payload: led4off
	Payload : ledallon Payload : ledalloff
	MQTT out 節點服務端 : broker.mqttgo.io 埠 : 1883 主題 :alex9ufo/esp32/led
LED接收 Node-red訂閱 WOkWI ESP32發行的部分
	MQTT in 節點服務端 : broker.mqttgo.io 埠 : 1883 主題 : alex9ufo/esp32/led_status
	LED Dispatcher 功能輸出要設定10個 // 建立一個陣列來裝每個輸出的訊息，預設都為 null let outputs = Array(10).fill(null); // 根據 payload 決定要送出的輸出端口 (0~9) switch (msg.payload) { case "LED1ON": outputs[0] = msg; break; case "LED1OFF": outputs[1] = msg; break; case "LED2ON": outputs[2] = msg; break; case "LED2OFF": outputs[3] = msg; break; case "LED3ON": outputs[4] = msg; break; case "LED3OFF": outputs[5] = msg; break; case "LED4ON": outputs[6] = msg; break; case "LED4OFF": outputs[7] = msg; break; case "LEDALLON": outputs[8] = msg; break; case "LEDALLOFF": outputs[9] = msg; break; default: return null; } // 回傳包含 10 個輸出的陣列 return outputs;
	LED1ON 功能內程式 if (msg.payload === "LED1ON") { msg.payload = true; return msg; } else { return null; } LED1OFF 功能內程式 if (msg.payload === "LED1OFF") { msg.payload = false; return msg; } else { return null; } 其餘依此列推 if (msg.payload === "LEDALLON") { msg.payload = true; return msg; } else { return null; } if (msg.payload === "LEDALLOFF") { msg.payload = false; return msg; } else { return null; }
	設定顏色 true: green false: red
RFID 資料庫與 Line Message API 部分訂閱WOKWI 模擬RFID送出UID碼暨發出Line通知
	MQTT in 節點服務端 : broker.mqttgo.io 埠 : 1883 主題 : alex9ufo/esp32/RFID
	增加日期時間功能程式 var Today = new Date(); var yyyy = Today.getFullYear(); //年 var MM = Today.getMonth()+1; //月 var dd = Today.getDate(); //日 var h = Today.getHours(); //時 var m = Today.getMinutes(); //分 var s = Today.getSeconds(); //秒 if(MM<10) { MM = '0'+MM; } if(dd<10) { dd = '0'+dd; } if(h<10) { h = '0'+h; } if(m<10) { m = '0' + m; } if(s<10) { s = '0' + s; } var var_date = yyyy+'/'+MM+'/'+dd; var var_time = h+':'+m+':'+s; var myUID = msg.payload.uid; msg.payload="新增一筆:"+ myUID +", 日期: "+ var_date +", 時間:"+var_time; return msg;
	LINE Messaging API 功能程式需修成成自己的CHANNEL_ACCESS_TOKEN 與 USER_ID //CHANNEL_ACCESS_TOKEN = 'Messaging API Token'; CHANNEL_ACCESS_TOKEN = 'E2ElxCQeoDszSHF0N1TJsyytnnae+HF1XZ733YVYj1RQcpjAT1oi2Fa2TScNbOz+q815fFVp4MuFW+UC4PsfKbvtc/o0OM6hchpxuQURZyvizGq+/cAz/TgCwJ9wQ4ebkQyEXEDzaYUZ/Dx3yaaBgwdB04t89/1O/w1cDnyilFU='; USER_ID = 'Ua2f646d82a75d31dee884a6fdfa95f76'; //'使用者ID(不是Line ID)'; var msg1=msg.payload; message = { type:'text', text:'Line Developers傳送的訊息：'+msg1 }; headers = { 'Content-Type': 'application/json; charset=UTF-8', 'Authorization': 'Bearer ' + CHANNEL_ACCESS_TOKEN, }; payload = { 'to': USER_ID, 'messages': [message] }; msg.headers = headers; msg.payload = payload; return msg;
	http request節點請求方式 : POST URL : https://api.line.me/v2/bot/message/push
	新增一筆資料的INSERT功能程式 var Today = new Date(); var yyyy = Today.getFullYear(); //年 var MM = Today.getMonth()+1; //月 var dd = Today.getDate(); //日 var h = Today.getHours(); //時 var m = Today.getMinutes(); //分 var s = Today.getSeconds(); //秒 if(MM<10) { MM = '0'+MM; } if(dd<10) { dd = '0'+dd; } if(h<10) { h = '0'+h; } if(m<10) { m = '0' + m; } if(s<10) { s = '0' + s; } var var_date = yyyy+'/'+MM+'/'+dd; var var_time = h+':'+m+':'+s; var myUID = msg.payload.uid; msg.topic = "INSERT INTO RFIDUID ( UID , Date , Time ) VALUES ($myUID, $var_date , $var_time ) " ; msg.payload = [myUID, var_date , var_time ] return msg; //INSERT INTO RFIDUID ( //id INTEGER, //UID TEXT, //Date DATE, //Time TIME, //PRIMARY KEY (id) //);
	名稱　：　 RFID_2025EX2 Database :　 2025EX2_RFID.db　　<<Read-Write-Create>> 存放位置 : C:\Users\User\ 2025EX2_RFID.db (第一次執行node-red 時要先將資料庫 C:\Users\User\ 2025EX2_RFID.db 建立按圖示 <<建立RFID資料庫>>
	檢視資料節點功能 //INSERT INTO RFIDUID ( //id INTEGER, //UID TEXT, //Date DATE, //Time TIME, //PRIMARY KEY (id) //); //SELECT * FROM RFIDUID ORDER BY id DESC LIMIT 50; msg.topic = "SELECT * FROM RFIDUID ORDER BY id DESC LIMIT 50"; return msg;
	CREATE　DATABASE 功能節點程式 //CREATE TABLE RFIDUID ( //id INTEGER, //UID TEXT, //Date DATE, //Time TIME, //PRIMARY KEY (id) //); //CREATE TABLE LEDSTATUS (id INTEGER,UID TEXT,Date DATE,Time TIME,PRIMARY KEY (id)); msg.topic = "CREATE TABLE RFIDUID (id INTEGER,UID TEXT,Date DATE,Time TIME,PRIMARY KEY (id))"; return msg;
	DELETE ALL DATA功能節點程式 //CREATE TABLE RFIDUID ( //id INTEGER, //UID TEXT, //Date DATE, //Time TIME, //PRIMARY KEY (id) //); //CREATE TABLE LEDSTATUS (id INTEGER,UID TEXT,Date DATE,Time TIME,PRIMARY KEY (id)); msg.topic = "DELETE from RFIDUID"; return msg;

2025年4月16日 星期三

作業3 WOKWI + Node-Red + SQlite + Line Developer

2025年3月8日 星期六

作業2 MQTT (Relay + DHT22) 控制 ------- 利用Node-Red

Node-Red 抓取 opendata 的資料集產生AQI 空氣品質指

2025年4月16日星期三

2025年3月8日星期六