main.ino 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421
  1. #include "TinyGPSPlus.h"
  2. #include "DHT.h"
  3. #include <Wire.h>
  4. #include <Adafruit_GFX.h>
  5. #include <Adafruit_SSD1306.h>
  6. #include "FS.h"
  7. #include "SD.h"
  8. #include "SPI.h"
  9. #include "Arduino.h"
  10. #include "math.h"
  11. /*
  12. Uncomment and set up if you want to use custom pins for the SPI communication
  13. #define REASSIGN_PINS
  14. int sck = -1;
  15. int miso = -1;
  16. int mosi = -1;
  17. int cs = -1;
  18. */
  19. // Inicia I2C en pines default ESP32 (21 SDA, 22 SCL)
  20. #define SCREEN_WIDTH 128 // Ancho píxeles
  21. #define SCREEN_HEIGHT 64 // Alto píxeles
  22. #define OLED_RESET -1 // Reset pin (no usado)
  23. // Pines para UART2 (Serial2)
  24. #define RX_PIN 16 // RX del ESP32 conectado a TX del GPS
  25. #define TX_PIN 17 // TX del ESP32 conectado a RX del GPS
  26. #define GPS_BAUD 115200
  27. #define DHTPIN 4 // Digital pin connected to the DHT sensor
  28. #define DHTTYPE DHT22
  29. #define BUTTON_PIN 27 // pin para pulsador
  30. //definicion de tiempos de pulsacion
  31. #define PULASCION_LARGA_MS 2000
  32. #define DURACION_WATCHDOG_MS 10000
  33. #define MEASUREMENT_INTERVAL_S 1 //separación entre mediciones (s)
  34. #define DEG2RAD (M_PI/180.0)
  35. // Objeto TinyGPS++
  36. TinyGPSPlus gps;
  37. HardwareSerial gpsSerial(2); // Usar UART2
  38. DHT dht(DHTPIN, DHTTYPE);
  39. Adafruit_SSD1306 display(SCREEN_WIDTH, SCREEN_HEIGHT, &Wire, OLED_RESET);
  40. //valores de los sensores
  41. struct SensorData {
  42. double latitude = 0.0;
  43. double longitude = 0.0;
  44. float altura = 0.0;
  45. String tiempo = "";
  46. float temperature = 0.0;
  47. float humidity = 0.0;
  48. float pressure = 0.0;
  49. };
  50. SensorData latestData;
  51. SensorData datosAntiguos;
  52. SemaphoreHandle_t dataMutex; // Mutex para proteger el acceso a latestData
  53. SemaphoreHandle_t buttonSemaphore; // Semáforo para la tarea del botón
  54. bool grabando = false; //inicia apagado
  55. TaskHandle_t medicionesHandle = NULL; //para suspend/resume
  56. int pantallaEstado_grab = 0; //maquina de estados cuando se graba ruta
  57. int pantallaEstado_menu = 0; //maquina de estados cuando no se esta grabando ruta
  58. float distancia_total = 0.0;
  59. volatile unsigned long ignore_isr_until = 0; //para debounce
  60. char filename[13];
  61. void OLED_print(const String& line1, const String& line2) {
  62. display.clearDisplay();
  63. display.setTextSize(2);
  64. display.setTextColor(SSD1306_WHITE);
  65. display.setCursor(0, 0);
  66. display.println(line1);
  67. display.println(line2);
  68. display.display();
  69. }
  70. void DHT_test() {
  71. dht.begin();
  72. float h = dht.readHumidity();
  73. float t = dht.readTemperature();
  74. if (isnan(h) || isnan(t)) {
  75. Serial.println("Failed to read from DHT sensor!");
  76. OLED_print("DHT22", "Error");
  77. delay(5000);
  78. DHT_test(); // Reintentar
  79. }
  80. else OLED_print("DHT22", "Correcto");
  81. }
  82. void OLED_test() { //pantallazo a blanco y luego iniciando
  83. // Inicia I2C en pines default ESP32 (21 SDA, 22 SCL)
  84. Wire.begin();
  85. if (!display.begin(SSD1306_SWITCHCAPVCC, 0x3C)) { // Dirección común: 0x3C
  86. Serial.println(F("Error: OLED no encontrado!"));
  87. for (;;); // Para siempre
  88. }
  89. display.clearDisplay();
  90. display.fillScreen(SSD1306_WHITE); // Pantalla blanca
  91. delay(500);
  92. display.display();
  93. display.clearDisplay();
  94. display.setTextSize(2); // Tamaño texto
  95. display.setTextColor(SSD1306_WHITE);
  96. display.setCursor(0, 0); // Posición
  97. display.println("Iniciando...");
  98. display.display(); // Muestra
  99. delay(1000);
  100. }
  101. void SD_test(){
  102. if (!SD.begin()) {
  103. Serial.println("SD Card Mount Failed");
  104. OLED_print("SD Card", "Error\nInserte");
  105. while (!SD.begin());
  106. OLED_print("SD Card", "Insertada");
  107. } else {
  108. OLED_print("SD Card", "Correcto");
  109. Serial.println("SD Card initialized.");
  110. }
  111. uint8_t cardType = SD.cardType();
  112. if (cardType == CARD_NONE) {
  113. Serial.println("No SD card attached");
  114. OLED_print("SD Card", "No detectada");
  115. while (cardType == CARD_NONE) {
  116. delay(1000);
  117. cardType = SD.cardType();
  118. }
  119. OLED_print("SD Card", "Detectada");
  120. }
  121. uint8_t cardSize = SD.cardSize() / (1024 * 1024);
  122. Serial.printf("SD Card Size: %uMB\n", cardSize);
  123. int num = 1;
  124. sprintf(filename, "/data%03d.xml", num);
  125. while (SD.exists(filename)) {
  126. num++;
  127. sprintf(filename, "/data%03d.xml", num);
  128. }
  129. File file = SD.open(filename, FILE_WRITE);
  130. if (file) {
  131. file.println('<?xml version="1.0" encoding="UTF-8"?>\n<gpx creator="ESP32 GPS LOGGER" version="1.1"\n\txmlns="http://www.topografix.com/GPX/1/1"\n\t
  132. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"\n\txmlns:gpxtpx="http://www.garmin.com/xmlschemas/TrackPointExtension/v2"\n\t
  133. xmlns:gpxdata="http://www.cluetrust.com/XML/GPXDATA/1/0"\n\txsi:schemaLocation="http://www.topografix.com/GPX/1/1 http://www.topografix.com/GPX/1/1/gpx.xsd">\n\t<trk>\n\t\t
  134. <name>Rutita</name>\n\t\t<type>hiking</type>\n\t\t<trkseg>');
  135. file.close();
  136. } else {
  137. OLED_print("Error","creando archivo");
  138. }
  139. }
  140. void GPS_test_wait() {
  141. // Iniciar Serial2 para GPS
  142. gpsSerial.begin(GPS_BAUD, SERIAL_8N1, RX_PIN, TX_PIN);
  143. while (((gpsSerial.available() > 0) && gps.location.isValid()) && (gps.speed.age() < 2000)) {
  144. gps.encode(gpsSerial.read());
  145. delay(100);
  146. OLED_print("GPS", "Esperando.");
  147. delay(100);
  148. OLED_print("GPS", "Esperando..");
  149. delay(100);
  150. OLED_print("GPS", "Esperando...");
  151. }
  152. OLED_print("GPS", "Encontrado");
  153. }
  154. float calcular_delta_dist(float lat1, float long1, float lat2, float long2){
  155. float R = 6371.0; // Radio de la Tierra en km
  156. float delta_lat = (lat2 - lat1) * DEG2RAD;
  157. float delta_long = (long2 - long1) * DEG2RAD;
  158. lat1 = lat1 * DEG2RAD;
  159. lat2 = lat2 * DEG2RAD;
  160. float a = sin(delta_lat/2)*sin(delta_lat/2)+cos(lat1)*cos(lat2)*sin(delta_long/2)*sin(delta_long/2);
  161. float c = 2 * atan2(sqrt(a),sqrt(1-a));
  162. return R * c; //En km
  163. }
  164. void task_mediciones(void *pvParameters) {
  165. TickType_t xLastWakeTime = xTaskGetTickCount();
  166. while(1) {
  167. // se leen los valores antes de utilizar el semaphore
  168. while (gpsSerial.available() > 0) {
  169. gps.encode(gpsSerial.read());
  170. }
  171. float new_latitude = gps.location.lat();
  172. float new_longitude = gps.location.lng();
  173. float new_altitude = gps.altitude.meters();
  174. String new_fecha = String(gps.date.year())+"-"+String(gps.date.month())+"-"+
  175. String(gps.date.day())+"T"+String(gps.time.hour())+":"+
  176. String(gps.time.minute())+":"+String(gps.time.second())+"."+
  177. String(gps.time.centisecond())
  178. float new_temp = dht.readTemperature();
  179. float new_hum = dht.readHumidity();
  180. float new_press = 0.0; // Placeholder, no hay sensor de presión
  181. if (gps.location.isValid() && datosAntiguos.latitude != 0.0) {
  182. distancia_total += calcular_delta_dist(datosAntiguos.latitude, datosAntiguos.longitude, new_latitude, new_longitude);
  183. }
  184. if (xSemaphoreTake(dataMutex, portMAX_DELAY) == pdTRUE) {
  185. latestData.latitude = new_latitude;
  186. latestData.longitude = new_longitude;
  187. latestData.altura = new_altitude;
  188. latestData.tiempo = new_fecha;
  189. latestData.temperature = new_temp;
  190. latestData.humidity = new_hum;
  191. latestData.pressure = new_press;
  192. datosAntiguos = latestData;
  193. xSemaphoreGive(dataMutex);
  194. }
  195. File file = SD.open(filename, FILE_APPEND);
  196. if (file) {
  197. //Crear la string para escribir en el archivo
  198. String frase = '\t\t\t<trkpt> lat="' + String(datosAntiguos.latitude,6) +
  199. '" lon="' + String(datosAntiguos.longitude,6) + '">\n\t\t\t\t<ele>'+
  200. String(datosAntiguos.altura) + '</ele>\n\t\t\t\t<time>'+
  201. datosAntiguos.tiempo+'</time>\n\t\t\t\t<extensions>\n\t\t\t\t\t<gpxtpx:TrackPointExtension>\n\t\t\t\t\t\t<gpxtpx:atemp>'+
  202. String(datosAntiguos.temperature)+'</gpxtpx:atemp>\n\t\t\t\t\t</gpxtpx:TrackPointExtension>\n\t\t\t\t\t<custom:humidity>'+
  203. String(datosAntiguos.humidity)+'</custom:humidity>\n\t\t\t\t\t<custom:pressure>'+String(datosAntiguos.pressure)+
  204. '</custom:pressure>\n\t\t\t\t</extensions>\n\t\t\t</trkpt>';
  205. // Escribir datos en el archivo
  206. file.println(frase);
  207. file.close();
  208. }
  209. vTaskDelayUntil(&xLastWakeTime, pdMS_TO_TICKS(MEASUREMENT_INTERVAL_S*1000)); // Espera x*1000 milisegundos
  210. }
  211. }
  212. void IRAM_ATTR isr_button() {
  213. unsigned long now = millis();
  214. if (now < ignore_isr_until) {
  215. return; // Ignorar interrupción si está dentro del período de debounce
  216. }
  217. static unsigned long lastInterrupt = 0;
  218. if ((now - lastInterrupt) > 300 ){ // debounce de 300 ms
  219. BaseType_t xHigherPriorityTaskWoken = pdFALSE;
  220. xSemaphoreGiveFromISR(buttonSemaphore, &xHigherPriorityTaskWoken);
  221. lastInterrupt = now;
  222. if (xHigherPriorityTaskWoken) {
  223. portYIELD_FROM_ISR();
  224. }
  225. }
  226. }
  227. void drawProgressBar(int x, int y, int w, int h, unsigned long progress, unsigned long total) {
  228. display.drawRect(x, y, w, h, SSD1306_WHITE); // Dibuja el borde
  229. int filledWidth = (progress * w) / total;
  230. display.fillRect(x + 1, y + 1, filledWidth - 2, h - 2, SSD1306_WHITE); // Dibuja la barra llena
  231. display.display();
  232. }
  233. void task_ui(void *pvParameters){
  234. unsigned long pressTime = 0;
  235. unsigned long lastActivity = millis();
  236. bool pantallaOn = true; //comprobar el estado inicial, no se cual sera
  237. bool processingButton = false;
  238. while(1){
  239. if (xSemaphoreTake(buttonSemaphore, pdMS_TO_TICKS(200)) == pdTRUE){ //button pressed
  240. if (processingButton) continue; //evita reentradas
  241. processingButton = true;
  242. pressTime = millis();
  243. lastActivity = millis(); //reset watchdog
  244. if (!pantallaOn){
  245. display.begin(SSD1306_SWITCHCAPVCC, 0x3C);
  246. pantallaOn = true;
  247. }
  248. bool timed_out = false;
  249. unsigned long checkTime = millis();
  250. while (digitalRead(BUTTON_PIN) == LOW){
  251. vTaskDelay(pdMS_TO_TICKS(10));
  252. checkTime = millis();
  253. if ((checkTime - pressTime) > DURACION_WATCHDOG_MS){ //10s timeout para evitar bloqueos
  254. timed_out = true;
  255. break;
  256. }
  257. drawProgressBar(0, SCREEN_HEIGHT - 10, SCREEN_WIDTH, 8, checkTime - pressTime, PULASCION_LARGA_MS);
  258. }
  259. ignore_isr_until = millis() + 50; //ignorar nuevas interrupciones durante 500 ms
  260. unsigned long duration = checkTime - pressTime;
  261. if (timed_out){
  262. OLED_print("Apagando","pantalla");
  263. display.ssd1306_command(SSD1306_DISPLAYOFF); //se apaga la
  264. pantallaOn = false;
  265. } else {
  266. if (duration >= PULASCION_LARGA_MS){
  267. //pulsacion larga: cabia entre grabacion y no grabacion de datos
  268. grabando = grabando ? false : true; //toggle
  269. if (grabando){
  270. vTaskResume(medicionesHandle);
  271. //Mostrar que empieza la grabación
  272. OLED_print("Ruta","iniciada");
  273. } else {
  274. vTaskSuspend(medicionesHandle);
  275. //Mostrar que se pausa/finaliza la grabación
  276. OLED_print("Ruta","pausada");
  277. }
  278. } else {
  279. //Pulsacion corta + grabando datos, cicla datos
  280. if (grabando) {
  281. pantallaEstado_grab = (pantallaEstado_grab + 1) % 5; //cicla entre 0-4
  282. SensorData currentData;
  283. if(xSemaphoreTake(dataMutex, portMAX_DELAY) == pdTRUE){
  284. currentData = latestData;
  285. xSemaphoreGive(dataMutex);
  286. }
  287. switch (pantallaEstado_grab){
  288. case 0:
  289. OLED_print("Posicion",String(currentData.longitude) + "," + String(currentData.latitude));
  290. break;
  291. case 1:
  292. OLED_print("Distancia",String(distancia_total)+"km");
  293. break;
  294. case 2:
  295. OLED_print("Altitud",String(gps.altitude.meters(), 1)+"m");
  296. break;
  297. case 3:
  298. OLED_print("Temp/Hum",String(currentData.temperature,1)+"C/"+String(currentData.humidity,1)+"%");
  299. break;
  300. case 4:
  301. OLED_print("Velocidad",String(gps.speed.kmph())+"km/h");
  302. break;
  303. }
  304. } else {
  305. pantallaEstado_menu = (pantallaEstado_menu + 1) % 3;
  306. OLED_print("Ruta","pausada");
  307. }
  308. }
  309. }
  310. lastActivity = millis(); //reset watchdog
  311. processingButton = false;
  312. vTaskDelay(pdMS_TO_TICKS(100)); //pequeño delay para no busy waiting
  313. }
  314. //check watchdog fuera del boton
  315. if (pantallaOn && ((millis() - lastActivity) > DURACION_WATCHDOG_MS)){
  316. display.ssd1306_command(SSD1306_DISPLAYOFF); //se apaga la pantalla
  317. pantallaOn = false;
  318. }
  319. }
  320. }
  321. void setup() {
  322. Serial.begin(115200);
  323. pinMode(BUTTON_PIN, INPUT_PULLUP);
  324. attachInterrupt(digitalPinToInterrupt(BUTTON_PIN), isr_button, FALLING);
  325. buttonSemaphore = xSemaphoreCreateBinary();
  326. dataMutex = xSemaphoreCreateMutex();
  327. // OLED check
  328. OLED_test();
  329. delay(1000);
  330. // DHT check
  331. DHT_test();
  332. delay(1000);
  333. // SD Card check
  334. SD_test();
  335. delay(1000);
  336. // GPS check
  337. GPS_test_wait();
  338. delay(2000);
  339. // Crear tarea para mediciones
  340. xTaskCreatePinnedToCore(
  341. task_mediciones, // Función de la tarea
  342. "Mediciones", // Nombre de la tarea
  343. 8192, // Tamaño del stack
  344. NULL, // Parámetro de la tarea
  345. 10, // Prioridad de la tarea
  346. &medicionesHandle, // Handle de la tarea
  347. 0 // Núcleo donde se ejecuta
  348. );
  349. xTaskCreatePinnedToCore(
  350. task_ui, // Función de la tarea
  351. "UI", // Nombre de la tarea
  352. 8192, // Tamaño del stack
  353. NULL, // Parámetro de la tarea
  354. 5, // Prioridad de la tarea
  355. NULL, // Handle de la tarea
  356. 1 // Núcleo donde se ejecuta
  357. );
  358. vTaskSuspend(medicionesHandle); //inicia suspendida
  359. }
  360. void loop() {
  361. vTaskDelay(pdMS_TO_TICKS(1000)); // Espera 1 segundo
  362. }