Skip to content

Instantly share code, notes, and snippets.

@teos0009

teos0009/gist:c6ccea717d6a35db1a0c

Last active August 29, 2015 14:13
Download ZIP

Revisions

  1. teos0009 revised this gist Jan 16, 2015. 1 changed file with 4 additions and 4 deletions.
    8 changes: 4 additions & 4 deletions gistfile1.cpp
    View file
    Original file line number Diff line number Diff line change
    @@ -23,9 +23,9 @@ DallasTemperature ds18B20(&oneWire);

    //thingspeak API
    String GET = "GET /update?key=API_KEY_HERE";
    //write key: ZS2IA826R67RJQ77
    //read key: 38HVL9FMAVW8SV96
    //Channel: 22051
    //my write key: APIKEY1
    //my read key: APIKEY2
    //my IoT Channel: 22051
    void setup()
    {
    // Start up the library for ds18B20
    @@ -51,7 +51,7 @@ void setup()
    delay(1000);
    //test if the module is ready by reset
    //Serial2.println("AT+RST");// high chance err: module not responding
    Serial2.println("AT");
    Serial2.println("AT");//test esp8266 via "AT" instead
    //delay(1000);
    //delay(1000);

  2. teos0009 revised this gist Jan 16, 2015. 1 changed file with 1 addition and 1 deletion.
    2 changes: 1 addition & 1 deletion gistfile1.cpp
    View file
    Original file line number Diff line number Diff line change
    @@ -22,7 +22,7 @@ OneWire oneWire(ONE_WIRE_BUS);
    DallasTemperature ds18B20(&oneWire);

    //thingspeak API
    String GET = "GET /update?key=ZS2IA826R67RJQ77&field1=";
    String GET = "GET /update?key=API_KEY_HERE";
    //write key: ZS2IA826R67RJQ77
    //read key: 38HVL9FMAVW8SV96
    //Channel: 22051
  3. teos0009 created this gist Jan 16, 2015.
    262 changes: 262 additions & 0 deletions gistfile1.cpp
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,262 @@
    //
    //#include <SoftwareSerial.h>
    //use mega Serial 2 for serial monitor; Serial 1 on pins 19 (RX) and 18 (TX);// Serial2 on pins 17 (RX) and 16 (TX), Serial3 on pins 15 (RX) and 14 (TX).
    //DS18B20 uses onewire protocol; need 5k pullup
    #include <OneWire.h>
    #include <DallasTemperature.h>

    #define SSID "SSID_HERE"
    #define PASS "PASSWORD_HERE"
    #define DST_IP "220.181.111.85" //baidu.com
    #define thingspeakIP "184.106.153.149" // thingspeak.com
    //SoftwareSerial dbgSerial(10, 11); // RX, TX
    #define acPin 7
    char myChar;

    //Data wire is plugged into pin A1 on the Arduino
    #define ONE_WIRE_BUS A1
    // Setup a oneWire instance to communicate with any OneWire devices
    // (not just Maxim/Dallas temperature ICs)
    OneWire oneWire(ONE_WIRE_BUS);
    // Pass our oneWire reference to Dallas Temperature.
    DallasTemperature ds18B20(&oneWire);

    //thingspeak API
    String GET = "GET /update?key=ZS2IA826R67RJQ77&field1=";
    //write key: ZS2IA826R67RJQ77
    //read key: 38HVL9FMAVW8SV96
    //Channel: 22051
    void setup()
    {
    // Start up the library for ds18B20
    ds18B20.begin();

    // Open serial communications and wait for port to open:
    //serial 2 is to esp8266
    Serial2.begin(9600);//9600 (mine), 57600, 115200
    Serial2.setTimeout(1000);

    //serial 0 is to usb
    Serial.begin(115200);
    //mod1 otherwise module cant be ready
    while(!Serial);
    while(!Serial2);

    Serial.println("ESP8266 on Mega2560 to thingspeak IoT ");

    //mod1 otherwise module cant be ready
    while(Serial2.available()>0)
    Serial2.read();

    delay(1000);
    //test if the module is ready by reset
    //Serial2.println("AT+RST");// high chance err: module not responding
    Serial2.println("AT");
    //delay(1000);
    //delay(1000);

    Serial.println("Resetting module");
    //mod1
    //Serial2.flush();


    //if(Serial2.find("ready"))
    if(Serial2.find("OK"))
    //if(Serial2.find("Ready")||Serial2.find("ready")||Serial2.find("OK"))
    {
    //dbgSerial.println("Module is ready");
    Serial.println("Module is ready");
    }
    else
    {
    //dbgSerial.println("Module have no response.");
    Serial.println("Module have no response.");
    while(1);//hang here
    }
    delay(1000);
    //connect to the wifi
    boolean connected=false;
    for(int i=0;i<5;i++)
    {
    if(connectWiFi())
    {
    Serial.println(" WiFi connected");
    connected = true;
    break;
    }
    }
    if (!connected){
    Serial.println("No WiFi connected");
    while(1);
    }
    delay(5000);
    //print the ip addr
    Serial2.println("AT+CIFSR=?");
    Serial.println("IP address:");
    while (Serial2.available())
    Serial.write(Serial2.read());

    //set the single connection mode
    //Serial2.println("AT+CIPMUX=0");//default single conn

    //LEDserver use
    //startLEDserver();


    }
    void loop()
    {
    /*
    //esp8266 as browser to open baidu.com
    String cmd = "AT+CIPSTART=\"TCP\",\"";
    cmd += DST_IP;
    cmd += "\",80";
    Serial2.println(cmd);
    //dbgSerial.println(cmd);
    Serial.println(cmd);
    if(Serial2.find("Error")) return;
    cmd = "GET / HTTP/1.0\r\n\r\n";
    Serial2.print("AT+CIPSEND=");
    Serial2.println(cmd.length());
    if(Serial2.find(">"))
    {
    //dbgSerial.print(">");
    Serial.print(">");
    }else
    {
    Serial2.println("AT+CIPCLOSE");
    //dbgSerial.println("connect timeout");
    Serial.println("connect timeout");
    delay(1000);
    return;
    }
    Serial2.print(cmd);
    delay(2000);
    //Serial.find("+IPD");
    while (Serial2.available())
    {
    char c = Serial2.read();
    //dbgSerial.write(c);
    Serial.write(c);
    //if(c=='\r') dbgSerial.print('\n');
    if(c=='\r') Serial.print('\n');
    }
    //dbgSerial.println("====");
    Serial.println("====");
    delay(1000);
    */

    /* LED server
    //Serial.println("waiting for cmd");
    if (Serial2.available()>0){
    if(Serial2.find("LED")){
    setLED();
    }
    }
    */

    float temp = readThermo();// read DS18B20
    char buffer[10];
    String tempC = dtostrf(temp, 4, 1, buffer);
    updateThingSpeakTemp(tempC);
    delay(60000);//read every 60sec
    }
    boolean connectWiFi()
    {
    Serial2.println("AT+CWMODE=1");
    String cmd="AT+CWJAP=\"";
    cmd+=SSID;
    cmd+="\",\"";
    cmd+=PASS;
    cmd+="\"";
    //dbgSerial.println(cmd);
    Serial2.println(cmd);
    Serial.println(cmd);
    delay(2000);
    if(Serial2.find("OK"))
    {
    //dbgSerial.println("OK, Connected to WiFi.");
    Serial.println("OK, Connected to WiFi.");
    return true;
    }
    else
    {
    //dbgSerial.println("Can not connect to the WiFi.");
    Serial.println("Can not connect to the WiFi.");
    return false;
    }
    }


    void setLED(){

    int red = Serial.parseInt();
    int green = Serial.parseInt();
    int blue = Serial.parseInt();
    Serial.print("LED set. Red: ");
    Serial.print(red);
    Serial.print(" Green ");
    Serial.print(green);
    Serial.print(" Blue ");
    Serial.println(blue);
    //colorWipe(strip.Color(red,green,blue),200);

    //simple test AC on/off for 2sec
    Serial.println("Set AC on/off");
    digitalWrite(acPin,HIGH);
    delay(2000);
    digitalWrite(acPin,LOW);

    }
    float readThermo() {//input pin#
    //using ds18B20
    ds18B20.requestTemperatures();
    float val = ds18B20.getTempCByIndex(0);
    return val; // Return the Temperature in degC
    }

    void startLEDserver(){
    //LED server use
    Serial2.println("AT+CIPMUX=1");//led server multi conn
    delay(1000);

    Serial2.println("AT+CIPSERVER=1,8266");
    delay(1000);
    Serial.println("Starting TCP Server");
    }

    void updateThingSpeakTemp(String tempC){
    String cmd = "AT+CIPSTART=\"TCP\",\"";
    cmd += thingspeakIP;
    cmd += "\",80";
    sendDebug(cmd);
    delay(2000);
    if(Serial2.find("Error")){
    Serial.print("RECEIVED: Error");
    return;
    }
    cmd = GET;
    cmd += tempC;
    cmd += "\r\n";
    Serial2.print("AT+CIPSEND=");
    Serial2.println(cmd.length());
    if(Serial2.find(">")){
    Serial.print(">");
    Serial.print(cmd);
    Serial2.print(cmd);
    }else{
    sendDebug("AT+CIPCLOSE");
    }
    if(Serial2.find("OK")){
    Serial.println("RECEIVED: OK");
    }else{
    Serial.println("RECEIVED: Error");
    }
    }
    void sendDebug(String cmd){
    Serial.print("SEND: ");
    Serial.println(cmd);
    //send cmd
    Serial2.println(cmd);
    }