attnode/v3_firmware
2
0
Fork 0
Code Issues Pull requests Releases Activity

Compare commits

base: attnode:master
Branches Tags
attnode:master
attnode:sps30
attnode:arduinoide
..
compare: attnode:sps30
Branches Tags
attnode:master
attnode:sps30
attnode:arduinoide

No commits in common. "master" and "sps30" have entirely different histories.
master ... sps30

6 changed files with 98 additions and 144 deletions
Show stats Expand all files Collapse all files

3
.vscode/extensions.json vendored
View file

@ -3,8 +3,5 @@
// for the documentation about the extensions.json format
"recommendations": [
"platformio.platformio-ide"
],
"unwantedRecommendations": [
"ms-vscode.cpptools-extension-pack"
]
}

2
include/debug.h
View file

@ -8,11 +8,9 @@ DebugUtils.h - Simple debugging utilities.
#ifdef DEBUG
#define DEBUG_PRINT(...) Serial.print(__VA_ARGS__); Serial.flush();
#define DEBUG_PRINTLN(...) Serial.println(__VA_ARGS__); Serial.flush();
#define DEBUG_PRINTARR(...) for (uint8_t i=0; i<(sizeof(__VA_ARGS__)/sizeof(__VA_ARGS__[0])); i++) { Serial.print(__VA_ARGS__[i], HEX); Serial.print(" ");}; Serial.flush();
#else
#define DEBUG_PRINT(...)
#define DEBUG_PRINTLN(...)
#define DEBUG_PRINTARR(...)
#endif
#endif

61
lib/HM330x/HM330x.cpp
View file

@ -46,11 +46,8 @@ void HM330x::initialize(void) {
}
// Wait for Sensor to get Ready
if (sleep_pin == 0) {
DEBUG_PRINTLN("HM330x::initialize Waiting for Sensor Startup");
delay(30000);
}
DEBUG_PRINTLN("HM330x::initialize Waiting for Sensor Startup");
delay(30000);
DEBUG_PRINTLN("HM330x::initialize Trying to send Select");
// Send select command
@ -68,58 +65,46 @@ void HM330x::initialize(void) {
// Read Data From Sensor and Put Them Into the Payload Array
uint8_t HM330x::getSensorData(char *payload, uint8_t startbyte) {
uint8_t data[HM330x_DATA_LEN] = {0};
uint16_t values[3] = { 0xEEEE, 0xEEEE, 0xEEEE };
uint16_t value = 0;
DEBUG_PRINTLN("HM330x::getSensorData");
// Enable Sensor and Wait for it to Settle
if (sleep_pin > 0) {
digitalWrite(sleep_pin, HIGH);
DEBUG_PRINTLN("HM330x::getSensorData Waiting for Stable Values after Sleep");
delay(30000);
sendCmd(HM330x_SELECT);
}
// Initialize Payload with 0s
for (uint8_t i=startbyte; i < startbyte+6; i++)
payload[i] = 0xFF;
bool dataok = false;
uint8_t tries = 5;
// Get Data from the Sensors
Wire.requestFrom(HM330x_ADDR, HM330x_DATA_LEN);
if (Wire.available()) {
DEBUG_PRINT("HM330x::getSensorData reading I2C:")
for (uint8_t i = 0; i<HM330x_DATA_LEN; i++){
data[i] = Wire.read();
DEBUG_PRINT(" 0x");
DEBUG_PRINT(data[i], HEX);
}
DEBUG_PRINTLN("");
while (!dataok && tries > 0) {
DEBUG_PRINT("HM330x::getSensorData reading I2C Try ");
DEBUG_PRINTLN(6-tries);
// Get Data from the Sensors
Wire.requestFrom(HM330x_ADDR, HM330x_DATA_LEN);
if (Wire.available()) {
DEBUG_PRINT("HM330x::getSensorData I2C data: 0x")
for (uint8_t i = 0; i<HM330x_DATA_LEN; i++){
data[i] = Wire.read();
DEBUG_PRINT(data[i], HEX);
DEBUG_PRINT(" ");
if (calcSum(data) == data[HM330x_DATA_LEN-1]) {
for (uint8_t pos = 5; pos<8; pos++) {
value = bytesToUint16(data, pos);
uint16ToPayload(value, payload, startbyte);
startbyte += 2;
}
DEBUG_PRINTLN("");
if (calcSum(data) == data[HM330x_DATA_LEN-1]) {
for (uint8_t pos = 5; pos<8; pos++) {
values[pos-5]= bytesToUint16(data, pos);
}
dataok = true;
} else {
DEBUG_PRINTLN("HM330x::getSensorData Checksum Error")
delay(2000);
tries--;
if (sleep_pin > 0) {
digitalWrite(sleep_pin, LOW);
}
return startbyte;
} else {
DEBUG_PRINTLN("HM330x::getSensorData I2C Not Ready")
delay(2000);
tries--;
for (uint8_t i=startbyte; i < startbyte+6; i++)
payload[i] = 0xEE;
}
}
uint16ToPayload(values[0], payload, startbyte);
uint16ToPayload(values[1], payload, startbyte+2);
uint16ToPayload(values[2], payload, startbyte+4);
if (sleep_pin > 0) {
digitalWrite(sleep_pin, LOW);
}

125
lib/SPS30/SPS30.cpp
View file

@ -27,90 +27,69 @@
#include <Arduino.h>
#include "SPS30.h"
// Read Measurements from Sensor and put them into the Paylaod
uint8_t SPS30::getSensorData(char *payload, uint8_t startbyte) {
// Buffer to hold the raw I2C Return
uint8_t data[30];
// Array with calculated Values.
// Predefined with 0xEEEE to recognize Read Errors in the Payload
uint16_t values[5] = {0xEEEE, 0xEEEE, 0xEEEE, 0xEEEE, 0xEEEE};
SPS30::SPS30() {
}
// Wakeup Sensor from Sleep
DEBUG_PRINTLN("SPS30::getSensorData - Wake Up Sensor");
Wire.beginTransmission(SPS30_I2C_ADDRESS);
Wire.endTransmission();
delay(50);
write(SPS30_WAKEUP);
delay(50);
uint8_t SPS30::getSensorData(char *payload, uint8_t startbyte) {
uint8_t data[30];
for (uint8_t i = 0; i < 30; i++)
data[i] = 0xFF;
uint16_t massPM1, massPM25, massPM4, massPM10, typPM;
// Start Measuring, Integer Output
DEBUG_PRINTLN("SPS30::getSensorData - StartMeasurement");
write(SPS30_START_MEASUREMENT, 0x0500);
// Wait for Stable Values
DEBUG_PRINTLN("SPS30::getSensorData - WaitForStabilize");
delay(SPS30_STABILIZE_TIME);
// Wait for Stable Values (max 30s according to datasheet)
delay(30000);
bool dataok = false;
uint8_t tries = 5;
if (hasData()) {
write(SPS30_READ_MEASUREMENT);
Wire.requestFrom(SPS30_I2C_ADDRESS, 30);
if (Wire.available() != 0) {
for (uint8_t i = 0; i < 30; i++)
data[i] = 0xFE;
// Retry up to 5 times to get a Valid Measurement from the Sensor
while (!dataok && tries > 0) {
DEBUG_PRINT("SPS30::getSensorData - Reading Sensor Data, Try ");
DEBUG_PRINTLN(6-tries);
if (hasData()) {
write(SPS30_READ_MEASUREMENT);
Wire.requestFrom(SPS30_I2C_ADDRESS, 30);
if (Wire.available() != 0) {
Wire.readBytes(data, 30);
Wire.readBytes(data, 30);
DEBUG_PRINT("SPS30::getSensorData - I2C-Data: ");
DEBUG_PRINTARR(data);
DEBUG_PRINTLN("");
// Get Values for PM1.0, 2.5, 4 and 10 in Order
dataok = true;
for (uint8_t i=0; i<4; i++)
if (data[(i*3)+2] == calcCRC(data+(i*3), 2)) {
values[i] = data[i*3] << 8 | data[(i*3)+1]; // Create uint16_t from Bytes
} else {
dataok = false; // Set false on Checksum Error
}
// Get Typical Particle size
if (data[29] == calcCRC(data+27, 2)) {
values[4] = data[27] << 8 | data[28]; // Create uint16_t from Bytes
} else {
dataok = false; // Set false on Checksum Error
}
if (!dataok) {
// If a Checksum error occured
DEBUG_PRINTLN("SPS30::getSensorData - CheckSum Error");
tries--;
delay(2000);
}
} else {
// No I2C Data Available
DEBUG_PRINTLN("SPS30::getSensorData - Error, no I2C Data available");
tries--;
delay(2000);
// DEBUG OUTPUT
DEBUG_PRINT("SPS30 I2C DATA: ")
for (uint8_t i = 0; i < 30; i++) {
DEBUG_PRINT("0x");
DEBUG_PRINT (data[i]);
DEBUG_PRINT(", ");
}
} else {
// No Data Ready from Sensor
DEBUG_PRINTLN("SPS30::getSensorData - Error, Sensor Data not Ready");
tries--;
delay(2000);
DEBUG_PRINTLN("");
// PM1.0
if (data[2] == calcCRC(data, 2))
massPM1 = data[0] << 8 | data[1];
// PM2.5
if (data[5] == calcCRC(data+3, 2))
massPM25 = data[3] << 8 | data[4];
// PM4
if (data[8] == calcCRC(data+6, 2))
massPM4 = data[6] << 8 | data[7];
// PM10
if (data[11] == calcCRC(data+9, 2))
massPM10 = data[9] << 8 | data[10];
// Typical Size
if (data[29] == calcCRC(data+27, 2))
typPM = data[27] << 8 | data[28];
}
}
DEBUG_PRINTLN("SPS30::getSensorData - StopMeasurement");
write(SPS30_STOP_MEASUREMENT);
delay(50);
DEBUG_PRINTLN("SPS30::getSensorData - SensorSleep");
write(SPS30_SLEEP);
// Put the Values into the Payload Array
for (uint8_t i=0; i<5; i++)
uint16ToPayload(values[i], payload, startbyte+(i*2));
uint16ToPayload(massPM1, payload, startbyte);
uint16ToPayload(massPM25, payload, startbyte+2);
uint16ToPayload(massPM4, payload, startbyte+4);
uint16ToPayload(massPM10, payload, startbyte+6);
uint16ToPayload(typPM, payload, startbyte+8);
}
// Check if Sensor has Data
@ -135,7 +114,6 @@ uint16_t SPS30::readReg(uint16_t regAddr) {
return(0);
}
// Write a 16 Bit Command without Parameters
bool SPS30::write(uint16_t cmd) {
Wire.beginTransmission(SPS30_I2C_ADDRESS);
Wire.write(cmd >> 8);
@ -145,7 +123,6 @@ bool SPS30::write(uint16_t cmd) {
return(true);
}
// Write a 16Bit Command with 16Bit Parameters
bool SPS30::write(uint16_t cmd, uint16_t arg){
uint8_t crcdata[2];
crcdata[0] = arg >> 8;

31
lib/SPS30/SPS30.h
View file

@ -32,21 +32,18 @@
#include "../../include/debug.h"
// I2C Address
#define SPS30_I2C_ADDRESS 0x69
#define SPS30_STABILIZE_TIME 30000
#define SPS30_I2C_ADDRESS 0x69
// I2C Commands and Registers
#define SPS30_START_MEASUREMENT 0x0010
#define SPS30_STOP_MEASUREMENT 0x0104
#define SPS30_GET_DATA_READY 0x0202
#define SPS30_READ_MEASUREMENT 0x0300
#define SPS30_START_MEASUREMENT 0x0010
#define SPS30_STOP_MEASUREMENT 0x0104
#define SPS30_GET_DATA_READY 0x0202
#define SPS30_READ_MEASUREMENT 0x0300
#define SPS30_AUTO_CLEAN_INTERVAL 0x8004
#define SPS30_START_FAN_CLEANING 0x5607
#define SPS30_READ_ARTICLE_CODE 0xD025
#define SPS30_READ_SERIAL_NUMBER 0xD033
#define SPS30_DEVICE_RESET 0xD304
#define SPS30_SLEEP 0x1001
#define SPS30_WAKEUP 0x1103
#define SPS30_START_FAN_CLEANING 0x5607
#define SPS30_READ_ARTICLE_CODE 0xD025
#define SPS30_READ_SERIAL_NUMBER 0xD033
#define SPS30_DEVICE_RESET 0xD304
class SPS30 : public AttSensor {
private:
@ -57,11 +54,11 @@ class SPS30 : public AttSensor {
bool write(uint16_t cmd, uint16_t arg);
public:
SPS30() {};
uint8_t getSensorData(char *payload, uint8_t startbyte) override;
void calibrate(void) override {};
void initialize(void) override {} ;
uint8_t numBytes(void) override { return 10; };
SPS30();
uint8_t getSensorData(char *payload, uint8_t startbyte);
void calibrate(void) {};
void initialize(void) {};
uint8_t numBytes(void) { return 10; };
};
#endif

0
src/config.example.h → src/config.h.example
View file