کنترل بی‌سیم لوازم خانگی با موبایل از طریق آردوینو و ماژول LoRa

*L1# Turn bulb ON
*L0# Turn bulb OFF
*F1# Turn fan ON
*F0# Turn fan OFF

DONE

/*
Code to receive commands from Mobile device using bluetooth functionality of RLY999 module and send these commands from one Arduino to another Arduino using LORA functionality of RYL999 Module and display complete communication on I2C LCD
by playwithcircuit.com
*/
#include <LiquidCrystal_I2C.h>
#include <SoftwareSerial.h>
// below MACROS are for LORA communication
#define REPLY_TIMEOUT_IN_MS 300
#define REPLY_END_CHAR '\n'
#define SELF_ADDRESS 0
#define TARGET_ADDRESS 1
#define MIN_CHAR_TO_RCV 1
#define WAIT_FOR_TARGET_REPLY 3000
// below MACROS and strings are for Bluetooth communication
#define START_CHAR_BT_COMM '*'
#define END_CHAR_BT_COMM '#'
#define START_CHAR_TIME_OUT_BT_COMM (3000U) // time in ms
#define END_CHAR_TIME_OUT_BT_COMM (300U) // time in ms
// these four strings can be received from bluetooth Rx pin which are transmitted by the mobile application
String sCMDLampON = "L1";
String sCMDLampOFF = "L0";
String sCMDFanON = "F1";
String sCMDFanOFF = "F0";
// save received command in this global string object
String receivedCommand;
// initialize softserial port at pin 3(Rx) and 2(Tx)
SoftwareSerial btSerial(3, 2);
// Init LCD at 0x27, 16x2
LiquidCrystal_I2C lcd(0x27, 16, 2);
void setup() {
boolean boRetVal = false;
// begin serial communication at baud 115200,n,8,1
// to communicate with the LORA functionality of module
Serial.begin(115200);
// begin soft serial communication at baud 115200,n,8,1
// to communicate with the Bluetooth functionality of module
btSerial.begin(115200);
btSerial.setTimeout(END_CHAR_TIME_OUT_BT_COMM); // set time out for readStringUntil() function
// Initialize the LCD
lcd.init();
// Turn ON the Backlight
lcd.backlight();
// Clear the display buffer
lcd.clear();
receivedCommand.reserve(50); // prevents fragmentation, as multiple times data shall be received in this string
// clear receive buffer of LORA
flushBuffer(); // clear rx data
// Reset settings to factory defaults for LORA functionality
boRetVal = boRestoreFactoryDefaults();
// setting the address of LORA
if (boRetVal == true) {
flushBuffer(); // clear rx data
boRetVal = boSetAddress();
}
if (boRetVal == true) {
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("Module Init");
lcd.setCursor(0, 1);
lcd.print("Successful");
delay(1000);
} else {
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("Module Init");
lcd.setCursor(0, 1);
lcd.print("Failed");
while (1)
;
}
}
void loop() {
String expected_reply = "DONE";
bool boRetVal = false;
flushBuffer(); // clear rx data
// get commands using BT functionality using Mobile Application
boRetVal = rcvCommand(START_CHAR_TIME_OUT_BT_COMM);
if (boRetVal == false) {
// Displaying Failed Msg
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("No BT Command");
lcd.setCursor(0, 1);
lcd.print("Received");
} else {
// check if valid command is received
if ((receivedCommand == sCMDLampON) || (receivedCommand == sCMDLampOFF) || (receivedCommand == sCMDFanON) || (receivedCommand == sCMDFanOFF)) {
// transmits receivedCommand
boRetVal = boSendData(receivedCommand);
if (boRetVal == true) {
// Displaying Sent Msg
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("Cmd Rcvd & Sent");
lcd.setCursor(0, 1);
lcd.print(receivedCommand);
delay(1000);
boRetVal = chkReply(expected_reply, REPLY_END_CHAR, WAIT_FOR_TARGET_REPLY);
if (boRetVal == true) {
// Displaying received Msg
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("Reply Received:");
lcd.setCursor(0, 1);
lcd.print(expected_reply);
} else {
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("No Reply");
lcd.setCursor(0, 1);
lcd.print("Received");
}
} else {
// Displaying Failed Msg
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("Command");
lcd.setCursor(0, 1);
lcd.print("Sending Failed");
}
} else {
// Displaying Invalid Msg
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("Invalid:");
lcd.print(receivedCommand);
lcd.setCursor(0, 1);
lcd.print("Command Received");
}
}
}
/******************************************** Function Definition Related to LORA Functionality ***********************/
void sendCrLf(void) {
Serial.write(0x0D); // Carriage Return
Serial.write(0x0A); // Line Feed
}
// clear receive buffer of LORA
void flushBuffer(void) {
while (Serial.available() > 0) {
Serial.read();
}
}
// check data on rx pin of LORA functionality
bool chkReply(String chkString, char receiveUntil, unsigned int timeout) {
String receivedString; // save received data in this string object
bool boReturnValue = false; // function's return value
// wait for reply
do {
timeout--;
delay(1); // delay of 1 ms
} while ((Serial.available() < MIN_CHAR_TO_RCV) && (timeout > 0));
if (timeout) {
// if timeout is left then a reply is received check for the string in the reply
receivedString = Serial.readStringUntil(receiveUntil);
if (receivedString.indexOf(chkString) != -1) {
boReturnValue = true;
} else {
boReturnValue = false;
}
} else {
boReturnValue = false;
}
// return result
return boReturnValue;
}
// Reset settings to factory defaults for LORA functionality
bool boRestoreFactoryDefaults(void) {
const char factoryDefaultCmd[] = "AT+FACTORY"; // command to be sent
bool boReturnValue = false; // function's return value
char downCounter = 100; // Down counter to wait for reply
String receivedString; // save received data in this string object
String chkRcvString1 = "+FACTORY";
String chkRcvString2 = "+READY";
// send command
Serial.print(factoryDefaultCmd);
sendCrLf();
// check first string in reply
boReturnValue = chkReply(chkRcvString1, REPLY_END_CHAR, REPLY_TIMEOUT_IN_MS);
if (boReturnValue == true) {
// check second string in reply
boReturnValue = chkReply(chkRcvString2, REPLY_END_CHAR, REPLY_TIMEOUT_IN_MS);
}
// return result
return boReturnValue;
}
// setting the address of LORA
bool boSetAddress(void) {
const char setAddressCmd[] = "AT+ADDRESS="; // command to be sent
bool boReturnValue = false; // function's return value
String chkRcvString = "+OK";
// send command
Serial.print(setAddressCmd);
Serial.print(SELF_ADDRESS);
sendCrLf();
// check reply
boReturnValue = chkReply(chkRcvString, REPLY_END_CHAR, REPLY_TIMEOUT_IN_MS);
// return result
return boReturnValue;
}
// Send data to LORA in command form
bool boSendData(String data) {
const char sendDataCmd[] = "AT+SEND="; // command to be sent
bool boReturnValue = false; // function's return value
String chkRcvString = "+OK";
// send command
Serial.print(sendDataCmd);
Serial.print(TARGET_ADDRESS);
Serial.print(',');
Serial.print(data.length());
Serial.print(',');
Serial.print(data);
sendCrLf();
// check reply
boReturnValue = chkReply(chkRcvString, REPLY_END_CHAR, REPLY_TIMEOUT_IN_MS);
// return result
return boReturnValue;
}
/******************************************** Function Definition Related to BT Functionality *************************/
// Receive Command from Rx pin of Bluetooth functionality
bool rcvCommand(unsigned int timeout) {
bool boReturnValue = false; // function's return value
unsigned long startTime;
// wait for reply
do {
timeout--;
delay(1); // delay of 1 ms
if (((btSerial.available() >= MIN_CHAR_TO_RCV) && (btSerial.read() == START_CHAR_BT_COMM)) || (timeout == 0)) {
break;
}
} while (1);
// if start character is received within time then timeout will be greater than or equal to 1
if (timeout) {
startTime = millis();
receivedCommand = btSerial.readStringUntil(END_CHAR_BT_COMM);
if ((millis() - startTime) <= END_CHAR_TIME_OUT_BT_COMM) {
boReturnValue = true; // it means in readStringUntil() function '#' is received
} else {
boReturnValue = false; // it means in readStringUntil() function timeout has occurred
}
} else {
boReturnValue = false; // it means get character timeout has occured
}
// return result
return boReturnValue;
}

/*
Code to receive commands to control the appliances from another Arduino using RLYR999 Module and send "DONE" in reply after implementing the required task and display the communication and tasks over I2C LCD.
by playwithcircuit.com
*/
#include <LiquidCrystal_I2C.h>
// below MACROS are for LORA communication
#define REPLY_TIMEOUT_IN_MS 300
#define REPLY_END_CHAR '\n'
#define CMD_END_CHAR '\n'
#define MODULE_ADDRESS 1
#define CONTROLLER_ADDRESS 0
#define MIN_CHAR_TO_RCV 1
#define WAIT_FOR_REQUEST 3000
// these four commands can be received from controller module
String sCMDLampON = "L1";
String sCMDLampOFF = "L0";
String sCMDFanON = "F1";
String sCMDFanOFF = "F0";
// save received command in this global string object
String receivedCommand;
// Init LCD at 0x27, 16x2
LiquidCrystal_I2C lcd(0x27, 16, 2);
// Appliance Control MACROS
#define LAMP_CTRL_PIN 11
#define FAN_CTRL_PIN 12
#define LAMP_ON() digitalWrite(LAMP_CTRL_PIN, 0)
#define LAMP_OFF() digitalWrite(LAMP_CTRL_PIN, 1)
#define FAN_ON() digitalWrite(FAN_CTRL_PIN, 0)
#define FAN_OFF() digitalWrite(FAN_CTRL_PIN, 1)
void setup() {
boolean boRetVal = false;
// begin serial communication at baud 115200,n,8,1
// to communicate with the RF module
Serial.begin(115200);
// Initialize the LCD
lcd.init();
// Turn ON the Backlight
lcd.backlight();
// Clear the display buffer
lcd.clear();
// initialize appliances pins and turn off
pinMode(LAMP_CTRL_PIN, OUTPUT);
pinMode(FAN_CTRL_PIN, OUTPUT);
LAMP_OFF();
FAN_OFF();
receivedCommand.reserve(50); // prevents fragmentation, as multiple times data shall be received in this string
delay(1000);
flushBuffer(); // clear rx data
// Reset settings to factory defaults
boRetVal = boRestoreFactoryDefaults();
// setting the address if reset successfully
if (boRetVal == true) {
flushBuffer(); // clear rx data
boRetVal = boSetAddress();
}
if (boRetVal == true) {
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("Module Init");
lcd.setCursor(0, 1);
lcd.print("Successful");
delay(1000);
} else {
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("Module Init");
lcd.setCursor(0, 1);
lcd.print("Failed");
while (1)
;
}
}
void loop() {
String expected_reply = "DONE";
bool boRetVal = false;
// check string sent by controller
boRetVal = rcvCommand(CMD_END_CHAR, WAIT_FOR_REQUEST);
if (boRetVal == false) {
// Displaying Failed Msg
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("No Command");
lcd.setCursor(0, 1);
lcd.print("Received");
} else {
// check if valid command is received
if ((receivedCommand == sCMDLampON) || (receivedCommand == sCMDLampOFF) || (receivedCommand == sCMDFanON) || (receivedCommand == sCMDFanOFF)) {
// Implement receivedCommand
vImplementTask(receivedCommand);
// Displaying Sent Msg
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("Command Received");
lcd.setCursor(0, 1);
lcd.print("Task Done");
delay(1000);
// transmits receivedCommand
boRetVal = boSendData(expected_reply);
if (boRetVal == true) {
// Displaying Sent Msg
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("Reply Sent");
} else {
// Displaying Failed Msg
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("Reply");
lcd.setCursor(0, 1);
lcd.print("Sending Failed");
}
delay(1000);
} else {
// Displaying Invalid Msg
lcd.clear();
lcd.setCursor(0, 0);
lcd.print("Invalid:");
lcd.print(receivedCommand);
lcd.setCursor(0, 1);
lcd.print("Command Received");
}
}
}
void sendCrLf(void) {
Serial.write(0x0D); // Carriage Return
Serial.write(0x0A); // Line Feed
}
void flushBuffer(void) {
while (Serial.available() > 0) {
Serial.read();
}
}
bool rcvCommand(char receiveUntil, unsigned int timeout) {
bool boReturnValue = false; // function's return value
unsigned long startTime;
int firstComma;
int secondComma;
int thirdComma;
String data;
// wait for reply
do {
timeout--;
delay(1); // delay of 1 ms
} while ((Serial.available() < MIN_CHAR_TO_RCV) && (timeout > 0));
if (timeout) {
startTime = millis();
// if timeout is left then a reply is received check for the string in the reply
data = Serial.readStringUntil(receiveUntil);
if ((millis() - startTime) <= timeout) {
boReturnValue = true; // it means in readStringUntil() function receiveUntil character is received
// as the data will be in form of "+RCV=0,2,F1,-88,11" we need to extract command between second and third comma
firstComma = data.indexOf(',');
secondComma = data.indexOf(',', firstComma + 1);
thirdComma = data.indexOf(',', secondComma + 1);
// extract value between 2nd and 3rd comma
receivedCommand = data.substring(secondComma + 1, thirdComma);
} else {
boReturnValue = false; // it means in readStringUntil() function timeout has occurred
}
} else {
boReturnValue = false; // it means get character timeout has occured
}
// return result
return boReturnValue;
}
bool chkReply(String chkString, char receiveUntil, unsigned int timeout) {
String receivedString; // save received data in this string object
bool boReturnValue = false; // function's return value
// wait for reply
do {
timeout--;
delay(1); // delay of 1 ms
} while ((Serial.available() < MIN_CHAR_TO_RCV) && (timeout > 0));
if (timeout) {
// if timeout is left then a reply is received check for the string in the reply
receivedString = Serial.readStringUntil(receiveUntil);
if (receivedString.indexOf(chkString) != -1) {
boReturnValue = true;
} else {
boReturnValue = false;
}
} else {
boReturnValue = false;
}
// return result
return boReturnValue;
}
bool boRestoreFactoryDefaults(void) {
const char factoryDefaultCmd[] = "AT+FACTORY"; // command to be sent
bool boReturnValue = false; // function's return value
char downCounter = 100; // Down counter to wait for reply
String receivedString; // save received data in this string object
String chkRcvString1 = "+FACTORY";
String chkRcvString2 = "+READY";
// send command
Serial.print(factoryDefaultCmd);
sendCrLf();
// check first string in reply
boReturnValue = chkReply(chkRcvString1, REPLY_END_CHAR, REPLY_TIMEOUT_IN_MS);
if (boReturnValue == true) {
// check second string in reply
boReturnValue = chkReply(chkRcvString2, REPLY_END_CHAR, REPLY_TIMEOUT_IN_MS);
}
// return result
return boReturnValue;
}
bool boSetAddress(void) {
const char setAddressCmd[] = "AT+ADDRESS="; // command to be sent
bool boReturnValue = false; // function's return value
String chkRcvString = "+OK";
// send command
Serial.print(setAddressCmd);
Serial.print(MODULE_ADDRESS);
sendCrLf();
// check reply
boReturnValue = chkReply(chkRcvString, REPLY_END_CHAR, REPLY_TIMEOUT_IN_MS);
// return result
return boReturnValue;
}
bool boSendData(String data) {
const char sendDataCmd[] = "AT+SEND="; // command to be sent
bool boReturnValue = false; // function's return value
String chkRcvString = "+OK";
// send command
Serial.print(sendDataCmd);
Serial.print(CONTROLLER_ADDRESS);
Serial.print(',');
Serial.print(data.length());
Serial.print(',');
Serial.print(data);
sendCrLf();
// check reply
boReturnValue = chkReply(chkRcvString, REPLY_END_CHAR, REPLY_TIMEOUT_IN_MS);
// return result
return boReturnValue;
}
// this function is used to control the relay which controls the appliances using digital pins
void vImplementTask(String data) {
if (receivedCommand == sCMDLampON) {
LAMP_ON();
} else if (receivedCommand == sCMDLampOFF) {
LAMP_OFF();
} else if (receivedCommand == sCMDFanON) {
FAN_ON();
} else if (receivedCommand == sCMDFanOFF) {
FAN_OFF();
}
}