okoyono/weatherstation
7
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Compare commits

base: okoyono:5fcfd8965298c9e58c459b601bc42a30edd3ae93
Branches Tags
okoyono:master
okoyono:feature/http_call_send_json
okoyono:feature/main_loop_to_fsm
okoyono:feature/InfluxDB-Connection-Update
..
compare: okoyono:35c62fbce2fd1a71951bfc7ce4944aaa5b33b0d6
Branches Tags
okoyono:master
okoyono:feature/http_call_send_json
okoyono:feature/main_loop_to_fsm
okoyono:feature/InfluxDB-Connection-Update

No commits in common. "5fcfd8965298c9e58c459b601bc42a30edd3ae93" and "35c62fbce2fd1a71951bfc7ce4944aaa5b33b0d6" have entirely different histories.
5fcfd89652 ... 35c62fbce2

9 changed files with 133 additions and 268 deletions
Show stats Expand all files Collapse all files

2
firmware/config.h
View file

@ -41,8 +41,6 @@
#define BME_CS 10
#define BME_ADDRESS 0x76
#define SERIAL_BAUD_RATE 115200
#define WEB_UPDATER_HTTP_PORT 8080
#endif

43
firmware/config_user.h.example
View file

@ -12,43 +12,28 @@
// maybe have a TOO LONG SSID!
String DEVICE_NAME = "weatherstation";
/********************************************************************************/
// Enable/Disable general features
#define BATTERY_POWERED
// retries to connect after 5 seconds or starts the wifimanager
//#define SLEEP_IF_NO_WLAN_CONNECTION
// Enable/Disable features
#define INFLUXDB_FEATURE
#define INFLUXDB_VERSION 1 // 1 or 2
//#define LOG_MILLIS_TO_INFLUXDB
//#define SERIAL_FEATURE
#define SENSOR_WIND
#define SERIAL_FEATURE
//#define BATTERY_POWERED
//#define SENSOR_WIND
#define SENSOR_APDS9960
//#define SENSOR_APDS9930
#define SENSOR_BME280
#define SENSOR_BATTERY
//#define BAT_PINS_D34
/********************************************************************************/
// not available or recommended for battery mode
/********************************************************************************/
// Restarts the firmware every n seconds
//#define RESET_ESP_TIME_INTERVAL
//#define ENABLE_WATCHDOG
//#define WEBUPDATER_FEATURE
// only available in case that webupdater is enabled
//#define USE_LOGGER
// only possible if webupdater is also enabled
// Homebridge Webstat is only possible if webupdater is also enabled
//#define HOMEBRIDGE_WEBSTAT
// for debugging windspeed measurement only, trigger and results are handled by webupdater
//#define DEBUG_WINDSPEED_MEASUREMENT
//#define HTTP_CALL_ON_WINDSPEED_EXCEED
// retries to connect after 5 seconds or starts the wifimanager
#define SLEEP_IF_NO_WLAN_CONNECTION
// Restarts the firmware every n seconds
//#define RESET_ESP_TIMEINTERVAL // BETA STATUS
//#define HTTP_CALL_ON_WINDSPEED_EXCEED // BETA STATUS
//#define DEBUG_WINDSPEED_MEASUREMENT // for debugging windspeed measurement only
//#define LOG_MILLIS_TO_INFLUXDB
//#define ENABLE_WATCHDOG
//#define WATCHDOG_TIMEOUT_MS 30000
const float HUMIDITY_FACTOR = 1.0;
const float LIGHT_FACTOR = 1.0;

21
firmware/constants.h
View file

@ -18,17 +18,14 @@
#define ENERGY_SAVE_MODE_ENABLED 1.0
#define ENERGY_SAVE_MODE_DISABLED 0.0
#define FSM_STATE_1 0
#define FSM_STATE_2 1
#define FSM_STATE_3 2
#define FSM_STATE_4 3
#define FSM_STATE_5 4
#define FSM_STATE_6 5
#define FSM_STATE_7 6
#define FSM_STATE_8 7
#define FSM_STATE_9 8
#define FSM_STATE_10 9
#define FSM_STATE_11 10
#define FSM_STATE_12 11
#define FSM_STATE_WU 0
#define FSM_STATE_WSE 1
#define FSM_STATE_RS 2
#define FSM_STATE_WC 3
#define FSM_STATE_WS 4
#define FSM_STATE_US 5
#define FSM_STATE_SC 6
#define FSM_STATE_ID 7
#define FSM_STATE_SD 8
#endif

250
firmware/firmware.ino
View file

@ -40,7 +40,7 @@ const String wifiName = "oko-weather-" + DEVICE_NAME;
WiFiManager wifiManager;
uint8_t fsm_state = FSM_STATE_1;
uint8_t fsm_state = FSM_STATE_WU;
uint8_t sensor_cnt = 0;
@ -67,7 +67,7 @@ void setup()
{
#if defined(DEBUG) || defined(SERIAL_FEATURE)
Serial.begin(SERIAL_BARD_RATE);
Serial.begin(115200);
#endif
// Pin settings
@ -109,11 +109,7 @@ void setup()
#ifdef BATTERY_POWERED
debug("battery powered");
do {
_battery_mode_main();
} while (fsm_state != FSM_STATE_1);
_loop();
digitalWrite(STATUS_LED_PIN, LOW);
@ -130,12 +126,10 @@ void setup()
delay(100);
#endif
#ifndef BATTERY_POWERED
#ifdef ENABLE_WATCHDOG
// Enable the internal watchdog
ESP.wdtEnable(WATCHDOG_TIMEOUT_MS);
#endif
#endif
}
@ -244,7 +238,7 @@ void wifiConnectionCheck()
return;
}
debug("no wifi connection, try to reconnect");
debug("no connection or time to check " + String(WiFi.status() == WL_CONNECTED));
wifiConnect();
@ -309,23 +303,19 @@ void loop()
#ifdef BATTERY_POWERED
delay(50);
return;
#endif
#else
// call fsm loop function
_fsm_loop();
// call sub loop function
_loop();
// Needed to give WIFI time to function properly
delay(DELAY_LOOP_MS);
#endif
}
//*************************************************************************//
#ifndef BATTERY_POWERED
void _fsm_loop()
void _loop()
{
#ifdef WEBUPDATER_FEATURE
@ -340,27 +330,37 @@ void _fsm_loop()
switch (fsm_state)
{
/* -------------------------------------------------------------------------------- */
case FSM_STATE_1:
case FSM_STATE_WU:
/*
//debug("web updater call if required");
#ifdef WEBUPDATER_FEATURE
if ((update_webserver_cnt + (UPDATE_WEBSERVER_INTVERVAL_S * 1000)) <= millis())
{
//debug("web updater call");
update_webserver_cnt = millis();
doWebUpdater();
}
#endif
*/
fsm_state = FSM_STATE_WSE;
break;
case FSM_STATE_WSE:
//debug("wind speed exceeded check if required");
#ifdef HTTP_CALL_ON_WINDSPEED_EXCEED
if ((update_windspeed_exceed_cnt + (HTTP_CALL_ON_WINDSPEED_INTERVAL_S * 1000)) <= millis())
{
debug("reading wind sensor exceed");
// reset the wait timer to get a value every HTTP_CALL_ON_WINDSPEED_INTERVAL_S independently to the runtime of the measurement
update_windspeed_exceed_cnt = millis();
start_measure_wind(); // start measurement of wind speed
fsm_state = FSM_STATE_11; // wait untile the wind meas time exceeded
break; // abort case here to prevent read of next sensor in list
readWindSpeedExceed();
}
#endif
fsm_state = FSM_STATE_2;
fsm_state = FSM_STATE_RS;
break;
/* -------------------------------------------------------------------------------- */
case FSM_STATE_2:
case FSM_STATE_RS:
//debug("reset time check if required");
#ifdef RESET_ESP_TIME_INTERVAL
// if millis() reached interval restart ESP
@ -371,21 +371,18 @@ void _fsm_loop()
ESP.restart();
}
#endif
fsm_state = FSM_STATE_3;
fsm_state = FSM_STATE_WC;
break;
/* -------------------------------------------------------------------------------- */
case FSM_STATE_3:
case FSM_STATE_WC:
wifiConnectionCheck();
fsm_state = FSM_STATE_4;
fsm_state = FSM_STATE_WS;
break;
/* -------------------------------------------------------------------------------- */
case FSM_STATE_4:
case FSM_STATE_WS:
//debug("disable measure of wind speed if required");
#ifdef defined(BATTERY_POWERED) && defined(SENSOR_WIND)
if (energySavingMode() == 1)
{
if (energySavingMode() == 1) {
// Disable expensive tasks
//sensors[SENSOR_WINDSPEED] = 0;
//debug("read of wind sensor because of low battery disabled");
@ -398,57 +395,45 @@ void _fsm_loop()
}
#endif
sensor_cnt = 0;
fsm_state = FSM_STATE_5;
fsm_state = FSM_STATE_US;
break;
/* -------------------------------------------------------------------------------- */
case FSM_STATE_5:
case FSM_STATE_US:
//debug("read sensor data check");
if ((update_sensor_cnt + (UPDATE_SENSOR_INTERVAL_S * 1000)) <= millis())
{
debug("read sensor data " + String(sensor_cnt));
if (sensor_cnt != SENSOR_WINDSPEED)
{
// read data from sensor
currentSensorData[sensor_cnt] = readSensors(sensor_cnt);
} else {
start_measure_wind(); // start measurement of wind speed
fsm_state = FSM_STATE_9; // wait untile the wind meas time exceeded
break; // abort case here to prevent read of next sensor in list
}
currentSensorData[sensor_cnt] = readSensors(sensor_cnt);
if (sensor_cnt < VALUES)
{
sensor_cnt++;
fsm_state = FSM_STATE_5; // jump to same state again, more sensors to read
fsm_state = FSM_STATE_US; // jump to same state again, more sensors to read
} else {
update_sensor_cnt = millis(); // reset the update interval counter
update_sensor_cnt = millis();
sensor_cnt = 0;
fsm_state = FSM_STATE_6; // next state
fsm_state = FSM_STATE_SC; // next state
}
} else {
//debug("skip read sensor data");
fsm_state = FSM_STATE_1; // no new data, reset FSM
fsm_state = FSM_STATE_WU; // no new data, reset FSM
}
break;
/* -------------------------------------------------------------------------------- */
case FSM_STATE_6:
case FSM_STATE_SC:
//debug("log to serial if required");
#ifdef SERIAL_FEATURE
logToSerial(currentSensorData);
#endif
fsm_state = FSM_STATE_7;
fsm_state = FSM_STATE_ID;
break;
/* -------------------------------------------------------------------------------- */
case FSM_STATE_7:
case FSM_STATE_ID:
//debug("send data to influxdb if required");
#ifdef INFLUXDB_FEATURE
for (uint8_t i = 0; i < 5 and validData == false; i++)
@ -465,157 +450,73 @@ void _fsm_loop()
pushToInfluxDB(DEVICE_NAME, currentSensorData);
}
#endif
fsm_state = FSM_STATE_8;
fsm_state = FSM_STATE_SD;
break;
/* -------------------------------------------------------------------------------- */
case FSM_STATE_8:
case FSM_STATE_SD:
//debug("set sensor data in webupdater if required");
#ifdef WEBUPDATER_FEATURE
setSensorData(currentSensorData);
#endif
fsm_state = FSM_STATE_1;
fsm_state = FSM_STATE_WU;
break;
/* -------------------------------------------------------------------------------- */
case FSM_STATE_9:
#ifdef SENSOR_WIND
if (check_measure_wind_done() == false)
{
//debug("wait for wind sensor finish");
fsm_state = FSM_STATE_9; // stay here until the wind measurement is done
} else {
debug("wind sensor read finish");
fsm_state = FSM_STATE_10;
}
#else
// in case that the wind sensor is not used skip this step
sensor_cnt++;
fsm_state = FSM_STATE_5;
#endif
break;
/* -------------------------------------------------------------------------------- */
case FSM_STATE_10:
#ifdef SENSOR_WIND
currentSensorData[sensor_cnt] = measure_wind_result();
debug("wind sensor " + String(currentSensorData[sensor_cnt]));
#endif
// step into read of next sensor read
sensor_cnt++;
fsm_state = FSM_STATE_5;
break;
/* -------------------------------------------------------------------------------- */
case FSM_STATE_11:
#ifdef SENSOR_WIND
if (check_measure_wind_done() == false)
{
//debug("wait for wind sensor finish");
fsm_state = FSM_STATE_11; // stay here until the wind measurement is done
} else {
debug("wind sensor read finish");
fsm_state = FSM_STATE_12;
}
#else
// in case that the wind sensor is not used skip this step
sensor_cnt++;
fsm_state = FSM_STATE_5;
#endif
break;
/* -------------------------------------------------------------------------------- */
case FSM_STATE_12:
#ifdef HTTP_CALL_ON_WINDSPEED_EXCEED
currentSensorData[sensor_cnt] = measure_wind_result();
debug("wind sensor value " + String(currentSensorData[sensor_cnt]));
if (currentSensorData[SENSOR_WINDSPEED] >= HTTP_CALL_ON_WINDSPEED_EXCEED_MPS)
{
// windspeed exceeded send http call
digitalWrite(STATUS_LED_PIN, HIGH);
// call the url HTTP_CALL_ON_WINDSPEED_URL
WiFiClient client;
HTTPClient http;
http.begin(client, String(HTTP_CALL_ON_WINDSPEED_URL).c_str());
// Send HTTP GET request
int httpResponseCode = http.GET();
if (httpResponseCode > 0)
{
String response = http.getString();
debug("http response code: " + String(httpResponseCode) + " = " + response);
// TODO handle response
}
http.end();
debug("Called windspeed exceed callout");
digitalWrite(STATUS_LED_PIN, LOW);
}
#ifdef WEBUPDATER_FEATURE
setSensorData(currentSensorData);
#endif
#endif
// step into read of next fsm state
fsm_state = FSM_STATE_2;
break;
/* -------------------------------------------------------------------------------- */
default:
fsm_state = FSM_STATE_1;
fsm_state = FSM_STATE_WU;
break;
} // close of switch
//delay(100); // TODO warum hier ein delay?
//debug("FSM state = " + String(fsm_state));
/*if (fsm_state == FSM_STATE_1)
/*if (fsm_state == FSM_STATE_WU)
{
debug("----------");
}*/
}
#endif
//*************************************************************************//
void _battery_mode_main()
void readWindSpeedExceed()
{
if (energySavingMode() == 1)
// read from windspeed sensorSTATUS_LED_PIN
digitalWrite(STATUS_LED_PIN, HIGH);
currentSensorData[SENSOR_WINDSPEED] = readSensors(SENSOR_WINDSPEED);
digitalWrite(STATUS_LED_PIN, LOW);
if (currentSensorData[SENSOR_WINDSPEED] >= HTTP_CALL_ON_WINDSPEED_EXCEED_MPS)
{
// Disable expensive tasks
//debug("read of wind sensor because of low battery disabled");
do_not_read_windsensor = true;
digitalWrite(STATUS_LED_PIN, HIGH);
} else {
//debug("read of wind sensor because of high battery enabled");
do_not_read_windsensor = false;
// call the url HTTP_CALL_ON_WINDSPEED_URL
WiFiClient client;
HTTPClient http;
http.begin(client, String(HTTP_CALL_ON_WINDSPEED_URL).c_str());
// Send HTTP GET request
int httpResponseCode = http.GET();
if (httpResponseCode > 0) {
String response = http.getString();
debug("http response code: " + String(httpResponseCode) + " = " + response);
// TODO handle response
}
http.end();
debug("Called windspeed exceed callout");
digitalWrite(STATUS_LED_PIN, LOW);
}
for (uint8_t i = 0; i < VALUES; i++)
{
currentSensorData[i] = readSensors(i);
}
#ifdef SERIAL_FEATURE
logToSerial(currentSensorData);
#endif
#ifdef INFLUXDB_FEATURE
pushToInfluxDB(DEVICE_NAME, currentSensorData);
#endif
#ifdef WEBUPDATER_FEATURE
setSensorData(currentSensorData);
#endif
}
//*************************************************************************//
#ifdef SERIAL_FEATURE
void logToSerial(float sensorValues[])
{
Serial.println("");
@ -629,6 +530,5 @@ void logToSerial(float sensorValues[])
Serial.println("Bat charge state: " + String(sensorValues[SENSOR_BATCHARGESTATE]));
Serial.println("Energy saving: " + String(sensorValues[SENSOR_ESAVEMODE]));
}
#endif
//*************************************************************************//

17
firmware/sensor_apds9930.ino
View file

@ -2,30 +2,21 @@
APDS9930 _sensor_apds9930 = APDS9930();
bool sensor_apds9930_begin()
{
bool sensor_apds9930_begin() {
bool status = _sensor_apds9930.init();
if (status)
{
if (status) {
_sensor_apds9930.enableLightSensor(false);
debug("APDS9930 Connected");
} else {
debug("Could not find a valid APDS9930 sensor, check wiring!");
}
return status;
}
float apds9930_light()
{
float apds9930_light() {
float ambient_light = 0;
if (_sensor_apds9930.readAmbientLightLux(ambient_light))
{
if (_sensor_apds9930.readAmbientLightLux(ambient_light)) {
return ambient_light;
} else {
return 0;
}

16
firmware/sensor_apds9960.ino
View file

@ -2,34 +2,26 @@
Adafruit_APDS9960 _sensor_apds9960;
bool sensor_apds9960_begin()
{
bool sensor_apds9960_begin() {
bool status = _sensor_apds9960.begin();
if (status)
{
if (status) {
_sensor_apds9960.enableColor(true);
debug("APDS9960 Connected");
} else {
debug("Could not find a valid APDS9960 sensor, check wiring!");
}
return status;
}
float apds9960_light()
{
float apds9960_light() {
uint16_t red, green, blue, white, lux;
while(!_sensor_apds9960.colorDataReady())
{
while(!_sensor_apds9960.colorDataReady()) {
delay(5);
}
_sensor_apds9960.getColorData(&red, &green, &blue, &white);
//calculate lux
lux = _sensor_apds9960.calculateLux(red, green, blue);
return lux * LIGHT_FACTOR;
}

20
firmware/sensor_bme280.ino
View file

@ -3,32 +3,22 @@
Adafruit_BME280 _sensor_bme280;
bool sensor_bme280_begin(uint8_t addr)
{
bool sensor_bme280_begin(uint8_t addr) {
bool status = _sensor_bme280.begin(addr);
if (status)
{
if (status) {
debug("BME280 Connected");
} else {
debug("Could not find a valid BME280 sensor, check wiring!");
}
return status;
}
float bme280_temperature()
{
float bme280_temperature() {
return _sensor_bme280.readTemperature() * TEMP_FACTOR;
}
float bme280_pressure()
{
float bme280_pressure() {
return _sensor_bme280.readPressure() / 100.0F;
}
float bme280_humidity()
{
float bme280_humidity() {
return _sensor_bme280.readHumidity() * HUMIDITY_FACTOR;
}

29
firmware/sensor_wind.ino
View file

@ -4,7 +4,6 @@
unsigned int anemometerRotations = 0;
uint32_t start_meas_wind_time = 0;
int interruptNumber;
ICACHE_RAM_ATTR void _anemometerInterrupt()
{
@ -14,14 +13,28 @@ ICACHE_RAM_ATTR void _anemometerInterrupt()
#endif
}
/*
float wind_speed()
{
start_measure_wind();
do {
delay(1000); // minimum delay of measurement time is 1 second
} while (check_measure_wind_done() == false);
return measure_wind_result();
anemometerRotations = 0;
int interruptNumber = digitalPinToInterrupt(ANEMOMETER_PIN);
attachInterrupt(interruptNumber, _anemometerInterrupt, RISING);
delay(1000 * WIND_SENSOR_MEAS_TIME_S); // time to measure
detachInterrupt(interruptNumber);
// calculate the speed as km/h
float tmp_speed = (float)anemometerRotations * WINDSPEED_FACTOR;
#ifdef DEBUG
Serial.print("Windspeed: " + String(tmp_speed));
#endif
return tmp_speed;
}
*/
void start_measure_wind()
{
@ -32,7 +45,7 @@ void start_measure_wind()
boolean check_measure_wind_done()
{
if ((start_meas_wind_time + (WIND_SENSOR_MEAS_TIME_S * 1000)) <= millis())
if (start_meas_wind + WIND_SENSOR_MEAS_TIME_S <= millis())
{
detachInterrupt(interruptNumber);
return true;
@ -40,7 +53,7 @@ boolean check_measure_wind_done()
return false;
}
float measure_wind_result()
float stop_measure_wind()
{
return (float)anemometerRotations * WINDSPEED_FACTOR;
}

3
firmware/webUpdater.ino
View file

@ -86,8 +86,7 @@ void setSensorData(float sensorValues[])
}
}
for (uint8_t i = 0; i < VALUES; i++)
{
for (uint8_t i = 0; i < VALUES; i++) {
_webUpdater_sensValues[i] = sensorValues[i];
}
}