/**************************************************/
/*  Copyright © 2021 CAVEDU. All rights reserved.

  The AirBox program is suitable for sensors:

  Grove-DHT20:
  https://robotkingdom.com.tw/product/grove-%e6%ba%ab%e6%ba%bc%e5%ba%a6%e6%84%9f%e6%b8%ac%e5%99%a8temperature-humidity-sensor-v2-0-dht20-upgraded-dht11-i2c-port/

  SPG30:
  https://robotkingdom.com.tw/product/grove-voc-and-eco2-gas-sensor-sgp30/

  OLED Display 0.96:
  https://robotkingdom.com.tw/product/grove-oled-display-0-96/
  (Also suitable for Grove-OLED Display 0.96”:https://robotkingdom.com.tw/product/oled-display-0-96/)

  Education Kit 001 Button :
  https://robotkingdom.com.tw/product/rk-education-kit-001/

  You can see the AirBox Technical article:
  https://blog.cavedu.com/2021/01/20/linkit-7697-airbox/

  https://blog.cavedu.com/2021/11/25/linkit-7697-airbox-2/

*/
/***************************************************/

#include "PMS.h"
#include  <SoftwareSerial.h>
#include "U8g2lib.h"
#include <DHT.h>
#include "sensirion_common.h"
#include "sgp30.h"
#include <LRTC.h>
#include <WiFiUdp.h>
#include <ctime>
#include "Wire.h"
#include "MCS.h"



/*============Pins==================*/
#define buttonPin 4
#define PMSTx     2
#define PMSRx     3
//#define DHT11Pin 10
#define DHTTYPE DHT20   // DHT 20
/*====================================*/

//Enter WIFI SSID & Password
#include <LWiFi.h>
char _lwifi_ssid[] = "_lwifi_ssid";
char _lwifi_pass[] = "_lwifi_pass";

//Enter IFTTT_key & Event_name
char IFTTT_key[] = "IFTTT_KEY";
char Event_name[] = "Event_Name";

unsigned long current_time = 0;//record current time
unsigned long previous_IFTTT_time = 0;//Record the last time of IFTTT
int IFTTT_upload_time = 2000;//IFTTT intervals of time

int frame = 0;

/*ThingSpeak value*/
unsigned long previous_ThingSpeak_time = 0;//record current time
int ThingSpeak_upload_time = 1000*60*10;//ThingSpeak intervals of time 

String Write_API_key= "Write_API_key";//輸入ThingSpeak的 Write_API_Key

/*MCSLITE value*/
unsigned long previous_mcslite_time = 0;//record current time
int mcslite_upload_time = 1000*60*10;//MCSLITE intervals of time 

#define _your_MCSLite_DeviceId   "_your_MCSLite_DeviceId"  //輸入MCSLite的DeviceId
#define _your_MCSLite_DeviceKey  "_your_MCSLite_DeviceKey" //輸入MCSLite的Devicekey
#define _your_MCSLite_IP         "_your_MCSLite_IP" //輸入MCSLite的IP                         
MCSLiteDevice mcs(_your_MCSLite_DeviceId , _your_MCSLite_DeviceKey, _your_MCSLite_IP, 3000);

MCSDisplayInteger _1F_CO2("_1F_CO2");
MCSDisplayInteger _1F_TVOC("_1F_TVOC");
MCSDisplayInteger _1F_PM10("_1F_PM10");
MCSDisplayInteger _1F_PM1_0("_1F_PM1_0");
MCSDisplayInteger _1F_PM2_5("_1F_PM2_5");
MCSDisplayInteger _1F_TEMP("_1F_TEMP");
MCSDisplayInteger _1F_HUMI("_1F_HUMI");

SoftwareSerial PMSSerial(PMSTx, PMSRx);
PMS pms(PMSSerial);
PMS::DATA data;
U8G2_SSD1306_128X64_NONAME_1_HW_I2C u8g2(U8G2_R0, /* reset=*/ U8X8_PIN_NONE);
/*Monitor rotate angle
   U8G2_R0     0   degrees
   U8G2_R1     90  degrees
   U8G2_R2     180 degrees
   U8G2_R3     270 degrees
   U8G2_MIRROR mirror
*/
#define imgWidth 128
#define imgHeight 48

int pms1_0, pms2_5, pms10_0;
int temp;
int humi;
int button_state;

s16 err = 0;
u16 tvoc_ppb, co2_eq_ppm;


//DHT dht11_p10(DHT11Pin, DHT11);  //define dht11 PIN
DHT dht(DHTTYPE);

#if defined(ARDUINO_ARCH_AVR)
#define debug  Serial

#elif defined(ARDUINO_ARCH_SAMD) ||  defined(ARDUINO_ARCH_SAM)
#define debug  SerialUSB
#else
#define debug  Serial
#endif


float temp_hum_val[2];

void setup()
{
  Serial.begin(115200);
  while (!Serial) {
    ; // wait for serial port to connect. Needed for native USB port only
  }
  debug.println("DHT20 test!");
  Wire.begin();
  dht.begin();
  //dht11_p10.begin();

  PMSSerial.begin(9600);
  LRTC.begin();
  SGP30_int();
  oled_int();
  msclite_channel_int();
  pinMode(buttonPin, INPUT);

}

void loop()
{
  float temp_hum_val[2] = {0};
  button_state = digitalRead(buttonPin);
  //temp = dht11_p10.readTemperature();
  //humi = dht11_p10.readHumidity();


  while (!pms.read(data)) {}      //PM2.5 read Data
  pms1_0 = data.PM_AE_UG_1_0;
  pms2_5 = data.PM_AE_UG_2_5;
  pms10_0 = data.PM_AE_UG_10_0;

  err = sgp_measure_iaq_blocking_read(&tvoc_ppb, &co2_eq_ppm);
  if (err == STATUS_OK) {
    Serial.print("tVOC  Concentration:");
    Serial.print(tvoc_ppb);
    Serial.println("ppb");

    Serial.print("CO2eq Concentration:");
    Serial.print(co2_eq_ppm);
    Serial.println("ppm");
  } else {
    Serial.println("error reading IAQ values\n");
  }



  sensor_oled_task(); //OLED show sensor value
  button_oled_show_time();//Press Button to show time
  //IFTTT_pm25_temp_humi_task();//Upload sensor value to IFTTT
  upload_to_msclite_task();//Upload sensor value to msclite
  upload_to_ThingSpeak();//Upload sensor value to ThingSpeak
}