You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
122 lines
3.1 KiB
C++
122 lines
3.1 KiB
C++
// FARM DATA RELAY SYSTEM
|
|
//
|
|
// GATEWAY MODULE
|
|
//
|
|
// Developed by Timm Bogner (bogner1@gmail.com) for Sola Gratia Farm in Urbana, Illinois, USA.
|
|
// Setup instructions located in the "fdrs_config.h" file.
|
|
|
|
#if defined(ESP8266)
|
|
#include <ESP8266WiFi.h>
|
|
#include <espnow.h>
|
|
#elif defined(ESP32)
|
|
#include <esp_now.h>
|
|
#include <WiFi.h>
|
|
#include <esp_wifi.h>
|
|
#endif
|
|
#include "fdrs_config.h"
|
|
#include <ArduinoJson.h>
|
|
|
|
typedef struct DataReading {
|
|
float d;
|
|
uint16_t id;
|
|
uint8_t t;
|
|
|
|
} DataReading;
|
|
|
|
typedef struct DataPacket {
|
|
uint8_t l;
|
|
DataReading packet[30];
|
|
|
|
} DataPacket;
|
|
|
|
//uint8_t prevAddress[] = {0xAA, 0xBB, 0xCC, 0xDD, 0xEE, PREV_MAC};
|
|
uint8_t selfAddress[] = {0xAA, 0xBB, 0xCC, 0xDD, 0xEE, UNIT_MAC};
|
|
DataPacket incData;
|
|
DataReading theData[30];
|
|
bool newData = false;
|
|
|
|
void encodeJSON() {
|
|
StaticJsonDocument<2048> doc;
|
|
for (int i = 0; i < 30; i++) {
|
|
doc[i]["id"] = theData[i].id;
|
|
doc[i]["type"] = theData[i].t;
|
|
doc[i]["data"] = theData[i].d;
|
|
theData[i].id = 0;
|
|
theData[i].t = 0;
|
|
theData[i].d = 0;
|
|
}
|
|
serializeJson(doc, Serial);
|
|
}
|
|
|
|
#if defined(ESP8266)
|
|
void OnDataSent(uint8_t *mac_addr, uint8_t sendStatus) {
|
|
// Serial.print("Last Packet Send Status: ");
|
|
// if (sendStatus == 0) {
|
|
// Serial.println("Delivery success");
|
|
// }
|
|
// else {
|
|
// Serial.println("Delivery fail");
|
|
// }
|
|
}
|
|
|
|
void OnDataRecv(uint8_t * mac, uint8_t *incomingData, uint8_t len) {
|
|
#elif defined(ESP32)
|
|
void OnDataSent(const uint8_t *mac_addr, esp_now_send_status_t status) {
|
|
// Serial.print("Last Packet Send Status:");
|
|
// Serial.println(status == ESP_NOW_SEND_SUCCESS ? "Delivery Success" : "Delivery Fail");
|
|
}
|
|
void OnDataRecv(const uint8_t * mac, const uint8_t *incomingData, int len) {
|
|
#endif
|
|
memcpy(&incData, incomingData, sizeof(incData));
|
|
//Serial.println(":Packet:");
|
|
for (byte i = 0; i < incData.l; i++) {
|
|
//Serial.println("SENSOR ID: " + String(incData.packet[i].id) + " TYPE " + String(incData.packet[i].t) + " DATA " + String(incData.packet[i].d));
|
|
theData[i] = incData.packet[i];
|
|
}
|
|
newData = true;
|
|
}
|
|
|
|
void setup() {
|
|
// Init Serial Monitor
|
|
Serial.begin(115200);
|
|
// Init WiFi
|
|
WiFi.mode(WIFI_STA);
|
|
WiFi.disconnect();
|
|
// Init ESP-NOW for either ESP8266 or ESP32 and set MAC address
|
|
#if defined(ESP8266)
|
|
wifi_set_macaddr(STATION_IF, selfAddress);
|
|
if (esp_now_init() != 0) {
|
|
return;
|
|
}
|
|
esp_now_set_self_role(ESP_NOW_ROLE_COMBO);
|
|
esp_now_register_send_cb(OnDataSent);
|
|
esp_now_register_recv_cb(OnDataRecv);
|
|
// Register peer
|
|
// esp_now_add_peer(prevAddress, ESP_NOW_ROLE_COMBO, 0, NULL, 0);
|
|
#elif defined(ESP32)
|
|
esp_wifi_set_mac(WIFI_IF_STA, &selfAddress[0]);
|
|
if (esp_now_init() != ESP_OK) {
|
|
Serial.println("Error initializing ESP-NOW");
|
|
return;
|
|
}
|
|
esp_now_register_send_cb(OnDataSent);
|
|
esp_now_register_recv_cb(OnDataRecv);
|
|
esp_now_peer_info_t peerInfo;
|
|
peerInfo.channel = 0;
|
|
peerInfo.encrypt = false;
|
|
// // register peer
|
|
// memcpy(peerInfo.peer_addr, prevAddress, 6);
|
|
// if (esp_now_add_peer(&peerInfo) != ESP_OK) {
|
|
// Serial.println("Failed to add peer");
|
|
// return;
|
|
// }
|
|
#endif
|
|
}
|
|
|
|
void loop() {
|
|
if (newData) {
|
|
newData = false;
|
|
encodeJSON();
|
|
}
|
|
}
|