2024年11月3日星期日

2024_113_RFID 作業2 ESP32 Arduino程式

2024_113_RFID 作業2 ESP32 Arduino程式

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

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

int port = 1883;

const char *SubTopic1 = "alex9ufo/2024/RFID/LED_control";

const char *PubTopic2 = "alex9ufo/2024/RFID/LED_status";

const char *PubTopic3 = "alex9ufo/2024/RFID/RFID_UID";

//const char *PubTopic4 = "alex9ufo/2024/RFID/RFID_PICC";

ESP32 與 MFRC522連接方式 (硬體連接)

GND = GND 3.3V = 3.3V

The following table shows the typical pin layout used:

* MFRC522 ESP32

* Reader/PCD

* Signal Pin Pin

* RST/Reset RST GPIO27

* SPI SS SDA(SS) GPIO5

* SPI MOSI MOSI GPIO23

* SPI MISO MISO GPIO19

* SPI SCK SCK GPIO18

[1] (1, 2) Configurable, typically defined as RST_PIN in sketch/program.

[2] (1, 2) Configurable, typically defined as SS_PIN in sketch/program.

[3] The SDA pin might be labeled SS on some/older MFRC522 boards

(軟體)

Arduino 1.85版本下載解壓縮或安裝

( 載點 https://www.npackd.org/p/ArduinoSA.arduino/1.8.15)

https://www.arduino.cc/en/software/OldSoftwareReleases Arduino 1.8.16

參考網址

https://randomnerdtutorials.com/installing-the-esp32-board-in-arduino-ide-windows-instructions/

File> Preferences

https://raw.githubusercontent.com/espressif/arduino-esp32/gh-pages/package_esp32_index.json

Tools > Board > Boards Manager…

Select the Port (if you don’t see the COM Port in your Arduino IDE, you need to install the CP210x USB to UART Bridge VCP Drivers):

SKetch --- Include Library ---Manage Libraries

// Wifi 與 MQttClient 程式庫

#include <ArduinoMqttClient.h>

#include <WiFi.h>

//#include "arduino_secrets1.h"

//MFRC522 程式庫

#include <SPI.h>

#include <MFRC522.h>

安裝程式庫

貼上下方 "程式" 按上傳

Press the Upload button in the Arduino IDE

按住板子上的 BOOT 按鈕，再點 Arduino 上傳鈕
，當編譯訊息出現 “Connecting...” 的時候，再放開 BOOT 按鈕。如此，應可成功上傳程式。

Arduino程式

//定義MFRC522 RFID read 與 ESP32 介面接腳連接Pin assign

/* Wiring RFID RC522 module

==============================================================

GND = GND 3.3V = 3.3V

The following table shows the typical pin layout used:

* MFRC522 ESP32

* Reader/PCD

* Signal Pin Pin

* -----------------------------------

* RST/Reset RST GPIO27

* SPI SS SDA(SS) GPIO5

* SPI MOSI MOSI GPIO23

* SPI MISO MISO GPIO19

* SPI SCK SCK GPIO18

[1] (1, 2) Configurable, typically defined as RST_PIN in sketch/program.

[2] (1, 2) Configurable, typically defined as SS_PIN in sketch/program.

[3] The SDA pin might be labeled SS on some/older MFRC522 boards

=============================================================

// Wifi 與 MQttClient 程式庫

#include <ArduinoMqttClient.h>

#include <WiFi.h>

//#include "arduino_secrets1.h"

//MFRC522 程式庫

#include <SPI.h>

#include <MFRC522.h>

//GPIO 2 D1 Build in LED

//#define LED 13 //定義LED接腳

int LED = 13;

///////please enter your sensitive data in the Secret tab/arduino_secrets.h

//char ssid[] = "TOTOLINK_A3002MU"; // your network SSID (name)

//char pass[] = "24063173"; // your network password (use for WPA, or use as key for WEP)

// WiFi SSID password , SSID 和密碼進行Wi-Fi 設定

const char ssid[] = "alex9ufo"; // Enter your Wi-Fi name 修改成自己的wifi ssid

const char pass[] = "alex9981"; // Enter Wi-Fi password 修改成自己的wifi pwd

//char ssid[] = "ASUS_D0"; // your network SSID (name)

//char pass[] = "night_9754"; // your network password (use for WPA, or use as key for WEP)

WiFiClient wifiClient;

MqttClient mqttClient(wifiClient);

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

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

int port = 1883;

String json = "";

const char *SubTopic1 = "alex9ufo/2024/RFID/LED_control";

const char *PubTopic2 = "alex9ufo/2024/RFID/LED_status";

const char *PubTopic3 = "alex9ufo/2024/RFID/RFID_UID";

//const char *PubTopic4 = "alex9ufo/2024/RFID/RFID_PICC";

const char willTopic[] = "alex9ufo/2024/RFID/Starting";

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

#define RST_PIN 27 // 讀卡機的重置腳位

#define SS_PIN 5 // 晶片選擇腳位

MFRC522 mfrc522(SS_PIN, RST_PIN); // 建立MFRC522物件

MFRC522::MIFARE_Key key; // 儲存金鑰

MFRC522::StatusCode status;

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

//布林代數 LED狀態是否連上網路ESP32 ready ?

bool ledState = false;

bool atwork = false;

bool Send = false; //true

String LEDjson = "";

int Count= 0;

bool Flash = false; //true

bool Timer = false; //true

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

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/2024/RFID/LED_control") {

if (message == "on") {

digitalWrite(LED, LOW); // Turn on the LED

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

//設定各個旗號

LEDjson ="ON";

Send = true ;

Serial.print("LED =");

Serial.println(LEDjson);

}

if (message == "off" ) {

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

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

LEDjson ="OFF";

Send = true ;

Serial.print("LED =");

Serial.println(LEDjson);

}

if (message == "flash" ) {

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

Flash = true;

Timer = false;

LEDjson ="FLASH";

Send = true ;

Serial.print("LED =");

Serial.println(LEDjson);

}

if (message == "timer" ) {

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

Flash = false;

Timer = true;

LEDjson ="TIMER";

Send = true ;

Count= 11;

Serial.print("LED =");

Serial.println(LEDjson);

}

Serial.println();

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

}

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

String printHex(byte *buffer, byte bufferSize) {

String id = "";

for (byte i = 0; i < bufferSize; i++) {

id += buffer[i] < 0x10 ? "0" : "";

id += String(buffer[i], HEX);

id +=" ";

}

return id;

}

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

//副程式 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());

}

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

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

void LED_Message() {

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

if (Flash){

digitalWrite(LED, !digitalRead(LED));

delay(500);

if (digitalRead(LED))

ledState = true;

else

ledState = false;

} //(Flash)

if (Timer) {

digitalWrite(LED, LOW);

delay(500);

if (digitalRead(LED))

ledState = true;

else

ledState = false;

Count=Count-1;

if (Count == 0 ){

Timer=false;

digitalWrite(LED, HIGH);

ledState = false;

}

} //(Timer)

////判斷旗號 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為假

}

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

void setup() {

pinMode(LED, OUTPUT);

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

//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();

SPI.begin(); // Init SPI bus

mfrc522.PCD_Init(); // Init MFRC522

delay(4); // Optional delay. Some board do need more time after init to be ready, see Readme

//mfrc522.PCD_DumpVersionToSerial(); // Show details of PCD - MFRC522 Card Reader details

Serial.println(F("Scan PICC to see UID, SAK, type, and data blocks..."));

}

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

void loop() {

// 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();

// to avoid having delays in loop, we'll use the strategy from BlinkWithoutDelay

// see: File -> Examples -> 02.Digital -> BlinkWithoutDelay for more info

unsigned long currentMillis = millis();

if (mfrc522.PICC_IsNewCardPresent() && mfrc522.PICC_ReadCardSerial()) {

Serial.println(F("Please scan MIFARE Classic card..."));

// 確認是否有新卡片

byte *id = mfrc522.uid.uidByte; // 取得卡片的UID

byte idSize = mfrc522.uid.size; // 取得UID的長度

String Type;

Serial.print("PICC type: "); // 顯示卡片類型

// 根據卡片回應的SAK值（mfrc522.uid.sak）判斷卡片類型

MFRC522::PICC_Type piccType = mfrc522.PICC_GetType(mfrc522.uid.sak);

Type= mfrc522.PICC_GetTypeName(piccType);

Serial.println(mfrc522.PICC_GetTypeName(piccType));

Serial.print("UID Size: "); // 顯示卡片的UID長度值

Serial.println(idSize);

for (byte i = 0; i < idSize; i++) { // 逐一顯示UID碼

Serial.print("id[");

Serial.print(i);

Serial.print("]: ");

Serial.println(id[i], HEX); // 以16進位顯示UID值

}

Serial.println();

json="";

String json1=printHex(mfrc522.uid.uidByte, mfrc522.uid.size);

json1.toUpperCase();

json = json + json1;

json.trim();

bool retained = false;

int qos = 1;

bool dup = false;

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

mqttClient.print(json);

mqttClient.endMessage();

json="";

json = "PICC type: ";

json = json + Type;

json.trim();

retained = false;

qos = 1;

dup = false;

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

mqttClient.print(json);

mqttClient.endMessage();

Serial.println();

// Dump debug info about the card; PICC_HaltA() is automatically called

// 令卡片進入停止狀態

// Dump debug info about the card; PICC_HaltA() is automatically called

// mfrc522.PICC_DumpToSerial(&(mfrc522.uid));

mfrc522.PICC_HaltA();

mfrc522.PCD_StopCrypto1(); // stop encryption on PCD

}

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

2024_113_RFID 作業2 Node-Red程式

2024_113_RFID 作業2 Node-Red程式

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

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

int port = 1883;

const char *SubTopic1 = "alex9ufo/2024/RFID/LED_control";

const char *PubTopic2 = "alex9ufo/2024/RFID/LED_status";

const char *PubTopic3 = "alex9ufo/2024/RFID/RFID_UID";

2024年10月27日星期日

OPEN DATA AQI 空氣品質監測網 + NODE-RED

首頁 - 空氣品質監測網 https://airtw.moenv.gov.tw/

https://data.gov.tw/datasets/search?p=1&size=10&s=_score_desc&rft=AQI

https://data.gov.tw/dataset/40448

https://data.moenv.gov.tw/api/v2/aqx_p_432?api_key=e8dd42e6-9b8b-43f8-991e-b3dee723a52d&limit=1000&sort=ImportDate desc&format=CSV

https://data.moenv.gov.tw/api/v2/aqx_p_432?api_key=e8dd42e6-9b8b-43f8-991e-b3dee723a52d&limit=1000&sort=ImportDate desc&format=JSON

將pm2.5改成pm25 修改字體顏色 msg.color="red";

var a = context.global.aqi_records;

var site_name=global.get('site_Name');

var pm25;

a.forEach(function(e,i){

if(e.sitename== site_name){

pm25 = e['pm2.5'];

}

});

msg.payload=pm25;

msg.color="red";

return msg;

修改字體顏色 msg.color="red";

<font color={{msg.color}}> <font SIZE=14> {{msg.payload}}

程式:

2024年10月23日星期三

WOKWI ESP32 LED Control , Node-Red MQTT SQLITE 　

const char broker[] = "test.mosquitto.org";
//const char broker[] = "broker.mqtt-dashboard.com";
int        port     = 1883;

const char *SubTopic1 = "alex9ufo/LED_control";
const char *PubTopic2 = "alex9ufo/LED_status";

Wokwi硬體

Wokwi 程式庫

從程式 #include <ArduinoMqttClient.h> copy ArduinoMqttClient

Wokwi程式 (控制led on ,off , timer ,flash)

// Wifi 與 MQttClient 程式庫
#include <ArduinoMqttClient.h>
#include <WiFi.h>
//#include "arduino_secrets1.h"


//#define LED 13           //定義LED接腳
int LED = 13;
///////please enter your sensitive data in the Secret tab/arduino_secrets.h
//char ssid[] = "TOTOLINK_A3002MU";    // your network SSID (name)
//char pass[] = "24063173";    // your network password (use for WPA, or use as key for WEP)
// WiFi SSID password , SSID 和密碼進行Wi-Fi 設定 

///////please enter your sensitive data in the Secret tab/arduino_secrets.h
char ssid[] =  "Wokwi-GUEST"; // your network SSID (name)
char pass[] =  "" ;           // your network password (use for WPA, or use as key for WEP)


//char ssid[] = "dlink-103A";    // your network SSID (name)
//char pass[] = "bdcce12882";    // your network password (use for WPA, or use as key for WEP)

WiFiClient wifiClient;
MqttClient mqttClient(wifiClient);

const char broker[] = "test.mosquitto.org";
//const char broker[] = "broker.mqtt-dashboard.com";
int        port     = 1883;
String json = "";

const char *SubTopic1 = "alex9ufo/LED_control";
const char *PubTopic2 = "alex9ufo/LED_status";
//const char *PubTopic3 = "alex9ufo/2024/RFID/RFID_UID";
//const char *PubTopic4 = "alex9ufo/2024/RFID/RFID_PICC";

const char willTopic[] = "alex9ufo/2024/RFID/Starting";

//===========================================================
//布林代數 LED狀態 是否連上網路ESP32 ready ?
bool ledState = false;
bool atwork = false;
bool Send = false;  //true
String LEDjson = "";
int Count= 0;
bool Flash = false;  //true
bool Timer = false;  //true

//===========================================================
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/LED_control") {
  if (message == "on") {
    digitalWrite(LED, LOW);  // Turn on the LED
    //ledState = true;  //ledState = ture HIGH
    //設定 各個 旗號
    LEDjson ="ON";
    Send = true ;
    Serial.print("LED =");
    Serial.println(LEDjson);
  }

  if (message == "off" ) {
    digitalWrite(LED, HIGH); // Turn off the LED
    //ledState = false; //ledState = false LOW
    LEDjson ="OFF";
    Send = true ;
    Serial.print("LED =");
    Serial.println(LEDjson);
  }
  
  if (message == "flash" ) {
    digitalWrite(LED, HIGH); // Turn off the LED
    Flash = true;
    Timer = false;
    LEDjson ="FLASH";
    Send = true ;  
    Serial.print("LED =");
    Serial.println(LEDjson);      
  }

  if (message == "timer" ) {
    digitalWrite(LED, LOW); // Turn off the LED
    Flash = false;
    Timer = true;
    LEDjson ="TIMER";
    Send = true ;
    Count= 11;
    Serial.print("LED =");
    Serial.println(LEDjson);   
  }
  
    Serial.println();
    Serial.println("-----------------------");
  }  

}

//===========================================================
String printHex(byte *buffer, byte bufferSize) {
      String id = "";
      for (byte i = 0; i < bufferSize; i++) {
        id += buffer[i] < 0x10 ? "0" : "";
        id += String(buffer[i], HEX);
        id +=" ";
      }
      return id;
}
//===========================================================
//副程式  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());
}  
//===========================================================
//判斷 旗號Flash , Timer 是否為真
void LED_Message() {
  //判斷 旗號 Flash / timer  是否為真 ? 閃爍 定時
  
  if (Flash){
    digitalWrite(LED, !digitalRead(LED));
    delay(500);
    if (digitalRead(LED))
      ledState = true;
    else
      ledState = false;

  } //(Flash)

  if (Timer) {
    digitalWrite(LED, LOW);
    delay(500);
    if (digitalRead(LED))
      ledState = true;
    else
      ledState = false;

  Count=Count-1;
  if (Count == 0 ){
    Timer=false;
    digitalWrite(LED, HIGH);
    ledState = false;
    }
  } //(Timer)
  
  
  ////判斷 旗號 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為假
  }

} 
//=========================================================== 
void setup() {
  pinMode(LED, OUTPUT);
  digitalWrite(LED, HIGH);  // Turn off the LED initially
  //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();
}
//===========================================================
void loop() {
  // 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();
  Serial.println();

}

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

Node-Red程式及設定畫面

需要的節點有 dashboard , sqilte , mqtt in , mqtt out ,node-red-node-ui-table

匯入程式暨節點安裝

SQLite DB Browser : https://sqlitebrowser.org/dl/

Downloads

(Please consider sponsoring us on Patreon 😄)

Windows

Our latest release (3.13.1) for Windows:

Free code signing provided by SignPath.io, certificate by SignPath Foundation.

資料庫位置 C:\Users\User\.node-red\202409-LED_STATUS.db

用dbbrower 開啟檔案 C:\Users\User\.node-red\202409-LED_STATUS.db

取得 Line Notify 的發行權杖使得LEN ON , LED OFF 狀態可以隨時由手機APP LINE取得資訊

LINE結果畫面

進入 https://notify-bot.line.me/zh_TW/ 登入

進入發行權杖

指定名稱與要Line通知的人或群組

將發行權杖複製

檢視一下發行的權杖是否active

手機Line Notify 會送出 HEllo! LED Change 與一個貼圖

7) LINE 通知的方法2

設定2個function

發行權杖放入 Authorization':'Bearer 後面
A4wwPNh2WqB723dlfeQyyIAwtggn1kfZSI5LkkCdia1gB'};

msg.headers = {'content-type':'application/x-www-form-urlencoded','Authorization':'Bearer A4wwPNh2WqB723dlfeQyyIAwtggn1kfZSI5LkkCdia1gB'};
msg.payload = {"message":msg.payload};
return msg;

//oR7KdXvK1eob33Rr2sRRgsl4PMq23DjDlhfUs96SyUBZu

Bearer A4wwPN

有空白不可以連接再一起

設定Htpp Request

Request 方法 :ＰＯＳＴ
URL : https://notify-api.line.me/api/notify

Node-Red程式

資料庫系統建立資料庫(Create) 新增一筆(insert) 檢視資料庫(Select) 刪除所有資料(Delete) 刪除資料庫(Drop )

資料庫位置	C:\Users\User\.node-red\202409-LED_STATUS.db
建立資料庫(Create)	CREATE TABLE LEDSTATUS (id INTEGER,STATUS TEXT,Date DATE,Time TIME,PRIMARY KEY (id));
新增一筆(insert)	INSERT INTO LEDSTATUS (STATUS , Date , Time )values("on", "11/01" , "21:05")
檢視資料庫(Select)	SELECT * FROM LEDSTATUS
刪除所有資料(Delete)	DELETE from LEDSTATUS
刪除資料庫(Drop table )	DROP TABLE LEDSTATUS

LED控制命令

MQTT out	Broker : test.mosquitto.org :1883 Topic : alex9ufo/LED_control
ON	Payload : on
OFF	Payload : off
TIMER	Payload : timer
FLASH	Payload : flash
SQLite
Dashboard Text

資料庫

LED_STATUS

SQLite

</> SQL Query : Via msg.topic

建立資料庫

//CREATE TABLE LEDSTATUS (

//id INTEGER,

//STATUS TEXT,

//Date DATE,

//Time TIME,

//PRIMARY KEY (id)

//);

//CREATE TABLE LEDSTATUS (id INTEGER,STATUS TEXT,Date DATE,Time TIME,PRIMARY KEY (id));

msg.topic = "CREATE TABLE LEDSTATUS (id INTEGER,STATUS TEXT,Date DATE,Time TIME,PRIMARY KEY (id))";

return msg;

檢視資料庫資料

//INSERT INTO LEDSTATUS (

//id INTEGER,

//STATUS TEXT,

//Date DATE,

//Time TIME,

//PRIMARY KEY (id)

//);

//SELECT * FROM LEDSTATUS ORDER BY id DESC LIMIT 50;

msg.topic = "SELECT * FROM LEDSTATUS ORDER BY id DESC LIMIT 50";

return msg;

刪除所有資料

//CREATE TABLE LEDSTATUS (

//id INTEGER,

//STATUS TEXT,

//Date DATE,

//Time TIME,

//PRIMARY KEY (id)

//);

//CREATE TABLE LEDSTATUS (id INTEGER,STATUS TEXT,Date DATE,Time TIME,PRIMARY KEY (id));

msg.topic = "DELETE from LEDSTATUS";

return msg;

Function 100

Function 99

確認

Yes , Cancel

var topic=msg.payload;

if (topic==""){

return [msg,null];

}

if (topic=="Cancel"){

return [null,msg];

}

return msg;

刪除資料庫

DROP Database

//CREATE TABLE LEDSTATUS (

//id INTEGER,

//STATUS TEXT,

//Date DATE,

//Time TIME,

//PRIMARY KEY (id)

//);

//CREATE TABLE LEDSTATUS (id INTEGER,STATUS TEXT,Date DATE,Time TIME,PRIMARY KEY (id));

msg.topic = "DROP TABLE LEDSTATUS";

return msg;

查詢一筆資料

var id = msg.payload.id;

var s=global.get("SEL1")

msg.topic="";

var temp="";

if (s==1)

{

temp ="SELECT * FROM LEDSTATUS";

temp=temp+" WHERE id LIKE '"+ id +"'";

}

msg.topic=temp;

global.set("SEL1",0);

return msg;

輸入id

刪除一筆資料

var id = msg.payload.id;

var s=global.get("SEL2")

msg.topic="";

var temp="";

if (s==2)

{

temp ="DELETE FROM LEDSTATUS";

temp=temp+" WHERE id LIKE '"+ id +"'";

}

msg.topic=temp;

global.set("SEL2",0)

return msg;

Store ID資料 function

var id = msg.payload.id;

global.set("ID",id)

return msg;

查詢一筆資料 function

var id = global.get("ID");

msg.topic="";

var temp="";

temp ="SELECT * FROM LEDSTATUS";

temp=temp+" WHERE id LIKE '"+ id +"'";

msg.topic=temp;

return msg;

Line Notify的發行

MQTT in
Function	msg.payload=" ---ESP32回來資料---" +msg.payload; return msg;
Set Line API	msg.headers = {'content-type':'application/x-www-form-urlencoded','Authorization':'Bearer A4wwPNh12WqB7dlfeQyyIAwtggn1kfZSI5LkkCdia1gB'}; msg.payload = {"message":msg.payload}; return msg; //oR7KdXvK1eobRr2sRRgsl4PMq23DjDlhfUs96SyUBZu
http 請求	POST https://notify-api.line.me/api/notify
Dashboard Text	{{msg.payload}}