|
|
//include libraries
#include <ESP8266WiFi.h>
#include <ESP8266WiFiMulti.h>
#include <ESP8266HTTPClient.h>
#include <WiFiClient.h>
#include <TridentTD_LineNotify.h>
#include <BlynkSimpleEsp8266.h>
// Uncomment SoftwareSerial for Arduino Uno or Nano.
#include <SoftwareSerial.h>
#define ARDUINO_RX D5 //should connect to TX of the Serial MP3 Player module
#define ARDUINO_TX D6 //connect to RX of the module
/*
* relay 1 power amplifier
* relay 2 ไฟไซเร็น
* relay 3 power amp ในตัววงจร
*/
#define RELAY1 D7
#define RELAY2 D6
#define RELAY3 D5
SoftwareSerial mp3(ARDUINO_RX, ARDUINO_TX);
//#define mp3 Serial3 // Connect the MP3 Serial Player to the Arduino MEGA Serial3 (14 TX3 -> RX, 15 RX3 -> TX)
BlynkTimer timer;
static int8_t Send_buf[8] = {0}; // Buffer for Send commands. // BETTER LOCALLY
static uint8_t ansbuf[10] = {0}; // Buffer for the answers. // BETTER LOCALLY
String mp3Answer; // Answer from the MP3.
//Access point credentials
const char* ssid = "IoT99";
const char* pwd = "iot0837286389";
const char* host = "http://sisatgame.ddns.net";
String get_host = "http://sisatgame.ddns.net/iot";
/************ Command byte **************************/
#define CMD_NEXT_SONG 0X01 // Play next song.
#define CMD_PREV_SONG 0X02 // Play previous song.
#define CMD_PLAY_W_INDEX 0X03
#define CMD_VOLUME_UP 0X04
#define CMD_VOLUME_DOWN 0X05
#define CMD_SET_VOLUME 0X06
#define CMD_SNG_CYCL_PLAY 0X08 // Single Cycle Play.
#define CMD_SEL_DEV 0X09
#define CMD_SLEEP_MODE 0X0A
#define CMD_WAKE_UP 0X0B
#define CMD_RESET 0X0C
#define CMD_PLAY 0X0D
#define CMD_PAUSE 0X0E
#define CMD_PLAY_FOLDER_FILE 0X0F
#define CMD_STOP_PLAY 0X16
#define CMD_FOLDER_CYCLE 0X17
#define CMD_SHUFFLE_PLAY 0x18 //
#define CMD_SET_SNGL_CYCL 0X19 // Set single cycle.
#define CMD_SET_DAC 0X1A
#define DAC_ON 0X00
#define DAC_OFF 0X01
#define CMD_PLAY_W_VOL 0X22
#define CMD_PLAYING_N 0x4C
#define CMD_QUERY_STATUS 0x42
#define CMD_QUERY_VOLUME 0x43
#define CMD_QUERY_FLDR_TRACKS 0x4e
#define CMD_QUERY_TOT_TRACKS 0x48
#define CMD_QUERY_FLDR_COUNT 0x4f
/************ Opitons **************************/
#define DEV_TF 0X02
//WiFiServer server(80); // open port 80 for server connection
/*********************************************************************/
// กำหนด interval timer
#define INTERVAL_GETDATA 1000
unsigned long time_getdata = 0;
String payload;
void sendMP3Command(char c) {
switch (c) {
case '?':
case 'h':
Serial.println("HELP ");
Serial.println(" p = Play");
Serial.println(" P = Pause");
Serial.println(" > = Next");
Serial.println(" < = Previous");
Serial.println(" + = Volume UP");
Serial.println(" - = Volume DOWN");
Serial.println(" c = Query current file");
Serial.println(" q = Query status");
Serial.println(" v = Query volume");
Serial.println(" x = Query folder count");
Serial.println(" t = Query total file count");
Serial.println(" 1 = Play folder 1");
Serial.println(" 2 = Play folder 2");
Serial.println(" 3 = Play folder 3");
Serial.println(" 4 = Play folder 4");
Serial.println(" 5 = Play folder 5");
Serial.println(" S = Sleep");
Serial.println(" W = Wake up");
Serial.println(" r = Reset");
break;
case 'p':
Serial.println("Play ");
sendCommand(CMD_PLAY, 0);
break;
case 'P':
Serial.println("Pause");
sendCommand(CMD_PAUSE, 0);
break;
case '>':
Serial.println("Next");
sendCommand(CMD_NEXT_SONG, 0);
sendCommand(CMD_PLAYING_N, 0x0000); // ask for the number of file is playing
break;
case '<':
Serial.println("Previous");
sendCommand(CMD_PREV_SONG, 0);
sendCommand(CMD_PLAYING_N, 0x0000); // ask for the number of file is playing
break;
case '+':
Serial.println("Volume Up");
sendCommand(CMD_VOLUME_UP, 0);
break;
case '-':
Serial.println("Volume Down");
sendCommand(CMD_VOLUME_DOWN, 0);
break;
case 'c':
Serial.println("Query current file");
sendCommand(CMD_PLAYING_N, 0);
break;
case 'q':
Serial.println("Query status");
sendCommand(CMD_QUERY_STATUS, 0);
break;
case 'v':
Serial.println("Query volume");
sendCommand(CMD_QUERY_VOLUME, 0);
break;
case 'x':
Serial.println("Query folder count");
sendCommand(CMD_QUERY_FLDR_COUNT, 0);
break;
case 't':
Serial.println("Query total file count");
sendCommand(CMD_QUERY_TOT_TRACKS, 0);
break;
case '1':
Serial.println("Play folder 1");
sendCommand(CMD_FOLDER_CYCLE, 0x0101);
break;
case '2':
Serial.println("Play folder 2");
sendCommand(CMD_FOLDER_CYCLE, 0x0201);
break;
case '3':
Serial.println("Play folder 3");
sendCommand(CMD_FOLDER_CYCLE, 0x0301);
break;
case '4':
Serial.println("Play folder 4");
sendCommand(CMD_FOLDER_CYCLE, 0x0401);
break;
case '5':
Serial.println("Play folder 5");
sendCommand(CMD_FOLDER_CYCLE, 0x0501);
break;
case 'S':
Serial.println("Sleep");
sendCommand(CMD_SLEEP_MODE, 0x00);
break;
case 'W':
Serial.println("Wake up");
sendCommand(CMD_WAKE_UP, 0x00);
break;
case 'r':
Serial.println("Reset");
sendCommand(CMD_RESET, 0x00);
break;
case '6' :
Serial.println("Relay1 On");
digitalWrite(D7,HIGH);
break;
case '7' :
Serial.println("Relay2 On");
digitalWrite(D8,HIGH);
break;
case '8' :
Serial.println("Relay3 On");
digitalWrite(D4,HIGH);
break;
}
}
/********************************************************************************/
/*Function decodeMP3Answer: Decode MP3 answer. */
/*Parameter:-void */
/*Return: The */
String decodeMP3Answer() {
String decodedMP3Answer = "";
decodedMP3Answer += sanswer();
switch (ansbuf[3]) {
case 0x3A:
decodedMP3Answer += " -> Memory card inserted.";
break;
case 0x3D:
decodedMP3Answer += " -> Completed play num " + String(ansbuf[6], DEC);
break;
case 0x40:
decodedMP3Answer += " -> Error";
break;
case 0x41:
decodedMP3Answer += " -> Data recived correctly. ";
break;
case 0x42:
decodedMP3Answer += " -> Status playing: " + String(ansbuf[6], DEC);
break;
case 0x48:
decodedMP3Answer += " -> File count: " + String(ansbuf[6], DEC);
break;
case 0x4C:
decodedMP3Answer += " -> Playing: " + String(ansbuf[6], DEC);
break;
case 0x4E:
decodedMP3Answer += " -> Folder file count: " + String(ansbuf[6], DEC);
break;
case 0x4F:
decodedMP3Answer += " -> Folder count: " + String(ansbuf[6], DEC);
break;
}
return decodedMP3Answer;
}
/********************************************************************************/
/*Function: Send command to the MP3 */
/*Parameter:-int8_t command */
/*Parameter:-int16_ dat parameter for the command */
void sendCommand(int8_t command, int16_t dat)
{
delay(20);
Send_buf[0] = 0x7e; //
Send_buf[1] = 0xff; //
Send_buf[2] = 0x06; // Len
Send_buf[3] = command;//
Send_buf[4] = 0x01; // 0x00 NO, 0x01 feedback
Send_buf[5] = (int8_t)(dat >> 8); //datah
Send_buf[6] = (int8_t)(dat); //datal
Send_buf[7] = 0xef; //
Serial.print("Sending: ");
for (uint8_t i = 0; i < 8; i++)
{
mp3.write(Send_buf[i]) ;
Serial.print(sbyte2hex(Send_buf[i]));
}
Serial.println();
}
/********************************************************************************/
/*Function: sbyte2hex. Returns a byte data in HEX format. */
/*Parameter:- uint8_t b. Byte to convert to HEX. */
/*Return: String */
String sbyte2hex(uint8_t b)
{
String shex;
shex = "0X";
if (b < 16) shex += "0";
shex += String(b, HEX);
shex += " ";
return shex;
}
/********************************************************************************/
/*Function: sanswer. Returns a String answer from mp3 UART module. */
/*Parameter:- uint8_t b. void. */
/*Return: String. If the answer is well formated answer. */
String sanswer(void)
{
uint8_t i = 0;
String mp3answer = "";
// Get only 10 Bytes
while (mp3.available() && (i < 10))
{
uint8_t b = mp3.read();
ansbuf[i] = b;
i++;
mp3answer += sbyte2hex(b);
}
// if the answer format is correct.
if ((ansbuf[0] == 0x7E) && (ansbuf[9] == 0xEF))
{
return mp3answer;
}
return "???: " + mp3answer;
}
void get_device_status(int device_id, String device_text,int Port)
{
HTTPClient http; //start a HTTPClinet as http
//####DO NOT USE THE SAME API as below
http.begin("http://sisatgame.ddns.net/iot/sound_status.php?device_id="+String(device_id)); //Enter your API
int httpCode = http.GET(); //pass a get request
if (httpCode > 0) { //Check the returning code
payload = http.getString(); // Store the value on varibale Payload for debugging
Serial.println(payload); //Print the payload for debugging otherwise comment both lines
http.end();
if (payload.toInt() > 0) {
switch (payload.toInt()) {
case 1 :
sendCommand(CMD_PLAY_W_INDEX, 0x01);
Serial.println("Play Sound 1");
set_device_status(7,"STOP",RELAY1);
break;
case 2 :
sendCommand(CMD_PLAY_W_INDEX, 0x02);
Serial.println("Play Sound 2");
set_device_status(7,"STOP",RELAY1);
break;
case 3 :
sendCommand(CMD_PLAY_W_INDEX, 0x03);
Serial.println("Play Sound 3");
set_device_status(7,"STOP",RELAY1);
break;
case 4 :
sendCommand(CMD_PLAY_W_INDEX, 0x04);
Serial.println("Play Sound 4");
set_device_status(7,"STOP",RELAY1);
break;
case 5 :
sendCommand(CMD_PLAY_W_INDEX, 0x05);
Serial.println("Play Sound 5");
set_device_status(7,"STOP",RELAY1);
break;
case 6 :
sendCommand(CMD_PLAY_W_INDEX, 0x06);
Serial.println("Play Sound 6");
set_device_status(7,"STOP",RELAY1);
break;
}
}
} // http code >0
} //end get_device_status
void set_device_status(int device_id, String device_text,int Port) {
HTTPClient http; //start a HTTPClinet as http
//####DO NOT USE THE SAME API as below
http.begin("http://sisatgame.ddns.net/iot/update_sound.php?device_id="+String(device_id)+"&device_value=0"); //Enter your API
//Serial.println("http://sisatgame.ddns.net/iot/update_sound.php?device_id="+String(device_id)+"&device_value=0");
int httpCode = http.GET(); //pass a get request
if (httpCode > 0) { //Check the returning code
Serial.println("UPDATE DATA COMPLETE");
}
}
void setup()
{
Serial.begin(9600);
mp3.begin(9600);
delay(500);
sendCommand(CMD_SEL_DEV, DEV_TF);
delay(500);
WiFi.begin(ssid, pwd); //connect to the network specified above
while (WiFi.status() != WL_CONNECTED) { //Wait till Wi-Fi is connected
delay(1000);
Serial.print("Connecting.."); //Print Connecting.. till connection is established
}
pinMode(D7,OUTPUT); //Relay1
pinMode(D8,OUTPUT); //Relay2
pinMode(D4,OUTPUT); //Relay3
}
void loop()
{
//==================== timer getdata from server ========================================
if(millis() > time_getdata + INTERVAL_GETDATA){
time_getdata = millis();
get_device_status(7,"sound alarm",RELAY1);
}
char c = ' ';
// If there a char on Serial call sendMP3Command to sendCommand
if ( Serial.available() )
{
c = Serial.read();
sendMP3Command(c);
}
// Check for the answer.
if (mp3.available())
{
Serial.println(decodeMP3Answer());
}
// get_device_status(1,"power amp",D7);
// get_device_status(2,"siren",D8);
// get_device_status(3,"internal amp",D4);
delay(100);
}
|
|
โพสต์ 2019-11-5 16:28:24