ESP32 Forum

Code: Select all

#include <Arduino.h>
#include <HardwareSerial.h>

HardwareSerial simSerial(1);  // UART1
#define SIM_RX 43
#define SIM_TX 44

String APN = "free";
String BROKER = "IP";
int PORT = 1883;
String TOPIC = "test/esp32";

// -------------------- Fonctions AT --------------------
String sendAT(String cmd, unsigned long timeout = 2000) {
  simSerial.println(cmd);
  unsigned long start = millis();
  String response = "";
  while (millis() - start < timeout) {
    while (simSerial.available()) {
      char c = simSerial.read();
      response += c;
    }
  }
  Serial.println("AT Response: " + response);
  return response;
}

// Boucle pour attendre "OK"
bool waitForATReady(int retries = 10) {
  for (int i = 0; i < retries; i++) {
    String resp = sendAT("AT");
    if (resp.indexOf("OK") != -1) return true;
    delay(1000);
  }
  return false;
}

// -------------------- Vérifications --------------------
bool checkSIM() {
  String resp = sendAT("AT+CPIN?");
  if (resp.indexOf("READY") != -1) {
    Serial.println("SIM OK");
    return true;
  }
  Serial.println("SIM not ready");
  return false;
}

bool checkSignal() {
  String resp = sendAT("AT+CSQ");
  int rssiIndex = resp.indexOf("+CSQ:");
  if (rssiIndex != -1) {
    int rssi = resp.substring(rssiIndex + 6).toInt();
    Serial.println("RSSI = " + String(rssi));
    if (rssi == 99) return false;
    return true;
  }
  return false;
}

bool checkNetwork() {
  String cs = sendAT("AT+CREG?");
  String ps1 = sendAT("AT+CGREG?");
  String ps2 = sendAT("AT+CEREG?");
  if (cs.indexOf(",1") != -1 || ps1.indexOf(",1") != -1 || ps2.indexOf(",1") != -1) {
    Serial.println("Network registered");
    return true;
  }
  return false;
}

bool checkService() {
  String resp = sendAT("AT+CPSI?");
  if (resp.indexOf("NO SERVICE") != -1) {
    Serial.println("No network service");
    return false;
  }
  return true;
}

// -------------------- PDP Context --------------------
bool setupPDP() {
  sendAT("AT+CGDCONT=1,\"IP\",\"" + APN + "\"");
  sendAT("AT+CGACT=1,1");
  String resp = sendAT("AT+CGACT?");
  if (resp.indexOf("1,1") != -1) {
    Serial.println("PDP active, IP assigned");
    return true;
  }
  return false;
}

// -------------------- MQTT --------------------
bool mqttPublish(String topic, String payload) {
  sendAT("AT+CMQTTSTART"); // activer MQTT
  delay(2000);
  sendAT("AT+CMQTTACCQ=0,\"ESP32-S3\",0"); // config client
  delay(2000);
  sendAT("AT+CMQTTCONNECT=0,\"tcp://" + BROKER + ":" + String(PORT) + "\",60,1"); // connect broker
  delay(10000);

  // Préparer topic
  simSerial.printf("AT+CMQTTTOPIC=0,%d\r\n", topic.length());
  delay(500);
  simSerial.println(topic);
  delay(500);

  // Préparer payload
  simSerial.printf("AT+CMQTTPAYLOAD=0,%d\r\n", payload.length());
  delay(500);
  simSerial.println(payload);
  delay(500);

  // Publier message
  sendAT("AT+CMQTTPUB=0,1,60");
  delay(3000);
  Serial.println("Published: " + payload);
  return true;
}

// -------------------- Setup --------------------
void setup() {
  Serial.begin(115200);
  simSerial.begin(115200, SERIAL_8N1, SIM_RX, SIM_TX);

  Serial.println("\n=== ESP32-S3 + A7670E MQTT ===");

  if (!waitForATReady()) {
    Serial.println("Module not responding to AT commands. Halting.");
    while(1);
  }

  while (!checkSIM()) delay(2000);
  while (!checkSignal()) delay(2000);
  while (!checkNetwork()) delay(2000);
  while (!checkService()) delay(2000);
  while (!setupPDP()) delay(2000);

  Serial.println("\nModule ready, publishing first message in 5s...");
  delay(5000);
  mqttPublish(TOPIC, "Hello!");
}

// -------------------- Loop --------------------
void loop() {
  static uint32_t last = 0;
  if (millis() - last < 10000) return;
  last = millis();

  int r = random(1,101);
  String payload = String(r);
  mqttPublish(TOPIC, payload);
}