#include <WiFi.h>
#include "time.h"
#include "sntp.h"
#include <CircularBuffer.h>

const char* ssid       = "Wokwi-GUEST";
const char* password   = "";

const char* ntpServer1 = "pool.ntp.org";
const char* ntpServer2 = "time.nist.gov";
const long  gmtOffset_sec = 3600;
const int   daylightOffset_sec = 3600;

const char* time_zone = "CET-1CEST,M3.5.0,M10.5.0/3";  // TimeZone rule for Europe/Rome including daylight adjustment rules (optional)

boolean BrennerOn = false;
boolean WarmWasserBrennerOn = false;
int BeginBrennerOn = 0;
int EndBrennerOn = 0;
int LetzteBrennerLaufZeit;
int LetzteStdBrennerOn;
int HeuteBrennerOn;
int GesternBrennerOn;
int Letzte24hBrennerOn;
int Letzte48hBrennerOn;
int Letzte72hBrennerOn;
int LetzteWocheBrennerOn;
int HeuteWarmwasserBrennerOn;
int GesternWarmwasserBrennerOn;
int Letzte10TageWarmwasserBrennerOn;

struct HzgStr
{
  int sumBrOn;
  int sumWWBrOn;
  int BeginBrOn;
  int EndBrOn;
  int EndWWBrOn;
}HzgBr;

time_t now;

CircularBuffer<HzgStr, 60> LetzteHzgPer;		//Zehler wird alle Minuten mit Summe Zähler pro Minute am Ende hochgezählt -- erster wird verworfen


void NewOelVerbrauchCalc(int StromVerbr)
{
  printLocalTime();
	if (StromVerbr > 100 && BeginBrennerOn == 0)
	{
		if (BrennerOn == false)
		{
			BeginBrennerOn = now;
      HzgBr.BeginBrOn = BeginBrennerOn;
			BrennerOn = true;
		}
  }
  else if (StromVerbr < 100 && BeginBrennerOn > 0  && WarmWasserBrennerOn == false)
  {
    LetzteBrennerLaufZeit = now - BeginBrennerOn;  //Laufzeit in Sec
    BrennerOn = false;
    HzgBr.sumBrOn += LetzteBrennerLaufZeit;
    HzgBr.EndBrOn = now;
    HzgBr.EndWWBrOn = 0;
    BeginBrennerOn = 0;
    LetzteHzgPer.push(HzgBr);
  }
  else if (StromVerbr < 100 && BeginBrennerOn > 0 && WarmWasserBrennerOn == true)
  {
    GesternWarmwasserBrennerOn = HeuteWarmwasserBrennerOn;
    HeuteWarmwasserBrennerOn = now - BeginBrennerOn;  //Laufzeit in Sec
    HzgBr.EndWWBrOn = now;
    HzgBr.sumWWBrOn += HeuteWarmwasserBrennerOn;
    HzgBr.EndBrOn = 0;
    BrennerOn = false;
    WarmWasserBrennerOn = false;
    BeginBrennerOn = 0;
    LetzteHzgPer.push(HzgBr);
  }

  if (StromVerbr > 280 && (now - BeginBrennerOn) >= 2)
  { //Warmwasser weil Umlaufpumpe zusätzlich
    WarmWasserBrennerOn = true;
  }
  Serial.printf("Verbrauch: %u  BrennerOn: %u  WWBrennerOn: %u  BeginBrennerOn: %u\n",StromVerbr,BrennerOn,WarmWasserBrennerOn,BeginBrennerOn);
  Serial.printf("LetzteBrennerLaufZeit: %u  HeuteWarmwasserBrennerOn: %u\n",LetzteBrennerLaufZeit,HeuteWarmwasserBrennerOn);
}

void Ausw()
{
int begin = LetzteHzgPer.size() - 1;
int end = begin -4;

using index_t = decltype(LetzteHzgPer)::index_t;
		for (index_t ii = begin; ii >= end; --ii) {  
			HzgBr = LetzteHzgPer[ii];
			//			Serial.printf("Minn_ii: %u   Summ: %u\n", ii, Summ);
      Serial.printf("Index: %u\tSumBrOn:  %u\tSumWWBrOn:  %u\n", ii, HzgBr.sumBrOn, HzgBr.sumWWBrOn);
			if (ii == 0) break;    //notwendig da index_tStd keine negativen Werte hat !!!!!
			//		term.printf("Verbrauch Index: %u  Zehler: %u Summ: %u\n", ii, LetzteStunde[ii], Summ);

  
		}




}

void printLocalTime()
{
  struct tm timeinfo;
  if(!getLocalTime(&timeinfo)){
    Serial.println("No time available (yet)");
    return;
  }
  time(&now);
  Serial.printf("now: %u\n",now);
  Serial.println(&timeinfo, "%A, %B %d %Y %H:%M:%S");
}

// Callback function (get's called when time adjusts via NTP)
void timeavailable(struct timeval *t)
{
  Serial.println("Got time adjustment from NTP!");
  printLocalTime();
}

void test_1()
{
  NewOelVerbrauchCalc(30);
  delay(500);

  NewOelVerbrauchCalc(30);
  delay(500);

  NewOelVerbrauchCalc(230);
  delay(500);

  NewOelVerbrauchCalc(230);
  delay(2500);

  NewOelVerbrauchCalc(40);
  delay(500);

  NewOelVerbrauchCalc(40);
  delay(500);
}
 

void test_11()
{
  NewOelVerbrauchCalc(30);
  delay(500);

  NewOelVerbrauchCalc(30);
  delay(500);

  NewOelVerbrauchCalc(230);
  delay(500);

  NewOelVerbrauchCalc(230);
  delay(5500);

  NewOelVerbrauchCalc(40);
  delay(500);

  NewOelVerbrauchCalc(40);
  delay(500);

}

void test_12()
{
  NewOelVerbrauchCalc(30);
  delay(500);

  NewOelVerbrauchCalc(30);
  delay(500);

  NewOelVerbrauchCalc(230);
  delay(500);

  NewOelVerbrauchCalc(230);
  delay(1500);

  NewOelVerbrauchCalc(40);
  delay(500);

  NewOelVerbrauchCalc(40);
  delay(500);

}


void test_2()
{
  NewOelVerbrauchCalc(30);
  delay(500);

  NewOelVerbrauchCalc(30);
  delay(500);

  NewOelVerbrauchCalc(300);
  delay(2500);

  NewOelVerbrauchCalc(300);
  delay(1500);

  NewOelVerbrauchCalc(300);
  delay(1500);

  NewOelVerbrauchCalc(40);
  delay(500);

  NewOelVerbrauchCalc(40);
  delay(500);

}

void test_21()
{
  NewOelVerbrauchCalc(30);
  delay(500);

  NewOelVerbrauchCalc(30);
  delay(500);

  NewOelVerbrauchCalc(300);
  delay(2500);

  NewOelVerbrauchCalc(300);
  delay(1500);

  NewOelVerbrauchCalc(300);
  delay(1500);

  NewOelVerbrauchCalc(40);
  delay(500);

  NewOelVerbrauchCalc(40);
  delay(500);

}


void setup()
{
  Serial.begin(115200);

  // set notification call-back function
  sntp_set_time_sync_notification_cb( timeavailable );

  /**
   * NTP server address could be aquired via DHCP,
   *
   * NOTE: This call should be made BEFORE esp32 aquires IP address via DHCP,
   * otherwise SNTP option 42 would be rejected by default.
   * NOTE: configTime() function call if made AFTER DHCP-client run
   * will OVERRIDE aquired NTP server address
   */
  sntp_servermode_dhcp(1);    // (optional)

  /**
   * This will set configured ntp servers and constant TimeZone/daylightOffset
   * should be OK if your time zone does not need to adjust daylightOffset twice a year,
   * in such a case time adjustment won't be handled automagicaly.
   */
  configTime(gmtOffset_sec, daylightOffset_sec, ntpServer1, ntpServer2);

  /**
   * A more convenient approach to handle TimeZones with daylightOffset 
   * would be to specify a environmnet variable with TimeZone definition including daylight adjustmnet rules.
   * A list of rules for your zone could be obtained from https://github.com/esp8266/Arduino/blob/master/cores/esp8266/TZ.h
   */
  //configTzTime(time_zone, ntpServer1, ntpServer2);

  //connect to WiFi
  Serial.printf("Connecting to %s ", ssid);
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
      delay(500);
      Serial.print(".");
  }
  Serial.println(" CONNECTED");

test_1();
Serial.println();
test_11();
Serial.println();
test_21();
Serial.println();
test_12();
Serial.println();
test_2();

Ausw();



}





void loop()
{
 
}