#39 헌혈인증 내역 조회 API 개발

module-application/src/main/java/com/zoopi/client/certification/controller/BloodDonationCertController.java

@@ -6,8 +6,9 @@
 
 import lombok.RequiredArgsConstructor;
 
-import com.zoopi.client.certification.api.BloodDonationCertApi;
+import com.zoopi.ResultCode;
 import com.zoopi.ResultResponse;
+import com.zoopi.client.certification.api.BloodDonationCertApi;
 import com.zoopi.client.certification.service.BloodDonationCertService;
 
 @RestController
@@ -17,8 +18,10 @@ public class BloodDonationCertController implements BloodDonationCertApi {
 	private final BloodDonationCertService certService;
 
 	@GetMapping("/{petId}")
-	public ResponseEntity<ResultResponse> findCertification(Long petId) {
-		return ResponseEntity.ok(ResultResponse.of(null));
+	public ResponseEntity<ResultResponse> retrieveCertification(Long petId) {
+		return ResponseEntity.ok(
+			ResultResponse.of(ResultCode.OK, certService.retrieveCertification(petId))
+		);
 	}
 
 }

module-application/src/main/java/com/zoopi/client/certification/service/BloodDonationCertService.java

@@ -1,14 +1,28 @@
 package com.zoopi.client.certification.service;
 
+import java.util.List;
+import java.util.stream.Collectors;
+
 import org.springframework.stereotype.Service;
 
 import lombok.RequiredArgsConstructor;
 
-import com.zoopi.domain.certification.repository.BloodDonationCertRepository;
+import com.zoopi.client.certification.model.CertificationResponse;
+import com.zoopi.domain.certification.entity.BloodDonationHistory;
+import com.zoopi.domain.certification.service.CertificationService;
 
 @Service
 @RequiredArgsConstructor
 public class BloodDonationCertService {
 
-	private final BloodDonationCertRepository certRepository;
+	private final CertificationService certificationService;
+
+	public List<CertificationResponse> retrieveCertification(Long petId) {
+		List<BloodDonationHistory> histories = certificationService.findAllHistoryBy(petId);
+		return certificationService.mapHistoryAndDetail(histories)
+			.entrySet().stream()
+			.map(CertificationResponse::of)
+			.collect(Collectors.toList());
+	}
+
 }

module-application/src/test/java/com/zoopi/domain/certification/service/CertificationServiceTest.java

@@ -0,0 +1,81 @@
+package com.zoopi.domain.certification.service;
+
+import static com.zoopi.domain.certification.entity.BloodDonationType.*;
+import static com.zoopi.util.FunctionalUtils.*;
+import static org.mockito.Mockito.*;
+import static org.junit.jupiter.api.Assertions.*;
+
+import java.time.LocalDate;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+
+import org.junit.jupiter.api.Test;
+
+import com.zoopi.domain.certification.dto.CertDetailDto;
+import com.zoopi.domain.certification.entity.BloodDonationDetail;
+import com.zoopi.domain.certification.entity.BloodDonationHistory;
+import com.zoopi.domain.certification.repository.BloodDonationDetailRepository;
+import com.zoopi.domain.certification.repository.BloodDonationHistoryRepository;
+import com.zoopi.domain.chat.entity.ChatMessage;
+import com.zoopi.domain.chat.entity.ChatRoom;
+import com.zoopi.domain.chat.entity.ChatRoomStatus;
+import com.zoopi.domain.chat.entity.MessageType;
+import com.zoopi.domain.chat.repository.ChatMessageRepository;
+import com.zoopi.domain.hospital.entity.Hospital;
+import com.zoopi.domain.pet.entity.Pet;
+
+class CertificationServiceTest {
+
+	private final BloodDonationHistoryRepository historyRepository = mock(BloodDonationHistoryRepository.class);
+	private final BloodDonationDetailRepository detailRepository = mock(BloodDonationDetailRepository.class);
+	private final ChatMessageRepository chatMessageRepository = mock(ChatMessageRepository.class);
+
+	private final CertificationService certificationService = new CertificationService(
+		historyRepository,
+		detailRepository,
+		chatMessageRepository
+	);
+
+	private final Pet donorPet = Pet.builder().build();
+	private final Pet receiverPet = Pet.builder().build();
+	private final Hospital hospital1 = new Hospital(1L, "충북대학교 동물병원", "충북 청주시 서원구 충대로1, 충북대학교 수의과대학 동물병원");
+	private final Hospital hospital2 = new Hospital(2L, "건국대학교 부속 동물병원", "서울 광진구 능동로 120 건국대학교 수의학관");
+	private final List<BloodDonationHistory> histories = List.of(
+		new BloodDonationHistory(1L, donorPet, "https://smaple.com/1", hospital1, LocalDate.now(), APPOINT),
+		new BloodDonationHistory(2L, donorPet, "https://smaple.com/2", hospital2, LocalDate.now(), APPOINT),
+		new BloodDonationHistory(3L, donorPet, "https://smaple.com/3", hospital2, LocalDate.now(), GENERAL),
+		new BloodDonationHistory(4L, donorPet, "https://smaple.com/4", hospital2, LocalDate.now(), APPOINT),
+		new BloodDonationHistory(5L, donorPet, "https://smaple.com/5", hospital1, LocalDate.now(), GENERAL)
+	);
+	private final List<BloodDonationDetail> details = List.of(
+		new BloodDonationDetail(1L, receiverPet, 100L, "", histories.get(0)),
+		new BloodDonationDetail(2L, receiverPet, 200L, "", histories.get(1)),
+		new BloodDonationDetail(3L, receiverPet, 300L, "", histories.get(3))
+	);
+	private final ChatRoom chatRoom = new ChatRoom(200L, 2L, donorPet, true, ChatRoomStatus.DONE);
+	private final ChatMessage chatMessage = new ChatMessage(1000L, chatRoom, 1L, "헌혈해주셔서 감사합니다 :)", MessageType.THANKS, true);
+
+	@Test
+	public void mapHistoryAndDetail_happy_case() {
+		// given
+		when(detailRepository.findByHistoryIdsIn(mapFrom(histories, BloodDonationHistory::getId))).thenReturn(details);
+		when(chatMessageRepository.findByChatRoomIdAndType(100L, MessageType.THANKS)).thenReturn(null);
+		when(chatMessageRepository.findByChatRoomIdAndType(200L, MessageType.THANKS)).thenReturn(chatMessage);
+		when(chatMessageRepository.findByChatRoomIdAndType(300L, MessageType.THANKS)).thenReturn(null);
+
+		// when
+		final Map<BloodDonationHistory, CertDetailDto> res = certificationService.mapHistoryAndDetail(histories);
+
+		// then
+		res.forEach((history, dto) -> {
+			if (history.getType().equals(APPOINT)) {
+				assertNotNull(dto);
+				if (history.getId() == 2) assertEquals(dto.getThanksMessage(), "헌혈해주셔서 감사합니다 :)");
+				else assertNull(dto.getThanksMessage());
+			}
+			else if (history.getType().equals(GENERAL)) assertNull(dto);
+		});
+	}
+
+}

module-common/src/main/java/com/zoopi/util/FunctionalUtils.java

@@ -0,0 +1,25 @@
+package com.zoopi.util;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.function.Predicate;
+import java.util.stream.Collectors;
+
+public class FunctionalUtils {
+
+	public static <T, R> List<R> mapFrom(List<T> list, Function<T, R> func) {
+		return list.stream().map(func).collect(Collectors.toList());
+	}
+
+	public static <T> List<T> filter(List<T> list, Predicate<T> func) {
+		return list.stream().filter(func).collect(Collectors.toList());
+	}
+
+	public static <T, K, V> Map<K, V> associateFrom(List<T> list, Function<T, K> key, Function<T, V> value) {
+		return list.stream().collect(HashMap::new, (map, t) -> map.put(key.apply(t), value.apply(t)), HashMap::putAll);
+	}
+
+}
+

module-domain/src/main/java/com/zoopi/domain/certification/dto/CertDetailDto.java

@@ -0,0 +1,30 @@
+package com.zoopi.domain.certification.dto;
+
+import java.time.LocalDateTime;
+import java.util.Optional;
+
+import lombok.Getter;
+
+import com.zoopi.domain.certification.entity.BloodDonationDetail;
+import com.zoopi.domain.chat.entity.ChatMessage;
+import com.zoopi.domain.pet.entity.Pet;
+
+@Getter
+public class CertDetailDto {
+
+	private final Long bloodDonationDetailId;
+	private final Pet receiverPet;
+	private String thanksMessage = null;
+	private LocalDateTime thanksMessageAt = null;
+
+	public CertDetailDto(BloodDonationDetail detail, ChatMessage thanksMessage) {
+		this.bloodDonationDetailId = detail.getId();
+		this.receiverPet = detail.getReceiverPet();
+
+		Optional.ofNullable(thanksMessage).ifPresent(thanks -> {
+			this.thanksMessage = thanks.getMessage();
+			this.thanksMessageAt = thanks.getCreatedAt();
+		});
+	}
+
+}

module-domain/src/main/java/com/zoopi/domain/certification/entity/BloodDonationDetail.java

@@ -2,25 +2,42 @@
 
 import javax.persistence.Column;
 import javax.persistence.Entity;
+import javax.persistence.FetchType;
 import javax.persistence.GeneratedValue;
 import javax.persistence.GenerationType;
 import javax.persistence.Id;
+import javax.persistence.JoinColumn;
+import javax.persistence.ManyToOne;
+import javax.persistence.OneToOne;
 
 import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
 import lombok.NoArgsConstructor;
 
 import com.zoopi.domain.BaseEntity;
+import com.zoopi.domain.pet.entity.Pet;
 
 @Entity
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@Getter
 public class BloodDonationDetail extends BaseEntity {
 
 	@Id @GeneratedValue(strategy = GenerationType.IDENTITY)
 	@Column(name = "blood_dontation_detail_id")
 	private Long id;
 
+	@ManyToOne(fetch = FetchType.LAZY)
+	@JoinColumn(name = "receiver_pet_id", referencedColumnName = "pet_id")
+	private Pet receiverPet;
+
 	private Long chatRoomId;
 
 	private String message;
 
+	@OneToOne(fetch = FetchType.LAZY)
+	@JoinColumn(name = "blood_donation_history_id", referencedColumnName = "blood_donation_history_id")
+	private BloodDonationHistory history;
+
 }

module-domain/src/main/java/com/zoopi/domain/certification/entity/BloodDonationHistory.java

@@ -11,35 +11,40 @@
 import javax.persistence.GenerationType;
 import javax.persistence.Id;
 import javax.persistence.JoinColumn;
-import javax.persistence.OneToOne;
+import javax.persistence.ManyToOne;
 
 import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
 import lombok.NoArgsConstructor;
 
 import com.zoopi.domain.BaseEntity;
+import com.zoopi.domain.hospital.entity.Hospital;
+import com.zoopi.domain.pet.entity.Pet;
 
 @Entity
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@Getter
 public class BloodDonationHistory extends BaseEntity {
 
 	@Id @GeneratedValue(strategy = GenerationType.IDENTITY)
 	@Column(name = "blood_donation_history_id")
 	private Long id;
 
-	private Long petId;
-	private Long receiverPetId;
+	@ManyToOne(fetch = FetchType.LAZY)
+	@JoinColumn(name = "pet_id", referencedColumnName = "pet_id")
+	private Pet pet;
 
-	@OneToOne(fetch = FetchType.EAGER)
-	@JoinColumn(name = "blood_donation_detail_id")
-	private BloodDonationDetail detail;
-
-	@Column(name = "image")
 	private String imageUrl;
 
-	private Long hospitalId;
+	@ManyToOne(fetch = FetchType.LAZY)
+	@JoinColumn(name = "hospital_id", referencedColumnName = "hospital_id")
+	private Hospital hospital;
 
 	private LocalDate bloodDonationAt;
 
 	@Enumerated(EnumType.STRING)
 	private BloodDonationType type;
-}
+
+}

module-domain/src/main/java/com/zoopi/domain/certification/repository/BloodDonationDetailRepository.java

@@ -0,0 +1,39 @@
+package com.zoopi.domain.certification.repository;
+
+import java.util.List;
+
+import org.springframework.stereotype.Repository;
+
+import com.querydsl.jpa.impl.JPAQueryFactory;
+
+import lombok.RequiredArgsConstructor;
+
+import com.zoopi.domain.certification.entity.BloodDonationDetail;
+import com.zoopi.domain.certification.entity.QBloodDonationDetail;
+import com.zoopi.domain.certification.entity.QBloodDonationHistory;
+import com.zoopi.domain.chat.entity.QChatMessage;
+import com.zoopi.domain.chat.entity.QChatRoom;
+import com.zoopi.domain.pet.entity.QPet;
+
+@Repository
+@RequiredArgsConstructor
+public class BloodDonationDetailRepository {
+
+	private final JPAQueryFactory jpaQueryFactory;
+	private final QBloodDonationHistory bloodDonationHistory = QBloodDonationHistory.bloodDonationHistory;
+	private final QBloodDonationDetail bloodDonationDetail = QBloodDonationDetail.bloodDonationDetail;
+	private final QPet pet = QPet.pet;
+	private final QChatRoom chatRoom = QChatRoom.chatRoom;
+	private final QChatMessage chatMessage = QChatMessage.chatMessage;
+
+	public List<BloodDonationDetail> findByHistoryIdsIn(List<Long> ids) {
+		return jpaQueryFactory.selectFrom(bloodDonationDetail)
+			.innerJoin(bloodDonationHistory).on(bloodDonationHistory.id.eq(bloodDonationDetail.history.id))
+			.fetchJoin()
+			.innerJoin(pet).on(pet.id.eq(bloodDonationDetail.receiverPet.id))
+			.fetchJoin()
+			.where(bloodDonationDetail.history.id.in(ids))
+			.fetch();
+	}
+
+}

module-domain/src/main/java/com/zoopi/domain/certification/repository/BloodDonationHistoryRepository.java

@@ -0,0 +1,16 @@
+package com.zoopi.domain.certification.repository;
+
+import java.util.List;
+
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.CrudRepository;
+import org.springframework.stereotype.Repository;
+
+import com.zoopi.domain.certification.entity.BloodDonationHistory;
+
+@Repository
+public interface BloodDonationHistoryRepository extends CrudRepository<BloodDonationHistory, Long> {
+
+	@Query("select h from BloodDonationHistory h join fetch h.hospital join fetch h.pet where h.pet.id = :petId")
+	List<BloodDonationHistory> findAllByPetId(Long petId);
+}