forked from dok-net/esp_sds011
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Limited GPIO availability on ESP8266; Wemos D1 mini: D1&D2: I2C. D3&D…
…4: LED and flash. Use D7&D8, also can swap() HW serial there.
- Loading branch information
Showing
2 changed files
with
133 additions
and
131 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,16 +1,16 @@ | ||
| /* | ||
| Name: measure.ino | ||
| Created: 2019-04-06 12:16:00 | ||
| Author: Dirk O. Kaar <[email protected]> | ||
| Name: measure.ino | ||
| Created: 2019-04-06 12:16:00 | ||
| Author: Dirk O. Kaar <[email protected]> | ||
| */ | ||
|
|
||
| #ifndef ESP32 | ||
| #include <SoftwareSerial.h> | ||
| #endif | ||
| #include <Sds011.h> | ||
|
|
||
| #define SDS_PIN_RX D4 | ||
| #define SDS_PIN_TX D3 | ||
| #define SDS_PIN_RX D7 | ||
| #define SDS_PIN_TX D8 | ||
|
|
||
| #ifdef ESP32 | ||
| HardwareSerial& serialSDS(Serial2); | ||
|
|
@@ -33,99 +33,99 @@ int pm10_table[pm_tablesize]; | |
| bool is_SDS_running = true; | ||
|
|
||
| void start_SDS() { | ||
| Serial.println("Start wakeup SDS011"); | ||
| Serial.println("Start wakeup SDS011"); | ||
|
|
||
| if (sds011.set_sleep(false)) { is_SDS_running = true; } | ||
| if (sds011.set_sleep(false)) { is_SDS_running = true; } | ||
|
|
||
| Serial.println("End wakeup SDS011"); | ||
| Serial.println("End wakeup SDS011"); | ||
| } | ||
|
|
||
| void stop_SDS() { | ||
| Serial.println("Start sleep SDS011"); | ||
| Serial.println("Start sleep SDS011"); | ||
|
|
||
| if (sds011.set_sleep(true)) { is_SDS_running = false; } | ||
| if (sds011.set_sleep(true)) { is_SDS_running = false; } | ||
|
|
||
| Serial.println("End sleep SDS011"); | ||
| Serial.println("End sleep SDS011"); | ||
| } | ||
|
|
||
| // The setup() function runs once each time the micro-controller starts | ||
| void setup() | ||
| { | ||
| Serial.begin(115200); | ||
| Serial.begin(115200); | ||
|
|
||
| #ifdef ESP32 | ||
| serialSDS.begin(9600, SERIAL_8N1); | ||
| delay(100); | ||
| serialSDS.begin(9600, SERIAL_8N1, SDS_PIN_RX, SDS_PIN_TX); | ||
| delay(100); | ||
| #else | ||
| serialSDS.begin(9600, SDS_PIN_RX, SDS_PIN_TX, SWSERIAL_8N1, false, 192); | ||
| serialSDS.begin(9600, SDS_PIN_RX, SDS_PIN_TX, SWSERIAL_8N1, false, 192); | ||
| #endif | ||
|
|
||
| Serial.println("SDS011 start/stop and reporting sample"); | ||
|
|
||
| Sds011::Report_mode report_mode; | ||
| if (!sds011.get_data_reporting_mode(report_mode)) { | ||
| Serial.println("Sds011::get_data_reporting_mode() failed"); | ||
| } | ||
| if (Sds011::REPORT_ACTIVE != report_mode) { | ||
| Serial.println("Turning on Sds011::REPORT_ACTIVE reporting mode"); | ||
| if (!sds011.set_data_reporting_mode(Sds011::REPORT_ACTIVE)) { | ||
| Serial.println("Sds011::set_data_reporting_mode(Sds011::REPORT_ACTIVE) failed"); | ||
| } | ||
| } | ||
| Serial.println("SDS011 start/stop and reporting sample"); | ||
|
|
||
| Sds011::Report_mode report_mode; | ||
| if (!sds011.get_data_reporting_mode(report_mode)) { | ||
| Serial.println("Sds011::get_data_reporting_mode() failed"); | ||
| } | ||
| if (Sds011::REPORT_ACTIVE != report_mode) { | ||
| Serial.println("Turning on Sds011::REPORT_ACTIVE reporting mode"); | ||
| if (!sds011.set_data_reporting_mode(Sds011::REPORT_ACTIVE)) { | ||
| Serial.println("Sds011::set_data_reporting_mode(Sds011::REPORT_ACTIVE) failed"); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| // Add the main program code into the continuous loop() function | ||
| void loop() | ||
| { | ||
| // Per manufacturer specification, place the sensor in standby to prolong service life. | ||
| // At an user-determined interval (here 30s down plus 30s duty = 1m), run the sensor for 30s. | ||
| // Quick response time is given as 10s by the manufacturer, thus omit the measurements | ||
| // obtained during the first 10s of each run. | ||
|
|
||
| constexpr uint32_t down_s = 10; | ||
|
|
||
| stop_SDS(); | ||
| Serial.print("stopped SDS011 (is running = "); | ||
| Serial.print(is_SDS_running); | ||
| Serial.println(")"); | ||
|
|
||
| uint32_t deadline = millis() + down_s * 1000; | ||
| while (static_cast<int32_t>(deadline - millis()) > 0) { | ||
| delay(1000); | ||
| Serial.println(static_cast<int32_t>(deadline - millis()) / 1000); | ||
| sds011.perform_work(); | ||
| } | ||
|
|
||
| constexpr uint32_t duty_s = 30; | ||
|
|
||
| start_SDS(); | ||
| Serial.print("started SDS011 (is running = "); | ||
| Serial.print(is_SDS_running); | ||
| Serial.println(")"); | ||
|
|
||
| sds011.on_query_data_auto_completed([](int n) { | ||
| Serial.println("Begin Handling SDS011 query data"); | ||
| int pm25; | ||
| int pm10; | ||
| Serial.print("n = "); Serial.println(n); | ||
| if (sds011.filter_data(n, pm25_table, pm10_table, pm25, pm10) && | ||
| !isnan(pm10) && !isnan(pm25)) { | ||
| Serial.print("PM10: "); | ||
| Serial.println(float(pm10) / 10); | ||
| Serial.print("PM2.5: "); | ||
| Serial.println(float(pm25) / 10); | ||
| } | ||
| Serial.println("End Handling SDS011 query data"); | ||
| }); | ||
|
|
||
| if (!sds011.query_data_auto_async(pm_tablesize, pm25_table, pm10_table)) { | ||
| Serial.println("measurement capture start failed"); | ||
| } | ||
|
|
||
| deadline = millis() + duty_s * 1000; | ||
| while (static_cast<int32_t>(deadline - millis()) > 0) { | ||
| delay(1000); | ||
| Serial.println(static_cast<int32_t>(deadline - millis()) / 1000); | ||
| sds011.perform_work(); | ||
| } | ||
| // Per manufacturer specification, place the sensor in standby to prolong service life. | ||
| // At an user-determined interval (here 30s down plus 30s duty = 1m), run the sensor for 30s. | ||
| // Quick response time is given as 10s by the manufacturer, thus omit the measurements | ||
| // obtained during the first 10s of each run. | ||
|
|
||
| constexpr uint32_t down_s = 10; | ||
|
|
||
| stop_SDS(); | ||
| Serial.print("stopped SDS011 (is running = "); | ||
| Serial.print(is_SDS_running); | ||
| Serial.println(")"); | ||
|
|
||
| uint32_t deadline = millis() + down_s * 1000; | ||
| while (static_cast<int32_t>(deadline - millis()) > 0) { | ||
| delay(1000); | ||
| Serial.println(static_cast<int32_t>(deadline - millis()) / 1000); | ||
| sds011.perform_work(); | ||
| } | ||
|
|
||
| constexpr uint32_t duty_s = 30; | ||
|
|
||
| start_SDS(); | ||
| Serial.print("started SDS011 (is running = "); | ||
| Serial.print(is_SDS_running); | ||
| Serial.println(")"); | ||
|
|
||
| sds011.on_query_data_auto_completed([](int n) { | ||
| Serial.println("Begin Handling SDS011 query data"); | ||
| int pm25; | ||
| int pm10; | ||
| Serial.print("n = "); Serial.println(n); | ||
| if (sds011.filter_data(n, pm25_table, pm10_table, pm25, pm10) && | ||
| !isnan(pm10) && !isnan(pm25)) { | ||
| Serial.print("PM10: "); | ||
| Serial.println(float(pm10) / 10); | ||
| Serial.print("PM2.5: "); | ||
| Serial.println(float(pm25) / 10); | ||
| } | ||
| Serial.println("End Handling SDS011 query data"); | ||
| }); | ||
|
|
||
| if (!sds011.query_data_auto_async(pm_tablesize, pm25_table, pm10_table)) { | ||
| Serial.println("measurement capture start failed"); | ||
| } | ||
|
|
||
| deadline = millis() + duty_s * 1000; | ||
| while (static_cast<int32_t>(deadline - millis()) > 0) { | ||
| delay(1000); | ||
| Serial.println(static_cast<int32_t>(deadline - millis()) / 1000); | ||
| sds011.perform_work(); | ||
| } | ||
| } | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,93 +1,95 @@ | ||
| /* | ||
| Name: startstop.ino | ||
| Created: 2019-04-03 7:06:46 | ||
| Author: Dirk O. Kaar <[email protected]> | ||
| Name: startstop.ino | ||
| Created: 2019-04-03 7:06:46 | ||
| Author: Dirk O. Kaar <[email protected]> | ||
| */ | ||
|
|
||
| #ifndef ESP32 | ||
| #include <SoftwareSerial.h> | ||
| #endif | ||
| #include <Sds011.h> | ||
|
|
||
| #define SDS_PIN_RX D4 | ||
| #define SDS_PIN_TX D3 | ||
| #define SDS_PIN_RX D7 | ||
| #define SDS_PIN_TX D8 | ||
|
|
||
| #ifdef ESP32 | ||
| HardwareSerial& serialSDS(Serial2); | ||
| Sds011Async< HardwareSerial > sds011(serialSDS); | ||
| #else | ||
| SoftwareSerial serialSDS; | ||
| Sds011Async< SoftwareSerial > sds011(serialSDS); | ||
| #endif | ||
| Sds011 sds011(serialSDS); | ||
|
|
||
| bool is_SDS_running = true; | ||
|
|
||
| void start_SDS() { | ||
| Serial.println("Start wakeup SDS011"); | ||
| Serial.println("Start wakeup SDS011"); | ||
|
|
||
| if (sds011.set_sleep(false)) { is_SDS_running = true; } | ||
| if (sds011.set_sleep(false)) { is_SDS_running = true; } | ||
|
|
||
| Serial.println("End wakeup SDS011"); | ||
| Serial.println("End wakeup SDS011"); | ||
| } | ||
|
|
||
| void stop_SDS() { | ||
| Serial.println("Start sleep SDS011"); | ||
| Serial.println("Start sleep SDS011"); | ||
|
|
||
| if (sds011.set_sleep(true)) { is_SDS_running = false; } | ||
| if (sds011.set_sleep(true)) { is_SDS_running = false; } | ||
|
|
||
| Serial.println("End sleep SDS011"); | ||
| Serial.println("End sleep SDS011"); | ||
| } | ||
|
|
||
| // The setup() function runs once each time the micro-controller starts | ||
| void setup() | ||
| { | ||
| Serial.begin(115200); | ||
| Serial.begin(115200); | ||
|
|
||
| #ifdef ESP32 | ||
| serialSDS.begin(9600, SERIAL_8N1); | ||
| delay(100); | ||
| serialSDS.begin(9600, SERIAL_8N1, SDS_PIN_RX, SDS_PIN_TX); | ||
| delay(100); | ||
| #else | ||
| serialSDS.begin(9600, SDS_PIN_RX, SDS_PIN_TX, SWSERIAL_8N1, false, 192); | ||
| serialSDS.begin(9600, SDS_PIN_RX, SDS_PIN_TX, SWSERIAL_8N1, false, 192); | ||
| #endif | ||
|
|
||
| Serial.println("SDS011 start/stop and reporting sample"); | ||
|
|
||
| start_SDS(); | ||
| Serial.print("SDS011 is running = "); | ||
| Serial.println(is_SDS_running); | ||
|
|
||
| String firmware_version; | ||
| uint16_t device_id; | ||
| if (!sds011.device_info(firmware_version, device_id)) { | ||
| Serial.println("Sds011::firmware_version() failed"); | ||
| } | ||
| else | ||
| { | ||
| Serial.print("Sds011 firmware version: "); | ||
| Serial.println(firmware_version); | ||
| Serial.print("Sds011 device id: "); | ||
| Serial.println(device_id); | ||
| } | ||
|
|
||
| Sds011::Report_mode report_mode; | ||
| if (!sds011.get_data_reporting_mode(report_mode)) { | ||
| Serial.println("Sds011::get_data_reporting_mode() failed"); | ||
| } | ||
| if (Sds011::REPORT_ACTIVE != report_mode) { | ||
| Serial.println("Turning on Sds011::REPORT_ACTIVE reporting mode"); | ||
| if (!sds011.set_data_reporting_mode(Sds011::REPORT_ACTIVE)) { | ||
| Serial.println("Sds011::set_data_reporting_mode(Sds011::REPORT_ACTIVE) failed"); | ||
| } | ||
| } | ||
| Serial.println("SDS011 start/stop and reporting sample"); | ||
|
|
||
| start_SDS(); | ||
| Serial.print("SDS011 is running = "); | ||
| Serial.println(is_SDS_running); | ||
|
|
||
| String firmware_version; | ||
| uint16_t device_id; | ||
| if (!sds011.device_info(firmware_version, device_id)) { | ||
| Serial.println("Sds011::firmware_version() failed"); | ||
| } | ||
| else | ||
| { | ||
| Serial.print("Sds011 firmware version: "); | ||
| Serial.println(firmware_version); | ||
| Serial.print("Sds011 device id: "); | ||
| Serial.println(device_id); | ||
| } | ||
|
|
||
| Sds011::Report_mode report_mode; | ||
| if (!sds011.get_data_reporting_mode(report_mode)) { | ||
| Serial.println("Sds011::get_data_reporting_mode() failed"); | ||
| } | ||
| if (Sds011::REPORT_ACTIVE != report_mode) { | ||
| Serial.println("Turning on Sds011::REPORT_ACTIVE reporting mode"); | ||
| if (!sds011.set_data_reporting_mode(Sds011::REPORT_ACTIVE)) { | ||
| Serial.println("Sds011::set_data_reporting_mode(Sds011::REPORT_ACTIVE) failed"); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| // Add the main program code into the continuous loop() function | ||
| void loop() | ||
| { | ||
| stop_SDS(); | ||
| Serial.print("SDS011 is stopped = "); | ||
| Serial.println(!is_SDS_running); | ||
| delay(10000); | ||
| start_SDS(); | ||
| Serial.print("SDS011 is running = "); | ||
| Serial.println(is_SDS_running); | ||
| delay(10000); | ||
| stop_SDS(); | ||
| Serial.print("SDS011 is stopped = "); | ||
| Serial.println(!is_SDS_running); | ||
| delay(10000); | ||
| start_SDS(); | ||
| Serial.print("SDS011 is running = "); | ||
| Serial.println(is_SDS_running); | ||
| delay(10000); | ||
| } |