如何使用mqtt控制百叶窗并发送一些传感器数据？

我为此工作了一段时间。作为一个新手，这对我来说非常困难。我在这里发布我的代码供其他人使用。如果有人可以优化它，我会很高兴。
- 它从 mqtt 获得步骤编号以用于百叶窗。
- 发送温度湿度和勒克斯值。Lux 值用于家庭助理以实现自动化，
- 它有一个重置传感器，它会丢失步骤。
- 将最后一步写入 EEPROM
代码：全选// This code is for controlling blinds via MQTT, getting lux value (to automate blinds with home assistant), getting temp and humidity and reset with a sensor of your choice. Also record last value to EEPROM.
// Platform used is esp8266

#include
#include
#include
#include
#include

#define Motor1_Dir 5
#define Motor1_Step 4
#define Motor1_En 15

#define DHTPIN 14                                       
#define DHTTYPE DHT11

#define hall 12                                        // reset sensor

const char* ssid = "xxx";
const char* password = "xxx";
const char* mqtt_server = "xxx";
const char* mqttUser = "xxx";
const char* mqttPassword = "xxx";

int rec_value;                                          // recieved value from mqtt
int eep_value;                                          // value to write EEPROM  
int hall_value;                                         // for sensor reset
bool flag1;                                             // to prevent unnecessary loop
bool flag_res;                                          // for reset loop

DHT dht(DHTPIN, DHTTYPE);

AccelStepper stepper(1, Motor1_Step, Motor1_Dir);

WiFiClient espClient;
PubSubClient client(espClient);


// to connect wifi

void setup_wifi()
{
  delay(10);
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);

  WiFi.mode(WIFI_STA);
  WiFi.begin(ssid, password);

  while (WiFi.status() != WL_CONNECTED)
  {
    delay(500);
    Serial.print(".");
  }
  randomSeed(micros());
  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
}

// to recieve values from mqtt

void callback(char* topic, byte* payload, unsigned int length)
{
  Serial.print("Message arrived [");
  Serial.print(topic);
  Serial.print("] ");

  rec_value = 0;
  int tensValue = 1;
  for (int i = length - 1; i >=0; i--) // iterate backwards
  {
    rec_value += (payload - '0') * tensValue ;
    tensValue = tensValue * 10;
  }
  flag1 = true;    // to use in if fonction in loop
}


void reconnect()
{
  while (!client.connected())
  {
    Serial.print("Attempting MQTT connection...");
   
    if (client.connect("alkan")) // mqtt user
    {
      Serial.println("connected");
      client.subscribe("Alkan/perde"); // mqtt subject to subscribe
    }
    else
    {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 3 seconds");
      delay(3000);
    }
  }
}


void setup()
{
  Serial.begin(115200);
  
  setup_wifi();
  
  client.setServer(mqtt_server, 1883);
  client.setCallback(callback);

  dht.begin();

  pinMode(hall, INPUT);
  
  hall_value = digitalRead(hall);    // for reset
  flag_res = false;                  // for reset

  pinMode (Motor1_En, OUTPUT);       // for disable motor to prevent heating
  digitalWrite(Motor1_En, HIGH);     // for disable motor to prevent heating

  EEPROM.begin(512);
  stepper.setMaxSpeed(200);
  stepper.setAcceleration(100);  
  eep_value = int (EEPROM.read(0));  // get last saved value from EEPROM
  rec_value = eep_value * 25;        // convert to orjinal value. its divided to 25 below
  stepper.setCurrentPosition(rec_value);  
  Serial.print(rec_value);
  Serial.println();
}



void loop()
{
  if (!client.connected())
  {
    reconnect();
  }
  client.loop();
  {

     if( flag1 ==  true and rec_value < 3001 )     // go for the recieved value value is between 0 - 3000
        {
        digitalWrite(Motor1_En, LOW);
        stepper.moveTo(rec_value);
        stepper.run();
        Serial.print(stepper.currentPosition());
        Serial.println();
        }

     if( flag1 ==  true and rec_value == 4000 and hall_value == 1 )   // if value 4000 it means reset. it go stupidly up until sensor activate below
        {        
        digitalWrite(Motor1_En, LOW);
        stepper.moveTo(-3500);
        stepper.run();
        Serial.println("Reseting");
        hall_value = digitalRead(hall);
        }
        
     if (hall_value == 0 and flag_res == false )  // yes sensor activated. no need for analog value. digital is good for that. the sensor is up than my "0" point.
        {
        stepper.stop();
        stepper.setCurrentPosition(-250);
        flag_res = true;
        }

     if (flag_res == true)      // so lets go to "0" after sensor read
        {  
        stepper.moveTo(0);
        stepper.run();      
        Serial.print(stepper.currentPosition());
        Serial.println();
        }  

     if( flag_res ==  true and stepper.currentPosition() == 0 ) // when we reach "0" then it s time to stop and finish reset process
        {
        stepper.stop();
        flag_res = false;  
        flag1 = false;
        hall_value = digitalRead(hall);        
        rec_value = 0;     
        EEPROM.put(0, 0);                 // save new position to EEPROM
        EEPROM.commit();
        Serial.println("Reset Completed");   
        digitalWrite(Motor1_En, HIGH);
        }

     if( flag1 ==  true and stepper.currentPosition() == rec_value ) // in normal case when blinds reach desired position write that to EEPROM and disable motor
        {
         flag1 = false;
         eep_value = rec_value / 25;
         EEPROM.put(0, eep_value);
         EEPROM.commit();
         Serial.println("Stop");
         digitalWrite(Motor1_En, HIGH);
        }  

      
     if( flag1 == false)  // if not blinds moving we are getting temp, humidity, lux values
       {
       float temp = dht.readTemperature();
       float humi = dht.readHumidity();
       float isik = analogRead(A0);
       float dist = digitalRead(hall);
      
       Serial.println("Sıcaklık");
       Serial.println(temp);
       Serial.println("Nem");
       Serial.println(humi);      
       Serial.println("Isik");
       Serial.println(isik);
       Serial.println("Reset");
       Serial.println(dist);
      
       client.publish("alkan/temp", String(temp).c_str());   
       client.publish("alkan/humi", String(humi).c_str());
       client.publish("alkan/isik", String(isik).c_str());  
       client.publish("alkan/many", String(dist).c_str());   
      
       delay(5000);   
       }         
  }
}

0