mirror of
https://github.com/timmbogner/Farm-Data-Relay-System
synced 2024-11-01 03:20:56 +00:00
158 lines
3.7 KiB
C
158 lines
3.7 KiB
C
// FARM DATA RELAY SYSTEM
|
|
//
|
|
// "fdrs_sensor.h"
|
|
//
|
|
// Developed by Timm Bogner (timmbogner@gmail.com) for Sola Gratia Farm in Urbana, Illinois, USA.
|
|
//
|
|
#include <fdrs_datatypes.h>
|
|
#if defined(ESP8266)
|
|
#include <ESP8266WiFi.h>
|
|
#include <espnow.h>
|
|
#elif defined(ESP32)
|
|
#include <esp_now.h>
|
|
#include <WiFi.h>
|
|
#include <esp_wifi.h>
|
|
#endif
|
|
#ifdef USE_LORA
|
|
#include <LoRa.h>
|
|
#endif
|
|
|
|
#ifdef GLOBALS
|
|
#define FDRS_BAND GLOBAL_BAND
|
|
#define FDRS_SF GLOBAL_SF
|
|
#else
|
|
#define FDRS_BAND LORA_BAND
|
|
#define FDRS_SF LORA_SF
|
|
#endif
|
|
|
|
#ifdef DEBUG
|
|
#define DBG(a) (Serial.println(a))
|
|
#else
|
|
#define DBG(a)
|
|
#endif
|
|
|
|
#define MAC_PREFIX 0xAA, 0xBB, 0xCC, 0xDD, 0xEE // Should only be changed if implementing multiple FDRS systems.
|
|
|
|
typedef struct __attribute__((packed)) DataReading {
|
|
float d;
|
|
uint16_t id;
|
|
uint8_t t;
|
|
|
|
} DataReading;
|
|
|
|
const uint16_t espnow_size = 250 / sizeof(DataReading);
|
|
uint8_t gatewayAddress[] = {MAC_PREFIX, GTWY_MAC};
|
|
uint8_t gtwyAddress[] = {gatewayAddress[3], gatewayAddress[4], GTWY_MAC};
|
|
uint8_t LoRaAddress[] = {0x42, 0x00};
|
|
|
|
uint32_t wait_time = 0;
|
|
DataReading fdrsData[espnow_size];
|
|
uint8_t data_count = 0;
|
|
|
|
void beginFDRS() {
|
|
#ifdef DEBUG
|
|
Serial.begin(115200);
|
|
#endif
|
|
DBG("FDRS Sensor ID " + String(READING_ID) + " initializing...");
|
|
DBG(" Gateway: " + String (GTWY_MAC, HEX));
|
|
#ifdef POWER_CTRL
|
|
DBG("Powering up the sensor array!");
|
|
pinMode(POWER_CTRL, OUTPUT);
|
|
digitalWrite(POWER_CTRL, 1);
|
|
#endif
|
|
// Init ESP-NOW for either ESP8266 or ESP32 and set MAC address
|
|
#ifdef USE_ESPNOW
|
|
DBG("Initializing ESP-NOW!");
|
|
WiFi.mode(WIFI_STA);
|
|
WiFi.disconnect();
|
|
#if defined(ESP8266)
|
|
if (esp_now_init() != 0) {
|
|
return;
|
|
}
|
|
esp_now_set_self_role(ESP_NOW_ROLE_COMBO);
|
|
// Register peers
|
|
esp_now_add_peer(gatewayAddress, ESP_NOW_ROLE_COMBO, 0, NULL, 0);
|
|
#elif defined(ESP32)
|
|
if (esp_now_init() != ESP_OK) {
|
|
DBG("Error initializing ESP-NOW");
|
|
return;
|
|
}
|
|
esp_now_peer_info_t peerInfo;
|
|
peerInfo.ifidx = WIFI_IF_STA;
|
|
peerInfo.channel = 0;
|
|
peerInfo.encrypt = false;
|
|
// Register first peer
|
|
memcpy(peerInfo.peer_addr, gatewayAddress, 6);
|
|
if (esp_now_add_peer(&peerInfo) != ESP_OK) {
|
|
DBG("Failed to add peer");
|
|
return;
|
|
}
|
|
#endif
|
|
DBG(" ESP-NOW Initialized.");
|
|
#endif
|
|
#ifdef USE_LORA
|
|
DBG("Initializing LoRa!");
|
|
DBG(LORA_BAND);
|
|
DBG(LORA_SF);
|
|
#ifdef ESP32
|
|
SPI.begin(SPI_SCK, SPI_MISO, SPI_MOSI);
|
|
#endif
|
|
LoRa.setPins(LORA_SS, LORA_RST, LORA_DIO0);
|
|
if (!LoRa.begin(FDRS_BAND)) {
|
|
DBG("Unable to initialize LoRa!");
|
|
while (1);
|
|
}
|
|
LoRa.setSpreadingFactor(FDRS_SF);
|
|
DBG(" LoRa Initialized.");
|
|
#endif
|
|
}
|
|
void transmitLoRa(uint8_t* mac, DataReading * packet, uint8_t len) {
|
|
#ifdef USE_LORA
|
|
uint8_t pkt[5 + (len * sizeof(DataReading))];
|
|
memcpy(&pkt, mac, 3); //
|
|
memcpy(&pkt[3], &LoRaAddress, 2);
|
|
memcpy(&pkt[5], packet, len * sizeof(DataReading));
|
|
LoRa.beginPacket();
|
|
LoRa.write((uint8_t*)&pkt, sizeof(pkt));
|
|
LoRa.endPacket();
|
|
#endif
|
|
}
|
|
void sendFDRS() {
|
|
DBG("Sending FDRS Packet!");
|
|
#ifdef USE_ESPNOW
|
|
esp_now_send(gatewayAddress, (uint8_t *) &fdrsData, data_count * sizeof(DataReading));
|
|
delay(5);
|
|
DBG(" ESP-NOW sent.");
|
|
#endif
|
|
#ifdef USE_LORA
|
|
transmitLoRa(gtwyAddress, fdrsData, data_count);
|
|
DBG(" LoRa sent.");
|
|
#endif
|
|
data_count = 0;
|
|
}
|
|
void loadFDRS(float d, uint8_t t) {
|
|
DBG("Data loaded. Type: " + String(t));
|
|
if (data_count > espnow_size) sendFDRS();
|
|
DataReading dr;
|
|
dr.id = READING_ID;
|
|
dr.t = t;
|
|
dr.d = d;
|
|
fdrsData[data_count] = dr;
|
|
data_count++;
|
|
}
|
|
void sleepFDRS(int sleep_time) {
|
|
DBG("Sleepytime!");
|
|
#ifdef DEEP_SLEEP
|
|
DBG(" Deep sleeping.");
|
|
#ifdef ESP32
|
|
esp_sleep_enable_timer_wakeup(sleep_time * 1000000);
|
|
esp_deep_sleep_start();
|
|
#endif
|
|
#ifdef ESP8266
|
|
ESP.deepSleep(sleep_time * 1000000);
|
|
#endif
|
|
#endif
|
|
DBG(" Delaying.");
|
|
delay(sleep_time * 1000);
|
|
}
|