alex9ufo 聰明人求知心切: ESP32 NFC PN532 + Node-red +SQLite Database

ESP32 NFC PN532 + Node-red +SQLite Database

// MQTT Broker

const char *mqtt_broker = "broker.mqtt-dashboard.com";

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

const char *topic = "alex9ufo/esp32/Starting";

//====================================================
// esp32-wroom-32 devkit v1 default pins
//       SCL D22
//       SDA D21
//====================================================
// Define the interface type
#include <WiFi.h>           //WIFI
#include <PubSubClient.h>   //MQTT
#include <Wire.h>           //I2C
#include <PN532_I2C.h>      //PN532
#include <PN532.h>
#include <NfcAdapter.h>     //NFC

//NFC
PN532_I2C pn532i2c(Wire);
PN532 nfc(pn532i2c);


// WiFi
const char ssid[] = "alex9ufo"; // Enter your Wi-Fi name
const char password[] = "alex9981";  // Enter Wi-Fi password

// MQTT Broker
const char *mqtt_broker = "broker.mqtt-dashboard.com";
const char *topic2 = "alex9ufo/esp32/RFID";
const char *topic = "alex9ufo/esp32/Starting";
const char *mqtt_username = "alex9ufo";
const char *mqtt_password = "public";
const int mqtt_port = 1883;

bool atwork = false;

WiFiClient espClient;
PubSubClient MQTTclient(espClient);

long lastMsg = 0;
long lastMsg1= 0;
long countNFC= 0;
//=======NFC===============
boolean success;
volatile bool connected = false;
// Buffer to store the UID
uint8_t uid[] = { 0, 0, 0, 0, 0, 0, 0 };
  // UID size (4 or 7 bytes depending on card type)
uint8_t uidLength;

char jsonChar1[30];  //client.publish("alex9ufo/Esp32/RFID"
//===========================================================
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;
    }

//======================================================
bool NFCconnect() {
  nfc.begin();
  // Connected, show version
  uint32_t versiondata = nfc.getFirmwareVersion();
  if (! versiondata)
  {
    Serial.println("PN53x card not found!");
    return false;
  }

  //port
  Serial.print("Found chip PN5"); Serial.println((versiondata >> 24) & 0xFF, HEX);
  Serial.print("Firmware version: "); Serial.print((versiondata >> 16) & 0xFF, DEC);
  Serial.print('.'); Serial.println((versiondata >> 8) & 0xFF, DEC);

  // Set the max number of retry attempts to read from a card
  // This prevents us from waiting forever for a card, which is
  // the default behaviour of the PN532.
  nfc.setPassiveActivationRetries(0xFF);

  // configure board to read RFID tags
  nfc.SAMConfig();

  Serial.println("Waiting for card (ISO14443A Mifare)...");
  Serial.println("");

  return true;
}

//===========================================================
void setup() {
    // Set software serial baud to 115200;
    Serial.begin(115200);
    delay(1000); // Delay for stability
    //======================================================
    // Connecting to a WiFi network
    Serial.print("Connecting to ");
    Serial.println(ssid);

    WiFi.begin(ssid, password);

    while (WiFi.status() != WL_CONNECTED) {
      delay(500);
      Serial.print(".");
    }

    Serial.println("");
    Serial.println("WiFi connected");
    Serial.println("IP address: ");
    Serial.println(WiFi.localIP());
  

    Serial.println(F("Ready!"));
    Serial.println(F("======================================================")); 
    Serial.println("*** Testing Module PN532 NFC RFID ***");

    // Connecting to an MQTT broker
    MQTTclient.setServer(mqtt_broker, mqtt_port);
    MQTTclient.setCallback(callback);

    while (!MQTTclient.connected()) {
        String MQTTclient_id = "esp32-client-";
        MQTTclient_id += String(WiFi.macAddress());
        Serial.printf("The client %s connects to the public MQTT broker\n", MQTTclient_id.c_str());
        if (MQTTclient.connect(MQTTclient_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(MQTTclient.state());
            delay(2000);
        }
    } 

    // Publish and subscribe
    MQTTclient.publish(topic,"ESP32 at work");
    nfc.begin();
    connected = NFCconnect();
    while (!connected) {
        connected = NFCconnect();
        delay(200);
        Serial.print(". waiting NFC Readey ");
        countNFC=countNFC+1;
        if (countNFC==300){
            MQTTclient.publish(topic,"waiting NFC Readey");
            countNFC=0;
        }

    }
}
//===========================================================
void callback(char* topic, byte* message, unsigned int length) {
    Serial.println("Call back subroutine");
    Serial.println("--------------------");
    Serial.print("Message arrived on topic: ");
    Serial.print(topic);
    Serial.print(". Message: ");
    String messageTemp;
  
    for (int i = 0; i < length; i++) {
      Serial.print((char)message[i]);
      messageTemp += (char)message[i];
    }
    Serial.println();

}

//===========================================================
void reconnect() {
  // Loop until we're reconnected
  while (!MQTTclient.connected()) {
    Serial.print("Attempting MQTT connection...");
    delay(500);
    // Attempt to connect
    if (MQTTclient.connect("esp32-client")) {
      Serial.println("esp32-client connected");
      MQTTclient.setServer(mqtt_broker, mqtt_port);
      MQTTclient.setCallback(callback);  
    } else {
      Serial.print("failed, rc=");
      Serial.print(MQTTclient.state());
      Serial.println(" try again in 5 seconds");
      // Wait 5 seconds before retrying
      delay(5000);
    }
  }
}

//===========================================================
void loop() {
  if (!MQTTclient.connected()) {
    reconnect();
    delay(200);
  }
  MQTTclient.loop();
  long now = millis();
  long now1 = millis();

//============================================
    if (now - lastMsg > 5000) {
      Serial.println("Reading RFID card");
      lastMsg = now;
      connected = NFCconnect();
      while (!connected) {
        connected = NFCconnect();
      }
      // Wait for an ISO14443A type cards (Mifare, etc.).  When one is found
      // 'uid' will be populated with the UID, and uidLength will indicate
      // if the uid is 4 bytes (Mifare Classic) or 7 bytes (Mifare Ultralight)
      success = nfc.readPassiveTargetID(PN532_MIFARE_ISO14443A, &uid[0], &uidLength);

      // If the card is detected, print the UID
      if (success)
        {
          Serial.println("Card Detected");
          Serial.print("Size of UID: "); Serial.print(uidLength, DEC);
          Serial.println(" bytes");
          Serial.print("UID: ");
          for (uint8_t i = 0; i < uidLength; i++)
          {
            Serial.print(" 0x"); Serial.print(uid[i], HEX);
          }
          Serial.println("");
          Serial.println("");
        //=====================================    
          String json = printHex(uid, uidLength);
          // Convert JSON string to character array
          json.toCharArray(jsonChar1, json.length()+1);
    
          if  (MQTTclient.connected()) {
            Serial.print("Publish message: ");
            Serial.println(json);
            // Publish JSON character array to MQTT topic
            MQTTclient.publish(topic2,jsonChar1);
          }   
          //=====================================
          delay(100);
          connected = NFCconnect();
          
        }

      else
        {
            // PN532 probably timed out waiting for a card
            // Serial.println("Timed out waiting for a card");
        }      
         
    } //(now - lastMsg > 5000)
}
//========================================

alex9ufo 聰明人求知心切

2023年8月17日星期四

ESP32 NFC PN532 + Node-red +SQLite Database

沒有留言:

張貼留言

Messaging API作為替代方案

2023年8月17日 星期四

ESP32 NFC PN532 + Node-red +SQLite Database

沒有留言:

張貼留言

Messaging API作為替代方案

2023年8月17日星期四