โปรเจคเครื่องมือตรวจวัด PM2.5 ด้วย ESPino32 และ PMS5003ST

char col;
unsigned int PMSa = 0, FMHDSa = 0, TPSa = 0, HDSa = 0, PMSb = 0, FMHDSb = 0, TPSb = 0, HDSb = 0;
unsigned int PMS = 0, FMHDS = 0, TPS = 0, HDS = 0, CR1 = 0, CR2 = 0;
unsigned char buffer_RTT[40] = {}; //Serial buffer; Received Data
char DataStr[15];
String temp, Humi;

void Read_PMS_DATA() {
  while (!Serial2.available());
  while (Serial2.available() > 0) //Data check: weather there is any Data in Serial2
  {
    for (int i = 0; i < 40; i++)
    {
      col = Serial2.read();
      buffer_RTT[i] = (char)col;
      delay(2);
    }
    Serial2.flush();
    
    CR1 = (buffer_RTT[38] << 8) + buffer_RTT[39];
    CR2 = 0;
    for (int i = 0; i < 38; i++)
      CR2 += buffer_RTT[i];
    if (CR1 == CR2)               //Check
    {
      PMSa = buffer_RTT[12];       //Read PM2.5 High 8-bit
      PMSb = buffer_RTT[13];       //Read PM2.5 Low 8-bit
      PMS = (PMSa << 8) + PMSb;    //PM2.5 value
      FMHDSa = buffer_RTT[28];       //Read Formaldehyde High 8-bit
      FMHDSb = buffer_RTT[29];       //Read Formaldehyde Low 8-bit
      FMHDS = (FMHDSa << 8) + FMHDSb; //Formaldehyde value
      TPSa = buffer_RTT[30];        //Read Temperature High 8-bit
      TPSb = buffer_RTT[31];        //Read Temperature Low 8-bit
      TPS = (TPSa << 8) + TPSb;  //Temperature value
      HDSa = buffer_RTT[32];        //Read Humidity High 8-bit
      HDSb = buffer_RTT[33];        //Read Humidity Low 8-bit
      HDS = (HDSa << 8) + HDSb; //Humidity value
    }/*
    else
    {
      PMS = 0;
      FMHDS = 0;
      TPS = 0;
      HDS = 0;
    }*/
    sprintf(DataStr, "%d%d.%d", TPS / 100, (TPS / 10) % 10, TPS % 10);
    temp = DataStr;
    sprintf(DataStr, "%d%d.%d", HDS / 100, (HDS / 10) % 10, HDS % 10);
    Humi = DataStr;
  }
}

void PRINT_PMS_DATA() {
  Serial.println("-----------------------PMS5003ST--------------------------");
  Serial.print("Temp : ");
  Serial.print(temp);
  Serial.println("C");               //Serial pring Temperature
  Serial.print("RH   : ");
  Serial.print(Humi);            //Serial print humidity
  Serial.println(" %");               //"%"
  Serial.print("HCHO : ");
  Serial.print(FMHDS);
  Serial.println(" ug/m3");        // Serial print formaldehyde, unit: ug/m³
  Serial.print("PM2.5: ");
  Serial.print(PMS);
  Serial.println(" ug/m3");       // Serial print PM2.5, unit: ug/m³
  Serial.println();
}

void setup()
{
  Serial.begin(115200);
  Serial2.begin(9600);
}


void loop()
{
  Read_PMS_DATA();
  PRINT_PMS_DATA();
}

// ทำการเพิ่ม Library ที่เกี่ยวข้อง
#include <Wire.h>
#include "SSD1306Wire.h"
#include "OLEDDisplayUi.h"

//ตั้งค่าสำหรับจอ OLED
SSD1306Wire  display(0x3c, SDA, SCL);
OLEDDisplayUi ui     ( &display );

//ตั้งค่ารอบเวลาอ่านของเซ็นเซอร์ทุกๆ 10 วินาที หรือ 10000 ms
unsigned long previousMillis = 0;
const long interval = 10000; 

//ประกาศตัวแปลที่จำเป็นในการอ่านค่าเซ็นเซอร์
char col;
unsigned int PMSa = 0, FMHDSa = 0, TPSa = 0, HDSa = 0, PMSb = 0, FMHDSb = 0, TPSb = 0, HDSb = 0;
unsigned int PMS = 0, FMHDS = 0, TPS = 0, HDS = 0, CR1 = 0, CR2 = 0;
unsigned char buffer_RTT[40] = {}; //Serial buffer; Received Data
char DataStr[15];
String temp, Humi;

//ฟังก์ชันสำหรับอ่านค่าจะเซ็นเซอร์ PMS5003ST 
void Read_PMS_DATA() {
  while (!Serial2.available());
  while (Serial2.available() > 0) //Data check: weather there is any Data in Serial1
  {
    for (int i = 0; i < 40; i++)
    {
      col = Serial2.read();
      buffer_RTT[i] = (char)col;
      delay(2);
    }
    Serial2.flush();

    CR1 = (buffer_RTT[38] << 8) + buffer_RTT[39];
    CR2 = 0;
    for (int i = 0; i < 38; i++)
      CR2 += buffer_RTT[i];
    if (CR1 == CR2)               //Check
    {
      PMSa = buffer_RTT[12];       //Read PM2.5 High 8-bit
      PMSb = buffer_RTT[13];       //Read PM2.5 Low 8-bit
      PMS = (PMSa << 8) + PMSb;    //PM2.5 value
      FMHDSa = buffer_RTT[28];       //Read Formaldehyde High 8-bit
      FMHDSb = buffer_RTT[29];       //Read Formaldehyde Low 8-bit
      FMHDS = (FMHDSa << 8) + FMHDSb; //Formaldehyde value
      TPSa = buffer_RTT[30];        //Read Temperature High 8-bit
      TPSb = buffer_RTT[31];        //Read Temperature Low 8-bit
      TPS = (TPSa << 8) + TPSb;  //Temperature value
      HDSa = buffer_RTT[32];        //Read Humidity High 8-bit
      HDSb = buffer_RTT[33];        //Read Humidity Low 8-bit
      HDS = (HDSa << 8) + HDSb; //Humidity value
    }/*
    else
    {
      PMS = 0;
      FMHDS = 0;
      TPS = 0;
      HDS = 0;
    }*/
    sprintf(DataStr, "%d%d.%d", TPS / 100, (TPS / 10) % 10, TPS % 10);
    temp = DataStr;
    sprintf(DataStr, "%d%d.%d", HDS / 100, (HDS / 10) % 10, HDS % 10);
    Humi = DataStr;
  }
}

//ฟังก์ชันสำหรับแสดงค่าเซ็นเซอร์ PMS5003ST บน Serial monitor
void PRINT_PMS_DATA() {
  Serial.println("-----------------------PMS5003ST--------------------------");
  Serial.print("Temp : ");
  Serial.print(temp);
  Serial.println("C");               //Serial pring Temperature
  Serial.print("RH   : ");
  Serial.print(Humi);            //Serial print humidity
  Serial.println(" %");               //"%"
  Serial.print("HCHO : ");
  Serial.print(FMHDS);
  Serial.println(" ug/m3");        // Serial print formaldehyde, unit: ug/m³
  Serial.print("PM2.5: ");
  Serial.print(PMS);
  Serial.println(" ug/m3");       // Serial print PM2.5, unit: ug/m³
  Serial.println();
}

//ฟังก์ชันสำหรับออกแบบหน้าจอ โดยจะแบ่งเป็น 4 เฟรม ในแต่ละเฟรมจะแสดงค่าต่างๆที่อ่านมาจากเซ็นเซอร์
void drawFramePM2_5(OLEDDisplay *display, OLEDDisplayUiState* state, int16_t x, int16_t y) {
  display->setTextAlignment(TEXT_ALIGN_CENTER);
  display->setFont(ArialMT_Plain_16);
  display->drawString(64 + x, 0 + y, "PM 2.5");

  display->setFont(ArialMT_Plain_24);
  display->drawString(64 + x, 19 + y, String(PMS));

  display->setFont(ArialMT_Plain_10);
  display->drawString(64 + x, 45 + y, "ug/m3");
}

void drawFrameTemp(OLEDDisplay *display, OLEDDisplayUiState* state, int16_t x, int16_t y) {
  display->setTextAlignment(TEXT_ALIGN_CENTER);
  display->setFont(ArialMT_Plain_16);
  display->drawString(64 + x, 0 + y, "TEMPERATURE");

  display->setFont(ArialMT_Plain_24);
  display->drawString(64 + x, 19 + y, String(temp));

  display->setFont(ArialMT_Plain_10);
  display->drawString(64 + x, 45 + y, "°C");
}

void drawFrameHumi(OLEDDisplay *display, OLEDDisplayUiState* state, int16_t x, int16_t y) {
  display->setTextAlignment(TEXT_ALIGN_CENTER);
  display->setFont(ArialMT_Plain_16);
  display->drawString(64 + x, 0 + y, "HUMIDITY");

  display->setFont(ArialMT_Plain_24);
  display->drawString(64 + x, 19 + y, String(Humi));

  display->setFont(ArialMT_Plain_10);
  display->drawString(64 + x, 45 + y, "%");
}

void drawFrameFormal(OLEDDisplay *display, OLEDDisplayUiState* state, int16_t x, int16_t y) {
  display->setTextAlignment(TEXT_ALIGN_CENTER);
  display->setFont(ArialMT_Plain_16);
  display->drawString(64 + x, 0 + y, "Formaldehyde");

  display->setFont(ArialMT_Plain_24);
  display->drawString(64 + x, 19 + y, String(FMHDS));

  display->setFont(ArialMT_Plain_10);
  display->drawString(64 + x, 45 + y, "ug/m3");
}

FrameCallback frames[] = { drawFramePM2_5, drawFrameTemp, drawFrameHumi, drawFrameFormal};
int frameCount = 4;

//เริ่มใช้งานฟังก์ชันและประกาศตั้งค่าเริ่มต้นการทำงานของฟังก์ชันจอแสดงผล
void setup() {
  Serial.begin(115200);
  Serial2.begin(9600);
  Read_PMS_DATA();
  PRINT_PMS_DATA();
  ui.setTargetFPS(60);
  ui.setIndicatorPosition(BOTTOM);
  ui.setIndicatorDirection(LEFT_RIGHT);
  ui.setFrameAnimation(SLIDE_LEFT);
  ui.setFrames(frames, frameCount);
  ui.init();
  display.flipScreenVertically();
}

//การทำงานในลูป จะทำงานฟังก์ชันอ่านค่าจากเซ็นเซอร์ทุกๆ 10 วินาทีและแสดงผลบนหน้าจอ จะทำงานวนไปเรื่อยๆ
void loop() {
  ui.update();
  unsigned long currentMillis = millis();
  if (currentMillis - previousMillis >= interval) {
    previousMillis = currentMillis;
    Read_PMS_DATA();
    PRINT_PMS_DATA();
  }
}