diff --git a/src/main/java/com/howWeather/howWeather_backend/domain/ai_model/api/AiInternalController.java b/src/main/java/com/howWeather/howWeather_backend/domain/ai_model/api/AiInternalController.java index 4c537d1..2b0a80b 100644 --- a/src/main/java/com/howWeather/howWeather_backend/domain/ai_model/api/AiInternalController.java +++ b/src/main/java/com/howWeather/howWeather_backend/domain/ai_model/api/AiInternalController.java @@ -125,18 +125,6 @@ private Map encryptPredictionData(List d } } - // TODO : 테스트용 추후 삭제 - @GetMapping("/refresh-mark") - @Transactional - public ResponseEntity refreshClosetMark() { - List closets = closetRepository.findAll(); - for (Closet closet : closets) { - closet.markNeedsRefresh(); - } - log.info("모든 Closet의 needsCombinationRefresh를 true로 초기화 완료"); - return ResponseEntity.ok("모든 Closet의 needsCombinationRefresh가 true로 초기화되었습니다."); - } - // TODO : 테스트용 추후 삭제 @GetMapping("/test-prediction-data") public ResponseEntity> getAllUsersPredictionDataForTest() { diff --git a/src/main/java/com/howWeather/howWeather_backend/domain/member/service/MyAccountService.java b/src/main/java/com/howWeather/howWeather_backend/domain/member/service/MyAccountService.java index e6385ed..c7f83ae 100644 --- a/src/main/java/com/howWeather/howWeather_backend/domain/member/service/MyAccountService.java +++ b/src/main/java/com/howWeather/howWeather_backend/domain/member/service/MyAccountService.java @@ -227,16 +227,19 @@ private void pushPredictionForSingleMember(Member member, String region) { HttpHeaders headers = new HttpHeaders(); headers.setContentType(MediaType.APPLICATION_JSON); HttpEntity> requestEntity = new HttpEntity<>(encryptedData, headers); - ResponseEntity response = restTemplate.postForEntity(aiServerUrl, requestEntity, String.class); + + ResponseEntity response = restTemplate.postForEntity(aiServerUrl, requestEntity, Map.class); if (response.getStatusCode().is2xxSuccessful()) { log.info("[AI 예측 전송 완료] memberId={}, 응답={}", member.getId(), response.getStatusCode()); } else { log.warn("[AI 서버 응답 실패] memberId={}, 상태코드={}, 본문={}", member.getId(), response.getStatusCode(), response.getBody()); + return; } - saveRecommendationsInternal(encryptedData, region); + Map encryptedResponseData = response.getBody(); + saveRecommendationsInternal(encryptedResponseData, region); } catch (Exception e) { log.error("[AI 예측 처리 실패] memberId={}, message={}", member.getId(), e.getMessage(), e);