ADSL.Kirov.Ru

Cookie: old=1;

// Функция отправки показаний с термодатчика на MQTT
void TempSend() {
  float temp = bme.readTemperature();
  client.publish(MQTT::Publish("test/temp", String(temp)).set_retain(1));
  Serial.println(temp);
  t=temp;
  float pressure = bme.readPressure() / 133.33;
  client.publish(MQTT::Publish("press", String(pressure)).set_retain(1));
  Serial.println(pressure);
  p=pressure;
  float Hum = bme.readHumidity();
  client.publish(MQTT::Publish("Hum", String(Hum)).set_retain(1));
  Serial.println(Hum);
  h=Hum;
  delay(10);
}
// ------------------------------------  отправка данных на  Thingspeak.com --------------------------------
void Thingspeak() {

  if (!wclient.connect(host, 80)) {
    Serial.println("connection failed");
    return;
  }
  String url = apiKey;
  url += "&field1=";
  url += String(t);
  url += "&field2=";
  url += String(h);
  url += "&field3=";
  url += String(p);
  url += "\r\n\r\n";

  Serial.print("Sending data: ");
  Serial.println(url);

  wclient.print("POST /update HTTP/1.1\n");
  wclient.print("Host: api.thingspeak.com\n");
  wclient.print("Connection: close\n");
  wclient.print("X-THINGSPEAKAPIKEY: " + apiKey + "\n");
  wclient.print("Content-Type: application/x-www-form-urlencoded\n");
  wclient.print("Content-Length: ");
  wclient.print(url.length());
  wclient.print("\n\n");
  wclient.print(url);

  Serial.print("Temperature: ");
  Serial.print(t);
  Serial.print(" degrees Celcius Humidity: ");
  Serial.print(h);
  Serial.println("% send to Thingspeak");
  while (wclient.connected()) {
    String line = wclient.readStringUntil('\n');
    if (line == "\r") {
      break;
    }
  }
  String line = wclient.readStringUntil('\n');
  Serial.println("Feedback from Thingspeak.com:");
  Serial.println("==========");
  Serial.println(line);
  Serial.println("==========");
  Serial.println("closing connection");
  wclient.stop();
}

schedule("*/5 * * * *", function () {      //запускаем наш скрипт каждые 5 мин
createState('Thingspeak.field1', '');         //создаем переменную field1 в iobroker
createState('Thingspeak.field2', '');         //т.д...
createState('Thingspeak.field3', '');
createState('Thingspeak.field4', '');
createState('Thingspeak.field5', '');
createState('Thingspeak.field6', '');
createState('Thingspeak.field7', '');
createState('Thingspeak.field8', '');

var request = require('request');
var id_chennal = 12345;                      //Создаем переменную и записываем в нее нужный нам номер id канала  Thingspeak
request({                                    //Отправляем запрос на Thingspeak
    url: "https://api.thingspeak.com/channels/"+id_chennal+"/feeds.json?results=1",   //URL api Thingspeak
    method: 'GET',                          // Метод GET
 }, function(error, response, body){       //обрабатываем результат
    if(error) {
        log(error);                       //выводим в лог в случаи ошибки ответа от сервера
        } else {
        //log(body);                        //выводим в лог ответа в виде строки. 
    var jsob_obj = JSON.parse(body);      //преобразуем json ответ от сервера в объект
    var field1 = jsob_obj.feeds[0].field1;   //вытаскиваем значения field1 из ответа от сервера
    var field2 = jsob_obj.feeds[0].field2;   //т.д...
    var field3 = jsob_obj.feeds[0].field3;
    var field4 = jsob_obj.feeds[0].field4;
    var field5 = jsob_obj.feeds[0].field5;
    var field6 = jsob_obj.feeds[0].field6;
    var field7 = jsob_obj.feeds[0].field7;
    var field8 = jsob_obj.feeds[0].field8;
   setState("javascript.0.Thingspeak.field1"/*Thingspeak.field1*/, field1);  // записывает значения field1 в переменную iobroker
   setState("javascript.0.Thingspeak.field2"/*Thingspeak.field2*/, field2);  // т.д...
   setState("javascript.0.Thingspeak.field3"/*Thingspeak.field3*/, field3);
   setState("javascript.0.Thingspeak.field4"/*Thingspeak.field4*/, field4);
   setState("javascript.0.Thingspeak.field5"/*Thingspeak.field5*/, field5);
   setState("javascript.0.Thingspeak.field6"/*Thingspeak.field6*/, field6);
   setState("javascript.0.Thingspeak.field7"/*Thingspeak.field7*/, field7);
   setState("javascript.0.Thingspeak.field8"/*Thingspeak.field8*/, field8);
   
    }
});
});