[BE] 인원 변동 기능 구현

server/src/main/java/server/haengdong/application/MemberActionFactory.java

@@ -0,0 +1,80 @@
+package server.haengdong.application;
+
+import java.util.ArrayList;
+import java.util.Comparator;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import server.haengdong.application.request.MemberActionSaveAppRequest;
+import server.haengdong.application.request.MemberActionsSaveAppRequest;
+import server.haengdong.domain.Action;
+import server.haengdong.domain.MemberAction;
+import server.haengdong.domain.MemberActionStatus;
+import server.haengdong.domain.MemberGroupIdProvider;
+
+@RequiredArgsConstructor
+@Component
+public class MemberActionFactory {
+
+    private final MemberGroupIdProvider memberGroupIdProvider;
+
+    public List<MemberAction> createMemberActions(
+            MemberActionsSaveAppRequest request,
+            List<MemberAction> memberActions,
+            Action action
+    ) {
+        validateMemberNames(request);
+        validateActions(request, memberActions);
+
+        Long memberGroupId = memberGroupIdProvider.createGroupId();
+        List<MemberAction> createdMemberActions = new ArrayList<>();
+        List<MemberActionSaveAppRequest> actions = request.actions();
+        for (MemberActionSaveAppRequest appRequest : actions) {
+            MemberAction memberAction = appRequest.toMemberAction(action, memberGroupId);
+            createdMemberActions.add(memberAction);
+            action = action.next();
+        }
+
+        return createdMemberActions;
+    }
+
+    private void validateMemberNames(MemberActionsSaveAppRequest request) {
+        List<String> memberNames = request.actions().stream()
+                .map(MemberActionSaveAppRequest::name)
+                .toList();
+
+        long uniqueCount = memberNames.stream().distinct().count();
+        if (uniqueCount != memberNames.size()) {
+            throw new IllegalArgumentException();
+        }
+    }
+
+    private void validateActions(MemberActionsSaveAppRequest request, List<MemberAction> memberActions) {
+        List<MemberAction> reverseSortedMemberActions = memberActions.stream()
+                .sorted(Comparator.comparing(MemberAction::getSequence).reversed())
+                .toList();
+
+        for (MemberActionSaveAppRequest action : request.actions()) {
+            validateAction(action, reverseSortedMemberActions);
+        }
+    }
+
+    private void validateAction(MemberActionSaveAppRequest request, List<MemberAction> memberActions) {
+        MemberActionStatus memberActionStatus = MemberActionStatus.of(request.status());
+        if (isInvalidStatus(memberActions, request.name(), memberActionStatus)) {
+            throw new IllegalArgumentException();
+        }
+    }
+
+    private boolean isInvalidStatus(
+            List<MemberAction> memberActions,
+            String memberName,
+            MemberActionStatus memberActionStatus
+    ) {
+        return memberActions.stream()
+                .filter(action -> action.isSameName(memberName))
+                .findFirst()
+                .map(action -> action.isSameStatus(memberActionStatus))
+                .orElse(MemberActionStatus.IN != memberActionStatus);
+    }
+}

server/src/main/java/server/haengdong/application/MemberActionService.java

@@ -0,0 +1,41 @@
+package server.haengdong.application;
+
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import server.haengdong.application.request.MemberActionsSaveAppRequest;
+import server.haengdong.domain.Action;
+import server.haengdong.domain.Event;
+import server.haengdong.domain.MemberAction;
+import server.haengdong.persistence.ActionRepository;
+import server.haengdong.persistence.EventRepository;
+import server.haengdong.persistence.MemberActionRepository;
+
+@RequiredArgsConstructor
+@Transactional(readOnly = true)
+@Service
+public class MemberActionService {
+
+    private final MemberActionFactory memberActionFactory;
+    private final MemberActionRepository memberActionRepository;
+    private final EventRepository eventRepository;
+    private final ActionRepository actionRepository;
+
+    @Transactional
+    public void saveMemberAction(String token, MemberActionsSaveAppRequest request) {
+        Event event = eventRepository.findByToken(token)
+                .orElseThrow(() -> new IllegalArgumentException("event not found"));
+
+        List<MemberAction> findMemberActions = memberActionRepository.findAllByEvent(event);
+        Action action = createStartAction(event);
+        List<MemberAction> memberActions = memberActionFactory.createMemberActions(request, findMemberActions, action);
+        memberActionRepository.saveAll(memberActions);
+    }
+
+    private Action createStartAction(Event event) {
+        return actionRepository.findLastByEvent(event)
+                .map(Action::next)
+                .orElse(Action.createFirst(event));
+    }
+}

server/src/main/java/server/haengdong/application/request/MemberActionSaveAppRequest.java

@@ -0,0 +1,12 @@
+package server.haengdong.application.request;
+
+import server.haengdong.domain.Action;
+import server.haengdong.domain.MemberAction;
+import server.haengdong.domain.MemberActionStatus;
+
+public record MemberActionSaveAppRequest(String name, String status) {
+
+    public MemberAction toMemberAction(Action action, Long memberGroupId) {
+        return new MemberAction(action, name, MemberActionStatus.of(status), memberGroupId);
+    }
+}

server/src/main/java/server/haengdong/application/request/MemberActionsSaveAppRequest.java

@@ -0,0 +1,6 @@
+package server.haengdong.application.request;
+
+import java.util.List;
+
+public record MemberActionsSaveAppRequest(List<MemberActionSaveAppRequest> actions) {
+}

server/src/main/java/server/haengdong/domain/EventStep.java

@@ -21,7 +21,7 @@ public class EventStep {
 
     @ManyToOne(fetch = FetchType.LAZY)
     private Event event;
-    
+
     private String name;
 
     private Long sequence;

server/src/main/java/server/haengdong/domain/MemberAction.java

@@ -1,5 +1,6 @@
 package server.haengdong.domain;
 
+import jakarta.persistence.CascadeType;
 import jakarta.persistence.Entity;
 import jakarta.persistence.EnumType;
 import jakarta.persistence.Enumerated;
@@ -21,7 +22,7 @@ public class MemberAction {
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     private Long id;
 
-    @OneToOne(fetch = FetchType.LAZY)
+    @OneToOne(fetch = FetchType.LAZY, cascade = CascadeType.ALL, orphanRemoval = true)
     private Action action;
 
     private String memberName;
@@ -30,4 +31,23 @@ public class MemberAction {
     private MemberActionStatus status;
 
     private Long memberGroupId;
+
+    public MemberAction(Action action, String memberName, MemberActionStatus status, Long memberGroupId) {
+        this.action = action;
+        this.memberName = memberName;
+        this.status = status;
+        this.memberGroupId = memberGroupId;
+    }
+
+    public boolean isSameName(String name) {
+        return memberName.equals(name);
+    }
+
+    public boolean isSameStatus(MemberActionStatus memberActionStatus) {
+        return status == memberActionStatus;
+    }
+
+    public Long getSequence() {
+        return action.getSequence();
+    }
 }

server/src/main/java/server/haengdong/domain/MemberActionStatus.java

@@ -1,7 +1,16 @@
 package server.haengdong.domain;
 
+import java.util.Arrays;
+
 public enum MemberActionStatus {
     IN,
     OUT,
     ;
+
+    public static MemberActionStatus of(String status) {
+        return Arrays.stream(MemberActionStatus.values())
+                .filter(s -> s.name().equals(status))
+                .findFirst()
+                .orElseThrow(() -> new IllegalArgumentException("Invalid status: " + status));
+    }
 }

server/src/main/java/server/haengdong/domain/MemberGroupIdProvider.java

@@ -0,0 +1,11 @@
+package server.haengdong.domain;
+
+import org.springframework.stereotype.Component;
+
+@Component
+public class MemberGroupIdProvider {
+
+    public Long createGroupId() {
+        return System.currentTimeMillis();
+    }
+}

server/src/main/java/server/haengdong/persistence/ActionRepository.java

@@ -3,6 +3,7 @@
 import java.util.Optional;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
 import org.springframework.stereotype.Repository;
 import server.haengdong.domain.Action;
 import server.haengdong.domain.Event;
@@ -17,5 +18,5 @@ public interface ActionRepository extends JpaRepository<Action, Long> {
             ORDER BY a.sequence DESC
             LIMIT 1
             """)
-    Optional<Action> findLastByEvent(Event event);
+    Optional<Action> findLastByEvent(@Param("event") Event event);
 }

server/src/main/java/server/haengdong/persistence/EventRepository.java

@@ -7,6 +7,6 @@
 
 @Repository
 public interface EventRepository extends JpaRepository<Event, Long> {
-
+  
     Optional<Event> findByToken(String token);
 }

server/src/main/java/server/haengdong/persistence/MemberActionRepository.java

@@ -0,0 +1,16 @@
+package server.haengdong.persistence;
+
+import java.util.List;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import org.springframework.stereotype.Repository;
+import server.haengdong.domain.Event;
+import server.haengdong.domain.MemberAction;
+
+@Repository
+public interface MemberActionRepository extends JpaRepository<MemberAction, Long> {
+
+    @Query("select m from MemberAction m join fetch m.action where m.action.event = :event")
+    List<MemberAction> findAllByEvent(@Param("event") Event event);
+}

server/src/main/java/server/haengdong/presentation/MemberActionController.java

@@ -0,0 +1,27 @@
+package server.haengdong.presentation;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+import server.haengdong.application.MemberActionService;
+import server.haengdong.presentation.request.MemberActionsSaveRequest;
+
+@RequiredArgsConstructor
+@RestController
+public class MemberActionController {
+
+    private final MemberActionService memberActionService;
+
+    @PostMapping("/api/events/{token}/actions/members")
+    public ResponseEntity<Void> saveMemberAction(
+            @PathVariable("token") String token,
+            @RequestBody MemberActionsSaveRequest request
+    ) {
+        memberActionService.saveMemberAction(token, request.toAppRequest());
+
+        return ResponseEntity.ok().build();
+    }
+}

server/src/main/java/server/haengdong/presentation/request/MemberActionSaveRequest.java

@@ -0,0 +1,10 @@
+package server.haengdong.presentation.request;
+
+import server.haengdong.application.request.MemberActionSaveAppRequest;
+
+public record MemberActionSaveRequest(String name, String status) {
+
+    public MemberActionSaveAppRequest toAppRequest() {
+        return new MemberActionSaveAppRequest(name, status);
+    }
+}

server/src/main/java/server/haengdong/presentation/request/MemberActionsSaveRequest.java

@@ -0,0 +1,16 @@
+package server.haengdong.presentation.request;
+
+import java.util.List;
+import server.haengdong.application.request.MemberActionSaveAppRequest;
+import server.haengdong.application.request.MemberActionsSaveAppRequest;
+
+public record MemberActionsSaveRequest(List<MemberActionSaveRequest> actions) {
+
+    public MemberActionsSaveAppRequest toAppRequest() {
+        List<MemberActionSaveAppRequest> appRequests = actions.stream()
+                .map(MemberActionSaveRequest::toAppRequest)
+                .toList();
+
+        return new MemberActionsSaveAppRequest(appRequests);
+    }
+}