實驗1-2 RFID (Read Tag + MQTT+ Node-Red + Line Notify )
/*
ESP32 MQTT
*/
#include <WiFi.h>
#include <PubSubClient.h>
#include <SPI.h>
#include <MFRC522.h>
#define BUILTIN_LED 2
/* Wiring RFID RC522 module
=============================================================================
GND = GND 3.3V = 3.3V
The following table shows the typical pin layout used:
* MFRC522 ESP32 Arduino Arduino Arduino Arduino Arduino
* Reader/PCD Uno/101 Mega Nano v3 Leonardo/Micro Pro Micro
* Signal Pin Pin Pin Pin Pin Pin Pin
* -----------------------------------------------------------------------------------------
* RST/Reset RST GPIO27 9 5 D9 RESET/ICSP-5 RST
* SPI SS SDA(SS) GPIO5 10 53 D10 10 10
* SPI MOSI MOSI GPIO23 11 / ICSP-4 51 D11 ICSP-4 16
* SPI MISO MISO GPIO19 12 / ICSP-1 50 D12 ICSP-1 14
* SPI SCK SCK GPIO18 13 / ICSP-3 52 D13 ICSP-3 15
*
[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
=============================================================================
*/
#define SS_PIN 5 // ESP32 pin GIOP5
#define RST_PIN 27 // ESP32 pin GIOP27
// Update these with values suitable for your network.
//const char *ssid = "PTS-2F";
//const char *pass = "";
const char *ssid = "TOTOLINK_A3002MU";
const char *pass = "24063173";
//const char *ssid = "74170287";
//const char *pass = "24063173";
//const char *ssid = "yourSSID"; // change according to your Network - cannot be longer than 32 characters!
//const char *pass = "yourPASSWORD"; // change according to your Network
#define MQTTid "" //id of this mqtt client
#define MQTTip "broker.mqtt-dashboard.com" //ip address or hostname of the mqtt broker
#define MQTTport 1883 //port of the mqtt broker
#define MQTTuser "alex9ufo" //username of this mqtt client
#define MQTTpsw "alex1234" //password of this mqtt client
//#define MQTTuser "your_username" //username of this mqtt client
//#define MQTTpsw "your_password" //password of this mqtt client
#define MQTTpubQos 2 //qos of publish (see README)
#define MQTTsubQos 1 //qos of subscribe
MFRC522 rfid(SS_PIN, RST_PIN); // Create MFRC522 instance
//Variables
long lastMsg = 0;
char jsonChar[100];
String IDNo_buf="";
//=============================================================================
boolean pendingDisconnect = false;
void mqttConnectedCb(); // on connect callback
void mqttDisconnectedCb(); // on disconnect callback
void mqttDataCb(char* topic, byte* payload, unsigned int length); // on new message callback
WiFiClient wclient;
PubSubClient client(MQTTip, MQTTport, mqttDataCb, wclient);
//=============================================================================
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);
}
return id;
}
//=============================================================================
void mqttConnectedCb() {
Serial.println("mqtt connected");
// Once connected, publish an announcement...
client.publish("alex9ufo/outTopic/RFID/json", jsonChar, MQTTpubQos); // true means retain
// ... and resubscribe
client.subscribe("alex9ufo/inTopic", MQTTsubQos);
}
//=============================================================================
void mqttDisconnectedCb() {
Serial.println("disconnected");
}
//=============================================================================
void mqttDataCb(char* topic, byte* payload, unsigned int length) {
/*
you can convert payload to a C string appending a null terminator to it;
this is possible when the message (including protocol overhead) doesn't
exceeds the MQTT_MAX_PACKET_SIZE defined in the library header.
you can consider safe to do so when the length of topic plus the length of
message doesn't exceeds 115 characters
*/
char* message = (char *) payload;
message[length] = 0;
Serial.print("Message arrived [");
Serial.print(topic);
Serial.print("] ");
Serial.println(message);
// Switch on the LED if an 1 was received as first character
if (message[0] == '0') {
digitalWrite(BUILTIN_LED, LOW); // Turn the LED on (Note that LOW is the voltage level
// but actually the LED is on; this is because
Serial.println("Received 0 , Send LOW TO BuildIn_LED");
}
if (message[0] == '1') {
digitalWrite(BUILTIN_LED, HIGH); // Turn the LED off (Note that HIGH is the voltage level
// but actually the LED is on; this is because
Serial.println("Received 1 , Send HIGH TO BuildIn_LED");
}
if (message[0] == '2') {
digitalWrite(BUILTIN_LED, HIGH); // Turn the LED off (Note that HIGH is the voltage level
// but actually the LED is on; this is because
Serial.println("Received 2 , Flashing BuildIn_LED ");
for (int i=0; i <=5; i++){
digitalWrite(BUILTIN_LED, HIGH); // Turn the LED off (Note that HIGH is the voltage level
delay(500);
digitalWrite(BUILTIN_LED, LOW); // Turn the LED on (Note that HIGH is the voltage level
delay(500);
} //for (int
digitalWrite(BUILTIN_LED, HIGH);
} //if (message[0] == '2')
}
//======================================================
void setup_wifi() {
delay(10);
// We start by connecting to a WiFi network
Serial.println();
Serial.print("Connecting to ");
Serial.println(ssid);
WiFi.begin(ssid, pass);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
Serial.println("");
Serial.println("WiFi connected");
Serial.println("IP address: ");
Serial.println(WiFi.localIP());
}
//======================================================
void setup() {
Serial.begin(115200);
setup_wifi();
pinMode(BUILTIN_LED, OUTPUT);
Serial.println(F("Booting...."));
SPI.begin(); // Init SPI bus
rfid.PCD_Init(); // Init MFRC522
Serial.println(F("Ready!"));
Serial.println(F("======================================================"));
Serial.println("Tap an RFID/NFC tag on the RFID-RC522 reader");
}
//======================================================
void process_mqtt() {
if (WiFi.status() == WL_CONNECTED) {
if (client.connected()) {
client.loop();
} else {
// client id, client username, client password, last will topic, last will qos, last will retain, last will message
if (client.connect(MQTTid, MQTTuser, MQTTpsw, MQTTid "/status", 2, true, "0")) {
pendingDisconnect = false;
mqttConnectedCb();
}
}
} else {
if (client.connected())
client.disconnect();
}
if (!client.connected() && !pendingDisconnect) {
pendingDisconnect = true;
mqttDisconnectedCb();
}
}
//======================================================
void loop() {
process_mqtt();
if (rfid.PICC_IsNewCardPresent()) { // new tag is available
if (rfid.PICC_ReadCardSerial()) { // NUID has been readed
MFRC522::PICC_Type piccType = rfid.PICC_GetType(rfid.uid.sak);
Serial.print("RFID/NFC Tag Type: ");
Serial.println(rfid.PICC_GetTypeName(piccType));
// print UID in Serial Monitor in the hex format
Serial.print("UID:");
for (int i = 0; i < rfid.uid.size; i++) {
Serial.print(rfid.uid.uidByte[i] < 0x10 ? " 0" : " ");
Serial.print(rfid.uid.uidByte[i], HEX);
}
Serial.println();
String IDNo = printHex(rfid.uid.uidByte, rfid.uid.size);
IDNo_buf="";
IDNo_buf=IDNo;
// Convert data to JSON string
String json =
"{\"data\":{"
"\"RFID_No\": \"" + IDNo + "\"}"
"}";
// Convert JSON string to character array
json.toCharArray(jsonChar, json.length()+1);
if (client.connected()) {
Serial.print("Publish message: ");
Serial.println(json);
// Publish JSON character array to MQTT topic
client.publish("alex9ufo/outTopic/RFID/json",jsonChar);
}
rfid.PICC_HaltA(); // halt PICC
rfid.PCD_StopCrypto1(); // stop encryption on PCD
}
}
}
//======================================================
[{"id":"6ac1f2e21e5ce9f8","type":"mqtt in","z":"604dfe4cb3f271cf","name":"","topic":"alex9ufo/outTopic/RFID/json","qos":"1","datatype":"auto","broker":"841df58d.ee5e98","nl":false,"rap":false,"inputs":0,"x":180,"y":100,"wires":[["2d7d3efeb24e2709","bad530066bb75829","30fd337115bfddcd","7b834b63beb07dbe"]]},{"id":"2d7d3efeb24e2709","type":"ui_text","z":"604dfe4cb3f271cf","group":"6c9116b.b62d4e8","order":0,"width":0,"height":0,"name":"","label":"MQTT Suscribe Data","format":"{{msg.payload}}","layout":"col-center","x":520,"y":100,"wires":[]},{"id":"31fbbd66cc7a064d","type":"ui_button","z":"604dfe4cb3f271cf","name":"","group":"6c9116b.b62d4e8","order":0,"width":0,"height":0,"passthru":false,"label":"LED ON","tooltip":"","color":"white","bgcolor":"","className":"","icon":"fa-circle","payload":"1","payloadType":"str","topic":"","topicType":"str","x":140,"y":320,"wires":[["d986a407aed86654","b645b128e47df32b"]]},{"id":"044afb7ada96bd50","type":"ui_button","z":"604dfe4cb3f271cf","name":"","group":"6c9116b.b62d4e8","order":0,"width":0,"height":0,"passthru":false,"label":"LED OFF","tooltip":"","color":"black","bgcolor":"","className":"","icon":"fa-circle-o","payload":"0","payloadType":"str","topic":"","topicType":"str","x":140,"y":360,"wires":[["d986a407aed86654","b645b128e47df32b"]]},{"id":"d986a407aed86654","type":"mqtt out","z":"604dfe4cb3f271cf","name":"","topic":"alex9ufo/inTopic","qos":"1","retain":"false","respTopic":"","contentType":"","userProps":"","correl":"","expiry":"","broker":"841df58d.ee5e98","x":400,"y":360,"wires":[]},{"id":"bad530066bb75829","type":"function","z":"604dfe4cb3f271cf","name":"Format timestamp","func":"var date = new Date();\nvar h = date.getHours();\nvar m = date.getMinutes();\nvar s = date.getSeconds();\nif(h<10){\n h = '0'+h;\n}\nif(m<10){\n m = '0' + m;\n}\nif(s<10){\n s = '0' + s;\n}\nmsg.payload = msg.payload + ' --> Time:(' + h + ':' + m + ':' + s + ')' ;\n\nreturn msg;","outputs":1,"noerr":0,"x":170,"y":260,"wires":[["155dfcc289131f21"]]},{"id":"155dfcc289131f21","type":"function","z":"604dfe4cb3f271cf","name":"Set Line API ","func":"msg.headers = {'content-type':'application/x-www-form-urlencoded','Authorization':'Bearer A4wwPNh2WqB7dlfeQyyIAwtggn1kfZSI5LkkCdia1gB'};\nmsg.payload = {\"message\":msg.payload};\nreturn msg;\n\n//oR7KdXvK1eobRr2sRRgsl4PMq23DjDlhfUs96SyUBZu","outputs":1,"noerr":0,"x":390,"y":260,"wires":[["136bb096e188ff2f"]]},{"id":"136bb096e188ff2f","type":"http request","z":"604dfe4cb3f271cf","name":"","method":"POST","ret":"txt","paytoqs":false,"url":"https://notify-api.line.me/api/notify","tls":"","persist":false,"proxy":"","authType":"","x":560,"y":260,"wires":[["f62acb5a1c020805"]]},{"id":"f62acb5a1c020805","type":"debug","z":"604dfe4cb3f271cf","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"false","x":750,"y":260,"wires":[]},{"id":"30fd337115bfddcd","type":"debug","z":"604dfe4cb3f271cf","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"false","x":510,"y":40,"wires":[]},{"id":"613993d46e4a7e18","type":"ui_button","z":"604dfe4cb3f271cf","name":"","group":"6c9116b.b62d4e8","order":0,"width":0,"height":0,"passthru":false,"label":"LED Flashing","tooltip":"","color":"blue","bgcolor":"","className":"","icon":"fa-circle-o","payload":"2","payloadType":"str","topic":"","topicType":"str","x":160,"y":400,"wires":[["d986a407aed86654","b645b128e47df32b"]]},{"id":"b645b128e47df32b","type":"ui_audio","z":"604dfe4cb3f271cf","name":"","group":"6c9116b.b62d4e8","voice":"zh-TW","always":true,"x":360,"y":420,"wires":[]},{"id":"7b834b63beb07dbe","type":"ui_audio","z":"604dfe4cb3f271cf","name":"","group":"6c9116b.b62d4e8","voice":"zh-TW","always":true,"x":480,"y":160,"wires":[]},{"id":"841df58d.ee5e98","type":"mqtt-broker","name":"","broker":"broker.mqtt-dashboard.com","port":"1883","clientid":"","usetls":false,"compatmode":false,"keepalive":"15","cleansession":true,"birthTopic":"","birthQos":"0","birthPayload":"","closeTopic":"","closePayload":"","willTopic":"","willQos":"0","willPayload":""},{"id":"6c9116b.b62d4e8","type":"ui_group","name":"Storing IOT Data ","tab":"eeb8e179.a47a4","order":1,"disp":true,"width":"6","collapse":true},{"id":"eeb8e179.a47a4","type":"ui_tab","name":"eWeLink","icon":"dashboard","disabled":false,"hidden":false}]
沒有留言:
張貼留言