#include #include #include LiquidCrystal_I2C lcd(0x27, 16, 2); #define PIN_B1_EMR 13 #define PIN_B1_URG 16 #define PIN_B1_RTN 17 #define PIN_B2_EMR 18 #define PIN_B2_URG 19 #define PIN_B2_RTN 23 #define PIN_B3_EMR 32 #define PIN_B3_URG 33 #define PIN_B3_RTN 34 #define PIN_B4_EMR 35 #define PIN_B4_URG 5 #define PIN_B4_RTN 2 #define PIN_ACK 4 #define PIN_LED_R 25 #define PIN_LED_Y 26 #define PIN_LED_G 27 #define PIN_BUZZER 15 #define PRIORITY_EMERGENCY 3 #define PRIORITY_URGENT 2 #define PRIORITY_ROUTINE 1 #define QUEUE_MAX 16 #define NUM_BEDS 4 const char* PRIORITY_NAMES[] = {"", "ROUTINE", "URGENT ", "EMRGNCY"}; const char* BED_NAMES[] = {"Bed1", "Bed2", "Bed3", "Bed4"}; const int BUTTON_PINS[NUM_BEDS][3] = { {PIN_B1_EMR, PIN_B1_URG, PIN_B1_RTN}, {PIN_B2_EMR, PIN_B2_URG, PIN_B2_RTN}, {PIN_B3_EMR, PIN_B3_URG, PIN_B3_RTN}, {PIN_B4_EMR, PIN_B4_URG, PIN_B4_RTN} }; const int BUTTON_PRIORITIES[3] = { PRIORITY_EMERGENCY, PRIORITY_URGENT, PRIORITY_ROUTINE }; struct Call { int bed; int priority; unsigned long timestamp; }; Call queue[QUEUE_MAX]; int queueSize = 0; struct BedState { bool active; int currentPriority; }; BedState bedStates[NUM_BEDS]; volatile bool isrBed[NUM_BEDS][3] = { {false, false, false}, {false, false, false}, {false, false, false}, {false, false, false} }; volatile bool isrAck = false; unsigned long lastBuzzerTick = 0; bool buzzerOn = false; unsigned long lastAckTime = 0; portMUX_TYPE mux = portMUX_INITIALIZER_UNLOCKED; void IRAM_ATTR isr_b1e() { portENTER_CRITICAL_ISR(&mux); isrBed[0][0] = true; portEXIT_CRITICAL_ISR(&mux); } void IRAM_ATTR isr_b1u() { portENTER_CRITICAL_ISR(&mux); isrBed[0][1] = true; portEXIT_CRITICAL_ISR(&mux); } void IRAM_ATTR isr_b1r() { portENTER_CRITICAL_ISR(&mux); isrBed[0][2] = true; portEXIT_CRITICAL_ISR(&mux); } void IRAM_ATTR isr_b2e() { portENTER_CRITICAL_ISR(&mux); isrBed[1][0] = true; portEXIT_CRITICAL_ISR(&mux); } void IRAM_ATTR isr_b2u() { portENTER_CRITICAL_ISR(&mux); isrBed[1][1] = true; portEXIT_CRITICAL_ISR(&mux); } void IRAM_ATTR isr_b2r() { portENTER_CRITICAL_ISR(&mux); isrBed[1][2] = true; portEXIT_CRITICAL_ISR(&mux); } void IRAM_ATTR isr_b3e() { portENTER_CRITICAL_ISR(&mux); isrBed[2][0] = true; portEXIT_CRITICAL_ISR(&mux); } void IRAM_ATTR isr_b3u() { portENTER_CRITICAL_ISR(&mux); isrBed[2][1] = true; portEXIT_CRITICAL_ISR(&mux); } void IRAM_ATTR isr_b3r() { portENTER_CRITICAL_ISR(&mux); isrBed[2][2] = true; portEXIT_CRITICAL_ISR(&mux); } void IRAM_ATTR isr_b4e() { portENTER_CRITICAL_ISR(&mux); isrBed[3][0] = true; portEXIT_CRITICAL_ISR(&mux); } void IRAM_ATTR isr_b4u() { portENTER_CRITICAL_ISR(&mux); isrBed[3][1] = true; portEXIT_CRITICAL_ISR(&mux); } void IRAM_ATTR isr_b4r() { portENTER_CRITICAL_ISR(&mux); isrBed[3][2] = true; portEXIT_CRITICAL_ISR(&mux); } void IRAM_ATTR isr_ack() { portENTER_CRITICAL_ISR(&mux); isrAck = true; portEXIT_CRITICAL_ISR(&mux); } void sortQueue() { for (int i = 0; i < queueSize - 1; i++) { for (int j = 0; j < queueSize - i - 1; j++) { bool swap = false; if (queue[j].priority < queue[j + 1].priority) swap = true; else if (queue[j].priority == queue[j + 1].priority && queue[j].timestamp > queue[j + 1].timestamp) swap = true; if (swap) { Call temp = queue[j]; queue[j] = queue[j + 1]; queue[j + 1] = temp; } } } } void removeByBed(int bed) { for (int i = 0; i < queueSize; i++) { if (queue[i].bed == bed) { for (int j = i; j < queueSize - 1; j++) queue[j] = queue[j + 1]; queueSize--; return; } } } void addCall(int bed, int priority) { BedState* state = &bedStates[bed]; if (state->active) { if (priority <= state->currentPriority) return; removeByBed(bed); } if (queueSize >= QUEUE_MAX) return; queue[queueSize].bed = bed; queue[queueSize].priority = priority; queue[queueSize].timestamp = millis(); queueSize++; state->active = true; state->currentPriority = priority; sortQueue(); } void acknowledge() { if (queueSize == 0) return; int bed = queue[0].bed; bedStates[bed].active = false; bedStates[bed].currentPriority = 0; for (int i = 0; i < queueSize - 1; i++) queue[i] = queue[i + 1]; queueSize--; } void updateDisplay() { lcd.setCursor(0, 0); if (queueSize == 0) { lcd.print(" All Clear "); lcd.setCursor(0, 1); lcd.print(" No active calls"); return; } Call top = queue[0]; lcd.print(BED_NAMES[top.bed]); lcd.print(" "); lcd.print(PRIORITY_NAMES[top.priority]); lcd.print(" "); lcd.setCursor(0, 1); lcd.print("Queue:"); lcd.print(queueSize); if (queueSize > 1) { lcd.print(" Nxt:"); lcd.print(BED_NAMES[queue[1].bed]); lcd.print(" "); } else { lcd.print(" Only call "); } } void updateLEDs() { digitalWrite(PIN_LED_R, LOW); digitalWrite(PIN_LED_Y, LOW); digitalWrite(PIN_LED_G, LOW); if (queueSize == 0) return; switch (queue[0].priority) { case PRIORITY_EMERGENCY: digitalWrite(PIN_LED_R, HIGH); break; case PRIORITY_URGENT: digitalWrite(PIN_LED_Y, HIGH); break; case PRIORITY_ROUTINE: digitalWrite(PIN_LED_G, HIGH); break; } } void updateBuzzer() { unsigned long now = millis(); if (queueSize == 0) { noTone(PIN_BUZZER); buzzerOn = false; return; } switch (queue[0].priority) { case PRIORITY_EMERGENCY: if (now - lastBuzzerTick >= 200) { lastBuzzerTick = now; buzzerOn = !buzzerOn; if (buzzerOn) tone(PIN_BUZZER, 2500); else noTone(PIN_BUZZER); } break; case PRIORITY_URGENT: if (now - lastBuzzerTick >= 1500) { lastBuzzerTick = now; tone(PIN_BUZZER, 1200, 150); } break; case PRIORITY_ROUTINE: if (now - lastBuzzerTick >= 4000) { lastBuzzerTick = now; tone(PIN_BUZZER, 600, 250); } break; } } void setup() { Serial.begin(115200); Wire.begin(21, 22); lcd.init(); lcd.backlight(); lcd.setCursor(0, 0); lcd.print("Nurse Call Sys"); lcd.setCursor(0, 1); lcd.print("Initializing..."); delay(1500); pinMode(PIN_LED_R, OUTPUT); pinMode(PIN_LED_Y, OUTPUT); pinMode(PIN_LED_G, OUTPUT); pinMode(PIN_BUZZER, OUTPUT); pinMode(PIN_ACK, INPUT_PULLUP); for (int i = 0; i < NUM_BEDS; i++) { for (int j = 0; j < 3; j++) pinMode(BUTTON_PINS[i][j], INPUT_PULLUP); bedStates[i].active = false; bedStates[i].currentPriority = 0; } attachInterrupt(digitalPinToInterrupt(PIN_B1_EMR), isr_b1e, FALLING); attachInterrupt(digitalPinToInterrupt(PIN_B1_URG), isr_b1u, FALLING); attachInterrupt(digitalPinToInterrupt(PIN_B1_RTN), isr_b1r, FALLING); attachInterrupt(digitalPinToInterrupt(PIN_B2_EMR), isr_b2e, FALLING); attachInterrupt(digitalPinToInterrupt(PIN_B2_URG), isr_b2u, FALLING); attachInterrupt(digitalPinToInterrupt(PIN_B2_RTN), isr_b2r, FALLING); attachInterrupt(digitalPinToInterrupt(PIN_B3_EMR), isr_b3e, FALLING); attachInterrupt(digitalPinToInterrupt(PIN_B3_URG), isr_b3u, FALLING); attachInterrupt(digitalPinToInterrupt(PIN_B3_RTN), isr_b3r, FALLING); attachInterrupt(digitalPinToInterrupt(PIN_B4_EMR), isr_b4e, FALLING); attachInterrupt(digitalPinToInterrupt(PIN_B4_URG), isr_b4u, FALLING); attachInterrupt(digitalPinToInterrupt(PIN_B4_RTN), isr_b4r, FALLING); attachInterrupt(digitalPinToInterrupt(PIN_ACK), isr_ack, FALLING); esp_task_wdt_config_t wdtConfig = { .timeout_ms = 5000, .idle_core_mask = 0, .trigger_panic = true }; esp_task_wdt_init(&wdtConfig); esp_task_wdt_add(NULL); lcd.clear(); lcd.setCursor(0, 0); lcd.print("System Ready"); lcd.setCursor(0, 1); lcd.print("4 Beds | Q: 0"); } void loop() { esp_task_wdt_reset(); for (int i = 0; i < NUM_BEDS; i++) { for (int j = 0; j < 3; j++) { bool fired = false; portENTER_CRITICAL(&mux); if (isrBed[i][j]) { isrBed[i][j] = false; fired = true; } portEXIT_CRITICAL(&mux); if (fired) addCall(i, BUTTON_PRIORITIES[j]); } } bool ackFired = false; portENTER_CRITICAL(&mux); if (isrAck) { isrAck = false; ackFired = true; } portEXIT_CRITICAL(&mux); if (ackFired) { unsigned long now = millis(); if (now - lastAckTime > 300) { lastAckTime = now; acknowledge(); } } updateDisplay(); updateLEDs(); updateBuzzer(); delay(50); }