[요양보호사/보호자] coolSMS API를 사용하여 SMS 알림 기능 구현하기

build.gradle

@@ -68,7 +68,7 @@ dependencies {
     // Redis
     implementation 'org.springframework.boot:spring-boot-starter-data-redis'
 
-    // SQS
+    // Amazon SQS
     implementation platform("io.awspring.cloud:spring-cloud-aws-dependencies:3.0.1")
     implementation 'io.awspring.cloud:spring-cloud-aws-starter-sqs'
 

src/main/java/dbdr/domain/careworker/entity/Careworker.java

@@ -100,15 +100,11 @@ public void updateAlertTime(LocalTime alertTime) {
         this.alertTime = alertTime;
     }
 
-    public void updateInstitution(Institution institution) {
-      this.institution = institution;
-    }
-
     // 요일 설정 및 조회 메서드
     public void addWorkDay(DayOfWeek day) {
         this.workDays |= day.getValue();
     }
-  
+
     // 다음 근무일 찾기
     public DayOfWeek getNextWorkingDay(DayOfWeek currentDay) {
         for (int i = 1; i <= 7; i++) { // 최대 7일을 순환하여 다음 근무일 찾기
@@ -124,4 +120,8 @@ public DayOfWeek getNextWorkingDay(DayOfWeek currentDay) {
     public boolean isWorkingOn(DayOfWeek day) {
         return (this.workDays & (1 << (day.getValue() - 1))) != 0;
     }
+
+    public void updateInstitution(Institution institution) {
+      this.institution = institution;
+    }
 }

src/main/java/dbdr/domain/careworker/service/CareworkerService.java

@@ -142,6 +142,7 @@ public CareworkerMyPageResponse updateWorkingDaysAndAlertTime(Long careworkerId,
 
         careworker.updateWorkingDays(request.getWorkingDays());
         careworker.updateAlertTime(request.getAlertTime());
+        alarmService.updateAlarmByLocalTime(request.getAlertTime(), careworker.getPhone());
 
         return toMyPageResponseDTO(careworker);
     }
@@ -189,6 +190,15 @@ public Careworker findByPhone(String phoneNumber) {
         return careworkerRepository.findByPhone(phoneNumber).orElse(null);
     }
 
+    @Transactional
+    public void updateLineUserId(String userId, String phoneNumber) {
+        Careworker careworker = findByPhone(phoneNumber);
+        careworker.updateLineUserId(userId);
+        careworkerRepository.save(careworker);
+    }
+
+
+
     private CareworkerMyPageResponse toMyPageResponseDTO(Careworker careworker) {
         return new CareworkerMyPageResponse(
                 careworker.getName(),
@@ -198,13 +208,4 @@ private CareworkerMyPageResponse toMyPageResponseDTO(Careworker careworker) {
                 careworker.getWorkingDays()
         );
     }
-
-    @Transactional
-    public void updateLineUserId(String userId, String phoneNumber) {
-        Careworker careworker = findByPhone(phoneNumber);
-        careworker.updateLineUserId(userId);
-        careworkerRepository.save(careworker);
-    }
-
-
 }

src/main/java/dbdr/domain/chart/service/ChartService.java

@@ -8,6 +8,7 @@
 import dbdr.domain.chart.dto.response.ChartOverviewResponse;
 import dbdr.domain.chart.entity.Chart;
 import dbdr.domain.chart.repository.ChartRepository;
+import dbdr.domain.core.alarm.service.AlarmService;
 import dbdr.global.exception.ApplicationError;
 import dbdr.global.exception.ApplicationException;
 import java.util.List;
@@ -40,6 +41,7 @@
 import org.springframework.http.HttpMethod;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 @Service
 @RequiredArgsConstructor
@@ -50,6 +52,7 @@ public class ChartService {
     private final ChartMapper chartMapper;
     private final SummaryRepository summaryRepository;
     private final OpenAiSummarizationConfig summarizationConfig;
+    private final AlarmService alarmService;
 
     @Value("${openai.chat-completions}")
     private String chatUrl;
@@ -77,6 +80,7 @@ public void deleteChart(Long chartId) {
         chartRepository.deleteById(chartId);
     }
 
+    @Transactional
     public ChartDetailResponse saveChart(ChartDetailRequest request) {
         Chart chart = chartMapper.toEntity(request);
         Chart savedChart = chartRepository.save(chart);
@@ -87,7 +91,9 @@ public ChartDetailResponse saveChart(ChartDetailRequest request) {
                 summaryResponse.bodyManagement(), summaryResponse.recoveryTraining(),
                 summaryResponse.conditionDisease(), summaryResponse.nursingManagement(),
                 tagResponse.tag1(), tagResponse.tag2(), tagResponse.tag3()));
-        return chartMapper.toResponse(savedChart);
+        ChartDetailResponse chartDetailResponse = chartMapper.toResponse(savedChart);
+        alarmService.updateGuardianAlarmMessage(chartDetailResponse);
+        return chartDetailResponse;
     }
 
     public ChartDetailResponse updateChart(Long chartId, ChartDetailRequest request) {

src/main/java/dbdr/domain/core/alarm/service/AlarmService.java

@@ -9,6 +9,7 @@
 import org.springframework.transaction.annotation.Transactional;
 
 import dbdr.domain.careworker.entity.Careworker;
+import dbdr.domain.chart.dto.response.ChartDetailResponse;
 import dbdr.domain.core.alarm.entity.Alarm;
 import dbdr.domain.core.messaging.MessageChannel;
 import dbdr.domain.core.messaging.MessageTemplate;
@@ -17,6 +18,10 @@
 import dbdr.domain.core.alarm.repository.AlarmRepository;
 import dbdr.domain.core.messaging.service.CallSqsService;
 import dbdr.domain.guardian.entity.Guardian;
+import dbdr.domain.recipient.dto.response.RecipientResponse;
+import dbdr.domain.recipient.entity.Recipient;
+import dbdr.domain.recipient.repository.RecipientRepository;
+import dbdr.domain.recipient.service.RecipientService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
@@ -26,6 +31,7 @@
 public class AlarmService {
 	private final AlarmRepository alarmRepository;
 	private final CallSqsService callSqsService;
+	private final RecipientRepository recipientRepository;
 
 	@Transactional
 	public void createCareworkerAlarm(Careworker careworker) {
@@ -129,4 +135,38 @@ public void updateNewLineUser(String phone, String lineUserId) {
 			alarmRepository.save(alarm);
 		}
 	}
+
+	@Transactional
+	public void updateAlarmByLocalTime(LocalTime localTime, String phone) {
+		Alarm alarm = alarmRepository.findByPhone(phone).orElse(null);
+		if (alarm != null && !alarm.isSend()) {
+			alarm.setAlertTime(localTime.atDate(alarm.getAlertTime().toLocalDate()));
+			alarmRepository.save(alarm);
+		}
+	}
+
+	@Transactional
+	public void updateGuardianAlarmMessage(ChartDetailResponse chartDetailResponse) {
+		Recipient recipient = recipientRepository.findById(chartDetailResponse.recipientId()).orElse(null);
+		Alarm alarm = alarmRepository.findByPhone(recipient.getGuardian().getPhone()).orElse(null);
+
+		if (alarm != null && !alarm.isSend() && alarm.getAlertTime().isAfter(LocalDateTime.now())) {
+			// ChartDetailResponse의 데이터를 사용해 알림 메시지 생성
+			String message = MessageTemplate.CHART_UPDATED_MESSAGE.format(
+				recipient.getGuardian().getName(),
+				chartDetailResponse.conditionDisease(),
+				chartDetailResponse.bodyManagement().wash() ? "예" : "아니오",
+				chartDetailResponse.bodyManagement().bath() ? "예" : "아니오",
+				chartDetailResponse.bodyManagement().mealType(),
+				chartDetailResponse.nursingManagement().systolic(),
+				chartDetailResponse.nursingManagement().diastolic(),
+				chartDetailResponse.nursingManagement().healthTemperature(),
+				chartDetailResponse.cognitiveManagement().cognitiveHelp() ? "예" : "아니오",
+				chartDetailResponse.recoveryTraining().recoveryProgram()
+			);
+
+			alarm.setMessage(message);
+			alarmRepository.save(alarm);
+		}
+	}
 }

src/main/java/dbdr/domain/core/messaging/MessageTemplate.java

@@ -9,8 +9,14 @@ public enum MessageTemplate {
 	CAREWORKER_WELCOME_MESSAGE("%s 요양보호사님, 안녕하세요! 🌸\n 최고의 요양원 서비스 돌봄다리입니다. 🤗\n 저희와 함께 해주셔서 정말 감사합니다! 🙏\n 기본적인 알림 시간은 매일 오후 5시로 설정되어있습니다. 😄\n 돌봄다리 서비스의 마이페이지에서 알림 시간을 수정할 수 있습니다."),
 	GUARDIAN_WELCOME_MESSAGE("%s 보호자님, 안녕하세요! 🌸\n 최고의 요양원 서비스 돌봄다리입니다. 🤗\n 저희와 함께 해주셔서 정말 감사합니다! 🙏\n 새롭게 작성된 일지 내용을 원하시는 시간에 맞춰 알려드릴 수 있어요. ⏰\n 기본적인 알림 시간은 매일 오전 9시로 설정되어있습니다. 😄\n 돌봄다리 서비스의 마이페이지에서 알림 시간을 수정할 수 있습니다.\""),
 	NO_CHART_MESSAGE("새롭게 작성된 차트 내용이 없습니다! 😅"),
-	CAREWORKER_ALARM_MESSAGE("%s 요양보호사님, 오늘 하루는 어떠셨나요? 😊\n이제 차트를 작성하실 시간입니다. 잊지 마시고 차트 작성 부탁드립니다! 📝");
-
+	CAREWORKER_ALARM_MESSAGE("%s 요양보호사님, 오늘 하루는 어떠셨나요? 😊\n이제 차트를 작성하실 시간입니다. 잊지 마시고 차트 작성 부탁드립니다! 📝"),
+	CHART_UPDATED_MESSAGE("%s님, 안녕하세요! 😊 새로운 차트 정보가 업데이트되었습니다. 📋\n" +
+		"- 상태/질환: %s\n" +
+		"- 신체 관리: 세수 - %s, 목욕 - %s, 식사 - %s\n" +
+		"- 간호 관리: 혈압 - %s/%s, 체온 - %s도\n" +
+		"- 인지 관리: 인지 도움 제공 - %s\n" +
+		"- 회복 훈련 프로그램: %s\n\n" +
+		"더 자세한 내용은 돌봄다리에서 확인하세요. 감사합니다! 🙏");
 	private final String template;
 
 	MessageTemplate(String template) {

src/main/java/dbdr/domain/core/messaging/util/MessagingScheduler.java

@@ -42,23 +42,28 @@ public void sendChartUpdate() {
 			LocalDateTime alertTime = LocalDateTime.of(LocalDate.now(), currentTime);
 			Alarm alarm = alarmService.getAlarmByPhoneAndAlertTime(phone, alertTime);
 			String name = guardian.getName();
+
+			// (1) Line 채널 알림 보내기
 			if (alarm != null && alarm.getChannel().equals(MessageChannel.LINE)) {
 				log.info("알림 보낼 보호자 : {}", name);
 				alarmService.sendAlarmToSqs(alarm, alarm.getChannelId(), name);
 				alarmService.createGuardianNextDayAlarm(guardian);
 			}
+			// (2) SMS 알림 보내기
 		}
 
 		// 요양보호사에게 알람 메시지를 SQS로 전송합니다.
 		for (Careworker careworker : careworkers) {
 			String phone = careworker.getPhone();
 			Alarm alarm = alarmService.getAlarmByPhoneAndAlertTime(phone, currentDateTime);
 			String name = careworker.getName();
+			// (1) Line 채널 알림 보내기
 			if (alarm != null && alarm.getChannel().equals(MessageChannel.LINE) && !alarm.isSend()) {
 				log.info("알림 보낼 요양보호사 : {}", name);
 				alarmService.sendAlarmToSqs(alarm, alarm.getChannelId(), name);
 				alarmService.createCareworkerNextWorkingdayAlarm(careworker);
 			}
+			// (2) SMS 알림 보내기
 		}
 	}
 }

src/main/java/dbdr/domain/guardian/controller/GuardianController.java

@@ -20,7 +20,7 @@
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
-@Tag(name = "[보호자]", description = "보호자 정보 조회, 수정")
+@Tag(name = "[보호자] 마이페이지", description = "보호자 본인의 정보 조회, 수정")
 @RestController
 @RequestMapping("/${spring.app.version}/guardian")
 @RequiredArgsConstructor

src/main/java/dbdr/domain/guardian/dto/request/GuardianAlertTimeRequest.java

@@ -2,18 +2,22 @@
 
 import io.swagger.v3.oas.annotations.media.Schema;
 import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
 import jakarta.validation.constraints.Pattern;
 import java.time.LocalTime;
 
-public record GuardianAlertTimeRequest(@Schema(description = "보호자의 이름", example = "박준협")
-                                       @NotBlank(message = "이름은 필수 항목입니다.")
-                                       String name,
-                                       @Schema(description = "보호자의 휴대폰 번호", example = "01012341234")
-                                       @NotBlank(message = "휴대폰 번호는 필수 항목입니다.")
-                                       @Pattern(regexp = "010\\d{8}", message = "010XXXXXXXX형식으로 입력해주세요.")
-                                       String phone,
-                                       @Schema(description = "보호자의 알림 시간", example = "18:00:00")
-                                       @NotBlank(message = "알람 시간은 필수 항목입니다.")
-                                       LocalTime alertTime) {
+public record GuardianAlertTimeRequest(
+    @Schema(description = "보호자의 이름", example = "박준협")
+    @NotBlank(message = "이름은 필수 항목입니다.")
+    String name,
 
+    @Schema(description = "보호자의 휴대폰 번호", example = "01012341234")
+    @NotBlank(message = "휴대폰 번호는 필수 항목입니다.")
+    @Pattern(regexp = "010\\d{8}", message = "010XXXXXXXX 형식으로 입력해주세요.")
+    String phone,
+
+    @Schema(description = "보호자의 알림 시간", example = "18:00:00")
+    @NotNull(message = "알람 시간은 필수 항목입니다.")
+    LocalTime alertTime
+) {
 }

src/main/java/dbdr/domain/guardian/entity/Guardian.java

@@ -40,7 +40,7 @@ public class Guardian extends BaseEntity {
     private String lineUserId;
 
     @Column(nullable = true)
-    private LocalTime alertTime = LocalTime.of(18, 0); // 오후 6시로 초기화
+    private LocalTime alertTime = LocalTime.of(9, 0); // 오전 9시로 초기화
 
     @ManyToOne(fetch = FetchType.LAZY)
     @JoinColumn(name = "institution_id")

src/main/java/dbdr/domain/guardian/service/GuardianService.java

@@ -1,5 +1,6 @@
 package dbdr.domain.guardian.service;
 
+import dbdr.domain.core.alarm.service.AlarmService;
 import dbdr.domain.core.alarm.service.AlarmService;
 import dbdr.domain.guardian.dto.request.GuardianAlertTimeRequest;
 import dbdr.domain.guardian.dto.request.GuardianUpdateRequest;
@@ -45,12 +46,14 @@ public GuardianMyPageResponse getMyPageGuardianInfo(Long guardianId) {
             guardian.getAlertTime());
     }
 
+    @Transactional
     public GuardianMyPageResponse updateAlertTime(Long guardianId,
         GuardianAlertTimeRequest request) {
         ensureUniquePhoneButNotId(request.phone(), guardianId);
         Guardian guardian = findGuardianById(guardianId);
         guardian.updateAlertTime(request.name(), request.phone(), request.alertTime());
         guardianRepository.save(guardian);
+        alarmService.updateAlarmByLocalTime(request.alertTime(), request.phone());
         return new GuardianMyPageResponse(guardian.getName(), guardian.getPhone(),
             guardian.getAlertTime());
     }