[OING-340] feature: 가족 초대 딥링크 발급 로직 변경 및 가족 초대 뷰 기반 API 실제 로직 추가 (#262)

* feature: add column to deep_link tbl and family_invite_link tbl

* feature: modify logic for issuing deep links

* feature: add inviter information logic to view-based API

* feature: add family name column to family tbl

* test: add family constructor to familyName field in test

* feature: add countSurvivalPostsByFamilyId method

* feature: add getFamilyMember's info method

* feature: add getFamilyMember's info logic to getFamilyInviteLinkDetails method

* feature: add getFamilyMemberNames logic

* chore: add delete previous data from deep_link and family_invite_link tbl

* test: add MemberRepositoryCustomTest

common/src/main/java/com/oing/service/FamilyBridge.java

@@ -0,0 +1,5 @@
+package com.oing.service;
+
+public interface FamilyBridge {
+    String findFamilyNameByFamilyId(String familyId);
+}

common/src/main/java/com/oing/service/MemberBridge.java

@@ -35,4 +35,12 @@ public interface MemberBridge {
     boolean isDeletedMember(String memberId);
 
     List<String> getFamilyMembersIdsByFamilyId(String familyId);
+
+    String getMemberNameByMemberId(String memberId);
+
+    List<String> getFamilyMemberNamesByFamilyId(String familyId);
+
+    List<String> getFamilyMemberProfileImgUrlsByFamilyId(String familyId);
+
+    int getFamilyMemberCountByFamilyId(String familyId);
 }

common/src/main/java/com/oing/service/PostBridge.java

@@ -8,4 +8,6 @@
  */
 public interface PostBridge {
     boolean isUploadedToday(String familyId, String memberId);
+
+    int countSurvivalPostsByFamilyId(String familyId);
 }

family/src/main/java/com/oing/domain/Family.java

@@ -17,12 +17,16 @@ public class Family extends BaseEntity {
     @Column(name = "family_id", columnDefinition = "CHAR(26)", nullable = false)
     private String id;
 
+    @Column(name = "family_name", columnDefinition = "CHAR(10)")
+    private String familyName;
+
     @Column(name = "score", nullable = false)
     private Integer score = 0;
 
 
-    public Family(String id) {
+    public Family(String id, String familyName) {
         this.id = id;
+        this.familyName = familyName;
     }
 
     public static final int NEW_POST_SCORE = 20;

family/src/main/java/com/oing/domain/FamilyInviteLink.java

@@ -27,8 +27,14 @@ public class FamilyInviteLink extends BaseEntity implements SerializableDeepLink
     @Column(name = "family_id", columnDefinition = "CHAR(26)", nullable = false)
     private String familyId;
 
+    @Column(name = "member_id", columnDefinition = "CHAR(26)", nullable = false)
+    private String memberId;
+
     @Override
     public Map<String, String> serialize() {
-        return Map.of("familyId", familyId);
+        return Map.of(
+                "familyId", familyId,
+                "memberId", memberId
+        );
     }
 }

family/src/main/java/com/oing/dto/response/FamilyInviteDeepLinkResponse.java

@@ -13,6 +13,9 @@ public record FamilyInviteDeepLinkResponse(
         @Schema(description = "가족 명", example = "사랑하는 우리가족")
         String familyName,
 
+        @Schema(description = "대표 가족구성원 닉네임", example = "미밍이")
+        List<String> familyMemberNames,
+
         @Schema(description = "대표 가족구성원 프로필 이미지 URL", example = "https://asset.no5ing.kr/member/profile/ab3fde93ee")
         List<String> familyMembersProfileImageUrls,
 

family/src/main/java/com/oing/repository/FamilyInviteLinkRepository.java

@@ -10,5 +10,5 @@
  * Time: 7:17 PM
  */
 public interface FamilyInviteLinkRepository extends JpaRepository<FamilyInviteLink, String> {
-    public FamilyInviteLink findByFamilyId(String familyId);
+    public FamilyInviteLink findByFamilyIdAndMemberId(String familyId, String memberId);
 }

family/src/main/java/com/oing/service/FamilyInviteLinkService.java

@@ -26,7 +26,7 @@ public FamilyInviteLink storeDeepLinkDetails(FamilyInviteLink details) {
 
     @Override
     public FamilyInviteLink findPriorDeepLinkDetails(FamilyInviteLink details) {
-        return familyInviteLinkRepository.findByFamilyId(details.getFamilyId());
+        return familyInviteLinkRepository.findByFamilyIdAndMemberId(details.getFamilyId(), details.getMemberId());
     }
 
     @Override

family/src/main/java/com/oing/service/FamilyService.java

@@ -24,7 +24,7 @@ public class FamilyService {
 
     @Transactional
     public Family createFamily() {
-        Family family = new Family(identityGenerator.generateIdentity());
+        Family family = new Family(identityGenerator.generateIdentity(), null);
         return familyRepository.save(family);
     }
 

gateway/src/main/java/com/oing/controller/DeepLinkController.java

@@ -51,21 +51,21 @@ public DeepLinkResponse getLinkDetails(String linkId) {
     @Transactional
     @Override
     public DeepLinkResponse createFamilyDeepLink(
-            String familyId, String loginFamilyId
+            String familyId, String loginFamilyId, String loginMemberId
     ) {
         String linkId = deepLinkService.generateNewDeepLinkId();
 
         // 내 가족 외의 딥링크를 생성하려는 경우
         if (!Objects.equals(loginFamilyId, familyId)) throw new AuthorizationFailedException();
 
-        FamilyInviteLink newInviteLink = new FamilyInviteLink(linkId, familyId);
+        FamilyInviteLink newInviteLink = new FamilyInviteLink(linkId, familyId, loginMemberId);
         FamilyInviteLink familyInviteLink = familyDeepLinkService.findPriorDeepLinkDetails(newInviteLink);
         if (familyInviteLink != null) {
             return getLinkDetails(familyInviteLink.getLinkId());
         }
         newInviteLink = familyDeepLinkService.storeDeepLinkDetails(newInviteLink);
 
-        DeepLink deepLink = deepLinkService.createDeepLink(linkId, DeepLinkType.FAMILY_REGISTRATION);
+        DeepLink deepLink = deepLinkService.createDeepLink(linkId, DeepLinkType.FAMILY_REGISTRATION, loginMemberId, loginFamilyId);
         return new DeepLinkResponse(
                 deepLink.getLinkId(),
                 generateLink(deepLink.getLinkId()),

gateway/src/main/java/com/oing/controller/FamilyInviteViewController.java

@@ -1,9 +1,13 @@
 package com.oing.controller;
 
+import com.oing.dto.response.DeepLinkResponse;
 import com.oing.dto.response.FamilyInviteDeepLinkResponse;
+import com.oing.dto.response.MemberResponse;
 import com.oing.restapi.DeepLinkApi;
 import com.oing.restapi.FamilyInviteViewApi;
-import com.oing.restapi.MeApi;
+import com.oing.service.FamilyBridge;
+import com.oing.service.MemberBridge;
+import com.oing.service.PostBridge;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Controller;
 
@@ -14,32 +18,46 @@
 public class FamilyInviteViewController implements FamilyInviteViewApi {
 
     private final DeepLinkApi deepLinkApi;
-    private final MeApi meApi;
+    private final MemberBridge memberBridge;
+    private final FamilyBridge familyBridge;
+    private final PostBridge postBridge;
+    private final MemberController memberController;
 
     @Override
     public FamilyInviteDeepLinkResponse getFamilyInviteLinkDetails(String linkId, String loginMemberId) {
 
-        // TODO : 기능 구현할 때, 응답 모킹용 코드 삭제하고 아래 주석 풀기
-        boolean isRequesterJoinedFamily = false;
-//        MemberResponse me = meApi.getMe(loginMemberId);
-//        if (me.familyId() != null) {
-//            isRequesterJoinedFamily = true;
-//        }
-        //
-        if (loginMemberId != null) {
-            isRequesterJoinedFamily = true;
+        boolean isRequesterJoinedFamily = true;
+        MemberResponse me = memberController.getMemberNullable(loginMemberId);
+        if (me.familyId() == null) {
+            isRequesterJoinedFamily = false;
         }
 
+        DeepLinkResponse deepLinkResponse = deepLinkApi.getLinkDetails(linkId);
+        String familyId = deepLinkResponse.getDetails().get("familyId");
+        String familyName = familyBridge.findFamilyNameByFamilyId(familyId);
+        List<String> familyMemberNames = memberBridge.getFamilyMemberNamesByFamilyId(familyId);
+        List<String> familyMemberProfileImgUrls = memberBridge.getFamilyMemberProfileImgUrlsByFamilyId(familyId);
+        int familyMemberCount = memberBridge.getFamilyMemberCountByFamilyId(familyId);
+        int extraFamilyMemberCount;
+        if (familyMemberCount<3) {
+            extraFamilyMemberCount = 0;
+        } else {
+            extraFamilyMemberCount = familyMemberCount - 2;
+        }
+        int survivalPostCount = postBridge.countSurvivalPostsByFamilyId(familyId);
 
+        String inviterId = deepLinkResponse.getDetails().get("memberId");
+        String inviterName = memberBridge.getMemberNameByMemberId(inviterId);
 
         return new FamilyInviteDeepLinkResponse (
-                "01HGW2N7EHJVJ4CJ999RRS2E97",
-                "사랑하는 우리가족",
-                List.of("https://upload.wikimedia.org/wikipedia/en/thumb/6/63/Feels_good_man.jpg/200px-Feels_good_man.jpg", "https://upload.wikimedia.org/wikipedia/en/thumb/6/63/Feels_good_man.jpg/200px-Feels_good_man.jpg"),
-                3,
-                5,
-                "김철수",
-                3,
+                familyId,
+                familyName,
+                familyMemberNames,
+                familyMemberProfileImgUrls,
+                extraFamilyMemberCount,
+                familyMemberCount,
+                inviterName,
+                survivalPostCount,
                 isRequesterJoinedFamily
         );
     }

gateway/src/main/java/com/oing/domain/DeepLink.java

@@ -17,4 +17,10 @@ public class DeepLink extends BaseEntity {
     @Enumerated(EnumType.STRING)
     @Column(name = "type", columnDefinition = "VARCHAR(64)", nullable = false)
     private DeepLinkType type;
+
+    @Column(name = "member_id", columnDefinition = "CHAR(26)", nullable = false)
+    private String memberId;
+
+    @Column(name = "family_id", columnDefinition = "CHAR(26)", nullable = false)
+    private String familyId;
 }

gateway/src/main/java/com/oing/repository/PostRepositoryCustomImpl.java

@@ -186,6 +186,17 @@ public int countTodaySurvivalPostsByFamilyId(String familyId) {
         return count.intValue();
     }
 
+    @Override
+    public int countSurvivalPostsByFamilyId(String familyId) {
+        Long count = queryFactory
+                .select(post.id.count())
+                .from(post)
+                .where(post.familyId.eq(familyId),
+                        post.type.eq(SURVIVAL))
+                .fetchFirst();
+        return count.intValue();
+    }
+
     private BooleanExpression eqDate(LocalDate date) {
         DateTimeTemplate<LocalDate> createdAtDate = Expressions.dateTimeTemplate(LocalDate.class,
                 "DATE({0})", post.createdAt);

gateway/src/main/java/com/oing/restapi/DeepLinkApi.java

@@ -2,6 +2,7 @@
 
 import com.oing.dto.response.DeepLinkResponse;
 import com.oing.util.security.LoginFamilyId;
+import com.oing.util.security.LoginMemberId;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -36,6 +37,10 @@ DeepLinkResponse createFamilyDeepLink(
 
             @Parameter(hidden = true)
             @LoginFamilyId
-            String loginFamilyId
+            String loginFamilyId,
+
+            @Parameter(hidden = true)
+            @LoginMemberId
+            String loginMemberId
     );
 }

gateway/src/main/java/com/oing/service/DeepLinkService.java

@@ -32,12 +32,11 @@ public String generateNewDeepLinkId() {
     }
 
     @Transactional
-    public DeepLink createDeepLink(String linkId, DeepLinkType type) {
-        DeepLink newDeepLink = new DeepLink(linkId, type);
+    public DeepLink createDeepLink(String linkId, DeepLinkType type, String memberId, String familyId) {
+        DeepLink newDeepLink = new DeepLink(linkId, type, memberId, familyId);
         return deepLinkRepository.save(newDeepLink);
     }
 
-
     @Transactional
     public DeepLink getDeepLink(String linkId) {
         return deepLinkRepository

gateway/src/main/java/com/oing/service/FamilyBridgeImpl.java

@@ -0,0 +1,19 @@
+package com.oing.service;
+
+import com.oing.domain.Family;
+import com.oing.repository.FamilyRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+@RequiredArgsConstructor
+@Service
+public class FamilyBridgeImpl implements FamilyBridge {
+    private final FamilyRepository familyRepository;
+
+    @Override
+    public String findFamilyNameByFamilyId(String familyId) {
+        return familyRepository.findById(familyId)
+                .map(Family::getFamilyName)
+                .orElse(null);
+    }
+}

gateway/src/main/java/com/oing/service/MemberBridgeImpl.java

@@ -57,4 +57,26 @@ public List<String> getFamilyMembersIdsByFamilyId(String familyId) {
                 .map(Member::getId)
                 .toList();
     }
+
+    @Override
+    public String getMemberNameByMemberId(String memberId) {
+        return memberRepository.findById(memberId)
+                .map(Member::getName)
+                .orElseThrow(MemberNotFoundException::new);
+    }
+
+    @Override
+    public List<String> getFamilyMemberNamesByFamilyId(String familyId) {
+        return memberRepository.findFamilyMemberNamesByFamilyId(familyId);
+    }
+
+    @Override
+    public List<String> getFamilyMemberProfileImgUrlsByFamilyId(String familyId) {
+        return memberRepository.findFamilyMemberProfileImgUrlsByFamilyId(familyId);
+    }
+
+    @Override
+    public int getFamilyMemberCountByFamilyId(String familyId) {
+        return memberRepository.countByFamilyIdAndDeletedAtIsNull(familyId);
+    }
 }

gateway/src/main/resources/db/migration/V202406171820__add_column_to_deep_link_and_family_invite_link_tbl.sql

@@ -0,0 +1,8 @@
+ALTER TABLE `deep_link` ADD COLUMN (`member_id` CHAR(26) COMMENT 'ULID');
+ALTER TABLE `deep_link` ADD COLUMN (`family_id` CHAR(26) COMMENT 'ULID');
+ALTER TABLE `family_invite_link` ADD COLUMN (`member_id` CHAR(26) COMMENT 'ULID');
+DELETE FROM `deep_link` WHERE `family_id` IS NULL OR `member_id` IS NULL;
+DELETE FROM `family_invite_link` WHERE `member_id` IS NULL;
+ALTER TABLE `deep_link` MODIFY COLUMN `member_id` CHAR(26) NOT NULL;
+ALTER TABLE `deep_link` MODIFY COLUMN `family_id` CHAR(26) NOT NULL;
+ALTER TABLE `family_invite_link` MODIFY COLUMN `member_id` CHAR(26) NOT NULL;

gateway/src/main/resources/db/migration/V202406171920__add_family_name_column_to_family_tbl.sql

@@ -0,0 +1 @@
+ALTER TABLE `family` ADD COLUMN (`family_name` CHAR(10));

gateway/src/test/java/com/oing/event/FamilyScoreEventListenerTest.java

@@ -68,7 +68,7 @@ class FamilyScoreEventListenerTest {
 
     @BeforeEach
     void setUp() {
-        familyRepository.save(new Family(testMember1.getFamilyId()));
+        familyRepository.save(new Family(testMember1.getFamilyId(), null));
         memberRepository.save(testMember1);
         memberRepository.save(testMember2);
     }