基于Arduino 一个完整的DIY气象站 包含代码

#include  

#include  
#include  

#include  
#include  
#include  

#define TIMEOUT 5000
// SoftwareSerial dataSerial（39，38）; // RX，TX const int rs = 2 ，en = 3 ，d4 = 4 ，d5 = 5 ，d6 = 6 ，d7 = 7 ; const String THINGSPEAK_API_WRITE_KEY = “PWLOULJXD5GO8RWP” ; LiquidCrystal lcd （rs ，en ，d4 ，d5 ，d6 ，d7 ）; INT



                  
   
      
alarmLevel  =  7000 ;
int  devCount ;
int  swPin  =  11 ;
int  RlyPin  =  8 ;
const  int  receive_pin  =  9 ; //针对来自发射器在
天井中的
天气数据的RF接收器的引脚// bool OKtoPost;
bool  HeatControl ;    // ON状态表示温度控制处于活动状态
bool  SuspendData ;
浮动 t1 ， t2 ， t3 ， t4 ;
/ ******************* ******************* /
//数据线插入到Arduino的引脚12
#define ONE_WIRE_BUS 12
/ ************* ************************************************** ***** / /
设置一个oneWire实例与任何OneWire设备进行通信
//（不仅仅是Maxim / Dallas温度IC）
OneWire  oneWire （ONE_WIRE_BUS ）;
/ ******************* ******************* /
//将我们的oneWire参考传递给Dallas Temperature。
DallasTemperature  传感器（＆oneWire ）;
/ ******************* ******************* /
DeviceAddress Probe01 = { 0x28, 0xFF, 0x67, 0x18, 0x23, 0x17, 0x04, 0xBF }; //Outdoor Sensor
DeviceAddress Probe02 = { 0x28, 0xFF, 0xF5, 0x22, 0x23, 0x17, 0x04, 0xD8 }; //Under Stairs Sensor
DeviceAddress Probe03 = { 0x28, 0xFF, 0xA9, 0xE7, 0x22, 0x17, 0x04, 0x7F }; // Utility Room
DeviceAddress Probe04 = { 0x28, 0xFF, 0x7D, 0x18, 0x23, 0x17, 0x04, 0x7E };// Under Kitchen

long delayMS;
long OutdoorTrig = 25; // Trigger Relay if outdoor temp is below
long OutdoorCut = 26; // Cutoff Relay if outdoor temp is above
long SinkTrig = 35;
long SinkCut = 38;

struct package
{
  float temperature = 0;
  float humidity = 0;
  float barometer = 0;
  byte wind = 0;
  byte maxWind = 0;
  byte windPacketPeak = 0;
  float rain = 0;
  float rainRate = 0;
  float randDate = 0;
  float randTime = 0;
  float battery = 0;
  long packetID = 0;
  float CKSum = 1;
};


typedef struct package Package;
Package data;
Package lastData;

struct postingPackage{
  float temperature = 0;
  float barometer = 0;
  float humidity = 0;
  uint8_t avgWind = 0;
  uint8_t peakWindThisRead = 0;
  float rainThisRead = 0;
  float rainRate = 0;
  float battV = 0;
};

typedef struct postingPackage PostingPackage;

PostingPackage dataToPost;

bool wxMode;

void setup() {
  pinMode(13, OUTPUT);
  pinMode(RlyPin, OUTPUT);
  pinMode(swPin, INPUT);
  Serial.begin(115200);
  Serial1.begin(57600);
  HeatControl = false;
  SuspendData = false;
  //OKtoPost = false;// becomes true after first temperature readings
  
  //Serial.println("Dallas Temperature IC Control Library Demo");
  // Start up the library
  sensors.begin();
  lcd.begin(16, 2);
  // Print a message to the LCD.
  lcd.print("Pipe Protector 2");
  lcd.setCursor(0, 1);
  devCount = sensors.getDeviceCount();
  Serial.print("Device Count: ");
  Serial.println(devCount);
  delayMS = 60000;// WIll increase to 60000 ms when finished. One reading per minute is plenty
  randomSeed(analogRead(0));
  vw_set_rx_pin(receive_pin);
  vw_setup(2000);   // Bits per sec
  vw_rx_start();       // Start the receiver PLL running
  wxMode = true;// for now, we'll start in weather mode
  //lastData.

  //sensors.requestTemperatures();
}// End Setup

void stateSwitch(void) {
  /* if(delayMS >=50000){
     delayMS=10000;
    }
    else{
     delayMS=60000;
    }*/
}

bool SuspendToggle(void) {
  SuspendData = !SuspendData;
  return (SuspendData);

}

void sendStatus(void) {
  String myStr;// Variable to hold all values as text string for sending over serial port
  myStr = OutdoorTrig;
  myStr.concat(",");
  myStr.concat(OutdoorCut);
  myStr.concat(",");
  myStr.concat(SinkTrig);
  myStr.concat(",");
  myStr.concat(SinkCut);
  myStr.concat(",");
  myStr.concat(delayMS);
  myStr.concat(",");
  myStr.concat(HeatControl);
  myStr.concat(",");
  myStr.concat(SuspendData);
  Serial.println(myStr);
}




int HighestTemp() {
  int retVal;
  for (int cnt = 0; cnt < devCount; cnt++) {
    //int trVal = GetFTempDec(cnt);
    int trVal = sensors.getTempFByIndex(cnt);
    if (cnt == 0) {

      retVal = trVal;
    }
    //Serial.println(sensors.getTempFByIndex(cnt));

    if (retVal < trVal) {
      retVal = trVal;
    }
  }
  // checkRange(retVal);
  return (retVal);
}

float LowestTemp() {
  float retVal;
  for (int cnt = 0; cnt < devCount; cnt++) {
    //int trVal = GetFTempDec(cnt);
    int trVal = sensors.getTempFByIndex(cnt);
    if (cnt == 0) {

      retVal = trVal;
    }
    //Serial.println(sensors.getTempFByIndex(cnt));

    if (retVal > trVal) {
      retVal = trVal;
    }
  }
  //  checkRange(retVal);
  return (retVal);
}

float printTemperature(DeviceAddress deviceAddress)
{

  float retVal = sensors.getTempF(deviceAddress);

  if (retVal == -196.60)
  {
    Serial.print(F(""));
  }
  else
  {


    Serial.print(retVal);

    Serial.print(F(" F "));
    return (retVal);
    //Serial.print(DallasTemperature::toFahrenheit(tempC));
  }
}// End printTemperature

void serial1Check(){
String myCmd;

  if(Serial1.available() > 0){
   Serial.println("You are there");
       myCmd = Serial1.readString();
    Serial.println(myCmd);
      
  }
  Serial.println("You ARE LEAVING!!");
}

void serialCheck(){
  if (Serial.available() >> 0) {
    String NewVal = Serial.readString();
    lcd.clear();
    if (NewVal == "+") {
      //lcd.print("HEAT ON");
      // delay( 2000);
      HeatControl = true;

    }
    else if (NewVal == "-") {
      lcd.print(F("HEAT OFF"));
      HeatControl = false;
      //delay (2000);
    }
    else if (NewVal == "S") {
      sendStatus;
      //delay (2000);
    }
    else {
      long secs = NewVal.toInt();
      delayMS = secs * 1000;
      //lcd.clear();
      //lcd.print(delayMS);
      //delay (2000);
    }
    // digitalWrite(13,HeatControl);
  }
}


void pipeProtect(){
  sensors.requestTemperatures(); // Send the command to get temperature readings

    /********************************************************************/
    bool RelayOn;
    RelayOn = digitalRead(RlyPin);
    digitalWrite(13, HeatControl); // Board LED indicates Heat Control Status
    if (HeatControl == true) {

      //if (!(t1> OutdoorTrig && t4>SinkTrig)){

      //if (digitalRead(RlyPin)==false){// Heat status is OFF
      if (t1 > OutdoorCut) {
        RelayOn = false;
      }

      if (t4 > SinkCut) {
        RelayOn = false;
      }
      if (t1 < OutdoorTrig) {
        RelayOn = true;

      }

      if (t4 > 41) { //Absolute cutoff if temp at sink is above 41.  No need to heat more that?
        RelayOn = false;

      }

      if (t4 < SinkTrig) {
        RelayOn = true;

      }
      digitalWrite(RlyPin, RelayOn);
      // }
    }
    else {
      digitalWrite(RlyPin, false);
    }

    if (SuspendData == false) {

      Serial.println(F(" ** Temperatures Read **"));

      Serial.print(F("Outdoor temp. is:   "));
      t1 = printTemperature(Probe01);
      Serial.println();

      Serial.print(F("Near Furnace temp. is:   "));
      t2 = printTemperature(Probe02);

      Serial.println();

      Serial.print(F("Under Utility Room temp. is:   "));
      t3 = printTemperature(Probe03);
      Serial.println();

      Serial.print(F("Under Sink temp. is:   "));
      t4 = printTemperature(Probe04);
      String OutLogic;
      OutLogic = "*&*";
      if (digitalRead(RlyPin) == HIGH) {
        OutLogic.concat("+");
      }
      else {
        OutLogic.concat("-");
      }
      Serial.println();
      Serial.println();
      Serial.println(OutLogic);
      Serial.println();


    }

    lcd.clear();
    lcd.setCursor(0, 0);
    lcd.print(F("O="));
    lcd.print(t1);
    lcd.print(F(" F="));
    lcd.print(t2);
    lcd.setCursor(0, 1);
    lcd.print(F("U="));
    lcd.print(t3);
    lcd.print(F(" K="));
    lcd.print(t4);
}



void loop(void)
{
  static bool notFirstIteration;
  static long nextOneWireMillis;
  if (!notFirstIteration) {// Occurs on first run.  
    nextOneWireMillis = millis() + delayMS;
    pipeProtect();
    notFirstIteration = true;
  }

  if (wxMode == true) {// If monitoring weather station

    //Serial.println("WXMODE TRUE");
    rxSubLoop();
   
    delay(100);
    if(Serial1.available()>0){

        Serial.println("Something Returned I think");
        while(Serial1.available()){
          char c = Serial1.read();
          Serial.print(c);
        }
        Serial.println("nDDDDn");
  }

  }
  // call sensors.requestTemperatures() to issue a global temperature
  // request to all devices on the bus
  /********************************************************************/
  //Serial.print("**Requesting temperatures...");
  serialCheck();//检查传入命令的串行端口
// serial1Check（）; //Serial.println("Out of Serial1Check“）; if （nextOneWireMillis <= millis （））{ //这段是程序管道保护部分nextOneWireMillis = millis （）+ delayMS ; pipeProtect （）; //你可以在同一条总线上有多个DS18B20。// 0表示线上的第一个IC // delay（delayMS + 200）; } }

bool  CheckData （） {
float CkVal = data 。湿度+ 数据。温度+ 数据。晴雨表+ 数据。风+ 数据。雨+ 数据。maxWind + 数据。rainRate + 数据。packetID + 数据。windPacketPeak + 数据。randDate + 数据。randTime +
                            数据。电池;
布尔CKB = （（CkVal == 数据。CKSUM ）&& （数据。CKSUM > 30000 ））; if （ckB == false ）{ data 。温度= 0 ; 数据。湿度= 0 ; 数据。气压计= 0 ; 数据。风= 0 ; 数据

           
      
      
      
      
      
    。雨 =  0 ;
数据。CKSum = 1 ; } return （ckB ）; } float rainFallRate （）{ } // END rainFallRate（）********************** float windChill （float mTempF ，float mMPH ）{ //计算风寒如果温度<50，风力> 3 浮动Twc ; 如果（（mTempF < 50.0 ）&& （mMPH > 3.0 ））
      

  
   



  





     
   
          {
    Twc = 35.74 + 0.6215 * mTempF - 35.75 * pow(mMPH, 0.16) + 0.4275 * mTempF * pow(mMPH, 0.16);
  }
  else
  {
    Twc = mTempF;// return temp unchanged if no wind chill
  }

  return (Twc);
}// End windChill()---------------------------------------------


float RandianDate(byte dayOfMonth, byte month, byte year) { //  Date to integer format - 01-01-1980 becomes 111180
  String myStr;
  byte myDay = dayOfMonth + 10;// Adding 10 to values to make all 2 digit.  No need to do the years.
  byte myMonth = month + 10;
  byte myYear = year + 10;
  //month += 10;
  myStr.concat(myMonth);

  myStr.concat(myDay);

  myStr.concat(myYear);

  return (myStr.toFloat());
  //return(0);
}


float RandianTime(byte hours, byte minutes, byte seconds) { //  Time to integer format - 14:56:03 becomes 145603
  String myStr;
  hours += 10;   // Adding 10 to these values to ensure all are 2 digits.
  minutes += 10; //  Will subtract 10 again when decoded
  seconds += 10;
  myStr.concat(hours);

  myStr.concat(minutes);

  myStr.concat(seconds);

  return (myStr.toFloat());
  //return(0);
}

String RandianToDate(float RandDate) {
  String msg = "";
  msg.concat(RandDate);
  String token;
  String myDt;
  int trans;

  for ( int cnt = 0; cnt < 6 ; cnt++) {
    token.concat(msg.charAt(cnt));
    if ((cnt == 1) || (cnt == 3)) {
      trans = token.toInt() - 10;
      if (trans < 10) {
        myDt.concat("0");
      }
      myDt.concat(trans);
      myDt.concat("-");
      token = "";
    }

    else if (cnt == 5) {
      trans = token.toInt() - 10;
      myDt.concat("20");
      myDt.concat(trans);
    }

  }
  return (myDt);
}

String RandianToTime(float RandTime) {
  String msg = "";
  msg.concat(RandTime);
  String token;
  String myDt;
  int trans;

  for ( int cnt = 0; cnt < 6 ; cnt++) {
    token.concat(msg.charAt(cnt));
    if ((cnt == 1) || (cnt == 3) || (cnt == 5)) {
      trans = token.toInt() - 10;
      if (trans < 10) {
        myDt.concat("0");
      }
      myDt.concat(trans);
      if (cnt < 5) {
        myDt.concat(":");
      }

      token = "";
    }


  }
  return (myDt);
}

void showReport(void) {
  Serial.print(F("nTemperature: "));
  Serial.print(data.temperature);
  Serial.print(F(" Degrees FnHumidity: "));
  Serial.print(data.humidity);
  Serial.print(F("% nBarometer: "));
  Serial.print(data.barometer);
  Serial.print(F(" Inches Hg nWind (current): "));
  Serial.print(data.wind);
  Serial.print(F(" Mphn   Feels like "));
  Serial.print(windChill(data.temperature, data.wind));

  Serial.print(F(" Wind ChillnPeak Wind this Read: "));
  Serial.print(data.windPacketPeak);
  Serial.print(F(" MphnPeak Wind Today: "));
  Serial.print(data.maxWind);
  Serial.print(F(" MphnRainfall: "));
  Serial.print(data.rain);
  Serial.print(F(" InchesnRain Rate: "));
  Serial.print(data.rainRate);
  Serial.print(F(" Inches per HournnPacket ID: "));

  Serial.print(data.packetID);
  //Serial.print("nCheck Sum: ");
  //Serial.println(data.CKSum);
  Serial.print(F("nDate: "));
  Serial.println(RandianToDate(data.randDate));
  Serial.print(F("Time: "));
  Serial.println(RandianToTime(data.randTime));
  Serial.println("");
  Serial.print(F("Battery: "));
  Serial.print(data.battery);
  Serial.println(F(" Voltsnn****************************************n"));



}

void dataPrep() { // Process incoming data, prepare dataToPost for transmission to network interface.  Average some values

  //static bool firstSeries;
  static int avgCounter;
  static float tempAvg;
  static int windAvg;
  static int windPeak;
  static int windRing[10];
  static float tempRing[10];// the "Ring arrays keep the last 10 readings for averaging, constatly rotating through
  static float rainVals[10];
  static float barVals[10];
  static float humVals[10];
  float tempTot;
  float batt;
  float rainfallRate;
  static int clearCount;

  if (avgCounter == 0) { //  Reset some vals for next post
    windPeak = 0;
    for (int ct; ct < 10 ; ct++) {
      rainVals[ct] = 0;
      tempRing[ct] = 0;
      tempTot = 0;
    }

  }
  windRing[avgCounter] = data.wind;
  if (data.windPacketPeak > windPeak) {
    windPeak = data.windPacketPeak;
  }
  tempRing[avgCounter] = data.temperature;
  humVals[avgCounter] = data.humidity;
  barVals[avgCounter] = data.barometer;
  rainVals[avgCounter] = data.rain;// - lastData.rain;// Rain measurement from station is a daily total-we need to calculate rain per package
  String trTime = RandianToTime(data.randTime);
  bool saveNOW = (trTime.charAt(4) == '0') && (avgCounter > 0);// will cause update at least every 10 packets, but should keep it at 00 minutes
  if ((avgCounter == 9)|| (saveNOW)) { //Last of data packets. Prepare values, insert into dataToPost, then send to Network Interface
    float rainTot;
    float windTot;
    float humTot;
    float barTot;
    // int tempTot;
    for (int ct = 0; ct < avgCounter+1 ; ct++) {
      rainTot = rainVals[ct];// for rain, just use last reading sent. No need to average, will send as total for day
      windTot += windRing[ct];
      tempTot += tempRing[ct];
      barTot += barVals[ct]-28.00;// Subtracting out lowest likely reading.  Averaging difference to increase accuracy in the event of errors
      humTot += humVals[ct];
      /*    Serial.println();
        Serial.print(tempRing[ct]);
        Serial.print("  ");
        Serial.println(tempTot);
        //Serial.println();
      */
    }
    avgCounter ++;// increment for calculating averages (due to zero based array counter)
    dataToPost.battV = data.battery;
    dataToPost.temperature = tempTot / float(avgCounter);
    dataToPost.barometer = (barTot /  float(avgCounter))+28.00;
    dataToPost.humidity = humTot /  float(avgCounter);
    dataToPost.avgWind = windTot / (avgCounter);
    dataToPost.peakWindThisRead = windPeak;
    dataToPost.rainThisRead = rainTot;
    dataToPost.rainRate = data.rainRate;
    Serial.println(F("n~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~"));
    Serial.print(F("nData to Post:n"));
    Serial.println(dataToPost.temperature);
    Serial.println(dataToPost.barometer);
    Serial.println(dataToPost.humidity);
    Serial.println(dataToPost.avgWind);
    Serial.println(dataToPost.peakWindThisRead);
    Serial.println(dataToPost.rainThisRead);
    Serial.println(F("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~n"));
    delay (2000);
    String url = "@";// add start character
    url += String(dataToPost.temperature);
    url += ",2=";
    url += String(dataToPost.humidity);
    url += ",3=";
    url += String(dataToPost.avgWind);
    url += ",4=";
    url += String(dataToPost.peakWindThisRead);
    url += ",5=";
    url += String(dataToPost.rainThisRead);
    url += ",6=";
    url += String(dataToPost.barometer);
    url += ",7=";
    url += String(dataToPost.rainRate);
    url += ",8=";
    url += String(dataToPost.battV);
    url += "~";// add end character

    String datStr;
    datStr.concat(dataToPost.temperature);
    datStr.concat(",");
    datStr.concat(dataToPost.humidity);
    datStr.concat(",");
    datStr.concat(dataToPost.avgWind);
    datStr.concat(",");
    datStr.concat(dataToPost.peakWindThisRead);
    datStr.concat(",");
    datStr.concat(dataToPost.rainThisRead);
    datStr.concat(",");
    datStr.concat(dataToPost.barometer);
    Serial.println (datStr);
    Serial1.print(url);// This line is where data is submitted to Network Interface (NodeMCU)   
    delay(10000);       // Lets wait a little while then   
    Serial1.print(url);// Send again to minimize data gaps due to errors in transmission   

    avgCounter = -1;
    //  Serial.print("IN the Test");
  }

  avgCounter ++;
  if (avgCounter > 9) {
    avgCounter = 0;
  }


}


void simulateData() {
  static long cnt;

  data.temperature = t1;
  data.humidity = t2;
  data.barometer = t3;
  data.wind = random(t4);
  data.maxWind = t4 + random(0, 21);
  data.windPacketPeak = t4 + random(0, 21);
  data.rain = t1;
  data.rainRate = t2;
  data.randDate = 101218;
  data.randTime = 131313;
  data.packetID = cnt;
  cnt ++;

}



void rxSubLoop(void) {

  // Serial.println("In the rxSubLoop");
  uint8_t buf[sizeof(data)];
  uint8_t buflen = sizeof(data);
  //Serial.println("in Loop");
  //vw_wait_message();
  if (vw_have_message())  // Is there a packet for us?
  {
    vw_get_message(buf, &buflen);
    memcpy(&data, &buf, buflen);
    // delay(500);
    bool myCkV = CheckData();// Check for  valid Packet-return true if valid
    if (myCkV == true) {

      if (data.packetID != lastData.packetID) {
        dataPrep();
        showReport();

        lastData = data;

      }


    }
    else {
      Serial.print(F("Bad Packet"));
      Serial.print(F("nn****************************************nn"));
    }

  }
  /*else{//A place to add a line for data simlation-for devel purposes
    // This ELSE clause will be commented out after new transmitter comes in

       simulateData（）;
       dataPrep（）;
       showReport（）;
      lastData = data;      延迟（30000）; //希望每隔1分钟模拟一次数据包     //Serial.println("Exiting RX_Lib“）;     } * / }