3. Akıllı Depo ve Pompa Kontrolü

#include <PxServ.h>
 
const char* WIFI_SSID = "wifi_ssid";
const char* WIFI_PASSWORD = "wifi_sifre";
const char* PXSERV_API_KEY = "pxserv_api_anahtariniz";
const int TRIG_PIN = 5;
const int ECHO_PIN = 18;
const int HIGH_FLOAT_PIN = 19;
const int PUMP_PIN = 23;
 
const float EMPTY_CM = 90.0;
const float FULL_CM = 10.0;
const float START_LEVEL = 30.0;
const float STOP_LEVEL = 80.0;
const unsigned long MAX_RUN_MS = 60000;
 
PxServ client(PXSERV_API_KEY);
bool pumpOn = false;
bool timeoutFault = false;
unsigned long pumpStartedAt = 0;
unsigned long lastCycleAt = 0;
 
float readDistanceCm() {
  digitalWrite(TRIG_PIN, LOW);
  delayMicroseconds(2);
  digitalWrite(TRIG_PIN, HIGH);
  delayMicroseconds(10);
  digitalWrite(TRIG_PIN, LOW);
  unsigned long duration = pulseIn(ECHO_PIN, HIGH, 30000);
  return duration == 0 ? -1 : duration * 0.0343f / 2.0f;
}
 
void setPump(bool enabled) {
  if (pumpOn == enabled) return;
  pumpOn = enabled;
  digitalWrite(PUMP_PIN, enabled ? LOW : HIGH);
  if (enabled) pumpStartedAt = millis();
}
 
void publishState(float level, String state) {
  client.setData("depo-pompa/seviye", String(level, 1));
  client.setData("depo-pompa/pompa", pumpOn ? "1" : "0");
  client.setData("depo-pompa/durum", state);
}
 
void setup() {
  Serial.begin(115200);
  pinMode(TRIG_PIN, OUTPUT);
  pinMode(ECHO_PIN, INPUT);
  pinMode(HIGH_FLOAT_PIN, INPUT_PULLUP);
  pinMode(PUMP_PIN, OUTPUT);
  digitalWrite(PUMP_PIN, HIGH);
  PxServ::connectWifi(WIFI_SSID, WIFI_PASSWORD);
}
 
void loop() {
  unsigned long now = millis();
 
  if (pumpOn && now - pumpStartedAt >= MAX_RUN_MS) {
    setPump(false);
    timeoutFault = true;
  }
  if (now - lastCycleAt < 3000) {
    delay(20);
    return;
  }
  lastCycleAt = now;
 
  bool highFloatActive = digitalRead(HIGH_FLOAT_PIN) == LOW;
  float distance = readDistanceCm();
 
  if (highFloatActive) {
    setPump(false);
    publishState(100, "ust-sinir");
    return;
  }
  if (distance < 0) {
    setPump(false);
    publishState(-1, "sensor-hatasi");
    return;
  }
 
  float level = constrain(
    (EMPTY_CM - distance) * 100.0f / (EMPTY_CM - FULL_CM),
    0.0f,
    100.0f
  );
 
  PxServ::Callback reset = client.getData("depo-pompa/hata-sifirla");
  if (reset.status == 200 && reset.data == "1") {
    timeoutFault = false;
    client.setData("depo-pompa/hata-sifirla", "0");
  }
  if (timeoutFault) {
    setPump(false);
    publishState(level, "sure-hatasi");
    return;
  }
 
  String mode = "otomatik";
  PxServ::Callback modeValue = client.getData("depo-pompa/mod");
  if (modeValue.status == 200) mode = modeValue.data;
 
  bool request = false;
  if (mode == "manuel") {
    PxServ::Callback manual = client.getData("depo-pompa/manuel-komut");
    request = manual.status == 200 && manual.data == "1";
  } else {
    request = pumpOn ? level < STOP_LEVEL : level < START_LEVEL;
  }
 
  setPump(request);
  publishState(level, pumpOn ? "dolum" : "bekliyor");
}