Smart Switch Having 6 Outputs & 5 Inputs

Hello Makers,
I have made this smart switch using an ESP8266 and Raspberry Pi, which has the capacity of controlling 6 electrical devices.
Introduction video :-

Hardware: ESP8266, Raspberry PI3B, SSR relay board, optocoupler, MINI SMPS

Software: Mosquitto MQTT broker, Node-RED, Arduino IDE

Library: PubSub client (Arduino), node-red-contrib-alexa-home-skil

All devices/relays can operate using conventional switch gives me freedom to install it in my existing switch board without changing wiring.

All devices/relays can controlled via web page.

All devices/relays can controlled via Android application (MQTT-Dash).

All devices/relays can controlled via voice command.

Raspberry Pi used as MQTT broker and Node-RED used for to make dashboard & provide Alexa connectivity.

All devices/relays can also control using "OK Google" using tasker but currently some part of node red is not ready so I didn't mentioned here.

Step 1: Making of Custom Made PCB Using Esp8266

I have used Esp8266 as MCU. It has 11 usable io pins. From which I used 6 pins as output & 5 pins as inputs.
Remark fo D8 pin:-
Pin D8 required to be pulled low during esp bootup. So i have used it as output. But if I directly connect it with relay board then it creates problem, because connecting relay board to Gpio pin pulls that pin high & in case of Gpio D8 esp will not boot.
So I used pc817 optocoupler to resolve this problem.

Remark for Rx & TX pin :- until all testing not competed I had commented both this pin in code as this pins are used for fleshing & debugging of esp.

After final resting I removed commenting "//" so Rx & TX pin started working as output.(as per code )

For powering up esp I used Easy power make minismps. Having 230vac to 5 V dc 3 Watt. (600 ma).

For relay board connection I provided 8 pin female header. One VCC one pin for ground & remaining 6 for relay switching.

For all 5 input I provided pulldown resistor & provide 6 pin female header.
One Vcc pin & 5 for inputs.

Step 2: Connecting Relay Board

I have used 8 channel SSR relay board for switching my applieances. As shown in image I made belt using male female header & connect esp board with relay board.
As I have used only 6 Outputs 2 relay are spare.

Step 3: Connecting Esp Board With Relay Board.

After making esp board I had commectd both board using custom made male female header cable. & Attached both boards using hot glue.
As shown in attached image.

Step 4: Raspberry Pi Setup. Mosquito & Node Red

I flesh 32 GB SD card with raspbian is & indertedi Raspberry Pi 3B.
As node Red & mosquito is inbuilt in raspbian I just boot RPI & update & Upgrade it for to get all updates.
I had prepared nodered sketch which I attached.

Main hart of this project is mosquito Mqtt broker.
As it is inbuilt on raspbian I didn't have to do anything else.

I have used mqtt sub/pub tool to read & write messages of esp8266.

I used nodered Alexa contrib library written by Ben Hardill. Using which I integrated Alexa for voice command.

For making Dash board I used nodered dashboard tool.

Step 5: Arduino Code for Esp8266

In Arduino ide I wrote sketch using mosquito pubsub library written by "Nick O'Leary" guy who also wrote nodered.

Esp will connect local network on which my raspberry Pi & Alexa connected.
Esp subscribe topics & published on topics as mentioned in Arduino code.
If any input pin state change fore more than 20 Milli second then corresponding output toggles & esp published new state of output.
+++++ Arduino code++++++
#include
#include
// Update these with values suitable for your network.
const char* ssid = "Your network id";
const char* password = "your password";
const char* mqtt_server = "192.168.1.165"; //IP of your mqtt server(Raspberry PI)

//Output defination
byte night_lamp = 16 ; // D0
byte front_light = 0 ; // D3
byte rear_light = 2 ; // D4
byte fan = 15 ; // D8
byte socket1 = 3 ; // RX
byte socket2 = 1 ; // TX

//Input defination
byte night_lamp_in = 5 ; // D1
byte front_light_in = 4 ; // D2
byte rear_light_in = 14 ; // D5
byte socket_in = 12 ; // D6
byte fan_in = 13 ; // D7

//Input Bit status by reading input pin status
byte night_lamp_sts;
byte front_light_sts;
byte rear_light_sts;
byte fan_sts;
byte socket_sts;

//Input debounse delay to avoide unwanted switching
unsigned long night_lamp_sts_dly;
unsigned long front_light_sts_dly;
unsigned long rear_light_sts_dly;
unsigned long fan_sts_dly;
unsigned long socket_sts_dly;

//Output Setpoint
int night_lamp_stpt;
int front_light_stpt;
int rear_light_stpt;
int fan_stpt;
int socket1_stpt;
int socket2_stpt;

WiFiClient espClient;
PubSubClient client(espClient);
char msg[50]; // to storing MQTT message

void setup() {
//Output Setup
pinMode ( night_lamp , OUTPUT );
pinMode ( front_light , OUTPUT );
pinMode ( rear_light , OUTPUT );
pinMode ( fan , OUTPUT );
pinMode ( socket1 , OUTPUT );
pinMode ( socket2 , OUTPUT );

//Output initialised
digitalWrite ( night_lamp , HIGH );
digitalWrite ( front_light , HIGH );
digitalWrite ( rear_light , HIGH );
digitalWrite ( fan , HIGH );
digitalWrite ( socket1 ,HIGH );
digitalWrite ( socket2 ,HIGH );

//Input Setup
pinMode ( night_lamp_in , INPUT );
pinMode ( front_light_in , INPUT );
pinMode ( rear_light_in , INPUT );
pinMode ( socket_in , INPUT );
pinMode ( fan_in , INPUT );

//Printing initial input status **** do not connect rx & tx pin to relay during debugging ***
/*
Serial.begin(115200);
Serial.println();
Serial.print ("night_lamp_sts "); Serial.println ( night_lamp_sts );
Serial.print ("front_light_sts "); Serial.println ( front_light_sts );
Serial.print ("rear light_sts "); Serial.println ( rear_light_sts );
Serial.print ("fan_sts "); Serial.println ( fan_sts );
Serial.print ("socket_sts "); Serial.println ( socket_sts );
*/

//Setup WiFI
setup_wifi();
client.setServer(mqtt_server, 1883);
client.setCallback(callback);
night_lamp_sts_dly = millis();
front_light_sts_dly = millis();
rear_light_sts_dly = millis();
fan_sts_dly = millis();
socket_sts_dly = millis();

//Initialised input status bit
night_lamp_sts = digitalRead(night_lamp_in);
front_light_sts = digitalRead(front_light_in);
rear_light_sts = digitalRead(rear_light_in);
fan_sts = digitalRead(fan_in);
socket_sts = !digitalRead(socket_sts);
}

// XXXXXXXXXX uncomment Serial.print statement for debugging purpose.

void setup_wifi() {
delay(10);
// We start by connecting to a WiFi network
//Serial.println();
//Serial.print("Connecting to ");
//Serial.println(ssid);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
//Serial.print(".");
}
//Serial.println("");
//Serial.println("WiFi connected");
//Serial.println("IP address: ");
//Serial.println(WiFi.localIP());
}

void callback(char* topic, byte* payload, unsigned int length) {
String payloadval_str;
int payloadval_int, payload_pwm;
for (int i = 0; i < length; i++) payloadval_str += (char)payload[i];
payloadval_int = payloadval_str.toInt();
payload_pwm = map(payloadval_int, 100, 0, 0, 1024);
recieved_cmd(topic, payloadval_int, payload_pwm);
//Serial.println("Message Recieved");Serial.print(topic);Serial.print(" ");Serial.println(payloadval_int);
}

void reconnect() {
// Loop until we're reconnected
if (!client.connected()) {
//Serial.print("Attempting MQTT connection...");
// Attempt to connect
if (client.connect("ESP8266Client")) {
//Serial.println("connected");
// Once connected, publish an announcement...
client.publish("ashish/bed1/sw1/", "SB1 is Connected");
// ... and resubscribe
client.subscribe("ashish/bed1/sw1/cmd/#");
} else {
//Serial.print("failed, rc=");
//Serial.print(client.state());
//Serial.println(" try again in 5 seconds");
// Wait 5 seconds before retrying
}
}
//Serial.println("Pub start");
snprintf (msg, 1, "0");
client.publish("ashish/bed1/sw1/initialised", msg);
//Serial.print(msg);
}
void loop() {
if (!client.connected()) {
reconnect();
}
else client.loop();
if (digitalRead(front_light_in) != front_light_sts) front_light_call();
else front_light_sts_dly = millis();
if (digitalRead(rear_light_in) != rear_light_sts) rear_light_call();
else rear_light_sts_dly = millis();
if (digitalRead(fan_in) != fan_sts) fan_call();
else fan_sts_dly = millis();
if (digitalRead(night_lamp_in) != night_lamp_sts) night_lamp_call();
else night_lamp_sts_dly = millis();
if (digitalRead(socket_in) != socket_sts) socket_call();
else socket_sts_dly = millis();
}
void recieved_cmd(String in_str, int in_int1, int in_int2){ // this function handle all MQTT request
if (in_str == "ashish/bed1/sw1/cmd/front_light") {
//Serial.print("MQTT >> Front Light "); Serial.println(in_int2);
front_light_stpt = in_int1;
analogWrite(front_light, in_int2);
}
if (in_str == "ashish/bed1/sw1/cmd/rear_light") {
//Serial.print("MQTT >> Rear Light "); Serial.println(in_int2);
rear_light_stpt = in_int1;
analogWrite(rear_light, in_int2);
}
if (in_str == "ashish/bed1/sw1/cmd/fan") {
//Serial.print("MQTT >> Fan Light "); Serial.println(in_int2);
fan_stpt = in_int1;
analogWrite(fan, in_int2);
}
if (in_str == "ashish/bed1/sw1/cmd/socket1") {
//Serial.print("MQTT >> Socket1 "); Serial.println(in_int2);
socket1_stpt = in_int1;
analogWrite(socket1, in_int2);
}
if (in_str == "ashish/bed1/sw1/cmd/socket2") {
//Serial.print("MQTT >> Socket2 "); Serial.println(in_int2);
socket2_stpt = in_int1;
analogWrite(socket2, in_int2);
}
if (in_str == "ashish/bed1/sw1/cmd/night_lamp") {
//Serial.print("Night Lamp "); Serial.println(in_int2);
night_lamp_stpt = in_int1;
analogWrite(night_lamp, in_int2);
}
if (in_str == "ashish/bed1/sw1/cmd/all_device") {
//Serial.print("MQTT >>All Devices "); Serial.println(in_int2);
digitalWrite ( night_lamp , HIGH );
digitalWrite ( front_light , HIGH );
digitalWrite ( rear_light , HIGH );
digitalWrite ( fan , LOW );
digitalWrite ( socket1 ,HIGH );
digitalWrite ( socket2 ,HIGH );
}
}
void front_light_call(){ //This function handle hardwired switching request
if(millis() - front_light_sts_dly > 500) {
if (front_light_stpt > 0) {
front_light_stpt = 0;
client.publish("ashish/bed1/sw1/cmd/front_light", "0");
analogWrite(front_light, 0);
}
else {
front_light_stpt = 1024;
client.publish("ashish/bed1/sw1/cmd/front_light", "100");
analogWrite(front_light, 1024);
}
front_light_sts = ! front_light_sts;
}
}
void rear_light_call(){ //This function handle hardwired switching request
if (millis() - rear_light_sts_dly > 500) {
if (rear_light_stpt > 0) {
rear_light_stpt = 0;
client.publish("ashish/bed1/sw1/cmd/rear_light", "0");
analogWrite(rear_light, 0);
}
else {
rear_light_stpt = 1024;
client.publish("ashish/bed1/sw1/cmd/rear_light", "100");
analogWrite(rear_light, 1024);
}
rear_light_sts = ! rear_light_sts;
}
}
void night_lamp_call(){ //This function handle hardwired switching request
if (millis() - night_lamp_sts_dly > 500) {
if (night_lamp_stpt > 0) {
night_lamp_stpt = 0;
client.publish("ashish/bed1/sw1/cmd/night_lamp", "0");
analogWrite(night_lamp, 0);
}
else {
night_lamp_stpt = 1024;
client.publish("ashish/bed1/sw1/cmd/night_lamp", "100");
analogWrite(night_lamp, 1024);
}
night_lamp_sts = ! night_lamp_sts;
}
}
void fan_call(){ //This function handle hardwired switching request
if (millis() - fan_sts_dly > 500) {
if (fan_stpt > 0) {
fan_stpt = 1024;
client.publish("ashish/bed1/sw1/cmd/fan", "0");
analogWrite(fan, fan_stpt);
}
else {
fan_stpt = 1024;
client.publish("ashish/bed1/sw1/cmd/fan", "100");
analogWrite(fan, fan_stpt);
}
fan_sts = ! fan_sts;
}
}
void socket_call(){ //This function handle hardwired switching request
if (millis() - socket_sts_dly > 500) {
if (socket1_stpt > 0 and socket2_stpt == 0 ) {//10
socket1_stpt = 1024;
socket2_stpt = 1024;
client.publish("ashish/bed1/sw1/cmd/socket1", "100");
client.publish("ashish/bed1/sw1/cmd/socket2", "100");
}
else if (socket1_stpt == 0 and socket2_stpt > 0 ) {//01
socket1_stpt = 1024;
socket2_stpt = 1024;
client.publish("ashish/bed1/sw1/cmd/socket1", "100");
client.publish("ashish/bed1/sw1/cmd/socket2", "100");
}
else if (socket1_stpt == 0 and socket2_stpt == 0 ) {//00
socket1_stpt = 1024;
socket2_stpt = 1024;
client.publish("ashish/bed1/sw1/cmd/socket1", "100");
client.publish("ashish/bed1/sw1/cmd/socket2", "100");
}
else if (socket1_stpt > 0 and socket2_stpt > 0 ){//11
socket1_stpt = 0;
socket2_stpt = 0;
client.publish("ashish/bed1/sw1/cmd/socket1", "0");
client.publish("ashish/bed1/sw1/cmd/socket2", "0");
}
socket_sts = !socket_sts;
analogWrite(socket1, socket1_stpt);
analogWrite(socket2, socket2_stpt);
}
}