Looking to obtain and print additional data fields from the Plantower PMS5003. The current code below reads only the Start Character 1, 2, data 1, Data 2 and Data 3 (which are concentration of PM1.0, ug/m3, concentration of PM2.5, ug/m3, and concentration of PM10.0, ug/m3 respectively. Would like to add Data 7 thru 12 as they have listed on the PMS 5003 spec sheet. This is draft but working code so far from another project posting. What coding will be needed to read the other data 7 thru 12. This runs on a WEMOS D1 mini with the TX/RX from the PMS5003 connected to the RX/TX of the mini:
#include <Adafruit_PM25AQI.h>
#include <ESP8266WiFi.h>
#include <Wire.h>
//#include <Adafruit_Sensor.h>
//#include <Adafruit_BME280.h>
//#include "MQ135.h"
#include <Arduino.h>
#define LENG 31 //0x42 + 31 bytes equal to 32 bytes
unsigned char buf[LENG];
// wrong int transmitPB0_3(unsigned char *thebuf);
int PB0_3Value=0; // define PB0.3
int PM01Value=0; //define PM1.0 value of the air detector module
int PM2_5Value=0; //define PM2.5 value of the air detector module
int PM10Value=0; //define PM10 value of the air detector module
float h, t, p, pin, dp;
char temperatureFString[6];
char dpString[6];
char humidityString[6];
char pressureString[7];
char pressureInchString[6];
//Adafruit_BME280 bme; // I2C
String apiKey = "TG1KP70FVF9O8JQJ";
// replace with your routers SSID
const char* ssid = "link5-1";
// replace with your routers password
const char* password = "1234567890";
const char* server = "api.thingspeak.com";
WiFiClient client;
void setup()
{
Serial.begin(9600);
delay(10);
Serial.println();
Serial.print("Connecting to ");
Serial.println(ssid);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
Serial.println("");
Serial.println("WiFi connected");
// Printing the ESP IP address
Serial.println(WiFi.localIP());
// if (!bme.begin())
// {
// Serial.println("Could not find a valid BME280 sensor, check wiring!");
// while (1);
//}
}
void loop()
{
if(Serial.find(0x42)){ //start to read when detect 0x42
Serial.readBytes(buf,LENG);
if(buf[0] == 0x4d){
if(checkValue(buf,LENG)){
// causes errors PB0_3Value=transmitPB0_3(buf);
PM01Value=transmitPM01(buf); //count PM1.0 value of the air detector module
PM2_5Value=transmitPM2_5(buf);//count PM2.5 value of the air detector module
PM10Value=transmitPM10(buf); //count PM10 value of the air detector module
}
}
}
static unsigned long OledTimer=millis();
if (millis() - OledTimer >=1000)
{
OledTimer=millis();
Serial.print("PM1.0: ");
Serial.print(PM01Value);
Serial.println(" ug/m3");
Serial.print("PM2.5: ");
Serial.print(PM2_5Value);
Serial.println(" ug/m3");
Serial.print("PM10 : ");
Serial.print(PM10Value);
Serial.println(" ug/m3");
Serial.println();
// MQ135 gasSensor = MQ135(A0);
// float air_quality = gasSensor.getPPM();
/* Serial.print("Air Quality: ");
Serial.print(air_quality);
Serial.println(" PPM");
Serial.println();
/
// h = bme.readHumidity();
// t = bme.readTemperature();
// t = t1.8+32.0;
// dp = t-0.36*(100.0-h);
// p = bme.readPressure()/100.0F;
pin = 0.02953*p;
// dtostrf(t, 5, 1, temperatureFString);
// dtostrf(h, 5, 1, humidityString);
// dtostrf(p, 6, 1, pressureString);
// dtostrf(pin, 5, 2, pressureInchString);
// dtostrf(dp, 5, 1, dpString);
// Serial.print("Temperature = ");
// Serial.println(temperatureFString);
// Serial.print("Humidity = ");
// Serial.println(humidityString);
// Serial.print("Pressure = ");
// Serial.println(pressureString);
// Serial.print("Pressure Inch = ");
// Serial.println(pressureInchString);
// Serial.print("Dew Point = ");
// Serial.println(dpString);
Serial.println("...............................................");
if (client.connect(server,80)) // "184.106.153.149" or api.thingspeak.com
{
String postStr = apiKey;
postStr +="&field1=";
postStr += String(PM01Value);
postStr +="&field2=";
postStr += String(PM2_5Value);
postStr +="&field3=";
postStr += String(PM10Value);
// postStr +="&field4=";
// postStr += String(air_quality);
// postStr +="&field5=";
// postStr += String(temperatureFString);
// postStr +="&field6=";
// postStr += String(humidityString);
// postStr +="&field7=";
// postStr += String(pressureInchString);
postStr += "\r\n\r\n";
client.print("POST /update HTTP/1.1\n");
client.print("Host: api.thingspeak.com\n");
client.print("Connection: close\n");
client.print("X-THINGSPEAKAPIKEY: "+apiKey+"\n");
client.print("Content-Type: application/x-www-form-urlencoded\n");
client.print("Content-Length: ");
client.print(postStr.length());
client.print("\n\n");
client.print(postStr);
}
client.stop();
}
// delay(1000);
}
char checkValue(unsigned char *thebuf, char leng)
{
char receiveflag=0;
int receiveSum=0;
for(int i=0; i<(leng-2); i++){
receiveSum=receiveSum+thebuf[i];
}
receiveSum=receiveSum + 0x42;
if(receiveSum == ((thebuf[leng-2]<<8)+thebuf[leng-1])) //check the serial data
{
receiveSum = 0;
receiveflag = 1;
}
return receiveflag;
}
int transmitPM01(unsigned char *thebuf)
{
int PM01Val;
PM01Val=((thebuf[3]<<8) + thebuf[4]); //count PM1.0 value of the air detector module
return PM01Val;
}
//transmit PM Value to PC
int transmitPM2_5(unsigned char *thebuf)
{
int PM2_5Val;
PM2_5Val=((thebuf[5]<<8) + thebuf[6]);//count PM2.5 value of the air detector module
return PM2_5Val;
}
//transmit PM Value to PC
int transmitPM10(unsigned char *thebuf)
{
int PM10Val;
PM10Val=((thebuf[7]<<8) + thebuf[8]); //count PM10 value of the air detector module
return PM10Val;
}