-
Notifications
You must be signed in to change notification settings - Fork 2
/
AQLoRaBurk.ino
318 lines (278 loc) · 9.12 KB
/
AQLoRaBurk.ino
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
/*******************************************************************************
Copyright (c) 2018 Vekotinverstas / Forum Virium Helsinki
Permission is hereby granted, free of charge, to anyone
obtaining a copy of this document and accompanying files,
to do whatever they want with them without any restriction,
including, but not limited to, copying, modification and redistribution.
NO WARRANTY OF ANY KIND IS PROVIDED.
LoRaWAN part is heavily copied from lmic library's examples.
Do not forget to define the radio type correctly
#define CFG_eu868 1
in
libraries/MCCI_LoRaWAN_LMIC_library/project_config/lmic_project_config.h or from your BOARDS.txt.
*******************************************************************************/
uint8_t VERSION = 0x2C; // REMEMBER TO INCREASE BY ONE HEX DIGIT WHEN THERE IS CHANGES IN DATA!
#include <lmic.h>
#include <hal/hal.h>
#include <Wire.h>
#include <SPI.h>
#include "settings.h"
// Sensor support libraries
#include <Adafruit_Sensor.h>
#include <Adafruit_BME280.h>
#include <Adafruit_BME680.h>
#include <Adafruit_SSD1306.h>
#include "SDS011.h"
#include "QuickStats.h"
QuickStats stats;
// LoRa payload
#define payloadSize 26
static uint8_t payload[payloadSize];
// BME280 sensor
Adafruit_BME280 bme280;
uint8_t bme280_ok = 0;
uint32_t bme280_lastRead = 0;
uint32_t bme280_lastSend = 0;
float bme280_lastHumi = -999;
float bme280_lastTemp = -999;
float bme280_lastPres = -999;
// BME680 AQ sensor
Adafruit_BME680 bme680;
uint8_t bme680_ok = 0;
uint32_t bme680_lastRead = 0;
uint32_t bme680_lastSend = 0;
float bme680_lastTemp = -999;
float bme680_lastHumi = -999;
float bme680_lastPres = -999;
float bme680_lastGas = -999;
SDS011 sds011;
uint8_t sds011_ok = 0;
#define pm_array_size 120
uint32_t pm_array_counter = 0;
float sds011_pm25[pm_array_size];
float sds011_pm10[pm_array_size];
#define SCREEN_WIDTH 128 // OLED display width, in pixels
#define SCREEN_HEIGHT 64 // OLED display height, in pixels
// Declaration for an SSD1306 display connected to I2C (SDA, SCL pins)
#define OLED_RESET 4 // Reset pin
Adafruit_SSD1306 display(SCREEN_WIDTH, SCREEN_HEIGHT, &Wire, OLED_RESET);
unsigned long lastDisplay;
unsigned long maxDisplayTime = 15 * 60 * 1000; // how many milli seconds display will stay powered on
static osjob_t sendjob;
void setup() {
while (!Serial); // wait for Serial to be initialized
Serial.begin(115200);
delay(100); // per sample code on RF_95 test
Serial.println(F("Starting"));
printLoRaWANkeys();
// SDS011 serial
Serial2.begin(9600, SERIAL_8N1, SDS011_RXPIN, SDS011_TXPIN);
init_sensors();
displayInit();
uint16_t t = random(1000, 5000);
Serial.println(t);
delay(t);
lastDisplay = millis();
lmic_init();
// Start job
do_send(&sendjob);
// Initialise payload
for (uint8_t i = 0; i < payloadSize; i++) {
payload[i] = 0;
}
}
void loop() {
unsigned long now;
now = millis();
if ((now & 512) != 0) {
digitalWrite(13, HIGH);
}
else {
digitalWrite(13, LOW);
}
read_sensors();
os_runloop_once();
if (now > lastDisplay + 5000) {
displaySensorvalues();
lastDisplay = now;
}
}
void printArray(const char *keyName, u1_t x[], uint8_t s) {
char buf [2];
Serial.print(keyName);
Serial.print(": ");
for ( int i = 0 ; i < s; i++ ) {
sprintf(buf, "%02x", x[i]);
Serial.print(buf);
}
Serial.println();
}
void printLoRaWANkeys() {
#ifdef PRINT_KEYS
printArray("NWKSKEY", NWKSKEY, 16);
printArray("APPSKEY", APPSKEY, 16);
printArray("DEVEUI", DEVEUI, 8);
Serial.print(F("DevAddr: 0x"));
Serial.println(DEVADDR, HEX);
#endif
}
void displayInit() {
if (!display.begin(SSD1306_SWITCHCAPVCC, 0x3C)) { // Address 0x3D for 128x64
Serial.println(F("SSD1306 allocation failed"));
for (;;); // Don't proceed, loop forever
}
Serial.println(F("SSD1306 allocated"));
display.clearDisplay();
display.setTextSize(2); // Draw 2X-scale text
display.setCursor(0, 0);
display.setTextColor(BLACK, WHITE); // Draw 'inverse' text
display.println(F("AQ Burk"));
display.setTextSize(1); // Normal 1:1 pixel scale
display.setTextColor(WHITE); // Draw white text
display.print(F("Version 0.0."));
display.println(VERSION, HEX);
display.println(F("Dev "));
display.print(F("0x")); display.println(DEVADDR, HEX);
if ( bme280_ok || bme680_ok || sds011_ok) {
if (bme280_ok) {
display.println(F("BME280 OK"));
}
if (bme680_ok) {
display.println(F("BME680 OK"));
}
if (sds011_ok) {
display.println(F("SDS011 OK"));
}
} else {
display.println(F("NO SENSORS FOUND"));
}
display.display();
delay(1000);
}
void displaySensorvalues() {
// maxDisplayTime = 1000*20; // 20 sec for debugging
if (millis() > (maxDisplayTime)) {
display.ssd1306_command(SSD1306_DISPLAYOFF);
return;
}
if (millis() > maxDisplayTime - 10 * 1000) {
display.clearDisplay();
display.setTextSize(2);
display.setCursor(0, 0);
display.setTextColor(BLACK, WHITE);
display.println(F("Shutting"));
display.println(F("display"));
display.println(F("down..."));
display.display();
return;
}
Serial.println(F("Display values"));
float temp = 0;
float humi = 0;
float pres = 0;
float gas = 0;
// Add BME sensor values, if they are read at least once
if (bme280_ok && (bme280_lastTemp > -999)) {
temp = bme280_lastTemp;
humi = bme280_lastHumi;
pres = bme280_lastPres;
gas = 0;
} else if (bme680_ok && (bme680_lastTemp > -999)) {
temp = bme680_lastTemp;
humi = bme680_lastHumi;
pres = bme680_lastPres;
gas = bme680_lastGas;
}
uint8_t bufsize = 30;
char buf1 [bufsize];
int cx;
display.setCursor(0, 0);
display.clearDisplay();
display.setTextSize(1); // Normal 1:1 pixel scale
display.setTextColor(WHITE); // Draw white text
cx = snprintf ( buf1, bufsize, "T %.1f'C H %.1f%%", temp, humi);
display.println(buf1);
cx = snprintf ( buf1, bufsize, "Pres %.1f hPa", pres );
display.println(buf1);
cx = snprintf ( buf1, bufsize, "Gas %.1f kohm", gas );
display.println(buf1);
if (pm_array_counter > 0) {
cx = snprintf ( buf1, bufsize, "PM2.5/10 %.1f %.1f", sds011_pm25[pm_array_counter-1], sds011_pm10[pm_array_counter-1] );
display.println(buf1);
}
cx = snprintf ( buf1, bufsize, "Uptime %.1f s", (millis() / 1000.0) );
display.println(buf1);
display.display();
Serial.println(buf1);
}
uint32_t addToPayload(uint8_t pl[], uint16_t val, uint32_t i) {
pl[i++] = val >> 8;
pl[i++] = val & 0x00FF;
return i;
}
/**
Generate payload which is an uint8_t array full of uint16_t values meaning
bytes 0 and 1 contain the first uint16_t value and so on.
*/
void generatePayload() {
float min25 = 0;
float max25 = 0;
float avg25 = 0;
float med25 = 0;
float min10 = 0;
float max10 = 0;
float avg10 = 0;
float med10 = 0;
float temp = 0;
float humi = 0;
float pres = 0;
float gas = 0;
// More examples for statistics
// https://github.com/dndubins/QuickStats/blob/master/examples/statistics/statistics.ino
if (pm_array_counter > 0) {
min25 = stats.minimum(sds011_pm25, pm_array_counter);
max25 = stats.maximum(sds011_pm25, pm_array_counter);
avg25 = stats.average(sds011_pm25, pm_array_counter);
med25 = stats.median(sds011_pm25, pm_array_counter);
min10 = stats.minimum(sds011_pm10, pm_array_counter);
max10 = stats.maximum(sds011_pm10, pm_array_counter);
avg10 = stats.average(sds011_pm10, pm_array_counter);
med10 = stats.median(sds011_pm10, pm_array_counter);
}
// Add BME sensor values, if they are read at least once
if (bme280_ok && (bme280_lastTemp > -999)) {
temp = bme280_lastTemp + 100; // add 100 to make value always positive
humi = bme280_lastHumi;
pres = bme280_lastPres;
gas = 0;
} else if (bme680_ok && (bme680_lastTemp > -999)) {
temp = bme680_lastTemp + 100; // add 100 to make value always positive
humi = bme680_lastHumi;
pres = bme680_lastPres;
gas = bme680_lastGas;
}
char buffer [200];
int cx;
cx = snprintf ( buffer, 200, "Values to send: min2.5 %.1f max2.5 %.1f avg2.5 %.1f med2.5 %.1f min10 %.1f max10 %.1f avg10 %.1f med10 %.1f temp %.1f humi %.1f pres %.1f gas %.1f",
min25, max25, avg25, med25, min10, max10, avg10, med10, temp, humi, pres, gas );
Serial.println(buffer);
uint16_t tmp;
uint8_t i = 0;
// first byte defines protocol (AQBurk)
payload[i++] = 0x2A;
// second byte defines version
payload[i++] = VERSION;
i = addToPayload(payload, (uint16_t)(min25 * 10), i);
i = addToPayload(payload, (uint16_t)(max25 * 10), i);
i = addToPayload(payload, (uint16_t)(avg25 * 10), i);
i = addToPayload(payload, (uint16_t)(med25 * 10), i);
i = addToPayload(payload, (uint16_t)(min10 * 10), i);
i = addToPayload(payload, (uint16_t)(max10 * 10), i);
i = addToPayload(payload, (uint16_t)(avg10 * 10), i);
i = addToPayload(payload, (uint16_t)(med10 * 10), i);
i = addToPayload(payload, (uint16_t)(temp * 10), i);
i = addToPayload(payload, (uint16_t)(humi * 10), i);
i = addToPayload(payload, (uint16_t)(pres * 10), i);
i = addToPayload(payload, (uint16_t)(gas * 10), i);
pm_array_counter = 0;
}