Merge pull request #21 from studio-recoding/feat-chat-ai

[🚀feat] chat ai와의 통합

Author: JeonHaeseung

src/main/java/Ness/Backend/domain/schedule/ScheduleController.java

@@ -37,4 +37,10 @@ public ResponseEntity<Long> createSchedule(@AuthUser Member member, @RequestBody
         return new ResponseEntity<>(userId, HttpStatusCode.valueOf(200));
     }
 
-}
+    @PutMapping("/dev/schedule/new")
+    @Operation(summary = "새로운 스케쥴 내역", description = "새로운 스케쥴 내역 저장하는 API 입니다.")
+    public ResponseEntity<Long> createDevSchedule(@RequestBody ScheduleCreateRequestDto scheduleCreateRequestDto){
+        Long userId  = scheduleService.createNewSchedule(1L, scheduleCreateRequestDto);
+        return new ResponseEntity<>(userId, HttpStatusCode.valueOf(200));
+    }
+}

src/main/java/Ness/Backend/domain/schedule/ScheduleService.java

@@ -1,5 +1,6 @@
 package Ness.Backend.domain.schedule;
 
+import Ness.Backend.domain.schedule.dto.ScheduleCreateFastApiDto;
 import Ness.Backend.domain.report.dto.ReportMemoryDto;
 import Ness.Backend.domain.report.dto.ReportMemoryListResponseDto;
 import Ness.Backend.domain.report.entity.ReportMemory;
@@ -9,7 +10,12 @@
 import Ness.Backend.domain.schedule.entity.Schedule;
 import Ness.Backend.domain.member.MemberRepository;
 import Ness.Backend.domain.schedule.dto.ScheduleCreateRequestDto;
+import Ness.Backend.global.fastApi.FastApiScheduleApi;
+import com.fasterxml.jackson.databind.JsonNode;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.HttpStatusCode;
+import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -21,10 +27,12 @@
 
 @Service
 @RequiredArgsConstructor
+@Slf4j
 @Transactional(readOnly = true)
 public class ScheduleService {
     private final ScheduleRepository scheduleRepository;
     private final MemberRepository memberRepository;
+    private final FastApiScheduleApi fastApiScheduleApi;
 
     public ScheduleListResponseDto findOneUserMonthSchedule(Long id, String date){
         // 년도, 월, 일 추출
@@ -71,14 +79,6 @@ public ScheduleListResponseDto findOneUserDaySchedule(Long id, String date){
     public Long createNewSchedule(Long id, ScheduleCreateRequestDto scheduleCreateRequestDto){
         Member memberEntity = memberRepository.findMemberById(id);
 
-        /*
-        ScheduleDate newScheduleDate = ScheduleDate.builder()
-                .time(scheduleCreateRequestDto.getScheduleDateDto().getTime())
-                .date(scheduleCreateRequestDto.getScheduleDateDto().getDate())
-                .build();
-
-         */
-
         //새로운 채팅 생성
         Schedule newSchedule = Schedule.builder()
                 .info(scheduleCreateRequestDto.getInfo())
@@ -92,6 +92,24 @@ public Long createNewSchedule(Long id, ScheduleCreateRequestDto scheduleCreateRe
                 .build();
 
         scheduleRepository.save(newSchedule);
+
+        ScheduleCreateFastApiDto dto = ScheduleCreateFastApiDto.builder()
+                .info(scheduleCreateRequestDto.getInfo())
+                .location(scheduleCreateRequestDto.getLocation())
+                .person(scheduleCreateRequestDto.getPerson())
+                .date(scheduleCreateRequestDto.getDate())
+                .category("카테고리 없음") //일단은 null 처리하기
+                .member_id(newSchedule.getMember().getId())
+                .schedule_id(newSchedule.getId())
+                .build();
+
+        ResponseEntity<JsonNode> responseNode = fastApiScheduleApi.creatFastApiSchedule(dto);
+        if (responseNode.getStatusCode() == HttpStatusCode.valueOf(200)) {
+            log.info("Succeed to save data in Vector DB");
+        } else {
+            log.error("Failed to save data in Vector DB");
+        }
+
         return newSchedule.getId(); // 저장한 Chat 확인용
     }
 }

src/main/java/Ness/Backend/domain/schedule/dto/ScheduleCreateFastApiDto.java

@@ -0,0 +1,31 @@
+package Ness.Backend.domain.schedule.dto;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.time.ZonedDateTime;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class ScheduleCreateFastApiDto {
+
+    private Long schedule_id;
+
+    private Long member_id;
+
+    private String info;
+
+    private String location;
+
+    private String person;
+
+    @JsonFormat(shape = JsonFormat.Shape.STRING)
+    private ZonedDateTime date;
+
+    private String category;
+}

src/main/java/Ness/Backend/global/fastApi/FastApiScheduleApi.java

@@ -0,0 +1,15 @@
+package Ness.Backend.global.fastApi;
+
+import Ness.Backend.domain.schedule.dto.ScheduleCreateFastApiDto;
+import com.fasterxml.jackson.databind.JsonNode;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+
+@FeignClient(
+        name = "FastApiChat",
+        url = "${spring.cloud.openfeign.client.config.fastapi.url}")
+public interface FastApiScheduleApi {
+    @PostMapping(value = "/add_schedule")
+    ResponseEntity<JsonNode> creatFastApiSchedule(ScheduleCreateFastApiDto scheduleCreateFastApiDto);
+}