This document includes code for an ESP32-based IoT device that connects to WiFi, receives sensor data over radio, and sends data to a server via HTTP POST requests. It defines variables for sensor readings and device configuration. Setup code configures the radio, WiFi, web server, and initializes other libraries for GPS, OTA updates, and HTTP requests. RecvData() receives new sensor readings over radio and stores them in arrays.
This document includes code for an ESP32-based IoT device that connects to WiFi, receives sensor data over radio, and sends data to a server via HTTP POST requests. It defines variables for sensor readings and device configuration. Setup code configures the radio, WiFi, web server, and initializes other libraries for GPS, OTA updates, and HTTP requests. RecvData() receives new sensor readings over radio and stores them in arrays.
This document includes code for an ESP32-based IoT device that connects to WiFi, receives sensor data over radio, and sends data to a server via HTTP POST requests. It defines variables for sensor readings and device configuration. Setup code configures the radio, WiFi, web server, and initializes other libraries for GPS, OTA updates, and HTTP requests. RecvData() receives new sensor readings over radio and stores them in arrays.
This document includes code for an ESP32-based IoT device that connects to WiFi, receives sensor data over radio, and sends data to a server via HTTP POST requests. It defines variables for sensor readings and device configuration. Setup code configures the radio, WiFi, web server, and initializes other libraries for GPS, OTA updates, and HTTP requests. RecvData() receives new sensor readings over radio and stores them in arrays.
WiFi.mode(WIFI_STA); WiFi.begin(ssid, password); Serial.println(""); static uint16_t count_delay = 0; while (WiFi.status() != WL_CONNECTED) { delay(500); count_delay++; if (count_delay >= 30) { SPI.begin(14, 12, 13, 15); radio.begin(); radio.openReadingPipe(0, address); //Setting the address at which we will receive the data radio.setPALevel(RF24_PA_MIN); //You can set this as minimum or maximum depending on the distance between the transmitter and receiver. radio.startListening(); for (int i = 0; i < 10; i++) { digitalWrite(25, LOW); delay(200); digitalWrite(25, HIGH); delay(200); } sim_.setTimeout(100); return; } Serial.print("."); } connected_wifi = 1; Serial.println(""); Serial.print("IP address: "); Serial.println(WiFi.localIP()); delay(3000); // Port defaults to 8266 // ArduinoOTA.setPort(8266); if (!MDNS.begin(host)) { //http://esp32.local Serial.println("Error setting up MDNS responder!"); while (1) { delay(1000); } } Serial.println("mDNS responder started"); /*return index page which is stored in serverIndex */ server.on("/", HTTP_GET, []() { server.sendHeader("Connection", "close"); server.send(200, "text/html", loginIndex); }); server.on("/serverIndex", HTTP_GET, []() { server.sendHeader("Connection", "close"); server.send(200, "text/html", serverIndex); }); /*handling uploading firmware file */ server.on( "/update", HTTP_POST, []() { server.sendHeader("Connection", "close"); server.send(200, "text/plain", (Update.hasError()) ? "FAIL" : "OK"); ESP.restart(); }, []() { HTTPUpload& upload = server.upload(); if (upload.status == UPLOAD_FILE_START) { Serial.printf("Update: %s\n", upload.filename.c_str()); if (!Update.begin(UPDATE_SIZE_UNKNOWN)) { //start with max available size Update.printError(Serial); } } else if (upload.status == UPLOAD_FILE_WRITE) { /* flashing firmware to ESP*/ if (Update.write(upload.buf, upload.currentSize) != upload.currentSize) { Update.printError(Serial); } } else if (upload.status == UPLOAD_FILE_END) { if (Update.end(true)) { //true to set the size to the current progress Serial.printf("Update Success: %u\nRebooting...\n", upload.totalSize); } else { Update.printError(Serial); } } });
server.begin(); SPI.begin(14, 12, 13, 15); radio.begin(); radio.openReadingPipe(0, address); //Setting the address at which we will receive the data radio.setPALevel(RF24_PA_MIN); //You can set this as minimum or maximum depending on the distance between the transmitter and receiver. radio.startListening(); sim_.setTimeout(100); } int recvData() { if (radio.available()) { radio.read(&giatri, sizeof(giatri)); if ((int)giatri[4] == 6) { for (int i = 0; i < 5; i++) { if (giatri[i] == NAN) slave2[i] = 0; else slave2[i] = giatri[i]; } } else { for (int i = 0; i < 5; i++) { if (giatri[i] == NAN) slave1[i] = 0; else slave1[i] = giatri[i]; } } static uint8_t count_1 = 0; static uint8_t count_2 = 0; /* if (abs(last_value_1 - slave1[4]) ==0) { count_1++; if (count_1 >= 2) { count_1 = 0; for (int i = 0; i < 5; i++) { slave1[i] = 0; } } } if(abs(last_value_2-slave2[0])==0) { count_2++; if(count_2>=2) { count_2=0; for(int i =0 ; i<5;i++) { slave2[i]=0; } } } last_value_1 = slave1[4]; last_value_2 = slave2[0]; */ return 1; } return 0; } void loop() { static bool connected_2 = 0; static bool send_sms = 0; if (connected_wifi == 1) server.handleClient(); if (connected_ == 0 && connected_2 == 0) { static uint8_t count_signal = 0; static unsigned long time_d = millis(); if (millis() - time_d > 1000) { /// Serial.println("send"); sim_.println("AT+CSQ"); time_d = millis(); } if (sim_.available()) { String c = sim_.readString(); Serial.println(c); int m = c.indexOf(":"); if (m != -1) { // int u = c.indexOf(","); //Serial.println("m:"+String(m)); //Serial.println(c.substring(m+1,m+3)); int x = c.substring(m + 1, m + 4).toInt(); if (x >= 8) { count_signal++; } if (count_signal >= 5) { connected_2 = 1; connected_ = 0; gsm_config_gprs(); gsm_send_serial("AT+SAPBR=1,1"); } Serial.println("x:" + String(x)); } } } if (connected_2 == 1) { static unsigned long time_d2 = millis(); if (millis() - time_d2 > 1000) { /// Serial.println("send"); sim_.println("AT+SAPBR=2,1"); time_d2 = millis(); } if (sim_.available()) { String c = sim_.readString(); Serial.println(c); int m = c.indexOf("."); if (m != -1) { String str_2 = c.substring(m + 1); int ind_2 = str_2.indexOf("."); Serial.println("str:" + str_2);
//Serial.println("m:"+String(m)); //Serial.println(c.substring(m+1,m+3)); Serial.println(str_2.substring(0, ind_2)); int x = str_2.substring(0, ind_2).toInt();
if (x != 0) { connected_2 = 0; digitalWrite(25, LOW); // digitalWrite(33, HIGH); connected_ = 1; } Serial.println("x:" + String(x)); } } } run_every(1000) { send_sms = recvData(); if (send_sms) { Serial.print("slave1:"); for (int i = 0; i < 5; i++) { Serial.print(slave1[i]); Serial.print(","); } Serial.println(); Serial.print("slave2:"); for (int i = 0; i < 5; i++) { Serial.print(slave2[i]); Serial.print(","); } Serial.println(); } } if (connected_ == 1) { static unsigned long time_m = millis(); if (Serial2.available() > 0) { //Serial.println("serial2:"+String(Serial2.read())); gps.encode(Serial2.read()); if (gps_status == 0) { if (gps.location.isValid()) { lat_value = gps.location.lat(); lng_value = gps.location.lng(); // Serial.println(lat_value); gps_status = 1; } else { Serial.print(F("INVALID")); } // Serial.println(lng_value);
