水道漏水検知システムの開発

<pre class="C++">
#include 
#include 

#define LED_BLINK 13
#define InteruptInputPin 4

Ticker ticker1;
Ticker ticker2;

 uint32_t TimeDisplay = 5;
 uint32_t AlarmDisplay = 0;
 uint32_t Flow_Count = 0;
 uint32_t Q_FlowTime = 0;

 uint32_t Previous_Flow_Count = 0;
 bool Flow_Status = false;
 uint32_t Previous_Time;
 const int32_t Alarm_Set_Time_Flow = 60*60; // 60*60;sec
 const int32_t Alarm_Set_Time_Stop = 120*60; //120*60;sec
 bool Alarm_FlowTimeExess = false;
 bool Alarm_StopTimeExess = false;
 uint32_t Meter_Rotate=0;
 const uint32_t Meter_Rotate_Set = 10; // 10sec
 int32_t Duration_Time = 0;
 uint32_t GetCounter = 0;
 

const char* ssid = "My_ssid";
const char* password = "My_PassWord";

const char* host = "192.168.x.xx";

static int count_sec = 10;  // 60 sec counter

void count_down() { // １秒ごとの処理

  count_sec--;
  digitalWrite(LED_BLINK, count_sec%2 );

  GetCounter++;
  if (GetCounter >= 86400)
    GetCounter = 0;

  if(Flow_Count >= 50000000 )
    Flow_Count = Flow_Count - 50000000;
  
//  水道メーターのローター回転状態に応じた処理
      Duration_Time = GetCounter - Previous_Time;
      if( Duration_Time= Meter_Rotate_Set){
              Flow_Status = false;
              if(Alarm_FlowTimeExess){
                  Alarm_FlowTimeExess = false;
                  AlarmDisplay = 9;
              }
              AlarmDisplay = AlarmDisplay | 0x10;// FlowStatusOFF (000100000)
              Q_FlowTime = Q_FlowTime + Duration_Time;
              if(Q_FlowTime >= 86400) Q_FlowTime = 0;
              Duration_Time = 0;
              Previous_Time = GetCounter;
              /* Enable time update */
          }
          TimeDisplay--;
        }else{                                         // continue FLOW or start flowing again within Meter_Rotate_Set.
          Meter_Rotate = 0;
          if((!Alarm_FlowTimeExess) && (Duration_Time >= Alarm_Set_Time_Flow) ){
            Alarm_FlowTimeExess = true;
            /* Enable time update */
            AlarmDisplay = 0xb;
          }
          TimeDisplay--;
        }

      }else{ // Flow_Status = false. (isn't flowing. It's in STOP STATUS.)
        if(Previous_Flow_Count != Flow_Count){
          Flow_Status = true;
          Meter_Rotate = 0;
          Duration_Time = 0;
          Previous_Time = GetCounter;
          if(Alarm_StopTimeExess){
              Alarm_StopTimeExess = false;
              AlarmDisplay = 5;
          }
          AlarmDisplay = AlarmDisplay | 0x30;// FlowStatusOFF (00110000)
          /* Enable time update */
          TimeDisplay--;
        }else{


          if((!Alarm_StopTimeExess) && (Duration_Time >= Alarm_Set_Time_Stop) ){
            Alarm_StopTimeExess = true;
            /* Enable time update */
            AlarmDisplay = 7;
          }
          TimeDisplay--;
        }
      }

      Previous_Flow_Count = Flow_Count;
}


void roter_count() { //割込み処理
static int pin_state = 0;
      // Flow_Count increment
      if( pin_state != digitalRead(InteruptInputPin)){
        Flow_Count++;
        pin_state = digitalRead(InteruptInputPin);
      }

}
void setup() {
  Serial.begin(115200);
  delay(10);
  
  ticker1.attach_ms(1000, count_down);
  pinMode(LED_BLINK, OUTPUT);
 
  Serial.println("DHT11 init");
  dht.begin();
  
  // We start by connecting to a WiFi network
  Serial.println();
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);
  WiFi.mode(WIFI_STA);
  
//  WiFi.PrintDiag(Serial);
  
  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());

  pinMode(InteruptInputPin, INPUT);
  ticker2.attach_ms(10, roter_count);  // check input pulse level every 10msec 

}

// int value = 0;

void loop() {
static char url[50];
static  char str[150];
static char line[100];
static char str_time[5];
char *p;

      /* If 1sec has passed */
   if ( (TimeDisplay <= 0) || (AlarmDisplay &amp; 0x11) ){
       /* Display current time 
          cprintf("<Time:");
          Time_Display(RTC_GetCounter());
          cprintf("  RTC counter is %urn", RTC_GetCounter());*/


      int THH, TMM, TSS;
          /* Compute  hours */
      THH = Duration_Time / 3600;
          /* Compute minutes */
      TMM = (Duration_Time % 3600) / 60;
          /* Compute seconds */
      TSS = (Duration_Time % 3600) % 60;

      memset(str, 0, 150);
      if(Flow_Status)
        sprintf(&amp;str[0], "count=%d&amp;status=%s&amp;duration=%dh%dm%ds&amp;qflowtime=%d", Flow_Count, Flow_Status ? "Flow":"Stop", THH , TMM, TSS, Q_FlowTime + Duration_Time);
      else
        sprintf(&amp;str[0], "count=%d&amp;status=%s&amp;duration=%dh%dm%ds&amp;qflowtime=%d", Flow_Count, Flow_Status ? "Flow":"Stop", THH , TMM, TSS, Q_FlowTime);
      if(AlarmDisplay &amp; 0x11){
        switch(AlarmDisplay &amp; 0xf){ //下4桁がアラーム 

          case 0xb:   // Flow Excess On
            strcat(str, "&amp;alarm=FlowTimeExcess&amp;on_off=ON");
            break;
          case 0x9:     // Flow Excess Off
            strcat(str, "&amp;alarm=FlowTimeExcess&amp;on_off=OFF");
            break;
          case 0x7:    // Stop Excess On
            strcat(str,"&amp;alarm=StopTimeExcess&amp;on_off=ON");
            break;
          case 0x5:     // Stop Excess Off
            strcat(str, "&amp;alarm=StopTimeExcess&amp;on_off=OFF");
            break;
        }

        switch(AlarmDisplay &amp; 0x30){  //　上4桁がイベント

          case 0x30:   // Flow Status On
            strcat(str,"&amp;event=FlowStart");
            break;
          case 0x10:     // Flow Status Off
            strcat(str,"&amp;event=FlowStop");
            break;
        }
        AlarmDisplay = 0;
      }
      Serial.println(str);

// 水道メーター情報をサーバーへ送る
      Serial.print("connecting to ");
      Serial.println(host);

  // Use WiFiClient class to create TCP connections
      WiFiClient client;
      const int httpPort = 80;
      if (!client.connect(host, httpPort)) {
        Serial.println("connection failed");
        return;
      }
  // We now create a URI for the request

      memset(url, 0, 50);
      strcat(url, "/watermeter/receive_data.php");

      Serial.print("Requesting URL: ");
      Serial.println(url);

	  client.print(String("POST ") + url + " HTTP/1.1rn"
      + "Host: " + host + ":80rn"
      + "Connection: closern"
      + "Content-Type: application/x-www-form-urlencodedrn"
      + "Content-Length: " + strlen(str) + "rn" + "rn"
      + str + "rn");

      unsigned long timeout = millis();
      while (client.available() == 0) {
        if (millis() - timeout > 5000) {
          Serial.println(">>> Client Timeout !");
          client.stop();
          break;
        }
        delay(10);  // added 
        yield();    // added
      }

      while(client.available()){

        delay(10);  // added
        yield();    // added
        memset(line, 0, 100);
        sprintf(&line[0], "%s", client.readStringUntil('r').c_str());

        p = strstr(&line[0], ":Data Inserted");
        Serial.print(line);
        if(p){
          memset(str_time, 0, 5);
          strncpy(&str_time[0], p-2, 2);
          TimeDisplay = 65 - atoi(str_time); 
          Serial.print("timer set:");
          Serial.println( TimeDisplay);
        }
      }
      if(TimeDisplay <= 0) TimeDisplay=60;
	  Serial.print("Info:GetCounter=");
	  Serial.println(GetCounter);
      Serial.println("closing connection");
  }
}</pre>