#include <SoftwareSerial.h>
#include “WiFiEsp.h”
#include <TimerOne.h>
#include <Wire.h>
#include <EEPROM.h>
#include <SPI.h> // RFID를 위한 SPI 라이브러리
#include <MFRC522.h>// RFID 라이브러리

#define DEBUG
#define DEBUG_WIFI
#define AP_SSID “embsystem2″
#define AP_PASS “embsystem20″
#define SERVER_NAME “192.168.1.20″
#define SERVER_PORT 5000
#define LOGID “ECO_ARD”
#define PASSWD “PASSWD”
#define CMD_SIZE 50
#define ARR_CNT 5
#define SS_PIN 53 //RFID SS(SDA:ChipSelect) PIN
#define RST_PIN 5 //RFID Reset PIN
#define led1 10
#define led2 9
#define led3 8
#define WLV_PIN1 A0
#define WLV_PIN2 A1
#define WLV_PIN3 A2

//SoftwareSerial Serial2(6, 7);
MFRC522 mfrc(SS_PIN, RST_PIN); //RFID 라이브러리
//MFRC522::MIFARE_Key key;

char eepromPw[5]; //(eeprom에 저장된)비밀번호

char sendBuf[CMD_SIZE];
bool timerIsrFlag = false;
unsigned int secCount;
int tag;

WiFiEspClient client;
int drinkslt = 0; // 음료 선택
boolean sltflag = false; // ok 수신 플래그

int CokeCount;
int FantaCount;
int SpriteCount;

int watervalue1;
int watervalue2;
int watervalue3;

int waterlv1 = 1;
int waterlv2 = 1;
int waterlv3 = 1;

int buzzflag = 0; // 부저
int Checkflag = 0; // RFID

char received;

void isr1()
{
drinkslt = 1;
// Serial2.write(“a”);
}
void isr2()
{
drinkslt = 2;
// secCount2 = 0;
// Serial2.write(“b”);
}
void isr3()
{
drinkslt = 3;
// secCount3 = 0;
// Serial2.write(“c”);
}

void setup() {
Serial.begin(9600); //DEBUG
Serial2.begin(9600);
wifi_Setup();
SPI.begin(); // SPI 시작
mfrc.PCD_Init(); // RF 모듈 시작

attachInterrupt(3, isr1, RISING); //20번
attachInterrupt(0, isr2, RISING); //2번
attachInterrupt(1, isr3, RISING); //3번

pinMode(led1, OUTPUT);
pinMode(led2, OUTPUT);
pinMode(led3, OUTPUT);

digitalWrite(led1, LOW);
digitalWrite(led2, LOW);
digitalWrite(led3, LOW);

Timer1.initialize(1000000);
Timer1.attachInterrupt(timerIsr); // timerIsr to run every 1 seconds

readEeprom();
}

void loop() {
if (client.available()) {
socketEvent();
}
if (timerIsrFlag)
{
timerIsrFlag = false;
if (!(secCount % 5))
{
if (!client.connected()) {
server_Connect();
}
}
}

//카드가 인식 안되었다면 더이상 진행하지 말고 빠져나감
if (mfrc.PICC_IsNewCardPresent())
{
if (mfrc.PICC_ReadCardSerial())
{
for (byte i = 0; i < mfrc.uid.size; i++) {
Serial.print(mfrc.uid.uidByte[i] < 0×10 ? ” 0″ : ” “);
Serial.print(mfrc.uid.uidByte[i], DEC);
}
Serial.println();
Serial2.write(‘x’);
delay(500);
mfrc.PICC_HaltA();
}
}

if (waterlv1 && drinkslt == 1)
{
if ( sltflag )
{
Serial2.write(‘a’);
delay(500);
digitalWrite(led2, LOW);
digitalWrite(led3, LOW);
sprintf(sendBuf , “[ECO_WEB]chooseok\n”);
client.write(sendBuf, strlen(sendBuf));
sltflag = false;
CokeCount++;
EEPROM.write(1, CokeCount);
drinkslt = 0;
}
}
else if (waterlv2 && drinkslt == 2)
{
if ( sltflag )
{
Serial2.write(‘b’);
delay(500);
digitalWrite(led1, LOW);
digitalWrite(led3, LOW);
sprintf(sendBuf , “[ECO_WEB]chooseok\n”);
client.write(sendBuf, strlen(sendBuf));
sltflag = false;
FantaCount++;
EEPROM.write(2, FantaCount);
drinkslt = 0;
}
}
else if (waterlv3 && drinkslt == 3)
{
if ( sltflag )
{
Serial2.write(‘c’);
delay(500);
digitalWrite(led1, LOW);
digitalWrite(led2, LOW);
sprintf(sendBuf , “[ECO_WEB]chooseok\n”);
client.write(sendBuf, strlen(sendBuf));
sltflag = false;
SpriteCount++;
EEPROM.write(3, SpriteCount);
drinkslt = 0;
}
}

if (Serial2.available())
{
received = Serial2.read();
Serial.println(received);
if (received == ‘x’)
{
sprintf(sendBuf , “[ECO_CAM]camon\n”);
client.write(sendBuf, strlen(sendBuf));
sprintf(sendBuf , “[ECO_WEB]camon\n”);
client.write(sendBuf, strlen(sendBuf));
drinkslt = 0;
}
else if (received == ‘o’)
{
digitalWrite(led3, LOW);
digitalWrite(led1, LOW);
digitalWrite(led2, LOW);
delay(100);
}
}
}

void socketEvent()
{
int i = 0;
char * pToken;
char * pArray[ARR_CNT] = {0};
char recvBuf[CMD_SIZE] = {0};
int len;

Serial.print(“socket ok “);
sendBuf[0] = ”;
len = client.readBytesUntil(‘\n’, recvBuf, CMD_SIZE);
client.flush();
#ifdef DEBUG
Serial.print(“recv : “);
Serial.println(recvBuf);
#endif
pToken = strtok(recvBuf, “[@]“);
while (pToken != NULL)
{
pArray[i] = pToken;
if (++i >= ARR_CNT)
break;
pToken = strtok(NULL, “[@]“);
}
if (!strncmp(pArray[1], ” New”, 4)) // New Connected
{
Serial.write(‘\n’);
return ;
}
else if (!strncmp(pArray[1], ” Alr”, 4)) //Already logged
{
Serial.write(‘\n’);
client.stop();
server_Connect();
return ;
}
else if (!strncmp(pArray[1], “camok”, 5)) //rfid ok
{
waterlv_check();
sltflag = true;
drinkslt = 0;
digitalWrite(led1, HIGH);
digitalWrite(led2, HIGH);
digitalWrite(led3, HIGH);
if (!waterlv1)
digitalWrite(led1, LOW);
if (!waterlv2)
digitalWrite(led2, LOW);
if (!waterlv3)
digitalWrite(led3, LOW);
if (!waterlv1 && !waterlv2 && !waterlv3)
{
Serial2.write(‘d’);
sprintf(sendBuf, “[ECO_WEB]empty\n”);
client.write(sendBuf, strlen(sendBuf));
}
return ;
}
else if (!strncmp(pArray[1], “error”, 5)) //Error
{
Serial.write(‘\n’);
Serial2.write(‘d’);
return ;
}
else if (!strncmp(pArray[1], “STATE”, 5)) //State
{
waterlv_check();
sprintf(sendBuf, “[ECO_APP]DRINK@%d@%d@%d\n”, waterlv1, waterlv2, waterlv3);
client.write(sendBuf, strlen(sendBuf));
return;
}
else if (!strncmp(pArray[1], “RENEWAL”, 7)) //Renewal
{
sprintf(sendBuf, “[ECO_APP]SELL@%d@%d@%d\n”, CokeCount, FantaCount, SpriteCount);
client.write(sendBuf, strlen(sendBuf));
return;
}
else if (!strncmp(pArray[1], “RESET”, 5)) //Count Reset
{
CokeCount = 0;
EEPROM.write(1, CokeCount);
FantaCount = 0;
EEPROM.write(2, FantaCount);
SpriteCount = 0;
EEPROM.write(3, SpriteCount);
sprintf(sendBuf, “[ECO_APP]SELL@%d@%d@%d\n”, CokeCount, FantaCount, SpriteCount);
client.write(sendBuf, strlen(sendBuf));
return;
}
else {
sprintf(sendBuf, “[%s]%s@%s\n”, pArray[0], pArray[1], pArray[2]);
}
client.write(sendBuf, strlen(sendBuf));
client.flush();

#ifdef DEBUG
Serial.print(“, send : “);
Serial.print(sendBuf);
#endif
}

void timerIsr()
{
timerIsrFlag = true;
secCount++;
}
void wifi_Setup() {
Serial3.begin(9600);
wifi_Init();
server_Connect();
}
void wifi_Init()
{
do {
WiFi.init(&Serial3);
if (WiFi.status() == WL_NO_SHIELD) {
#ifdef DEBUG_WIFI
Serial.println(“WiFi shield가 존재하지 않습니다.”);
#endif
}
else
break;
} while (1);

#ifdef DEBUG_WIFI
Serial.print(“WiFi 연결을 시도합니다.”);
//Serial.println(AP_SSID);
#endif
while (WiFi.begin(AP_SSID, AP_PASS) != WL_CONNECTED) {

#ifdef DEBUG_WIFI
Serial.print(“WiFi 연결을 시도합니다.”);
//Serial.println(AP_SSID);
#endif
}

#ifdef DEBUG_WIFI
Serial.println(“WiFi 연결에 성공하였습니다.”);
printWifiStatus();
#endif
}
int server_Connect()
{
#ifdef DEBUG_WIFI
Serial.println(“Server 연결을 시도합니다.”);

#endif

if (client.connect(SERVER_NAME, SERVER_PORT)) {
#ifdef DEBUG_WIFI
Serial.println(“Server 연결에 성공하였습니다.”);
#endif
client.print(“["LOGID":"PASSWD"]“);
}
else
{
#ifdef DEBUG_WIFI
Serial.println(“Server 연결에 실패하였습니다.”);
#endif
}
}
void printWifiStatus()
{
// print the SSID of the network you’re attached to
//Serial.print(“SSID: “);
//Serial.println(WiFi.SSID());
// print your WiFi shield’s IP address
IPAddress ip = WiFi.localIP();
//Serial.print(“IP Address: “);

Serial.println(ip);
// print the received signal strength
long rssi = WiFi.RSSI();
//Serial.print(“Signal strength (RSSI):”);
//Serial.print(rssi);
//Serial.println(” dBm”);
}

//EEPROM에 저장된 판매량을 읽어옴
void readEeprom() {
CokeCount = EEPROM.read(1);
// Serial.print(CokeCount);
FantaCount = EEPROM.read(2);
//Serial.print(FantaCount);
SpriteCount = EEPROM.read(3);
//Serial.print(SpriteCount);
}
void waterlv_check()
{
watervalue1 = analogRead(WLV_PIN1);
watervalue2 = analogRead(WLV_PIN2);
watervalue3 = analogRead(WLV_PIN3);
Serial.println(watervalue1);
if (watervalue1 >= 1000)
{
waterlv1 = 0;
}
else
{
waterlv1 = 1;
}
Serial.println(watervalue2);
if (watervalue2 >= 1000)
{
waterlv2 = 0;
}
else
{
waterlv2 = 1;
}
Serial.println(watervalue3);
if (watervalue3 >= 1000)
{
waterlv3 = 0;
}
else
{
waterlv3 = 1;
}
}

#include <SoftwareSerial.h>
#include <SPI.h>
#include <TimerOne.h>
#define buzz 5
SoftwareSerial rfid(6, 7);
bool timerIsrFlag = false;
unsigned int secCount1 = 11;
unsigned int secCount2 = 11;
unsigned int secCount3 = 11;
//static boolean selectmod1 = false; //인터럽트

char receved; // serial 통신 수신 값

int Relaypin1 = 8;
int Relaypin2 = 9;
int Relaypin3 = 10;

int buzzflag = 0; // 부저
int Checkflag = 0; // RFID

void setup()
{
// put your setup code here, to run once:
Serial.begin(9600); //DEBUG
rfid.begin(9600);
SPI.begin(); // SPI 시작

pinMode(Relaypin1, OUTPUT); // 릴레이를 출력으로 설정
pinMode(Relaypin2, OUTPUT);
pinMode(Relaypin3, OUTPUT);
Timer1.initialize(1000000);
Timer1.attachInterrupt(timerIsr);

digitalWrite(Relaypin1, HIGH);
digitalWrite(Relaypin2, HIGH);
digitalWrite(Relaypin3, HIGH);

Serial.println(“연진아 준비해라”);
}

void loop() {
if (rfid.available())
{
if (Checkflag == 0)
{
receved = rfid.read();
if (receved == ‘x’)
{
Serial.println(receved);
Serial.println(“x 재송신 후 다음 동작 대기”);
rfid.write(‘x’);
Checkflag = 1;
}
}
if (Checkflag == 1)
{
receved = rfid.read();
if (receved == ‘a’)
{
secCount1 = 0;
Serial.println(receved);
Serial.println(“물펌프a 동작”);
digitalWrite(Relaypin1, LOW); // 1채널 릴레이 ON
}
else if (receved == ‘b’)
{
secCount2 = 0;
Serial.println(receved);
Serial.println(“물펌프b 동작”);
digitalWrite(Relaypin2, LOW); // 2채널 릴레이 ON
}
else if (receved == ‘c’)
{
secCount3 = 0;
Serial.println(receved);
Serial.println(“물펌프c 동작”);
digitalWrite(Relaypin3, LOW); // 3채널 릴레이 ON
}
else if (receved == ‘d’)
{
Serial.println(receved);
Checkflag = 0;
}
}
}
if (buzzflag == 1)
{
tone(buzz, 262, 500); // 도
delay(400);
tone(buzz, 330, 500); // 미
delay(400);
tone(buzz, 392, 500); // 솔
delay(400);
tone(buzz, 523, 500); // 높은 도
delay(400);
rfid.write(‘o’);
delay(500);
Checkflag = 0;
Serial.println(Checkflag);
buzzflag = 0;
}
}

void timerIsr()
{
timerIsrFlag = true;
secCount1++;
secCount2++;
secCount3++;
if (secCount1 == 10 )
{
digitalWrite(Relaypin1, HIGH); // 1채널 릴레이
buzzflag = 1;
Serial.println(buzzflag);
}
else if (secCount2 == 10 )
{
digitalWrite(Relaypin2, HIGH); // 2채널 릴레이
buzzflag = 1;
}
else if (secCount3 == 10 )
{
digitalWrite(Relaypin3, HIGH); // 3채널 릴레이
buzzflag = 1;
}
}