Arduino UNO and ESP01S use MQTT to control the switch of LED, steering engine, fan and sprinkler

Make a simple web page with node-red to control the arduino connected lights and other things
#### For example, my condition has been snguangmin. 500, should be always on the light, I set the delay is two seconds, but it will be on for two seconds and dark for two seconds will jump into ddkg=0 to turn off the light for two seconds
2, my idea is to receive ddkg=0 to turn off the light, ddkg=1 to turn on the light, to achieve the effect of web control light on and off, but this is only in snguangmin< At 500, I can control it. What I want to achieve is this. 500 can also control his on and off, I do not know how to do this part, so I did not write.(relevant code part)

if(snguangmin>500)
{ 
       digitalWrite(ledpin,HIGH);
  
  }
  else{
   if (ddkg==0){
           digitalWrite(ledpin,LOW);}
           else{
           digitalWrite(ledpin,HIGH);}
    }

3, want to use the web to control the lights, steering gear, fan, spray machine(no matter what the condition is what kind of page end wants him to shut off to open on)
#### all code

#include <dht11.h>
#include "SGP30.h"
#include "WiFiEspAT.h"
#include "Serial.h"
#include <LiquidCrystal.h>
SoftwareSerial Serial1(0,6);    // RX, TX
#include <PubSubClient.h>         // MQTT通信使用的库
 
 
unsigned long previousMillis = 0;
 
const long interval = 2000; 
 
 
int ledpin=10;//定义数字10 接口
const int snpin=A0;//室内光敏电阻
const int swpin=A1;//室外光敏电阻
int fsPin = 8;//继电器引脚
int djPin = 7;    //定义舵机接口数字接口7 也就是舵机的橙色信号线。
int sensorPin = A2;    // 设置模拟口A2土壤湿度传感器
int pgjPin = 13;      // 设置继电器控制引脚为13
int sensorValue = 0;  // 存放模拟信号量的变量
 
int state=LOW;
int ddkg=0;
int fskg=2;
int pgkg=4;
int jlkg=6;
 
 
char ssid[] = "kk01";    // your network SSID (name)
char pass[] = "kk011209..";        // your network password
int status = WL_IDLE_STATUS;     // the Wifi radio's status
    
long lastMsg = 0;
char msg[50];
 
int value=0;
WiFiClient client;
 
PubSubClient pubSubClient(client); 
char server[] = "broker-cn.emqx.io";
 
int port = 1883;
 
 
//char topic[] = "fjjxu/13/303/temp15";
char topic[] = "fjjxu/13/303/light15";
 
int count = 0;
int countPub = 0;
 
dht11 DHT11;
#define DHT11PIN 9 //定义温湿度针脚号为9号引脚
 
 
 
 
const int rs = 12, en = 11, d4 = 5, d5 = 4, d6 = 3, d7 = 2;
LiquidCrystal lcd(rs, en, d4, d5, d6, d7);
 
 
 
SGP mySGP30;
 
u16 CO2Data,TVOCData;//定义CO2浓度变量与TVOC浓度变量
u32 sgp30_dat;
 
void servopulse(int angle)//定义一个脉冲函数,这个函数的频率是50hz的，20000us=20ms=1/50hz
 
{
  
  for(int i=0;i<100;i++){
  int pulsewidth=(angle*11)+500;  //将角度转化为500-2480的脉宽值
  digitalWrite(djPin,HIGH);    //将舵机接口电平至高,反过来也是可以的
  delayMicroseconds(pulsewidth);  //延时脉宽值的微秒数
  digitalWrite(djPin,LOW);     //将舵机接口电平至低
  delayMicroseconds(20000-pulsewidth);}
}
 
 
void callback(char* topic, byte* payload, unsigned int length) {  //回调函数
  count++;
 // char str[length]={0};
  Serial.print(count );
  Serial.print(" - Message arrived [");
  Serial.print(topic);
  Serial.print("] ");
  for (int i = 0; i < length; i++) {
    //str[i] = (char)payload[i]; 
    Serial.print((char)payload[i]);
  }
  Serial.println();//
//char a=str[0];
//String c =(String)str;
//String b=c.substring(1,4);
//int j = atoi(b.c_str());
// int n=atoi(&a);
 
  if((char)payload[0]=='0')//电灯
   {  ddkg=0;}  
   else if((char)payload[0]=='1')
   { ddkg=1;}
  else if((char)payload[0]=='2')//风扇
   {  fskg=2; }
  else if((char)payload[0]=='3')
   {  fskg=3; }
  else if((char)payload[0]=='4')//喷灌机
   {  pgkg=4; }
  else if((char)payload[0]=='5')
   {  pgkg=5; }
  else if((char)payload[0]=='6')//卷帘机
   {  jlkg=6; }
  else if((char)payload[0]=='7')
   {  jlkg=7; }
   
    Serial.println((char)payload[0]);
 
}
 
 
void connectToInternet() {
 
  Serial1.begin(9600);
  WiFi.init(Serial1);
 
  if (WiFi.status() == WL_NO_SHIELD) {
    Serial.println("【ERROR】WiFi shield not present");
   
    while (true);
  }
 
  while ( status != WL_CONNECTED) {
    Serial.print("【INFO】Attempting to connect to WPA SSID: ");
    Serial.println(ssid);
  
    status = WiFi.begin(ssid, pass);
  }
 
  Serial.println("【INFO】Connection Successful");
 
}
 
 
 
void setup()
{
pinMode(ledpin,OUTPUT);//定义小灯接口为输出接口
pinMode(fsPin, OUTPUT);  //继电器输出模式
pinMode(djPin, OUTPUT); //设定舵机接口为输出接口
pinMode(pgjPin, OUTPUT);  //设置对应的引脚为输出
  lcd.begin(16, 2);
 
  Serial.begin(9600);
 connectToInternet();
 
 pubSubClient.setServer(server, port);
 pubSubClient.setCallback(callback);
 
  reconnect();
  
mySGP30.SGP30_Init();
  mySGP30.SGP30_Write(0x20,0x08);
  sgp30_dat = mySGP30.SGP30_Read();//读取SGP30的值
  CO2Data = (sgp30_dat & 0xffff0000) >> 16;
  TVOCData = sgp30_dat & 0x0000ffff; 
  //SGP30模块开机需要一定时间初始化，在初始化阶段读取的CO2浓度为400ppm，TVOC为0ppd且恒定不变，因此上电后每隔一段时间读取一次
  //SGP30模块的值，如果CO2浓度为400ppm，TVOC为0ppd，发送“正在检测中...”，直到SGP30模块初始化完成。
  //初始化完成后刚开始读出数据会波动比较大，属于正常现象，一段时间后会逐渐趋于稳定。
  //气体类传感器比较容易受环境影响，测量数据出现波动是正常的，可自行添加滤波函数。
  while(CO2Data == 400 && TVOCData == 0)
  {
    mySGP30.SGP30_Write(0x20,0x08);
    sgp30_dat = mySGP30.SGP30_Read();//读取SGP30的值
    CO2Data = (sgp30_dat & 0xffff0000) >> 16;//取出CO2浓度值
    TVOCData = sgp30_dat & 0x0000ffff;       //取出TVOC值
    Serial.println("正在检测中...");
    delay(500);
  }
}
 
 
void loop()
{
  if (pubSubClient.connected()) //如果没有成功连接服务器
  {
     pubSubClient.loop();//保持客户端心跳
    }
  else{
   reconnect();//尝试连接
  }
 
  
  lcd.clear();
  lcd.setCursor(0, 1);
 
  Serial.println("\n");
 
  DHT11.read(DHT11PIN);
 
 float tem=(float)DHT11.temperature;        //将温度值赋值给tem
 float hum=(float)DHT11.humidity; 
 int t=tem;
  int g=analogRead(swpin);
 
  g=map(g,0,1023,100,0);
  //float gg=analogRead(snpin);
  int c = CO2Data;
  c=map(c,0,1023,0,100);
  
  int tr = analogRead(sensorPin);
int  r=map(tr,0,1023,100,0);
  
 char b[50]="";
String date="{\"t\":"+String(t)+",\"c\":"+String(c)+",\"r\":"+String(r)+",\"g\":"+String(g)+"}";
 
 strcpy(b,date.c_str());//转格式字符数组  不能接收字符串
 
 
 
  Serial.print("Humidity (%): ");
  Serial.println(hum);
 
  Serial.print("Temperature (oC): ");
  Serial.println(tem);
 
    lcd.clear();//清屏，光标回到左上角
      lcd.print("Hum:");//共12个字符
      lcd.setCursor(4,0);//光标定位到上面字符的后面，即第1行第13列
      lcd.print(hum,1);//显示采集到湿度值，保留小数点后1位
      lcd.print("%");
      lcd.setCursor(0,1);//光标定位到第1列第2行
      lcd.print("Tem:");//8个字符
      lcd.setCursor(4,1);//光标定位到第9列第2行
      lcd.print(tem,1);//显示采集到温度值，保留小数点后1位
      lcd.print("C");
       lcd.setCursor(9,0);//光标定位到第1列第2行
   lcd.print("Tu:");
       lcd.setCursor(12,0);//光标定位到第1列第2行
       lcd.print(sensorValue);
       
   lcd.setCursor(9,1);//光标定位到第9列第2行
   lcd.print("CO2:");
       lcd.setCursor(13,1);//光标定位到第1列第2行
       lcd.print(CO2Data,DEC);
     
     
  if (tem >22)        //如果温度大于22摄氏度
    {
      digitalWrite(fsPin, LOW);        //继电器开，风扇开
      Serial.println(" OPEN!");
    } else
    {  
      if(fskg==2){ digitalWrite(fsPin,HIGH);
      Serial.println("CLOSE!");}
  else{ digitalWrite(fsPin, LOW); 
    Serial.println("OPEN!");
  }
   
      
    }
 
 
//灯
int snguangmin=analogRead(snpin);   //读入光敏电阻产生的模拟信号（范围：0~1023）
  Serial.print("snvalue= ");
  Serial.print(snguangmin);
 // snguangmin=map(snguangmin,0,1023,0,255);  //map函数 将0~1023范围映射到255~0
  //这里反着写255,0；因为想实现随着光强增加LED变亮
  //analogWrite(ledpin,snguangmin);    //让13号引脚发出PWM波
 
 
if(snguangmin>500)
{ 
       digitalWrite(ledpin,HIGH);
  
  }
  else{
   if (ddkg==0){
           digitalWrite(ledpin,LOW);}
           else{
           digitalWrite(ledpin,HIGH);}
  
 
    }
 
 
//喷灌机
sensorValue = analogRead(sensorPin);
  
  if(sensorValue<900)//当读取的值小于700时，启动
  {
   digitalWrite(pgjPin, HIGH);
  }else
  {
        if(pgkg==4){ digitalWrite(pgjPin, LOW);}
  else{ digitalWrite(pgjPin, HIGH);}
   
  }
   Serial.print("turang= ");
  Serial.println(sensorValue);
 
 
 
 //舵机
 int swguangmin=analogRead(swpin); 
 Serial.print("swvalue= ");
  Serial.println(swguangmin);
if(swguangmin>500)
{
  servopulse(0);
 
  }else
  {
       if(jlkg==6){ servopulse(180);}
  else{ servopulse(0);}
    
    }
 
 
//CO2检测
  mySGP30.SGP30_Write(0x20,0x08);
  sgp30_dat = mySGP30.SGP30_Read();//读取SGP30的值
  CO2Data = (sgp30_dat & 0xffff0000) >> 16;//取出CO2浓度值
  TVOCData = sgp30_dat & 0x0000ffff;       //取出TVOC值
  Serial.print("CO2:");
  Serial.print(CO2Data);
  Serial.println("ppm");
 
 long now = millis();
  if (now - lastMsg > 2000) {
    lastMsg = now;
    ++value;
    
    snprintf (msg,75, b, value);
  
    Serial.print("Publish message: ");
    
    Serial.println(msg);
    
     pubSubClient.publish("fjjxu/13/303/date15", msg);
  
  }
 
delay（2000）；
}
 
 
void reconnect() {
 
  while (!pubSubClient.connected()) {
    Serial.println("【INFO】 Retry  connect  MQTT  ...");
  
    String clientId = "Arduinoskw66-";
    clientId += String(random(0xffff), HEX);   //产生随机的ClientID
   
 
    if (pubSubClient.connect(clientId.c_str())) {
      Serial.println("connected");
  
     
      pubSubClient.subscribe(topic);   //订阅主题
 
      Serial.print("【INFO】 Successfully Subscribed to MQTT Topic:");
      Serial.println(topic);     
    } else {
      Serial.print("【ERR】 failed, rc=");
      Serial.print(pubSubClient.state());
      Serial.println(" try again in 5 seconds");
    
      delay(5000);
    }
  }
}