Merge pull request #29 from shim-pyoo/feat/#27-todayShim-result

✨ FEAT. 오늘의 쉼 결과 조회 기능

src/main/java/com/hsu/shimpyoo/domain/breathing/controller/BreathingController.java

@@ -0,0 +1,34 @@
+package com.hsu.shimpyoo.domain.breathing.controller;
+
+import com.hsu.shimpyoo.domain.breathing.dto.BreathingRequestDto;
+import com.hsu.shimpyoo.domain.breathing.service.BreathingService;
+import com.hsu.shimpyoo.domain.user.entity.User;
+import com.hsu.shimpyoo.domain.user.repository.UserRepository;
+import com.hsu.shimpyoo.global.response.CustomAPIResponse;
+import com.hsu.shimpyoo.global.security.jwt.util.AuthenticationUserUtils;
+import lombok.RequiredArgsConstructor;
+import org.springframework.security.core.userdetails.UsernameNotFoundException;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+@RestController
+@RequestMapping("/api/breathing")
+@RequiredArgsConstructor
+public class BreathingController {
+    private final BreathingService breathingService;
+    private final AuthenticationUserUtils authenticationUserUtils;
+    private final UserRepository userRepository;
+
+    // 오늘의 쉼 결과
+    @PostMapping("/todayResult")
+    public CustomAPIResponse<Map<String, Object>> getTodayBreathingResult(
+            @RequestBody BreathingRequestDto dto) {
+        // 현재 로그인된 사용자 정보 가져오기
+        String loginId = authenticationUserUtils.getCurrentUserId();
+        User user = userRepository.findByLoginId(loginId)
+                .orElseThrow(() -> new UsernameNotFoundException("해당 사용자가 존재하지 않습니다."));
+
+        return breathingService.calculateBreathingResult(dto, user);
+    }
+}

src/main/java/com/hsu/shimpyoo/domain/breathing/dto/BreathingRequestDto.java

@@ -0,0 +1,16 @@
+package com.hsu.shimpyoo.domain.breathing.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+public class BreathingRequestDto {
+    private Float first;
+    private Float second;
+    private Float third;
+}

src/main/java/com/hsu/shimpyoo/domain/breathing/entity/Breathing.java

@@ -21,7 +21,16 @@ public class Breathing extends BaseEntity {
     @JoinColumn(name = "user_id", nullable = false)
     private User userId; // 사용자 기본키
 
-    @Column(name = "breathing_rate", nullable = false)
+    @Column(name = "breathing_rate")
     private Float breathingRate; // 호흡 수치
+
+    @Column(name = "first")
+    private Float first; // 1회차
+
+    @Column(name = "second")
+    private Float second; // 2회차
+
+    @Column(name = "third")
+    private Float third; // 3회차
 }
 

src/main/java/com/hsu/shimpyoo/domain/breathing/repository/BreathingRepository.java

@@ -1,7 +1,10 @@
 package com.hsu.shimpyoo.domain.breathing.repository;
 
 import com.hsu.shimpyoo.domain.breathing.entity.Breathing;
+import com.hsu.shimpyoo.domain.user.entity.User;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 public interface BreathingRepository extends JpaRepository<Breathing, Long> {
+    // UserId로 가장 최근의 Breathing 데이터를 가져오는 메서드
+    Breathing findTopByUserIdOrderByCreatedAtDesc(User userId);
 }

src/main/java/com/hsu/shimpyoo/domain/breathing/service/BreathingService.java

@@ -0,0 +1,75 @@
+package com.hsu.shimpyoo.domain.breathing.service;
+import com.hsu.shimpyoo.domain.breathing.dto.BreathingRequestDto;
+import com.hsu.shimpyoo.domain.breathing.entity.Breathing;
+import com.hsu.shimpyoo.domain.breathing.repository.BreathingRepository;
+import com.hsu.shimpyoo.domain.user.entity.User;
+import com.hsu.shimpyoo.global.response.CustomAPIResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+@Service
+@RequiredArgsConstructor
+public class BreathingService {
+    private final BreathingRepository breathingRepository;
+
+    public CustomAPIResponse<Map<String, Object>> calculateBreathingResult(BreathingRequestDto dto, User user) {
+        // 가장 최근의 Breathing 데이터를 userId로 조회
+        Breathing recentBreathing = breathingRepository.findTopByUserIdOrderByCreatedAtDesc(user);
+
+        // 최대호기량 설정
+        Float maxBreathingRate = Math.max(dto.getFirst(), Math.max(dto.getSecond(), dto.getThird()));
+
+        // 새로운 Breathing 데이터 저장
+        Breathing breathing = Breathing.builder()
+                .userId(user)
+                .breathingRate(maxBreathingRate)
+                .first(dto.getFirst())
+                .second(dto.getSecond())
+                .third(dto.getThird())
+                .build();
+        breathingRepository.save(breathing);
+
+        // 이전 breathingRate 값과 비교하여 상태 결정
+        String status;
+        String rateChangeDirection = "";  // 증가 또는 감소 방향
+        int rateDifferencePercent = 0;
+
+        if (recentBreathing != null) {
+            Float previousBreathingRate = recentBreathing.getBreathingRate();
+            rateDifferencePercent = Math.round(((maxBreathingRate - previousBreathingRate) / previousBreathingRate) * 100);
+
+            if (rateDifferencePercent >= 0) {
+                rateChangeDirection = "증가";
+            } else {
+                rateChangeDirection = "감소";
+                rateDifferencePercent = Math.abs(rateDifferencePercent); // 절대값으로 변환
+            }
+
+            // 상태 결정 로직 수정
+            float rateChange = ((float) maxBreathingRate / previousBreathingRate) * 100;
+            if (rateChange >= 80) {
+                status = "안정";
+            } else if (rateChange >= 60) {
+                status = "주의";
+            } else {
+                status = "위험";
+            }
+        } else {
+            // 이전 데이터가 없을 때
+            return CustomAPIResponse.createFailWithout(404, "이전 데이터를 찾을 수 없습니다.");
+        }
+
+        // 반환 데이터
+        Map<String, Object> responseData = new LinkedHashMap<>();
+        responseData.put("status", status);
+        responseData.put("breathingRate", maxBreathingRate);
+        responseData.put("rateDifference", rateDifferencePercent + "% " + rateChangeDirection);
+        responseData.put("first", breathing.getFirst());
+        responseData.put("second", breathing.getSecond());
+        responseData.put("third", breathing.getThird());
+
+        return CustomAPIResponse.createSuccess(200, responseData, "오늘의 쉼 결과 조회에 성공했습니다.");
+    }
+}