alex9ufo 聰明人求知心切

ESP32 MFRC522 Read 讀取資料 Sector / Block + Node-Red UI控制 Sector / Block
//wifi &  MQTT
#include <WiFi.h>             //定義Wifi 程式庫
#include <PubSubClient.h>      //定義MQTT Pub發行 Sub 訂閱 程式庫

#include <SPI.h>
#include <MFRC522.h>

#define RST_PIN      27        // 讀卡機的重置腳位
#define SS_PIN       5        // 晶片選擇腳位

//GPIO 2 D1 Build in LED
#define LED 2                //定義LED接腳
//定義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 SSID password , SSID 和密碼進行Wi-Fi 設定 
//const char *ssid = "TOTOLINK_A3002MU"; // Enter your Wi-Fi name
//const char *password = "24063173";  // Enter Wi-Fi password
const char *ssid = "dlink-103A"; // Enter your Wi-Fi name
const char *password = "bdcce12882";  // Enter Wi-Fi password

// MQTT Broker
const char *mqtt_broker = "broker.hivemq.com"; //broker.mqtt-dashboard.com
const char *topic1 = "alex9ufo/RFID/read";
const char *topic3 = "alex9ufo/RFID/back";

const char *mqtt_username = "alex9ufo";
const char *mqtt_password = "public";
const int mqtt_port = 1883;

WiFiClient espClient;
PubSubClient client(espClient);
//定義 MQTT 發行及訂閱需要的變數
String json = "";
char jsonChar[50];  //client.publish
bool toggle=false;
bool RD_flag=false;
String text="";

MFRC522 mfrc522(SS_PIN, RST_PIN);    // 建立MFRC522物件
MFRC522::MIFARE_Key key;  // 儲存金鑰


byte sector = 15;   // 指定讀寫的「區段」，可能值:0~15
byte block = 1;     // 指定讀寫的「區塊」，可能值:0~3
byte blockData[16] = "             ";   // 最多可存入16個字元
// 若要清除區塊內容，請寫入16個 0
//byte blockData[16] = {0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0};

// 暫存讀取區塊內容的陣列，MIFARE_Read()方法要求至少要18位元組空間，來存放16位元組。
byte bufferarray[18]="               "; 
MFRC522::StatusCode status;
//====================================================   
/*** 位元組陣列轉儲為串列的十六進位值
 * 這個副程式把讀取到的UID，用16進位顯示出來
*/
void dump_byte_array(byte *buffer, byte bufferSize) {
  for (byte i = 0; i < bufferSize; i++) {
    Serial.print(buffer[i] < 0x10 ? " 0" : " ");
    Serial.print(buffer[i], HEX);
  }
}
//===========================================================
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;
    }
//===========================================================
void readBlock(byte _sector, byte _block, byte _blockData[])  {
  if (_sector < 0 || _sector > 15 || _block < 0 || _block > 3) {
    // 顯示「區段或區塊碼錯誤」，然後結束函式。
    Serial.println(F("Wrong sector or block number."));
    return;
  }

  byte blockNum = _sector * 4 + _block;  // 計算區塊的實際編號（0~63）
  byte trailerBlock = _sector * 4 + 3;   // 控制區塊編號

  // 驗證金鑰
  status = (MFRC522::StatusCode) mfrc522.PCD_Authenticate(MFRC522::PICC_CMD_MF_AUTH_KEY_A, trailerBlock, &key, &(mfrc522.uid));
  // 若未通過驗證…
  if (status != MFRC522::STATUS_OK) {
    // 顯示錯誤訊息
    Serial.print(F("PCD_Authenticate() failed: "));
    Serial.println(mfrc522.GetStatusCodeName(status));
    return;
  }

  byte buffersize = 18;
  status = (MFRC522::StatusCode) mfrc522.MIFARE_Read(blockNum, _blockData, &buffersize);

  // 若讀取不成功…
  if (status != MFRC522::STATUS_OK) {
    // 顯示錯誤訊息
    Serial.print(F("MIFARE_read() failed: "));
    Serial.println(mfrc522.GetStatusCodeName(status));
    return;
  }

  // 顯示「讀取成功！」
  Serial.println(F("Data was read."));

}
//===========================================================
//副程式  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, password);  //初始化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());
}    

//===========================================================
// 接收MQTT主題後呼叫運行程式
//===========================================================
void callback(char *topic, byte *payload, unsigned int length) {
    Serial.print("Message arrived in topic: ");
    Serial.println(topic);
    String topic1=topic;
    Serial.print("Message: ");
    String message;
   //將接收資料轉成字串以利後續判斷
    for (int i = 0; i < length; i++) {
        message += (char) payload[i];  // Convert *byte to string
    }
    Serial.println(message); 
    String  sec1;
    String  blk1;
    String  text1;
    toggle = false;

    sec1=message.substring(0,2);
    blk1=message.substring(3,5);
    text=message.substring(6);
    sector = sec1.toInt();
    block  = blk1.toInt();


    if (topic1.substring(14,18) == "read") {
      String  sec1=message.substring(0,2);
      String  blk1=message.substring(3,5);
      //String  text1=message.subString(6);
      sector = sec1.toInt();
      block  = blk1.toInt();  
      Serial.print(sec1); 
      Serial.print(blk1);

      digitalWrite(LED, LOW);  // Turn off
      toggle=true;
      RD_flag=true;
    }
}

//===========================================================
//  若目前沒有和伺服器相連，則反覆執行直到連結成功
void reconnect() {
  // Loop until we're reconnected
  while (!client.connected()) {
    Serial.print("Attempting MQTT connection...");
    // Attempt to connect
    if (client.connect("esp32-client-")) {
      Serial.println("connected");
      // Subscribe
      client.subscribe("alex9ufo/RFID/read");
      client.subscribe("alex9ufo/RFID/write");      
    } else {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      // Wait 5 seconds before retrying
      delay(5000);
      if (WiFi.status() != WL_CONNECTED)  {
        Serial.println("Reconnecting to WiFi...");
        WiFi.disconnect();
        WiFi.reconnect();
      }
    }
  }
}
//===========================================================
void setup() {
  Serial.begin(115200);
  SPI.begin();               // 初始化SPI介面
  mfrc522.PCD_Init();        // 初始化MFRC522卡片
  //======================================================
  // Connecting to a WiFi network
  setup_wifi();
  // Setting LED pin as output
  pinMode(LED, OUTPUT);
  digitalWrite(LED, LOW);  // Turn off the LED initially

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

  // 準備金鑰（用於key A和key B），出廠預設為6組 0xFF。
  for (byte i = 0; i < 6; i++) {
    key.keyByte[i] = 0xFF;
  }
  
  Serial.println(F("============================================="));
  Serial.println("Tap an RFID/NFC tag on the RFID-RC522 reader");
  // Connecting to an MQTT broker
  client.setServer(mqtt_broker, mqtt_port);
  while (!client.connected()) {
    String client_id = "esp32-client-";
    client_id += String(WiFi.macAddress());
    Serial.printf("The client %s connects to the public MQTT broker\n", client_id.c_str());
    if (client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {
        Serial.println("Public HiveMQ MQTT broker (broker.mqtt-dashboard.com) connected");
    } else {
        Serial.print("Failed with state ");
        Serial.print(client.state());
        delay(2000);
    }
  }

  // MQTT　Publish and subscribe
  client.subscribe(topic1);
  client.setCallback(callback);

}
//===========================================================
void loop() {
  // 查看是否感應到卡片
  if ( ! mfrc522.PICC_IsNewCardPresent()) {
    return;
  }
  // 選取一張卡片
   if ( ! mfrc522.PICC_ReadCardSerial()) {  // 若傳回1，代表已讀取到卡片的ID
    return;
  }   
  
  digitalWrite(LED, HIGH);  // Turn on 

  if (RD_flag==true) {
    if ((sector>0) || (block>0)) {
      Serial.print("sector=");
      Serial.print(sector,DEC);
      Serial.print(", block=");
      Serial.println(block,DEC);

      readBlock(sector, block, bufferarray);      // 區段編號、區塊編號、存放讀取資料的陣列

      Serial.print(F("Read block: "));        // 顯示儲存讀取資料的陣列元素值
      String str=String((char *)bufferarray);
      //for (byte i = 0 ; i <18 ; i++) {
      //  Serial.write (bufferarray[i]);
      //}

      Serial.println(str); 
      //========publish topic3 =========
      json = "sector=";
      json = json + String(sector);
      json = json + ", block=";
      json = json + String(block);
      json = json + ", Read data : ";
      //str=String((char *)bufferarray);
      json =json + str;
      json.trim();
      //json.toCharArray(jsonChar, json.length()+1);
      json.toCharArray(jsonChar,20+28+1);
      client.publish(topic3,jsonChar);
      RD_flag=false;
      
    } 
    else 
    {
      Serial.print(F("Card UID:"));
      dump_byte_array(mfrc522.uid.uidByte, mfrc522.uid.size); // 顯示卡片的UID
      Serial.println();
      Serial.print(F("PICC type: "));
      MFRC522::PICC_Type piccType = mfrc522.PICC_GetType(mfrc522.uid.sak);
      Serial.println(mfrc522.PICC_GetTypeName(piccType));  //顯示卡片的類型  
    
      json = "sector=";
      json = json + String(sector);
      json = json + "blockr=";
      json = json + String(block);
      json =json +(" Card UID: ");
      json = json + printHex(mfrc522.uid.uidByte, mfrc522.uid.size);
      json.trim();
      json = json +(" , PICC type: ");
      json = json + String(mfrc522.PICC_GetTypeName(piccType));
      json.trim();
      //json.toUpperCase();
      // Convert JSON string to character array
      json.toCharArray(jsonChar, json.length()+1);
      client.publish(topic3,jsonChar);

      // Dump debug info about the card; PICC_HaltA() is automatically called
      mfrc522.PICC_DumpToSerial(&(mfrc522.uid));
      RD_flag=false;  
    }
    // 令卡片進入停止狀態
    mfrc522.PICC_HaltA();
    mfrc522.PCD_StopCrypto1(); // stop encryption on PCD

  } //if (RD_flag==true)
         
  
  if (!client.connected()) { //假設未連接的處理程序
      reconnect();
      Serial.print(" client not connected  reconnect ");
      delay(200);
    } 
  client.loop();

  // if WiFi is down, try reconnecting
  if (WiFi.status() != WL_CONNECTED) {
    Serial.print(millis());
    Serial.println("Reconnecting to WiFi...");
    WiFi.disconnect();
    WiFi.reconnect();
    client.setCallback(callback);
  }

}
//===========================================================
alex9ufo 聰明人求知心切

2024年1月19日星期五

沒有留言:

張貼留言

Messaging API作為替代方案

2024年1月19日 星期五

沒有留言:

張貼留言

Messaging API作為替代方案

2024年1月19日星期五
