API tools faq
paste
PowerTGS440

LESZEK_ESP32

PowerTGS440
Apr 17th, 2021
179
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 51.10 KB | None | 0 0
raw download clone embed print report
  1. // ------------------------------------------------------------------------------------------------------------ //
  2. // --- D a r k N e t S e r v e r & M e s h & B T B Y T O M A S Z M A J C H E R --------- //
  3. // ------------------------------------------------------------------------------------------------------------ //
  4. //
  5. // by Tomasz Majcher (TLG) Trans Line Group, Lubin POLSKA
  6. // NIP: 692-201-09-78
  7. // TEL: 667-08-21-21
  8. // mail: [email protected]
  9. //
  10. //
  11. //
  12. //
  13. //
  14. //
  15. // ------------------------------------------------------------------------------------------------------------ //
  16. // --- HISTORIA WERSJI ---------------------------------------------------------------------------------------- //
  17. // ------------------------------------------------------------------------------------------------------------ //
  18. //
  19. // DarkNet Server v0.02 - rozbudowa usług MESH
  20. // DarkNet Server v0.01 - budowa pod serwer WEATHER
  21. //
  22. // ------------------------------------------------------------------------------------------------------------ //
  23. // --- DOŁĄCZONE NAGŁÓWKI BIBLIOTEK --------------------------------------------------------------------------- //
  24. // ------------------------------------------------------------------------------------------------------------ //
  25.  
  26. #include <Arduino.h>
  27. #include <painlessMesh.h>
  28. #include <PubSubClient.h>
  29. #include <WiFiClient.h>
  30. #include <NTPClient.h> // NTP klient (czas)
  31. #include <TimeLib.h> // parser
  32. #include <WiFiUdp.h> // UDP Wi-Fi
  33. #include <HTTPClient.h>
  34. #include <WiFiClient.h>
  35. #include <Arduino_JSON.h>
  36. #include <ESP32Time.h> // zegar RTC ESP32
  37. #include "tools.h" // dołącz moje narzędzia
  38.  
  39.  
  40. // ------------------------------------------------------------------------------------------------------------ //
  41. // --- D E F I N I C J E -------------------------------------------------------------------------------------- //
  42. // ------------------------------------------------------------------------------------------------------------ //
  43.  
  44. #define MESH_PREFIX "ESP_Root" // nazwa sieci MESH
  45. #define MESH_PASSWORD "ESP_Root" // hasło sieci MESH
  46. #define MESH_PORT 5555 // port sieci MESH
  47.  
  48. #define STATION_SSID "XXXXXXXXXX" // nazwa sieci Wi-Fi (router podłączony do sieci)
  49. #define STATION_PASSWORD "XXXXXXXXXX" // hasło sieci Wi-Fi (router podłączony do sieci)
  50.  
  51. #define HOSTNAME "DarkNet" // nazwa hosta (bridge) most sieci MESH i INTERNET
  52.  
  53. #define SERIAL 1 // włącz terminal SERIAL.MONITOR
  54. #define SPEED 115200 // prędkość terminala SERIAL
  55. #define THREAD_INFO 0
  56. #define CORE0_TASK1 1
  57.  
  58.  
  59. // ------------------------------------------------------------------------------------------------------------ //
  60. // --- P R O T O T Y P Y -------------------------------------------------------------------------------------- //
  61. // ------------------------------------------------------------------------------------------------------------ //
  62.  
  63. void receivedCallback( const uint32_t &from, const String &msg );
  64. void mqttCallback(char* topic, byte* payload, unsigned int length);
  65.  
  66. // ------------------------------------------------------------------------------------------------------------ //
  67. // --- O B I E K T Y ------------------------------------------------------------------------------------------ //
  68. // ------------------------------------------------------------------------------------------------------------ //
  69.  
  70. WiFiUDP ntpUDP; // dla NTP (pobieranie czasu z internetu)
  71. NTPClient timeClient(ntpUDP, "pool.ntp.org", 7200); // dla NTP (pobieranie czasu z internetu)
  72. IPAddress getlocalIP(); // pobierz adres lokalny IP
  73. IPAddress myIP(0,0,0,0); // mój adres IP
  74. IPAddress mqttBroker(192, 168, 1, 1); // mój adres IP
  75. painlessMesh mesh; // obiekt mesh
  76. WiFiClient wifiClient; // obiekt WiFi
  77. HTTPClient http; // obiekt HTTP
  78. PubSubClient mqttClient(mqttBroker, 1883, mqttCallback, wifiClient);
  79. ESP32Time rtc;
  80.  
  81. JSONVar JSON_Astronomy; // obiekt Astronomia
  82. JSONVar JSON_Weather; // obiekt Pogoda
  83. JSONVar JSON_Forecast; // obiekt Forecast
  84. JSONVar JSON_Air; // obiekt Powietrze
  85. JSONVar JSON_Mesh; // obiekt Mesh Incoming
  86.  
  87. void Core0_Task1( void * pvParameters ); // funkcja Task1 dla rdzenia nr. 0 CPU
  88. void Core0_Task2( void * pvParameters ); // funkcja Task2 dla rdzenia nr. 0 CPU
  89.  
  90. void Core1_Task1( void * pvParameters ); // funkcja Task1 dla rdzenia nr. 1 CPU
  91. void Core1_Task2( void * pvParameters ); // funkcja Tasl2 dla rdzenia nr. 1 CPU
  92.  
  93. TaskHandle_t CPU_Core_0; // rdzeń nr. 0 CPU - ESP32
  94. TaskHandle_t CPU_Core_1; // rdzeń nr. 1 CPU - ESP32
  95.  
  96. // ------------------------------------------------------------------------------------------------------------ //
  97. // --- Z M I E N N E G L O B A L N E ------------------------------------------------------------------------ //
  98. // ------------------------------------------------------------------------------------------------------------ //
  99. // --- M I E S I Ą C E P L ---------------------------------------------------------------------------------- //
  100. // ------------------------------------------------------------------------------------------------------------ //
  101.  
  102. const char MONTH_00 [] = "Error";
  103. const char MONTH_01 [] = "Styczeń";
  104. const char MONTH_02 [] = "Luty";
  105. const char MONTH_03 [] = "Marzec";
  106. const char MONTH_04 [] = "Kwiecień";
  107. const char MONTH_05 [] = "Maj";
  108. const char MONTH_06 [] = "Czerwiec";
  109. const char MONTH_07 [] = "Lipiec";
  110. const char MONTH_08 [] = "Sierpień";
  111. const char MONTH_09 [] = "Wrzesień";
  112. const char MONTH_10 [] = "Pazdziernik";
  113. const char MONTH_11 [] = "Listopad";
  114. const char MONTH_12 [] = "Grudzień";
  115.  
  116. const char* const MONTH [] = {
  117. MONTH_00,
  118. MONTH_01, MONTH_02, MONTH_03, MONTH_04, MONTH_05, MONTH_06,
  119. MONTH_07, MONTH_08, MONTH_09, MONTH_10, MONTH_11, MONTH_12
  120. };
  121.  
  122. // ------------------------------------------------------------------------------------------------------------ //
  123. // --- Z E G A R N T P ------------------------------------------------------------------------------------- //
  124. // ------------------------------------------------------------------------------------------------------------ //
  125.  
  126. struct NTP_TIME
  127. {
  128. String SformatowanaData;
  129. String SformatowanaDataPL;
  130. int DzienTygodnia;
  131. int DzienMiesiaca;
  132. int Miesiac;
  133. int Rok;
  134. String SformatowanyCzas;
  135. String SformatowanyCzasHM;
  136. int Godzina;
  137. int Minuta;
  138. int Sekunda;
  139. }
  140. zegar;
  141.  
  142. // ------------------------------------------------------------------------------------------------------------ //
  143. // --- Z M I E N N E G L O B A L N E ------------------------------------------------------------------------ //
  144. // ------------------------------------------------------------------------------------------------------------ //
  145. // --- A S T R O N O M I A ------------------------------------------------------------------------------------ //
  146. // ------------------------------------------------------------------------------------------------------------ //
  147.  
  148. struct ASTRONOMY
  149. {
  150. String miejscowosc = "";
  151. String kraj = "";
  152. double szerokosc_geograficzna = 0;
  153. double dlugosc_geograficzna = 0;
  154. long czas_epoch = 0;
  155. String czas_lokalny = "";
  156. String wschod_slonca = "";
  157. String zachod_slonca = "";
  158. String wschod_ksiezyca = "";
  159. String zachod_ksiezyca = "";
  160. String faza_ksiezyca = "";
  161. String oswietlenie_ksiezyca = "";
  162. }
  163. astronomia;
  164.  
  165. // ------------------------------------------------------------------------------------------------------------ //
  166. // --- Z M I E N N E G L O B A L N E ------------------------------------------------------------------------ //
  167. // ------------------------------------------------------------------------------------------------------------ //
  168. // --- P O G O D A -------------------------------------------------------------------------------------------- //
  169. // ------------------------------------------------------------------------------------------------------------ //
  170.  
  171. struct Weather
  172. {
  173. String miejscowosc = "";
  174. String kraj = "";
  175. double szerokosc_geograficzna = 0;
  176. double dlugosc_geograficzna = 0;
  177. String id = "";
  178. long czas_epoch = 0;
  179. String czas_lokalny = "";
  180. String ostatnia_aktualizacja = "";
  181. double temperatura_C = 0;
  182. double temperatura_C_odczuwalna = 0;
  183. String kondycja = "";
  184. double predkosc_wiatru_kph = 0;
  185. double podmuchy_wiatru = 0;
  186. int kierunek_wiatru_stopnie = 0;
  187. String kierunek_wiatru_kompas = "";
  188. int cisnienie = 0;
  189. double opady = 0;
  190. int wilgotnosc = 0;
  191. int zachmurzenie = 0;
  192. int widzialnosc = 0;
  193. int index_uv = 0;
  194. }
  195. pogoda;
  196.  
  197. // ------------------------------------------------------------------------------------------------------------ //
  198. // --- Z M I E N N E G L O B A L N E ------------------------------------------------------------------------ //
  199. // ------------------------------------------------------------------------------------------------------------ //
  200. // --- P O W I E T R Z E -------------------------------------------------------------------------------------- //
  201. // ------------------------------------------------------------------------------------------------------------ //
  202.  
  203. struct Air
  204. {
  205. double co = 0; // Carbon Monoxide (μg/m3) - Tlenek węgla (μg / m3)
  206. double o3 = 0; // Ozone (μg/m3) - Ozon (μg / m3)
  207. double no2 = 0; // Nitrogen dioxide (μg/m3) - Dwutlenek azotu (μg / m3)
  208. double so2 = 0; // Sulphur dioxide (μg/m3) - Dwutlenek siarki (μg / m3)
  209. double pm25 = 0; // PM2.5 (μg/m3) - aerozole atmosferyczne o średnicy nie większej niż 2,5 μm
  210. double pm10 = 0; // PM10 (μg/m3) - mieszanina zawieszonych w powietrzu cząsteczek o średnicy nie większej niż 10 μm
  211. int Defra = 0; // Air Quality Index - index jakości powietrza
  212. }
  213. powietrze;
  214.  
  215. // ------------------------------------------------------------------------------------------------------------ //
  216. // --- Z M I E N N E G L O B A L N E ------------------------------------------------------------------------ //
  217. // ------------------------------------------------------------------------------------------------------------ //
  218. // --- P A R S E R M S G S E N D ------------------------------------------------------------------------- //
  219. // ------------------------------------------------------------------------------------------------------------ //
  220.  
  221. struct JSON_MSG
  222. {
  223. String czas; // JSON czas HH:MM:SS
  224. String czasHM; // JSON czas HH:MM
  225. String data; // JSON data DD.MM.YYYY
  226. String dataPL; // JSON data DD miesiac YYYY
  227. }
  228. jmsg;
  229.  
  230. // ------------------------------------------------------------------------------------------------------------ //
  231. // --- Z M I E N N E G L O B A L N E ------------------------------------------------------------------------ //
  232. // ------------------------------------------------------------------------------------------------------------ //
  233. // --- F L A G I ---------------------------------------------------------------------------------------------- //
  234. // ------------------------------------------------------------------------------------------------------------ //
  235.  
  236. bool F_Astronomia = false;
  237. bool F_Pogoda = false;
  238. bool F_Prognoza = false;
  239. bool F_Powietrze = false;
  240. bool F_Zegar = false;
  241.  
  242. // ------------------------------------------------------------------------------------------------------------ //
  243. // --- Z M I E N N E G L O B A L N E ------------------------------------------------------------------------ //
  244. // ------------------------------------------------------------------------------------------------------------ //
  245. // --- M I L L I S -------------------------------------------------------------------------------------------- //
  246. // ------------------------------------------------------------------------------------------------------------ //
  247.  
  248. unsigned long timeZERO = 0;
  249. unsigned long task01m = 0;
  250. unsigned long task05m = 0;
  251. unsigned long task10m = 0;
  252. unsigned long task15m = 0;
  253. unsigned long timeout_task01m = 0;
  254. unsigned long timeout_task05m = 0;
  255. unsigned long timeout_task10m = 0;
  256. unsigned long timeout_task15m = 0;
  257.  
  258. String root = "{\"ID\":\"ROOT\",\"CODE\":0000,\"ROOT\":\"Ja tu rządze [DarkNet] mesh serwer\"}";
  259.  
  260. // ------------------------------------------------------------------------------------------------------------ //
  261. // --- Z M I E N N E G L O B A L N E ------------------------------------------------------------------------ //
  262. // ------------------------------------------------------------------------------------------------------------ //
  263. // --- P A R S E R M E S H ---------------------------------------------------------------------------------- //
  264. // ------------------------------------------------------------------------------------------------------------ //
  265.  
  266. struct MeshParser
  267. {
  268. long Id;
  269. int Code;
  270. }
  271. meshParser;
  272.  
  273. // ------------------------------------------------------------------------------------------------------------ //
  274. // --- p a r s e r m s g ------------------------------------------------------------------------------------ //
  275. // ------------------------------------------------------------------------------------------------------------ //
  276.  
  277. void parserMsg(const String &msg)
  278. {
  279. JSON_Mesh = JSON.parse(msg);
  280.  
  281. meshParser.Id = JSON_Mesh["ID"]; // ID urządzenia ESP w sieci MESH
  282. meshParser.Code = JSON_Mesh["CODE"]; // KOD rządania z ESP w sieci MESH
  283. }
  284.  
  285. // ------------------------------------------------------------------------------------------------------------ //
  286. // --- o d b i o r n i k b r o a d c a s t ------------------------------------------------------------------ //
  287. // ------------------------------------------------------------------------------------------------------------ //
  288.  
  289. void receivedCallback( const uint32_t &from, const String &msg )
  290. {
  291. Serial.printf("\n[ESP Bridge] [otrzymałem od] %u [wiadomosc JSON] %s", from, msg.c_str());
  292.  
  293. parserMsg(msg);
  294.  
  295. switch(meshParser.Code)
  296. {
  297. case 0000 : mesh.sendSingle ( from, root.c_str());
  298. break;
  299.  
  300. case 1001 : mesh.sendSingle ( from, jmsg.czas.c_str() ); // jeśli nadawca wysłał kod 1001 wyślij mu aktualny czas
  301. Serial.printf("\n[ESP Bridge] [wysyłam do] %u [wiadomosc JSON] %s", from, jmsg.czas.c_str());
  302. break;
  303.  
  304. case 1002 : mesh.sendSingle ( from, jmsg.czasHM.c_str() ); // jeśli nadawca wysłał kod 1002 wyślij mu aktualny czas
  305. Serial.printf("\n[ESP Bridge] [wysyłam do] %u [wiadomosc JSON] %s", from, jmsg.czasHM.c_str());
  306. break;
  307.  
  308. case 1011 : mesh.sendSingle ( from, jmsg.data.c_str() ); // jeśli nadawca wysłał kod 1011 wyślij mu aktualną datę - format: DD.MM.RRRR
  309. Serial.printf("\n[ESP Bridge] [wysyłam do] %u [wiadomosc JSON] %s", from, jmsg.data.c_str());
  310. break;
  311.  
  312. case 1012 : mesh.sendSingle ( from, jmsg.dataPL.c_str() ); // jeśli nadawca wysłał kod 1012 wyślij mu aktualną datę - format: DD miesiac RRRR
  313. Serial.printf("\n[ESP Bridge] [wysyłam do] %u [wiadomosc JSON] %s", from, jmsg.dataPL.c_str());
  314. break;
  315.  
  316. default : mesh.sendSingle ( from, "nieznany kod mesh" ); break;
  317. }
  318.  
  319. }
  320.  
  321. // ------------------------------------------------------------------------------------------------------------ //
  322. // --- m q t t C a l l b a c k ----------------------------------------------------------------------------- //
  323. // ------------------------------------------------------------------------------------------------------------ //
  324.  
  325. void mqttCallback(char* topic, uint8_t* payload, unsigned int length)
  326. {
  327. char* cleanPayload = (char*)malloc(length+1);
  328. memcpy(cleanPayload, payload, length);
  329. cleanPayload[length] = '\0';
  330. String msg = String(cleanPayload);
  331. free(cleanPayload);
  332.  
  333. String targetStr = String(topic).substring(16);
  334.  
  335. if(targetStr == "gateway")
  336. {
  337. if(msg == "getNodes")
  338. {
  339. auto nodes = mesh.getNodeList(true);
  340. String str;
  341. for (auto &&id : nodes)
  342. str += String(id) + String(" ");
  343. mqttClient.publish("painlessMesh/from/gateway", str.c_str());
  344. }
  345. }
  346. else
  347. if(targetStr == "broadcast")
  348. {
  349. mesh.sendBroadcast(msg);
  350. }
  351. else
  352. {
  353. uint32_t target = strtoul(targetStr.c_str(), NULL, 10);
  354. if(mesh.isConnected(target))
  355. {
  356. mesh.sendSingle(target, msg);
  357. }
  358. else
  359. {
  360. mqttClient.publish("painlessMesh/from/gateway", "Klient nie podłaczony!");
  361. }
  362. }
  363. }
  364. //
  365. // ------------------------------------------------------------------------------------------------------------ //
  366. // --- M U L T I - C O R E T A S K --- //
  367. // ------------------------------------------------------------------------------------------------------------ //
  368. //
  369. //
  370. //
  371. //
  372. // ------------------------------------------------------------------------------------------------------------ //
  373. // --- CORE0 TASK1 POBIERANIE CZASU i DATY Z SERWERA NTP i AKTUALIZACJA ZEGARA ESP32 RTC --- //
  374. // ------------------------------------------------------------------------------------------------------------ //
  375. //
  376. void Core0_Task1( void * pvParameters )
  377. {
  378. for(;;)
  379. {
  380. #if THREAD_INFO
  381. PrintLine(60);
  382. PrintMSG("ESP32","CORE", "Wykonuje watek TASK1 na CORE0");
  383. #endif
  384.  
  385. timeClient.update();
  386.  
  387. unsigned long epochTime = timeClient.getEpochTime();
  388. struct tm *ptm = gmtime ((time_t *)&epochTime);
  389.  
  390. zegar.Godzina = timeClient.getHours();
  391. zegar.Minuta = timeClient.getMinutes();
  392. zegar.Sekunda = timeClient.getSeconds();
  393. zegar.SformatowanyCzas = timeClient.getFormattedTime();
  394. zegar.DzienTygodnia = timeClient.getDay();
  395. zegar.DzienMiesiaca = ptm->tm_mday;
  396. zegar.Miesiac = ptm->tm_mon+1;
  397. zegar.Rok = ptm->tm_year+1900;
  398.  
  399. if (zegar.Godzina < 10)
  400. {
  401. zegar.SformatowanyCzasHM = "0" + String (zegar.Godzina) + ":";
  402. }
  403. else zegar.SformatowanyCzasHM = String(zegar.Godzina) + ":";
  404.  
  405. if (zegar.Minuta < 10)
  406. {
  407. zegar.SformatowanyCzasHM += "0" + String (zegar.Minuta) + ":";
  408. }
  409. else zegar.SformatowanyCzasHM += String(zegar.Minuta);
  410.  
  411.  
  412. if (zegar.Rok !=1970)
  413. {
  414. if(zegar.DzienMiesiaca < 10)
  415. {
  416. zegar.SformatowanaData = "0" + String(zegar.DzienMiesiaca) + ".";
  417. zegar.SformatowanaDataPL = "0" + String(zegar.DzienMiesiaca) + " ";
  418. }
  419. else
  420. {
  421. zegar.SformatowanaData = String(zegar.DzienMiesiaca) + ".";
  422. zegar.SformatowanaDataPL = String(zegar.DzienMiesiaca) + " ";
  423. }
  424.  
  425. if(zegar.Miesiac < 10)
  426. {
  427. zegar.SformatowanaData += "0" + String(zegar.Miesiac) + ".";
  428. zegar.SformatowanaDataPL += String(MONTH[zegar.Miesiac]) + " ";
  429. }
  430. else
  431. {
  432. zegar.SformatowanaData += String(zegar.Miesiac) + ".";
  433. zegar.SformatowanaDataPL += String(MONTH[zegar.Miesiac]) + " ";
  434. }
  435.  
  436. zegar.SformatowanaData += String(zegar.Rok);
  437. zegar.SformatowanaDataPL += String(zegar.Rok);
  438.  
  439. // --- zapisz aktualny czas pobrany z serwera NTP do zegara RTC --------------------------------------- //
  440.  
  441. rtc.setTime(zegar.Sekunda, zegar.Minuta, zegar.Godzina, zegar.DzienMiesiaca, zegar.Miesiac, zegar.Rok);
  442.  
  443. // --- zbuduj obiekty typu (JSON STRING) do odesłania na żadanie do innego ESP w sieci MESH
  444.  
  445. jmsg.czas = "{\"ID\":\"ROOT\",\"CODE\":1001,\"CZAS\":\"" + zegar.SformatowanyCzas + "\"}";
  446. jmsg.czasHM = "{\"ID\":\"ROOT\",\"CODE\":1002,\"CZAS\":\"" + zegar.SformatowanyCzasHM + "\"}";
  447. jmsg.data = "{\"ID\":\"ROOT\",\"CODE\":1011,\"DATA\":\"" + zegar.SformatowanaData + "\"}";
  448. jmsg.dataPL = "{\"ID\":\"ROOT\",\"CODE\":1012,\"DATA\":\"" + zegar.SformatowanaDataPL + "\"}";
  449.  
  450. #if CORE0_TASK1
  451. PrintLine(60);
  452. PrintMSG("CORE0_TASK1", "NTP Time", zegar.SformatowanyCzas.c_str());
  453. PrintMSG("CORE0_TASK1", "NTP Date", zegar.SformatowanaData.c_str());
  454. Serial.printf("\n[CORE0_TASK1] [RTC Time] ");
  455. Serial.print(rtc.getTime());
  456. Serial.printf("\n[CORE0_TASK1] [RTC Date] ");
  457. Serial.print(rtc.getDate());
  458. Serial.printf("\n[CORE0_TASK1] [FREE RAM] ");
  459. Serial.print(ESP.getFreeHeap());
  460. PrintLine(60);
  461. PrintEND();
  462. #endif
  463.  
  464. F_Zegar = true; // dane OK, flaga na true
  465. }
  466. else F_Zegar = false; // dane złe, flaga na false
  467.  
  468. vTaskDelay(60000 / portTICK_PERIOD_MS); // wykonuj 1 minutę
  469. }
  470. }
  471. //
  472. // ------------------------------------------------------------------------------------------------------------ //
  473. // --- CORE0 TASK2 POBIERANIE ASTRONOMII --- //
  474. // ------------------------------------------------------------------------------------------------------------ //
  475. //
  476. void Core0_Task2( void * pvParameters ) // Rdzeń 0 Zadanie 1
  477. { // początek
  478. for(;;) // nieskończona pętla
  479. { // początek FOR
  480. delay(3600000); // sprawdzaj co 1 godzinę
  481. }
  482. }
  483. //
  484. // ------------------------------------------------------------------------------------------------------------ //
  485. // --- CORE1 TASK1
  486. // ------------------------------------------------------------------------------------------------------------ //
  487.  
  488. void Core1_Task1( void * pvParameters ) // Rdzeń 0 Zadanie 1
  489. { // początek
  490. for(;;) // nieskończona pętla
  491. { // początek FOR
  492. #if SERIAL
  493. PrintLine(60);
  494. PrintMSG("ESP32","CORE", "Wykonuje watek Task1 na CORE-1");
  495. #endif
  496.  
  497. delay(1800000); // wykonuj co 30 minut
  498. }
  499. }
  500.  
  501. // ------------------------------------------------------------------------------------------------------------ //
  502. // --- CORE1 TASK2
  503. // ------------------------------------------------------------------------------------------------------------ //
  504.  
  505. void Core1_Task2( void * pvParameters ) // Rdzeń 0 Zadanie 1
  506. { // początek
  507. for(;;) // nieskończona pętla
  508. { // początek FOR
  509. #if SERIAL
  510. PrintLine(60);
  511. PrintMSG("ESP32","CORE", "Wykonuje watek Task2 na CORE-1");
  512. #endif
  513.  
  514. mesh.sendBroadcast( root.c_str() ); // roześlij Broadcast co wszystkich w sieci MESH
  515. delay(900000); // wykonuj co 15 minut
  516. }
  517. }
  518.  
  519. // ------------------------------------------------------------------------------------------------------------ //
  520. // --- p o b i e r z a d r e s I P ----------------------------------------------------------------------- //
  521. // ------------------------------------------------------------------------------------------------------------ //
  522.  
  523. IPAddress getlocalIP()
  524. {
  525. return IPAddress(mesh.getStationIP());
  526. }
  527.  
  528. // ------------------------------------------------------------------------------------------------------------ //
  529. // --- Aktualizacja Pogody z Serwera ------------------------------------------------------------------------- //
  530. // ------------------------------------------------------------------------------------------------------------ //
  531. //
  532. String httpGETRequest(const char* serverName)
  533. {
  534. HTTPClient http;
  535. http.begin(serverName);
  536. int httpResponseCode = http.GET();
  537. String bufor = "{}";
  538.  
  539. if ( httpResponseCode > 0 )
  540. {
  541. #if SERIAL
  542. //Serial.print("\nHTTP Response code: ");
  543. //Serial.print(httpResponseCode);
  544. #endif
  545.  
  546. bufor = http.getString();
  547. }
  548. else
  549. {
  550. #if SERIAL
  551. //Serial.print("Error code: ");
  552. //Serial.println(httpResponseCode);
  553. #endif
  554. }
  555. http.end();
  556. return bufor;
  557. }
  558. //
  559. // ------------------------------------------------------------------------------------------------------------ //
  560. // --- A K T U A L I Z A C J A P O G O D Y --- //
  561. // ------------------------------------------------------------------------------------------------------------ //
  562. //
  563. void PogodaAktualizuj()
  564. {
  565. PrintLine(60);
  566. PrintMSG("ESP32","MyTask", "Aktualizję pogodę z serwera : api.weatherapi.com");
  567.  
  568. String path = "http://api.weatherapi.com/v1/current.json?key=d27d7ab450e84466822133129211704&q=Mieroszow&aqi=no";
  569. String jsonBuffer = httpGETRequest(path.c_str());
  570.  
  571. JSON_Weather = JSON.parse(jsonBuffer);
  572.  
  573. if (JSON.typeof(JSON_Weather) == "undefined")
  574. {
  575. PrintLine(60);
  576. PrintMSG("DarkNet", "POGODA PARSER", "BŁĄD, BRAK DANYCH" );
  577. }
  578.  
  579. pogoda.miejscowosc = JSON_Weather["location"]["name"];
  580. pogoda.kraj = JSON_Weather["location"]["country"];
  581. pogoda.szerokosc_geograficzna = JSON_Weather["location"]["lat"];
  582. pogoda.dlugosc_geograficzna = JSON_Weather["location"]["lon"];
  583. pogoda.id = JSON_Weather["location"]["tz_id"];
  584. pogoda.czas_epoch = JSON_Weather["location"]["localtime_epoch"];
  585. pogoda.czas_lokalny = JSON_Weather["location"]["localtime"];
  586. pogoda.ostatnia_aktualizacja = JSON_Weather["current"]["last_updated"];
  587. pogoda.temperatura_C = JSON_Weather["current"]["temp_c"];
  588. pogoda.temperatura_C_odczuwalna = JSON_Weather["current"]["feelslike_c"];
  589. pogoda.kondycja = JSON_Weather["current"]["condition"]["text"];
  590. pogoda.predkosc_wiatru_kph = JSON_Weather["current"]["wind_kph"];
  591. pogoda.kierunek_wiatru_stopnie = JSON_Weather["current"]["wind_degree"];
  592. pogoda.kierunek_wiatru_kompas = JSON_Weather["current"]["wind_dir"];
  593. pogoda.podmuchy_wiatru = JSON_Weather["current"]["gust_kph"];
  594. pogoda.cisnienie = JSON_Weather["current"]["pressure_mb"];
  595. pogoda.opady = JSON_Weather["current"]["precip_mm"];
  596. pogoda.wilgotnosc = JSON_Weather["current"]["humidity"];
  597. pogoda.zachmurzenie = JSON_Weather["current"]["cloud"];
  598. pogoda.widzialnosc = JSON_Weather["current"]["vis_km"];
  599. pogoda.index_uv = JSON_Weather["current"]["uv"];
  600.  
  601. if(pogoda.miejscowosc == "Lubin")
  602. {
  603. PrintLine(60);
  604. Serial.printf("\n[DarkNet] [Pogoda] Miejscowość \t\t: ");
  605. Serial.print(pogoda.miejscowosc);
  606. Serial.printf("\n[DarkNet] [Pogoda] Kraj \t\t: ");
  607. Serial.print(pogoda.kraj);
  608. Serial.printf("\n[DarkNet] [Pogoda] Szer.Geograficzna \t: %2.2f",pogoda.szerokosc_geograficzna);
  609. Serial.printf("\n[DarkNet] [Pogoda] Dług.Geograficzna \t: %2.2f",pogoda.dlugosc_geograficzna);
  610. Serial.printf("\n[DarkNet] [Pogoda] Czas Epoch \t\t: %u",pogoda.czas_epoch );
  611. Serial.printf("\n[DarkNet] [Pogoda] Serwer ID \t\t: ");
  612. Serial.print( pogoda.id );
  613. Serial.printf("\n[DarkNet] [Pogoda] Czas Epoch \t\t: %u",pogoda.czas_epoch );
  614. Serial.printf("\n[DarkNet] [Pogoda] Czas Lokalny \t: ");
  615. Serial.print( pogoda.czas_lokalny );
  616. Serial.printf("\n[DarkNet] [Pogoda] Aktualizacja \t: ");
  617. Serial.print( pogoda.ostatnia_aktualizacja );
  618. Serial.printf("\n[DarkNet] [Pogoda] Temperatura \t\t: %2.2f",pogoda.temperatura_C);
  619. Serial.printf("\n[DarkNet] [Pogoda] Temp.Odczuwalna \t: %2.2f",pogoda.temperatura_C_odczuwalna);
  620. Serial.printf("\n[DarkNet] [Pogoda] Opis pogody \t\t: ");
  621. Serial.print(pogoda.kondycja);
  622. Serial.printf("\n[DarkNet] [Pogoda] Predkosc wiatru \t: %2.2f",pogoda.predkosc_wiatru_kph);
  623. Serial.printf("\n[DarkNet] [Pogoda] Podmuchy wiatru \t: %2.2f",pogoda.podmuchy_wiatru);
  624. Serial.printf("\n[DarkNet] [Pogoda] Kierunek wiatru \t: %2.2f",pogoda.kierunek_wiatru_stopnie);
  625. Serial.printf("\n[DarkNet] [Pogoda] Kierunek wiatru \t: ");
  626. Serial.print(pogoda.kierunek_wiatru_kompas);
  627. Serial.printf("\n[DarkNet] [Pogoda] Cisnienie \t\t: %d",pogoda.cisnienie);
  628. Serial.printf("\n[DarkNet] [Pogoda] Opady deszczu \t: %2.2f",pogoda.opady);
  629. Serial.printf("\n[DarkNet] [Pogoda] Wilgotnosc \t\t: %d",pogoda.wilgotnosc);
  630. Serial.printf("\n[DarkNet] [Pogoda] Zachmurzenie \t: %d",pogoda.zachmurzenie);
  631. Serial.printf("\n[DarkNet] [Pogoda] Widzialnosc \t\t: %d",pogoda.widzialnosc);
  632. Serial.printf("\n[DarkNet] [Pogoda] Index UV \t\t: %d",pogoda.index_uv);
  633.  
  634. PrintLine(60);
  635. PrintEND();
  636.  
  637. F_Pogoda = true; // dane OK, ustaw flagę na true
  638. }
  639. else F_Pogoda = false; // dane ZŁE, ustaw flagę na false
  640.  
  641. }
  642. //
  643. // ------------------------------------------------------------------------------------------------------------ //
  644. // --- A K T U A L I Z A C J A A S T R O N O M I I --- //
  645. // ------------------------------------------------------------------------------------------------------------ //
  646. //
  647. void AstronomiaAktualizuj()
  648. {
  649. PrintLine(60);
  650. PrintMSG("ESP32","MyTask", "Aktualizję astronomię z serwera : api.weatherapi.com");
  651.  
  652. // pobierz dane astronomiczne z serwera dla miasta LUBIN
  653.  
  654. String path = "http://api.weatherapi.com/v1/astronomy.json?key=d27d7ab450e84466822133129211704&q=Mieroszow&dt=2021-04-17";
  655. String jsonBuffer = httpGETRequest(path.c_str());
  656.  
  657. JSON_Astronomy = JSON.parse(jsonBuffer);
  658.  
  659. if (JSON.typeof(JSON_Astronomy) == "undefined")
  660. {
  661. PrintLine(60);
  662. PrintMSG("DarkNet", "ASTRONOMIA PARSER", "BŁĄD, BRAK DANYCH" );
  663. }
  664.  
  665. astronomia.miejscowosc = JSON_Astronomy["location"]["name"];
  666. astronomia.kraj = JSON_Astronomy["location"]["country"];
  667. astronomia.szerokosc_geograficzna = JSON_Astronomy["location"]["lat"];
  668. astronomia.dlugosc_geograficzna = JSON_Astronomy["location"]["lon"];
  669. astronomia.czas_epoch = JSON_Astronomy["location"]["localtime_epoch"];
  670. astronomia.czas_lokalny = JSON_Astronomy["location"]["localtime"];
  671. astronomia.wschod_slonca = JSON_Astronomy["astronomy"]["astro"]["sunrise"];
  672. astronomia.zachod_slonca = JSON_Astronomy["astronomy"]["astro"]["sunset"];
  673. astronomia.wschod_ksiezyca = JSON_Astronomy["astronomy"]["astro"]["moonrise"];
  674. astronomia.zachod_ksiezyca = JSON_Astronomy["astronomy"]["astro"]["moonset"];
  675. astronomia.faza_ksiezyca = JSON_Astronomy["astronomy"]["astro"]["moon_phase"];
  676. astronomia.oswietlenie_ksiezyca = JSON_Astronomy["astronomy"]["astro"]["moon_illumination"];
  677.  
  678. if(astronomia.miejscowosc == "Lubin")
  679. {
  680. PrintLine(60);
  681. Serial.printf("\n[DarkNet] [Astronomia] Miejscowość \t\t: ");
  682. Serial.print(astronomia.miejscowosc);
  683. Serial.printf("\n[DarkNet] [Astronomia] Kraj \t\t\t: ");
  684. Serial.print(astronomia.kraj);
  685. Serial.printf("\n[DarkNet] [Astronomia] Szer.Geograficzna \t: %2.2f",astronomia.szerokosc_geograficzna);
  686. Serial.printf("\n[DarkNet] [Astronomia] Dług.Geograficzna \t: %2.2f",astronomia.dlugosc_geograficzna);
  687. Serial.printf("\n[DarkNet] [Astronomia] Czas Epoch \t\t: %u",astronomia.czas_epoch );
  688. Serial.printf("\n[DarkNet] [Astronomia] Czas Lokalny \t\t: ");
  689. Serial.print( astronomia.czas_lokalny );
  690. Serial.printf("\n[DarkNet] [Astronomia] Wschód Słońca \t\t: ");
  691. Serial.print(astronomia.wschod_slonca );
  692. Serial.printf("\n[DarkNet] [Astronomia] Zachód Słońca \t\t: ");
  693. Serial.print(astronomia.zachod_slonca );
  694. Serial.printf("\n[DarkNet] [Astronomia] Wschód Księżyca \t\t: ");
  695. Serial.print(astronomia.wschod_ksiezyca );
  696. Serial.printf("\n[DarkNet] [Astronomia] Zachód Księżyca \t\t: ");
  697. Serial.print(astronomia.zachod_ksiezyca );
  698. Serial.printf("\n[DarkNet] [Astronomia] Faza Księżyca \t\t: ");
  699. Serial.print(astronomia.faza_ksiezyca);
  700. Serial.printf("\n[DarkNet] [Astronomia] Oświetlenie Księżyca \t: ");
  701. Serial.print(astronomia.oswietlenie_ksiezyca );
  702. PrintLine(60);
  703. PrintEND();
  704. F_Astronomia = true; // dane OK, ustaw flagę na true
  705. }
  706. else F_Astronomia = false; // dane ZŁE, ustaw flagę na false
  707. }
  708. //
  709. // ------------------------------------------------------------------------------------------------------------ //
  710. // --- A K T U A L I Z A C J A J A K O Ś C I P O W I E T R Z A --- //
  711. // ------------------------------------------------------------------------------------------------------------ //
  712. //
  713. void PowietrzeAktualizuj()
  714. {
  715. PrintLine(60);
  716. PrintMSG("ESP32","MyTask", "Aktualizję jakość powietrza z serwera : api.weatherapi.com");
  717.  
  718. // pobierz dane jakości powietrza z serwera dla miasta LUBIN
  719.  
  720. String path = "http://api.weatherapi.com/v1/current.json?key=d27d7ab450e84466822133129211704&q=Mieroszow&aqi=yes";
  721. String jsonBuffer = httpGETRequest(path.c_str());
  722.  
  723. JSON_Air = JSON.parse(jsonBuffer);
  724.  
  725. if (JSON.typeof(JSON_Air) == "undefined")
  726. {
  727. PrintLine(60);
  728. PrintMSG("DarkNet", "AIR PARSER", "BŁĄD, BRAK DANYCH" );
  729. }
  730.  
  731. powietrze.co = JSON_Air["current"]["air_quality"]["co"];
  732. powietrze.o3 = JSON_Air["current"]["air_quality"]["o3"];
  733. powietrze.no2 = JSON_Air["current"]["air_quality"]["no2"];
  734. powietrze.so2 = JSON_Air["current"]["air_quality"]["so2"];
  735. powietrze.pm25 = JSON_Air["current"]["air_quality"]["pm2_5"];
  736. powietrze.pm10 = JSON_Air["current"]["air_quality"]["pm10"];
  737. powietrze.Defra = JSON_Air["current"]["air_quality"]["gb-defra-index"];
  738.  
  739. if (powietrze.co != 0)
  740. {
  741. PrintLine(60);
  742. Serial.printf("\n[DarkNet] [Jakość Powietrza] Tlenek węgla \t\t: %2.8f [μg/ m3]", powietrze.co);
  743. Serial.printf("\n[DarkNet] [Jakość Powietrza] Dwutlenek azotu \t\t: %2.8f [μg/ m3]", powietrze.no2);
  744. Serial.printf("\n[DarkNet] [Jakość Powietrza] Ozon \t\t\t: %2.8f [μg/m3]", powietrze.o3);
  745. Serial.printf("\n[DarkNet] [Jakość Powietrza] Pyły i aerozole PM2.5 \t: %2.8f [μm]", powietrze.pm25);
  746. Serial.printf("\n[DarkNet] [Jakość Powietrza] Pyły i aerozole PM10 \t: %2.8f [μm]", powietrze.pm10);
  747. Serial.printf("\n[DarkNet] [Jakość Powietrza] Index jakości \t\t: %d IND", powietrze.Defra);
  748. PrintLine(60);
  749. PrintEND();
  750.  
  751. F_Powietrze = true;
  752. }
  753. else F_Powietrze = false;
  754. }
  755. //
  756. // ------------------------------------------------------------------------------------------------------------ //
  757. // --- A K T U A L I Z A C J A P R O G N O Z Ę --- //
  758. // ------------------------------------------------------------------------------------------------------------ //
  759. //
  760. void PrognozaAktualizuj()
  761. {
  762. PrintLine(60);
  763. PrintMSG("ESP32","MyTask", "Aktualizję prognozę z serwera : api.weatherapi.com");
  764.  
  765. // pobierz dane astronomiczne z serwera dla miasta LUBIN
  766.  
  767. String path = "http://api.weatherapi.com/v1/forecast.json?key=d27d7ab450e84466822133129211704&q=Mieroszow&days=1&aqi=no&alerts=no";
  768. String jsonBuffer = httpGETRequest(path.c_str());
  769.  
  770. JSON_Forecast = JSON.parse(jsonBuffer);
  771.  
  772. if (JSON.typeof(JSON_Forecast) == "undefined")
  773. {
  774. PrintLine(60);
  775. PrintMSG("DarkNet", "AIR PARSER", "BŁĄD, BRAK DANYCH" );
  776. }
  777. }
  778. //
  779. // ------------------------------------------------------------------------------------------------------------ //
  780. // --- MyTask ------------------------------------------------------------------------------------------------- //
  781. // ------------------------------------------------------------------------------------------------------------ //
  782. //
  783. void MyTask()
  784. {
  785. timeZERO = millis(); // zapisz czas 0
  786. task01m = timeZERO - timeout_task01m; // wyznacz nowy
  787. task05m = timeZERO - timeout_task05m; // wyznacz nowy
  788. task10m = timeZERO - timeout_task10m; // wyznacz nowy
  789. task15m = timeZERO - timeout_task15m; // wyznacz nowy
  790.  
  791. // --- ZADANIE co 1 minutę ------------------------------------------------------------------------------- //
  792.  
  793. if(task01m >= 60000UL) // wykonuj co 1 minutę
  794. {
  795. if (!F_Astronomia) AstronomiaAktualizuj(); // jeśli BRAK DANYCH wykonuj co minutę
  796. if (!F_Pogoda) PogodaAktualizuj(); // jeśli BRAK DANYCH wykonuj co minutę
  797. if (!F_Powietrze) PowietrzeAktualizuj(); // jeśli BRAK DANYCH wykonuj co minutę
  798. //if (!F_Prognoza) PrognozaAktualizuj(); // jeśli BRAK DANYCH wykonuj co minutę
  799.  
  800. timeout_task01m = timeZERO;
  801. }
  802.  
  803. // --- ZADANIE co 5 minut -------------------------------------------------------------------------------- //
  804.  
  805. if(task05m >= 300000UL) // wykonuj co 5 minut
  806. {
  807. timeout_task05m = timeZERO;
  808. }
  809.  
  810. // --- ZADANIE co 10 minut ------------------------------------------------------------------------------- //
  811.  
  812. if(task10m >= 600000UL) // wykonuj co 10 minut
  813. {
  814. timeout_task10m = timeZERO;
  815. }
  816.  
  817. // --- ZADANIE co 15 minut ------------------------------------------------------------------------------- //
  818.  
  819. if(task15m >= 900000UL) // wykonuj co 15 minut
  820. {
  821. if (F_Astronomia) AstronomiaAktualizuj(); // jeśli DANE OK co 15 minut
  822. if (F_Pogoda) PogodaAktualizuj(); // jeśli DANE OK co 15 minut
  823. if (F_Powietrze) PowietrzeAktualizuj(); // jeśli DANE OK co 15 minut
  824. //if (F_Prognoza) PrognozaAktualizuj(); // jeśli BRAK DANYCH wykonuj co minutę
  825.  
  826. timeout_task15m = timeZERO;
  827. }
  828.  
  829. }
  830. //
  831. // ------------------------------------------------------------------------------------------------------------ //
  832. // --- S E T U P ---------------------------------------------------------------------------------------------- //
  833. // ------------------------------------------------------------------------------------------------------------ //
  834. //
  835. void setup()
  836. {
  837. #if SERIAL
  838. Serial.begin(SPEED); // ustaw prędkość terminala SERIAL
  839. #endif
  840.  
  841. mesh.setDebugMsgTypes( ERROR | STARTUP | CONNECTION ); // ustaw przed init (), abyś mógł zobaczyć komunikaty startowe
  842.  
  843. mesh.init( MESH_PREFIX, MESH_PASSWORD, MESH_PORT, WIFI_AP_STA, 6 );
  844. mesh.onReceive(&receivedCallback);
  845. mesh.stationManual(STATION_SSID, STATION_PASSWORD);
  846. mesh.setHostname(HOSTNAME);
  847.  
  848. mesh.setRoot(true); // sieć MESH na tym urządzeniu jako ROOT
  849. mesh.setContainsRoot(true); // sieć MESH na tym urządzeniu jako ROOT
  850.  
  851. timeClient.begin(); // włącz klienta NTP (pobieranie czasu z internetu)
  852.  
  853. // --- CPU_Core_0 ----------------------------------------------------------------------------------
  854.  
  855. xTaskCreatePinnedToCore(Core0_Task1, "CPU_Core_0", 5000, NULL, 1, &CPU_Core_0, 0);
  856. vTaskDelay(500 / portTICK_PERIOD_MS);
  857.  
  858. xTaskCreatePinnedToCore(Core0_Task2, "CPU_Core_0", 5000, NULL, 1, &CPU_Core_0, 0);
  859. vTaskDelay(500 / portTICK_PERIOD_MS);
  860.  
  861. // --- CPU_Core_1 ----------------------------------------------------------------------------------
  862.  
  863. xTaskCreatePinnedToCore(Core1_Task1, "CPU_Core_1", 5000, NULL, 1, &CPU_Core_1, 1);
  864. vTaskDelay(500 / portTICK_PERIOD_MS);
  865.  
  866. xTaskCreatePinnedToCore(Core1_Task2, "CPU_Core_1", 5000, NULL, 1, &CPU_Core_1, 1);
  867. vTaskDelay(500 / portTICK_PERIOD_MS);
  868. }
  869.  
  870. // ------------------------------------------------------------------------------------------------------------ //
  871. // --- L O O P ------------------------------------------------------------------------------------------------ //
  872. // ------------------------------------------------------------------------------------------------------------ //
  873. //
  874. void loop()
  875. {
  876. mesh.update(); // aktulizuj MESH
  877. mqttClient.loop(); // pętla dla klienta mqtt
  878.  
  879. if(myIP != getlocalIP()) // jeśli moje IP różne od lokalnego IP
  880. {
  881. myIP = getlocalIP(); // zapisz lokalne IP
  882.  
  883. #if SERIAL
  884. Serial.println("Adres lokalny IP: " + myIP.toString());
  885. #endif
  886.  
  887. if (mqttClient.connect("painlessMeshClient")) // jeśli client
  888. {
  889. mqttClient.publish("painlessMesh/from/gateway","Gotowe!");
  890. mqttClient.subscribe("painlessMesh/to/#");
  891. }
  892. }
  893.  
  894. MyTask();
  895. }
  896. //
  897. // ------------------------------------------------------------------------------------------------------------ //
  898. // --- E N D ------------------------------------------------------------------------------------------------- //
  899. // ------------------------------------------------------------------------------------------------------------ //
  900.  
Advertisement
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!