Arduino.ru

#include <DHT.h>
#include <OneWire.h>
#include <DallasTemperature.h>
#include <Ethernet.h>

//DHT temperature and humidity
#define dhtPin 7
#define dhType DHT11
DHT dhtSensor(dhtPin,dhType);

//dallas temperature
#define bus A2 //
OneWire oneWire(bus); // шина для чтения датчика
DallasTemperature dallaSensor(&oneWire);

//fork 
#define moisturePin A0
#define ledPin 13

#define sensorCount 4
float sensorData[sensorCount];
char *sensorName[]= {"dht_t", "dht_h", "ground_t", "ground_h", "brightness"};
#define dhtTemp 0
#define dhtHumidity 1
#define dallas 2
#define fork 3
#define brightness 4

//Block C ----------------------------------------------------------------------------
#include <ArduinoJson.h>
#include <Servo.h>
#define INPUT_BUFFER_LEN 128
#define servoPin 5
#define pumpRelayPin 14

Servo servo;

bool isProtectionMode = false;
bool servoState = false;
bool pumpState = false;
bool lightOn = true;
bool handRefreshTime;
bool flags[3];

char *flagName[] = {"servState","pumpState","isProtectionMode"};
char inputBuffer[INPUT_BUFFER_LEN] = "";

short int dayTime;
short int nighTime;

//------------------------------------------------------------------------------------

char* sensorDescription[] = {"Air temperature in *C", "Air humidity in %", "Soil temperature in *C", "Soil humidity in %", "Brightness in %"}; 

#define brightneSensor A1

//Ethernet

byte mac[] = {0xBA, 0xDC, 0xC0, 0xFE, 0x00, 0x00};

IPAddress ip(192, 168, 1, 250);
IPAddress dnsServerIP(192, 168, 1, 1);
IPAddress gateway(192, 168, 1, 1);
IPAddress subnet(255, 255, 255, 0);
EthernetClient client;
IPAddress iot_add(52,4,204,67);

bool openWindow = false;
short int  reacTime = 3; //задержка системы в секундах

void ifBadEthernetSetUp() {
  if (Ethernet.begin(mac) == 0)
  {
    Serial.println("Failed to configure Ethernet using DHCP");
    Ethernet.begin(mac, ip, dnsServerIP, gateway, subnet);
  }
}

void connectToThigworx() {
  if (client.connect(iot_add, 80)) {
    Serial.println("iot connected");
    if(client.connected()){
       Serial.println("client connected");
    client.print("POST /Thingworx/Things/");
    client.print(thingName);
    client.print("/Services/");
    client.print(serviceName);
    client.print("?appKey=");
    client.print(appKey);
    client.print("&method=post&x-thingworx-session=true");
    }
  }
}
// CCCC
void sendFlags(){
   for(short i=0; i<3; ++i){
    client.print("&");
    client.print(flagName[i]);
    client.print("=");
    client.print(flags[i]);
  }
}
//CCCCC

void sendData(){
  for(short i=0; i<sensorCount; ++i){
    client.print("&");
    client.print(sensorName[i]);
    client.print("=");
    client.print(sensorData[i]);
  }
  sendFlags();
//    client.print("&");
//    client.print("windowOpen");
//    client.print("=");
//    client.print(openWindow);
}

void closePack(){
  client.println(" HTTP/1.1");
  client.println("Accept: application/json");
  client.print("Host: ");
  client.println(iot_server);
  client.println("Content-Type: application/json");
  client.println();
}

float readDHTemperature(){
  return dhtSensor.readTemperature();
}

float readDHTHumidity(){
  return dhtSensor.readHumidity();
}

float readDallas(){
   dallaSensor.requestTemperatures();
  return dallaSensor.getTempCByIndex(0);
}

float readMoisture(){
  return analogRead(moisturePin)/10.23;
}

int readBrightness(){
  float valueBrightness=abs((1000-analogRead(brightneSensor))/10);

 return valueBrightness;
}

void getInfo(){
//  sensorData[dhtTemp] = readDHTemperature();
//  sensorData[dhtHumidity]= readDHTHumidity();
//  sensorData[dallas] = readDallas();
//  sensorData[fork] = readMoisture();
//  sensorData[brightness] = readBrightness(); 
  sensorData[dhtTemp] = random(0,60);
  sensorData[dhtHumidity]= random(5,100);
  sensorData[dallas] = random(0,20);
  sensorData[fork] = random(0,100);
  sensorData[brightness] = 5;     
}

void showInfo(){
  for(short int i=0; i<sensorCount; ++i){
    Serial.println(String(sensorDescription[i]) + ": "+String(sensorData[i]));
  }
   Serial.println("-------------------------------");
    Serial.println("\t\n");
}

void blinkledOn(){
  digitalWrite(ledPin, HIGH);
}

void blinkledOFF(){
  digitalWrite(ledPin, LOW);
}

void setReacTime(){
  if(handRefreshTime){
    if(readBrightness() < 20){
    reacTime = nighTime;
  }else{
    reacTime = dayTime;
  }
  }
  if(readBrightness() < 20){
    reacTime =5 ;
  }else{
    reacTime =1;
  }
}

//Block C ----------------------------------------------------------------------------
void getServerResponse(){
  short int i;
  bool inputFlag=false;
  char inputSmb;
  while(client.connected()){
    while(client.available()){
      inputSmb = client.read();
      if(inputSmb == '{'){
        inputFlag= true;
      }else{
        if(inputSmb == '}'){
          inputFlag = false;
        }
      }
      if(inputFlag == true){
        inputBuffer[i] = inputSmb;
        i++;
      }
    }
  }
  inputBuffer[i] = '}';
  inputBuffer[i+1] = '\0';
}

void responseParser(){
  StaticJsonBuffer<INPUT_BUFFER_LEN> jsonBuffer;
  JsonObject& jsonArray = jsonBuffer.parseObject(inputBuffer);
  
  servoState = jsonArray["servState"];
  pumpState = jsonArray["PumpState"];
  lightOn = jsonArray["lightState"];
  isProtectionMode = jsonArray["isProtectionMode"];
  handRefreshTime = jsonArray[""]; 
  dayTime =  jsonArray[""]; 
  nighTime= jsonArray[""]; ; 
}

void workWithThingWorx(){
  connectToThigworx();
  sendData();
  closePack();
  getServerResponse();
  responseParser();
  client.stop();
}

void tesTBlocC(){
  Serial.println(servoState);
  Serial.println(pumpState);
  Serial.println(isProtectionMode);
  Serial.println(lightOn);
}

void getFlagState(){// {"servState","pumpState","isProtectionMode",reacTime"}
  flags[0]=servoState;
  flags[1] = pumpState;
  flags[2] = isProtectionMode;
  
}


void controlDevices() {
  if (servoState)
  {
    servo.write(120);
  }
  else
  {
    servo.write(90);
  }
  if(lightOn){
   digitalWrite(ledPin,HIGH);
  }
  else{
     analogWrite(ledPin,LOW);
  }
  // Помпа
  if(pumpState){
    digitalWrite(pumpRelayPin, HIGH);
  }
 //  //?
}
#define max_dht_t 15
#define max_ground_t 15
#define max_dht_hum 30
#define max_ground_hum 15
#define min_brightness 40

void protectedMode(){//{"dht_t", "dht_h", "ground_t", "ground_h", "brightness"};
  if(sensorData[0]>= max_dht_t || sensorData[2]>=max_ground_t|| sensorData[1]>= max_dht_hum){
    servoState= true;
  }
  if(sensorData[3]>=max_ground_hum){
    pumpState = true;
  }
  if(sensorData[4]<=min_brightness){
    lightOn = true;
  }
}

//-------------------------------------------------------------------------------------

void setup() {
  // put your setup code here, to run once:
 Serial.begin(9600);
 dhtSensor.begin();
 pinMode(ledPin, OUTPUT);
 servo.attach(servoPin);
 dallaSensor.begin();
 
ifBadEthernetSetUp();
}

void loop() {
  blinkledOn();
  getInfo();
  getFlagState();
  workWithThingWorx();
  if(flags[2]){
    protectedMode();
  }
  controlDevices();
  showInfo();
  setReacTime();
  tesTBlocC();
  delay(reacTime*1000);
  blinkledOFF();
}