Relay Board

1#include <ESP8266WiFi.h>
2#include <PubSubClient.h>
3
4#define topico_subscribe  "pub/pin"
5#define topico_publish    "sub/pin"
6#define id_mqtt           "esp01"
7
8const  char* ssid = "LINKESTOQUE";
9const char* password = "qualidade12345";
10const  char* mqtt_server = "192.168.1.104";
11
12WiFiClient espClient;
13PubSubClient  client(espClient);
14
15char EstadoSaida = '0';
16
17void initWiFi() 
18{
19    delay(10);
20    Serial.println("------Conexao WI-FI------");
21    Serial.print("Conectando-se  na rede: ");
22    Serial.println(ssid);
23    Serial.println("Aguarde");
24    
25    reconectWiFi();
26}
27
28void reconnectMQTT() 
29{
30    while  (!client.connected()) 
31    {
32        Serial.print("* Tentando se conectar  ao MQTT Sever: ");
33        Serial.println(mqtt_server);
34        
35        if  (client.connect(id_mqtt)) 
36        {
37            Serial.println("Conectado  com sucesso ao MQTT Server!");
38            client.subscribe(topico_subscribe);  
39        } 
40        else 
41        {
42            Serial.println("Falha  ao reconectar no Servidor.");
43            Serial.println("Havera nova tentatica  de conexao em 2s");
44            delay(2000);
45        }
46    }
47}
48
49void  reconectWiFi() 
50{
51    if (WiFi.status() == WL_CONNECTED)
52        return;
53        
54    WiFi.begin(ssid, password); 
55    
56    while (WiFi.status()  != WL_CONNECTED) 
57    {
58        delay(100);
59        Serial.print(".");
60    }
61  
62    Serial.println();
63    Serial.print("Conectado com sucesso  na rede ");
64    Serial.print(ssid);
65    Serial.println("IP obtido: ");
66    Serial.println(WiFi.localIP());
67}
68
69void mqtt_callback(char* topic,  byte* payload, unsigned int length) 
70{
71    String msg;
72    char On[4]   =  {0xA0, 0x01, 0x01, 0xA2};
73    char Off[4]  = {0xA0, 0x01, 0x00, 0xA1};
74    
75    for(int i = 0; i < length; i++) 
76      {
77        char c = (char)payload[i];
78        msg += c;
79      }
80  
81    
82    if (msg.equals("L"))
83    {
84        for(int a = 0; a < 4; a ++)
85           {
86              Serial.write  (On[a]);
87              EstadoSaida = '1';
88           }
89    }
90 
91    
92    if (msg.equals("D"))
93    {
94        for(int a = 0; a < 4; a ++)
95          {
96            Serial.write (Off[a]); 
97            EstadoSaida = '0';
98          }
99    }   
100}
101
102void EnviaEstadoOutputMQTT(void)
103{
104    if (EstadoSaida  == '0')
105    client.publish(topico_publish, "Rele desligado");
106 
107    if  (EstadoSaida == '1')
108    client.publish(topico_publish, "Rele ligado");
109  
110    Serial.println("- Estado da saida PIN enviado ao broker!");
111    delay(1000);
112}
113
114void  VerificaConexoesWiFIEMQTT(void)
115{
116    if (!client.connected()) 
117        reconnectMQTT();  
118        reconectWiFi(); 
119}
120
121void setup() {
122
123  client.setServer(mqtt_server,  1883);
124  client.setCallback(mqtt_callback);
125  
126  WiFi.begin(ssid, password);   
127  
128  Serial.begin(9600);
129
130  initWiFi();  
131 
132}                                                                                                                                                                                                                                                                                                                                   
133
134void  loop() 
135{
136  VerificaConexoesWiFIEMQTT();
137  EnviaEstadoOutputMQTT();
138
139  client.loop();
140
141}
142