#include <ESP8266WiFi.h>
#include <Thread.h>
#include <SoftwareSerial.h>
#include <PubSubClient.h>
#include <ArduinoJson.h>
#include <Adafruit_GFX.h>
#include <Adafruit_SSD1306.h>
#include <Wire.h>

#define OLED_RESET 5
Adafruit_SSD1306 display(OLED_RESET);

// Update these with values suitable for your network.
const char* ssid = "xxxxx";
const char* password = "xxxxx";
const char* mqtt_server = "192.168.1.110";

const char* clientID = "espgeiger";
const char* mqtt_topic = "Home/Global";

WiFiClient espClient;
PubSubClient client(espClient);

Thread geigerThread = Thread();

//geiger
volatile unsigned long counts = 0;                       // Tube events
unsigned long cpm = 0;                                   // CPM
unsigned long previousMillis;                            // Time measurement
const int geigerPin = 4;
unsigned long currentMillis = millis();

#define LOG_PERIOD 30000 //Logging period in milliseconds
#define MINUTE_PERIOD 60000

void ICACHE_RAM_ATTR ISR_impulse ();
void ISR_impulse() { // Captures count of events from Geiger counter board
  counts++;
}

void geigerCallback(){
	currentMillis = millis();
    if (currentMillis - previousMillis > LOG_PERIOD) {

    previousMillis = currentMillis;
    cpm = counts * MINUTE_PERIOD / LOG_PERIOD;
    counts = 0;
  }
}

void setup() {
	Wire.begin(0, 2);
	Serial.begin(115200);
	pinMode(geigerPin, INPUT);                                                // Set pin for capturing Tube events
	interrupts();                                                            // Enable interrupts
	attachInterrupt(digitalPinToInterrupt(geigerPin), ISR_impulse, FALLING); // Define interrupt on falling edge
	unsigned long clock1 = millis();
  
	geigerThread.onRun(geigerCallback);
	geigerThread.setInterval(1000);
  
	display.begin(SSD1306_SWITCHCAPVCC, 0x3C);
  
	display.clearDisplay();
	display.setTextSize(2);
	display.setTextColor(WHITE);
	display.setCursor(0,0);
	display.println("booting");
	display.display();
  
	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");
	Serial.println("IP address: ");
	Serial.println(WiFi.localIP());
  
	client.setServer(mqtt_server, 1883);
}

void reconnect() {
	while (!client.connected()) {
		Serial.print("AtDHTting MQTT connection...");
		if (client.connect(clientID)) {
			Serial.println("connected");
		} else {
			Serial.print("failed, rc=");
			Serial.print(client.state());
			Serial.println(" try again in 5 seconds");
			delay(5000);
		}
	}
}

void loop(){

	if(geigerThread.shouldRun())
		geigerThread.run();
	delay(30000);
  
	if (!client.connected()) {
		reconnect();
	}
	client.loop();
	if (cpm==0) {
		Serial.println("try to read sensor again!");
    return;
	}
  
	StaticJsonBuffer<300> JSONbuffer;
	JsonObject& JSONencoder = JSONbuffer.createObject(); 
	JSONencoder["cpm"] = cpm;
	float usvh = cpm/151.0;
	JSONencoder["usvh"] = usvh;
  
	char JSONmessageBuffer[300];
	JSONencoder.prettyPrintTo(JSONmessageBuffer, sizeof(JSONmessageBuffer));
	Serial.println(JSONmessageBuffer);

	boolean isOK = client.publish(mqtt_topic, JSONmessageBuffer, true);
	Serial.println(isOK);
	display.clearDisplay();
	  
	char str[100];
	display.setTextSize(2);
	display.setTextColor(WHITE);
	display.setCursor(0,0);
	snprintf(str,16, "cpm=%d", cpm);
	display.println(str);
	snprintf(str,16, "usvh=%.3f", usvh);
	display.println(str);
	display.display();
}

#include <ESP8266WiFi.h>
#include <Thread.h>
#include <SPI.h>
#include <Wire.h>
#include <SoftwareSerial.h>

Thread CO2Thread = Thread();
SoftwareSerial CO2sensor(14, 12, false, 128);

//CO2
static unsigned int CO2ppm = 0;
const unsigned char CO2AskData[7] = {0x42, 0x4d, 0xe3, 0x00, 0x00, 0x01, 0x72};

struct _panteng {
    unsigned char len[2];
    unsigned char co2_cf[2];
    unsigned char d[4];
    unsigned char crc_cf[2];
} panteng;
char crc1,crc2;

void CO2Callback(){
	unsigned char c;
	static int state = 0;
	static int count = 0;
    CO2sensor.write(CO2AskData, 7);

	while (CO2sensor.available()) {
        c = CO2sensor.read();
		//Serial.print(c,HEX);
        switch (state) {
            case 0:
                if (0x42 == c)
                    state = 1;
                break;
            case 1:
                if (0x4d == c) {
                    state = 2;
                    count = 0;
                }
                break;
            case 2:
                
				((unsigned char *) &panteng)[count++] = c;         
				if (count > 12) {
                    state = 0;
                    
					crc1 = panteng.crc_cf[0] * 256 + panteng.crc_cf[1];
                    crc2 =  0x42 + 0x4d + panteng.len[0]+ panteng.len[1]+panteng.co2_cf[0]+panteng.co2_cf[1]+panteng.d[0]+panteng.d[1]+panteng.d[2]+panteng.d[3];
                    
					//Serial.print("crc1 = ");Serial.println(crc1,HEX);
					//Serial.print("crc2 = ");Serial.println(crc2,HEX);
					
					if (crc1 == crc2){
						CO2ppm = panteng.co2_cf[0] * 256 + panteng.co2_cf[1];
						Serial.print("co2 = ");Serial.print(CO2ppm);Serial.println(" ppm");
                    }
                }
				break;
			default:
				break;
        }
    }
	delay(1000);
}

void setup(){
  CO2Thread.onRun(CO2Callback);
  CO2Thread.setInterval(1000);
  
  Serial.begin(115200);
  CO2sensor.begin(9600);
}

void loop(){
  if(CO2Thread.shouldRun())
    CO2Thread.run();
}

#include <ESP8266WiFi.h>
#include <PubSubClient.h>

#include <ArduinoJson.h>

#include "DHT.h"
#define DHTPIN 4
#define DHTTYPE DHT22

DHT dht(DHTPIN, DHTTYPE);

// Update these with values suitable for your network.
const char* ssid = "xxx";
const char* password = "xxx";
const char* mqtt_server = "xxx.xxx.xxx.xxx";
const char* mqtt_topic = "esp/sensor1";


WiFiClient espClient;
PubSubClient client(espClient);

void setup() {
  Serial.begin(9600);
  setup_wifi();
  client.setServer(mqtt_server, 1883);
  dht.begin();
}

void setup_wifi() {

  delay(10);
  // We start by connecting to a WiFi network
  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");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
}

void reconnect() {
  // Loop until we're reconnected
  while (!client.connected()) {
    Serial.print("Attempting MQTT connection...");
    // Attempt to connect
    if (client.connect("arduinoClient")) {
    //if (client.connect("arduinoClient", mqtt_user, mqtt_password)) {
      Serial.println("connected");
      // Once connected, publish an announcement...
      client.subscribe("esp/#");
    } else {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      // Wait 5 seconds before retrying
      delay(5000);
    }
  }
}

void loop() {
	if (!client.connected()) {
		reconnect();
	}
	client.loop();

	// Wait a few seconds between measurements.
	delay(2000);
	float h = dht.readHumidity();
	float t = dht.readTemperature();
	if (isnan(h) || isnan(t)) {
		Serial.println("Failed to read from DHT sensor!");
		return;
	}
	//Serial.print("Humidity: ");
	//Serial.print(h);
	//Serial.print(" %\t");
	//Serial.print("Temperature: ");
	//Serial.print(t);
	//Serial.print(" *C ");
  
	StaticJsonBuffer<300> JSONbuffer;   //Declaring static JSON buffer
	JsonObject& JSONencoder = JSONbuffer.createObject(); 
	JSONencoder["Humidity"] = h;
	JSONencoder["Temperature"] = t;
	//JsonObject& data = JSONencoder.createNestedObject("data");
	//data.set("Humidity", h);
	//data.set("Temperature", t);
	
	char JSONmessageBuffer[300];
	JSONencoder.prettyPrintTo(JSONmessageBuffer, sizeof(JSONmessageBuffer));
	Serial.println(JSONmessageBuffer);

	boolean isOK = client.publish(mqtt_topic, JSONmessageBuffer, true);
	Serial.println(isOK);
}

#include <ESP8266WiFi.h>
#include <PubSubClient.h>

// Update these with values suitable for your network.
const char* ssid = "xxx";
const char* password = "xxx";
const char* mqtt_server = "xxx.xxx.xxx.xxx";

WiFiClient espClient;
PubSubClient client(espClient);
String switch1;
String strTopic;
String strPayload;

void setup_wifi() {

  delay(10);
  // We start by connecting to a WiFi network
  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");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
}

void callback(char* topic, byte* payload, unsigned int length) {
  payload[length] = '\0';
  strTopic = String((char*)topic);
  if(strTopic == "esp/switch1")
    {
    switch1 = String((char*)payload);
    if(switch1 == "ON")
      {
        Serial.println("ON");
        digitalWrite(LED_BUILTIN, LOW);
      }
    else
      {
        Serial.println("OFF");
        digitalWrite(LED_BUILTIN, HIGH);
      }
    }
}
 
 
void reconnect() {
  // Loop until we're reconnected
  while (!client.connected()) {
    Serial.print("Attempting MQTT connection...");
    // Attempt to connect
    if (client.connect("arduinoClient")) {
      Serial.println("connected");
      // Once connected, publish an announcement...
      client.subscribe("esp/#");
    } else {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      // Wait 5 seconds before retrying
      delay(5000);
    }
  }
}
 
void setup()
{
  Serial.begin(115200);
  setup_wifi(); 
  client.setServer(mqtt_server, 1883);
  client.setCallback(callback);

  pinMode(LED_BUILTIN, OUTPUT);
  digitalWrite(LED_BUILTIN, HIGH);
}
 
void loop()
{
  if (!client.connected()) {
    reconnect();
  }
  client.loop();
}