fix: 회고 마감 로직 수정 (#240)

depromeet · Sep 12, 2024 · 9bf30ec · 9bf30ec
1 parent 0295259
commit 9bf30ec
Showing 1 changed file with 25 additions and 19 deletions.
diff --git a/layer-external/src/main/java/org/layer/external/ai/service/AIAnalyzeService.java b/layer-external/src/main/java/org/layer/external/ai/service/AIAnalyzeService.java
@@ -67,31 +67,37 @@ public void createAnalyze(Long spaceId, Long retrospectId, List<Long> memberIds)
 		String totalAnswer = answers.getTotalAnswer(rangeQuestionId, numberQuestionId);
 
 		// 분석 요청
-		List<Analyze> analyzes = new ArrayList<>();
-
-		OpenAIResponse aiResponse = openAIService.createAnalyze(totalAnswer);
-		OpenAIResponse.Content content = aiResponse.parseContent();
-		Analyze teamAnalyze = getAnalyzeEntity(retrospectId, answers, rangeQuestionId, numberQuestionId, content,
-			null, AnalyzeType.TEAM);
-		analyzes.add(teamAnalyze);
-
-		List<Analyze> individualAnalyzes = memberIds.stream()
-			.map(memberId -> {
-				String individualAnswer = answers.getIndividualAnswer(rangeQuestionId, numberQuestionId, memberId);
-				OpenAIResponse aiIndividualResponse = openAIService.createAnalyze(individualAnswer);
-				OpenAIResponse.Content individualcontent = aiIndividualResponse.parseContent();
-				return getAnalyzeEntity(retrospectId, answers, rangeQuestionId, numberQuestionId, individualcontent,
-					memberId, AnalyzeType.INDIVIDUAL);
-			}).toList();
-		analyzes.addAll(individualAnalyzes);
-
-		analyzeRepository.saveAll(analyzes);
+		try{
+			List<Analyze> analyzes = new ArrayList<>();
+
+			OpenAIResponse aiResponse = openAIService.createAnalyze(totalAnswer);
+			OpenAIResponse.Content content = aiResponse.parseContent();
+
+			Analyze teamAnalyze = getAnalyzeEntity(retrospectId, answers, rangeQuestionId, numberQuestionId, content,
+				null, AnalyzeType.TEAM);
+			analyzes.add(teamAnalyze);
+
+			List<Analyze> individualAnalyzes = memberIds.stream()
+				.map(memberId -> {
+					String individualAnswer = answers.getIndividualAnswer(rangeQuestionId, numberQuestionId, memberId);
+					OpenAIResponse aiIndividualResponse = openAIService.createAnalyze(individualAnswer);
+					OpenAIResponse.Content individualcontent = aiIndividualResponse.parseContent();
+					return getAnalyzeEntity(retrospectId, answers, rangeQuestionId, numberQuestionId, individualcontent,
+						memberId, AnalyzeType.INDIVIDUAL);
+				}).toList();
+			analyzes.addAll(individualAnalyzes);
+
+			analyzeRepository.saveAll(analyzes);
+		}catch (Exception e){
+			log.info("Not enough Answers");
+		}
 
 		long endTime = System.currentTimeMillis(); // 종료 시간 기록
 		long duration = endTime - startTime; // 경과 시간 계산
 		log.info("createAnalyze completed in {} ms", duration);
 
 		retrospect.updateAnalysisStatus(AnalysisStatus.DONE);
+		retrospectRepository.save(retrospect);  // TODO: 왜 더티체킹이 안될까??
 	}
 
 	private Analyze getAnalyzeEntity(Long retrospectId, Answers answers, Long rangeQuestionId, Long numberQuestionId,