整合空氣懸浮粒子感測器測試程式一

/*
 

This example demonstrate how to read pm2.5 value on PMS 3003 air condition sensor
PMS 3003 pin map is as follow:

   PIN1  :VCC, connect to 5V

   PIN2  :GND

   PIN3  :SET, 0:Standby mode, 1:operating mode

   PIN4  :RXD :Serial RX

   PIN5  :TXD :Serial TX

   PIN6  :RESET

   PIN7  :NC

   PIN8  :NC
In this example, we only use Serial to get PM 2.5 value.
The circuit:

* RX is digital pin 0 (connect to TX of PMS 3003)

* TX is digital pin 1 (connect to RX of PMS 3003)
*/

/*

 This example demonstrate how to upload sensor data to MQTT server of LASS.

 It include features:

     (1) Connect to WiFi

     (2) Retrieve NTP time with WiFiUDP

     (3) Get PM 2.5 value from PMS3003 air condition sensor with UART

     (4) Connect to MQTT server and try reconnect when disconnect
 You can find more information at this site:
     https://lass.hackpad.com/LASS-README-DtZ5T6DXLbu
*/
//  http://nrl.iis.sinica.edu.tw/LASS/show.php?device_id=FT1_074B3

#include <math.h> 
#define turnon HIGH

#define turnoff LOW

#define DHTSensorPin 7

#define ParticleSensorLed 9

#define InternetLed 10

#define AccessLed 11
#include “PMType.h"

#include <WiFi.h>

#include <PubSubClient.h>

#include <WiFiUdp.h>

// THIS INLCUDE LIB FOR dhx sensor

#include “DHT.h"

// Uncomment whatever type you’re using!

//#define DHTTYPE DHT11   // DHT 11

#define DHTTYPE DHT22   // DHT 22  (AM2302), AM2321

//#define DHTTYPE DHT21   // DHT 21 (AM2301)
#include <Wire.h>  // Arduino IDE 內建

// LCD I2C Library，從這裡可以下載：

// https://bitbucket.org/fmalpartida/new-liquidcrystal/downloads
#include “RTClib.h"

RTC_DS1307 RTC;

//DateTime nowT = RTC.now(); 
#include <LiquidCrystal_I2C.h>

#include <SoftwareSerial.h>
uint8_t MacData[6];
SoftwareSerial mySerial(0, 1); // RX, TX

char ssid[] = “TSAO";      // your network SSID (name)

char pass[] = “TSAO1234″;     // your network password

int keyIndex = 0;               // your network key Index number (needed only for WEP)
char gps_lat[] = “23.954710″;  // device’s gps latitude 清心福全(中正店) 510彰化縣員林市中正路254號

char gps_lon[] = “120.574482″; // device’s gps longitude 清心福全(中正店) 510彰化縣員林市中正路254號
char server[] = “gpssensor.ddns.net"; // the MQTT server of LASS
#define MAX_CLIENT_ID_LEN 10

#define MAX_TOPIC_LEN     50

char clientId[MAX_CLIENT_ID_LEN];

char outTopic[MAX_TOPIC_LEN];
WiFiClient wifiClient;

PubSubClient client(wifiClient);

IPAddress  Meip ,Megateway ,Mesubnet ;

String MacAddress ;

int status = WL_IDLE_STATUS;

boolean ParticleSensorStatus = true ;

WiFiUDP Udp;
const char ntpServer[] = “pool.ntp.org";

const long timeZoneOffset = 28800L;

const int NTP_PACKET_SIZE = 48; // NTP time stamp is in the first 48 bytes of the message

const byte nptSendPacket[ NTP_PACKET_SIZE] = {

 0xE3, 0x00, 0x06, 0xEC, 0x00, 0x00, 0x00, 0x00,  0x00, 0x00, 0x00, 0x00, 0x31, 0x4E, 0x31, 0x34,

 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,  0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,

 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,  0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00

};

byte ntpRecvBuffer[ NTP_PACKET_SIZE ];
#define LEAP_YEAR(Y)     ( ((1970+Y)>0) && !((1970+Y)%4) && ( ((1970+Y)0) || !((1970+Y)%400) ) )

static  const uint8_t monthDays[]={31,28,31,30,31,30,31,31,30,31,30,31}; // API starts months from 1, this array starts from 0

uint32_t epochSystem = 0; // timestamp of system boot up

#define pmsDataLen 32

uint8_t buf[pmsDataLen];

int idx = 0;

int pm10 = 0;

int pm25 = 0;

int pm100 = 0;

uint16_t PM01Value=0;          //define PM1.0 value of the air detector module

uint16_t PM2_5Value=0;         //define PM2.5 value of the air detector module

uint16_t PM10Value=0;         //define PM10 value of the air detector module

 int NDPyear, NDPmonth, NDPday, NDPhour, NDPminute, NDPsecond;

 unsigned long epoch  ;

LiquidCrystal_I2C lcd(0x27, 2, 1, 0, 4, 5, 6, 7, 3, POSITIVE);  // 設定 LCD I2C 位址

DHT dht(DHTSensorPin, DHTTYPE);

void setup() {

 initPins() ;

 Serial.begin(9600);

  dht.begin();

 mySerial.begin(9600); // PMS 3003 UART has baud rate 9600

 lcd.begin(20, 4);      // 初始化 LCD，一行 20 的字元，共 4 行，預設開啟背光

      lcd.backlight(); // 開啟背光

    //  while(!Serial) ;
 

 MacAddress = GetWifiMac() ;

 ShowMac() ;

   initializeWiFi();

 

 initRTC() ;

 ShowDateTime() ;

 showLed() ;

 ShowInternetStatus() ;

 

 initializeMQTT();

  //  initRTC() ;

    delay(1500);

}
void loop() { // run over and over

   ShowDateTime() ;

 showLed() ;

   retrievePM25Value() ;

   ShowHumidity() ;

  if (!client.connected()) {

   reconnectMQTT();

 }

 client.loop();
 delay(3000); // delay 1 minute for next measurement

 
}
uint8_t checkValue(uint8_t *thebuf, uint8_t leng)

{  

 uint8_t receiveflag=1;

 uint16_t receiveSum=0;

 uint8_t i=0;
 for(i=0;i<leng;i++)

 {

 receiveSum=receiveSum+thebuf[i];

 }

 

 if(receiveSum==((thebuf[leng-2]<<8)+thebuf[leng-1]+thebuf[leng-2]+thebuf[leng-1]))  //check the serial data

     {

       receiveSum=0;

     receiveflag=1;

   //  Serial.print(receiveflag);

     return receiveflag;

     }

}

//transmit PM Value to PC

uint16_t transmitPM01(uint8_t *thebuf)

{
 uint16_t PM01Val;
 PM01Val=((thebuf[4]<<8) + thebuf[5]); //count PM1.0 value of the air detector module

 return PM01Val;

}
//transmit PM Value to PC

uint16_t transmitPM2_5(uint8_t *thebuf)

{

     uint16_t PM2_5Val;

   

       PM2_5Val=((thebuf[6]<<8) + thebuf[7]);//count PM2.5 value of the air detector module

   

     return PM2_5Val;

 }
//transmit PM Value to PC

uint16_t transmitPM10(uint8_t *thebuf)

{

 

     uint16_t PM10Val;

   

       PM10Val=((thebuf[8]<<8) + thebuf[9]); //count PM10 value of the air detector module

     

     return PM10Val;

 }
void ShowMac()

{

    lcd.setCursor(0, 0); // 設定游標位置在第一行行首

    lcd.print(“MAC:");

    lcd.print(MacAddress);
}
void ShowInternetStatus()

{

    lcd.setCursor(0, 1); // 設定游標位置

       if (WiFi.status())

         {

              Meip = WiFi.localIP();

              lcd.print(“@:");

              lcd.print(Meip);

              digitalWrite(InternetLed,turnon) ;

         }

         else

                   {

              lcd.print(“DisConnected:");

             digitalWrite(InternetLed,turnoff) ;

         }
}

void ShowHumidity()

{

   float h = dht.readHumidity();

 // Read temperature as Celsius (the default)

 float t = dht.readTemperature();

 // Read temperature as Fahrenheit (isFahrenheit = true)

 float f = dht.readTemperature(true);

   Serial.print(“Humidity :") ;

   Serial.print(h) ;

   Serial.print(“%  /") ;

   Serial.print(t) ;

   Serial.print(“C  \n") ;

 // Check if any reads failed and exit early (to try again).

 if (isnan(h) || isnan(t) || isnan(f)) {

   Serial.println(“Failed to read from DHT sensor!");

   return;

 }

   lcd.setCursor(11, 3); // 設定游標位置在第一行行首

     lcd.print((int)h);

    lcd.print(“% “);

    lcd.print((int)t);

}
void ShowPM(int pp25, int pp10, int pp100)

{

   lcd.setCursor(0, 3); // 設定游標位置在第一行行首

    lcd.print(“S:");

    lcd.print(pp25);

    lcd.print(“/");

    lcd.print(pp10);

    lcd.print(“/");

    lcd.print(pp100);
}

void ShowDateTime()

{

 //  getCurrentTime(epoch, &NDPyear, &NDPmonth, &NDPday, &NDPhour, &NDPminute, &NDPsecond);

   lcd.setCursor(0, 2); // 設定游標位置在第一行行首

    lcd.print(StrDate());

   lcd.setCursor(11, 2); // 設定游標位置在第一行行首

    lcd.print(StrTime());

  //  lcd.print();
}
String  StrDate() {

 String ttt ;

//nowT  = now;

DateTime now = RTC.now();

ttt = print4digits(now.year()) + “-" + print2digits(now.month()) + “-" + print2digits(now.day()) ;

//ttt = print4digits(NDPyear) + “/" + print2digits(NDPmonth) + “/" + print2digits(NDPday) ;

 return ttt ;

}
String  StringDate(int yyy,int mmm,int ddd) {

 String ttt ;

//nowT  = now;

ttt = print4digits(yyy) + “-" + print2digits(mmm) + “-" + print2digits(ddd) ;

 return ttt ;

}

String  StrTime() {

 String ttt ;

// nowT  = RTC.now();

DateTime now = RTC.now();

 ttt = print2digits(now.hour()) + “:" + print2digits(now.minute()) + “:" + print2digits(now.second()) ;

 //  ttt = print2digits(NDPhour) + “:" + print2digits(NDPminute) + “:" + print2digits(NDPsecond) ;

return ttt ;

}
String  StringTime(int hhh,int mmm,int sss) {

 String ttt ;

 ttt = print2digits(hhh) + “:" + print2digits(mmm) + “:" + print2digits(sss) ;

return ttt ;

}

String GetWifiMac()

{

  String tt ;

   String t1,t2,t3,t4,t5,t6 ;

   WiFi.status();    //this method must be used for get MAC

 WiFi.macAddress(MacData);

 

 Serial.print(“Mac:");

  Serial.print(MacData[0],HEX) ;

  Serial.print(“/");

  Serial.print(MacData[1],HEX) ;

  Serial.print(“/");

  Serial.print(MacData[2],HEX) ;

  Serial.print(“/");

  Serial.print(MacData[3],HEX) ;

  Serial.print(“/");

  Serial.print(MacData[4],HEX) ;

  Serial.print(“/");

  Serial.print(MacData[5],HEX) ;

  Serial.print(“~");

  

  t1 = print2HEX((int)MacData[0]);

  t2 = print2HEX((int)MacData[1]);

  t3 = print2HEX((int)MacData[2]);

  t4 = print2HEX((int)MacData[3]);

  t5 = print2HEX((int)MacData[4]);

  t6 = print2HEX((int)MacData[5]);

tt = (t1+t2+t3+t4+t5+t6) ;

Serial.print(tt);

Serial.print(“\n");

 

 return tt ;

}

String  print2HEX(int number) {

 String ttt ;

 if (number >= 0 && number < 16)

 {

   ttt = String(“0″) + String(number,HEX);

 }

 else

 {

     ttt = String(number,HEX);

 }

 return ttt ;

}

String  print2digits(int number) {

 String ttt ;

 if (number >= 0 && number < 10)

 {

   ttt = String(“0″) + String(number);

 }

 else

 {

   ttt = String(number);

 }

 return ttt ;

}
String  print4digits(int number) {

 String ttt ;

 ttt = String(number);

 return ttt ;

}

void callback(char* topic, byte* payload, unsigned int length) {

 Serial.print(“Message arrived [“);

 Serial.print(topic);

 Serial.print(“] “);

 for (int i=0;i<length;i++) {

   Serial.print((char)payload[i]);

 }

 Serial.println();

}
// send an NTP request to the time server at the given address

void retrieveNtpTime() {

 Serial.println(“Send NTP packet");
 Udp.beginPacket(ntpServer, 123); //NTP requests are to port 123

 Udp.write(nptSendPacket, NTP_PACKET_SIZE);

 Udp.endPacket();
 if(Udp.parsePacket()) {

   Serial.println(“NTP packet received");

   Udp.read(ntpRecvBuffer, NTP_PACKET_SIZE); // read the packet into the buffer

   

   unsigned long highWord = word(ntpRecvBuffer[40], ntpRecvBuffer[41]);

   unsigned long lowWord = word(ntpRecvBuffer[42], ntpRecvBuffer[43]);

   unsigned long secsSince1900 = highWord << 16 | lowWord;

   const unsigned long seventyYears = 2208988800UL;

    epoch = secsSince1900 – seventyYears + timeZoneOffset ;
   epochSystem = epoch – millis() / 1000;

 }

}
void getCurrentTime(unsigned long epoch, int *year, int *month, int *day, int *hour, int *minute, int *second) {

 int tempDay = 0;
 *hour = (epoch  % 86400L) / 3600;

 *minute = (epoch  % 3600) / 60;

 *second = epoch % 60;
 *year = 1970;

 *month = 0;

 *day = epoch / 86400;
 for (*year = 1970; ; (*year)++) {

   if (tempDay + (LEAP_YEAR(*year) ? 366 : 365) > *day) {

     break;

   } else {

     tempDay += (LEAP_YEAR(*year) ? 366 : 365);

   }

 }

 tempDay = *day – tempDay; // the days left in a year

 for ((*month) = 0; (*month) < 12; (*month)++) {

   if ((*month) == 1) {

     if (LEAP_YEAR(*year)) {

       if (tempDay – 29 < 0) {

         break;

       } else {

         tempDay -= 29;

       }

     } else {

       if (tempDay – 28 < 0) {

         break;

       } else {

         tempDay -= 28;

       }

     }

   } else {

     if (tempDay – monthDays[(*month)] < 0) {

       break;

     } else {

       tempDay -= monthDays[(*month)];

     }

   }

 }

 (*month)++;

 *day = tempDay+2; // one for base 1, one for current day

}
void reconnectMQTT() {

 // Loop until we’re reconnected

 char payload[300];
 unsigned long epoch = epochSystem + millis() / 1000;

 int year, month, day, hour, minute, second;

//  getCurrentTime(epoch, &year, &month, &day, &hour, &minute, &second);

   digitalWrite(AccessLed,turnon) ;

DateTime now = RTC.now();

 //ttt = print2digits(now.hour()) + “:" + print2digits(now.minute()) + “:" + print2digits(now.second()) ;
 while (!client.connected()) {

   Serial.print(“Attempting MQTT connection…");

   // Attempt to connect

   if (client.connect(clientId)) {

     Serial.println(“connected");
//      sprintf(payload, “|ver_format=3|fmt_opt=1|app=Pm25Ameba|ver_app=0.0.1|device_id=%s|tick=%d|date=%4d-d-d|time=d:d:d|device=Ameba|s_d0=%d|gps_lat=%s|gps_lon=%s|gps_fix=1|gps_num=9|gps_alt=2″,

     sprintf(payload, “|ver_format=3|fmt_opt=1|app=PM25|ver_app=0.0.1|device_id=%s|tick=%d|date=%4d-d-d|time=d:d:d|device=Ameba|s_d0=%d|gps_lat=%s|gps_lon=%s|gps_fix=1|gps_num=9|gps_alt=2″,

       clientId,

       millis(),

       now.year(), now.month(), now.day(),

       now.hour(), now.minute(), now.second(),

       pm25,

       gps_lat, gps_lon

     );
     // Once connected, publish an announcement…

     client.publish(outTopic, payload);

   } else {

     Serial.print(“failed, rc=");

     Serial.print(client.state());

     Serial.println(" try again in 5 seconds");

     // Wait 5 seconds before retrying

     delay(5000);

   }

 }

   digitalWrite(AccessLed,turnoff) ;

}

void retrievePM25Value() {

 int idx;

 bool hasPm25Value = false;

 int timeout = 200;

 while (!hasPm25Value) {

   idx = 0;

   memset(buf, 0, pmsDataLen);

   while (mySerial.available()) {

     buf[idx++] = mySerial.read();

   }
   if (buf[0] == 0x42 && buf[1] == 0x4d) {

     pm25 = ( buf[12] << 8 ) | buf[13];

     pm10 = ( buf[10] << 8 ) | buf[11];

     pm100 = ( buf[14] << 8 ) | buf[15];

     Serial.print(“pm2.5: “);

     Serial.print(pm25);

     Serial.print(“, ug/m3″);

     Serial.print(“pm1.5: “);

     Serial.print(pm10);

     Serial.print(“, ug/m3″);

     Serial.print(“pm100: “);

     Serial.print(pm100);

     Serial.print(" ug/m3″);

     Serial.println(“");

     hasPm25Value = true;

     ShowPM(pm25,pm10,pm100) ;

   }

   timeout–;

   if (timeout < 0) {

     Serial.println(“fail to get pm2.5 data");

     break;

   }

 }

}
void initializeWiFi() {

 while (status != WL_CONNECTED) {

   Serial.print(“Attempting to connect to SSID: “);

   Serial.println(ssid);

   // Connect to WPA/WPA2 network. Change this line if using open or WEP network:

  status = WiFi.begin(ssid, pass);

 //  status = WiFi.begin(ssid);
   // wait 10 seconds for connection:

   delay(10000);

 }
 // local port to listen for UDP packets

 Udp.begin(2390);

}
void initializeMQTT() {

   digitalWrite(AccessLed,turnon) ;

// byte mac[6];

// WiFi.macAddress(MacData);

 memset(clientId, 0, MAX_CLIENT_ID_LEN);

 sprintf(clientId, “FT1_0XX", MacData[4], MacData[5]);

 sprintf(outTopic, “LASS/Test/PM25/%s", clientId);
 Serial.print(“MQTT client id:");

 Serial.println(clientId);

 Serial.print(“MQTT topic:");

 Serial.println(outTopic);
 client.setServer(server, 1883);

 client.setCallback(callback);
 digitalWrite(AccessLed,turnoff) ;

}
void printWifiData()

{

 // print your WiFi shield’s IP address:

 Meip = WiFi.localIP();

 Serial.print(“IP Address: “);

 Serial.println(Meip);

 // print your MAC address:

 byte mac[6];

 WiFi.macAddress(mac);

 Serial.print(“MAC address: “);

 Serial.print(mac[5], HEX);

 Serial.print(“:");

 Serial.print(mac[4], HEX);

 Serial.print(“:");

 Serial.print(mac[3], HEX);

 Serial.print(“:");

 Serial.print(mac[2], HEX);

 Serial.print(“:");

 Serial.print(mac[1], HEX);

 Serial.print(“:");

 Serial.println(mac[0], HEX);
 // print your subnet mask:

 Mesubnet = WiFi.subnetMask();

 Serial.print(“NetMask: “);

 Serial.println(Mesubnet);
 // print your gateway address:

 Megateway = WiFi.gatewayIP();

 Serial.print(“Gateway: “);

 Serial.println(Megateway);

}
void showLed()

{

   if (ParticleSensorStatus)

       {

         digitalWrite(ParticleSensorLed,turnon) ;

       }

       else

       {

         digitalWrite(ParticleSensorLed,turnoff) ;

       }

     if (status == WL_CONNECTED)

       {

         digitalWrite(InternetLed,turnon) ;

       }

       else

       {

         digitalWrite(InternetLed,turnoff) ;

       }

     

 

}

void initRTC()

{

    Wire.begin();

   RTC.begin();

   SetRTCFromNtpTime() ;

 if (! RTC.isrunning()) {

   Serial.println(“RTC is NOT running!");

   // following line sets the RTC to the date & time this sketch was compiled

//    RTC.adjust(DateTime(__DATE__, __TIME__));

 

 }

}

void initPins()

{

pinMode(DHTSensorPin,INPUT) ;

pinMode(ParticleSensorLed,OUTPUT) ;

pinMode(InternetLed,OUTPUT) ;

pinMode(AccessLed,OUTPUT) ;

digitalWrite(ParticleSensorLed,turnoff) ;

digitalWrite(InternetLed,turnoff) ;

digitalWrite(AccessLed,turnoff) ;
}

void SetRTCFromNtpTime()

{

 retrieveNtpTime();

 //DateTime ttt;

   getCurrentTime(epoch, &NDPyear, &NDPmonth, &NDPday, &NDPhour, &NDPminute, &NDPsecond);

   //ttt->year = NDPyear ;

   Serial.print(“NDP Date is :");

   Serial.print(StringDate(NDPyear,NDPmonth,NDPday));

   Serial.print(“and “);

   Serial.print(“NDP Time is :");

   Serial.print(StringTime(NDPhour,NDPminute,NDPsecond));

   Serial.print(“\n");

   

       RTC.adjust(DateTime(epoch));
 

}