triển khai chặn người dùng

connexa-common/src/main/java/org/connexa/connexacommon/entity/BlockAction.java

@@ -0,0 +1,5 @@
+package org.connexa.connexacommon.entity;
+
+public enum BlockAction {
+    BLOCK, UNBLOCK
+}

connexa-common/src/main/java/org/connexa/connexacommon/entity/UserBlock.java

@@ -0,0 +1,39 @@
+package org.connexa.connexacommon.entity;
+
+import jakarta.persistence.*;
+import lombok.*;
+
+import java.util.Date;
+
+@Entity
+@Table(
+        name = "user_blocks",
+        uniqueConstraints = {
+                @UniqueConstraint(name = "uq_user_block", columnNames = {"blocker_id", "blocked_id"})
+        },
+        indexes = {
+                @Index(name = "idx_blocker_id", columnList = "blocker_id"),
+                @Index(name = "idx_blocked_id", columnList = "blocked_id")
+        }
+)
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class UserBlock {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Integer id;
+
+    @ManyToOne(fetch = FetchType.LAZY, optional = false)
+    @JoinColumn(name = "blocker_id", nullable = false)
+    private UserProfile blocker;
+
+    @ManyToOne(fetch = FetchType.LAZY, optional = false)
+    @JoinColumn(name = "blocked_id", nullable = false)
+    private UserProfile blocked;
+
+    @Column(name = "created_at", nullable = false, updatable = false)
+    private Date createdAt;
+}

connexa-common/src/main/java/org/connexa/connexacommon/entity/UserBlockHistory.java

@@ -0,0 +1,40 @@
+package org.connexa.connexacommon.entity;
+
+import jakarta.persistence.*;
+import lombok.*;
+
+import java.util.Date;
+
+@Entity
+@Table(name = "user_block_histories",
+        indexes = {
+                @Index(name = "idx_block_history_blocker", columnList = "blocker_id"),
+                @Index(name = "idx_block_history_blocked", columnList = "blocked_id")
+        })
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class UserBlockHistory {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Integer id;
+
+    @ManyToOne(fetch = FetchType.LAZY, optional = false)
+    @JoinColumn(name = "blocker_id", nullable = false,
+            foreignKey = @ForeignKey(name = "fk_block_history_blocker"))
+    private UserProfile blocker;
+
+    @ManyToOne(fetch = FetchType.LAZY, optional = false)
+    @JoinColumn(name = "blocked_id", nullable = false,
+            foreignKey = @ForeignKey(name = "fk_block_history_blocked"))
+    private UserProfile blocked;
+
+    @Enumerated(EnumType.STRING)
+    @Column(name = "action", nullable = false, length = 20)
+    private BlockAction action;
+
+    @Column(name = "created_at", nullable = false, updatable = false)
+    private Date createdAt;
+}

connexa-parent/connexa-web/src/main/java/org/connexa/connexaweb/block/UserBlockHistoryRepository.java

@@ -0,0 +1,9 @@
+package org.connexa.connexaweb.block;
+
+import org.connexa.connexacommon.entity.UserBlockHistory;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface UserBlockHistoryRepository extends JpaRepository<UserBlockHistory, Integer> {
+}

connexa-parent/connexa-web/src/main/java/org/connexa/connexaweb/block/UserBlockNotFoundException.java

@@ -0,0 +1,7 @@
+package org.connexa.connexaweb.block;
+
+public class UserBlockNotFoundException extends RuntimeException {
+    public UserBlockNotFoundException(String s) {
+        super(s);
+    }
+}

connexa-parent/connexa-web/src/main/java/org/connexa/connexaweb/block/UserBlockRepository.java

@@ -0,0 +1,14 @@
+package org.connexa.connexaweb.block;
+
+import org.connexa.connexacommon.entity.UserBlock;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface UserBlockRepository extends JpaRepository<UserBlock, Integer> {
+    boolean existsByBlockerIdAndBlockedId(Integer userBlockerId, Integer userBlockedId);
+
+    @Modifying
+    void deleteByBlockerIdAndBlockedId(Integer blockerId, Integer blockedId);
+}

connexa-parent/connexa-web/src/main/java/org/connexa/connexaweb/block/UserBlockService.java

@@ -0,0 +1,7 @@
+package org.connexa.connexaweb.block;
+
+public interface UserBlockService {
+    void blockUser(String email,Integer userBlockedId);
+
+    void unblockUser(String email, Integer userUnblockedId);
+}

connexa-parent/connexa-web/src/main/java/org/connexa/connexaweb/block/impl/UserBlockServiceImpl.java

@@ -0,0 +1,84 @@
+package org.connexa.connexaweb.block.impl;
+
+import jakarta.transaction.Transactional;
+import org.connexa.connexacommon.entity.BlockAction;
+import org.connexa.connexacommon.entity.UserBlock;
+import org.connexa.connexacommon.entity.UserBlockHistory;
+import org.connexa.connexacommon.entity.UserProfile;
+import org.connexa.connexaweb.block.UserBlockHistoryRepository;
+import org.connexa.connexaweb.block.UserBlockNotFoundException;
+import org.connexa.connexaweb.block.UserBlockRepository;
+import org.connexa.connexaweb.block.UserBlockService;
+import org.connexa.connexaweb.user.UserNotFoundException;
+import org.connexa.connexaweb.user.UserRepository;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+
+@Service
+public class UserBlockServiceImpl implements UserBlockService {
+    @Autowired
+    private UserRepository userRepository;
+    @Autowired
+    private UserBlockRepository userBlockRepository;
+
+    @Autowired
+    private UserBlockHistoryRepository userBlockHistoryRepository;
+
+    @Transactional
+    @Override
+    public void blockUser(String email, Integer userBlockedId) {
+        UserProfile userBlocker = userRepository.findByEmail(email).orElseThrow(
+                () -> new UserNotFoundException("Không tìm thấy người dùng hiện tại")
+        );
+
+        UserProfile userBlocked = userRepository.findById(userBlockedId).orElseThrow(
+                () -> new UserNotFoundException("Không tìm thấy người dùng này: " + userBlockedId)
+        );
+        if(userBlocker.getId().equals(userBlockedId)){
+            throw new IllegalArgumentException("Không thể thực hiện hành động này");
+        }
+        if(userBlockRepository.existsByBlockerIdAndBlockedId(userBlocker.getId(), userBlocked.getId())){
+            return;
+        }
+
+        UserBlock userBlock = new UserBlock();
+        userBlock.setBlocker(userBlocker);
+        userBlock.setBlocked(userBlocked);
+        Date timeBlock = new Date();
+        userBlock.setCreatedAt(timeBlock);
+
+        userBlockRepository.save(userBlock);
+
+        createBlockHistory(userBlock.getBlocker(), userBlock.getBlocked(), BlockAction.BLOCK, timeBlock);
+    }
+
+    @Transactional
+    @Override
+    public void unblockUser(String email, Integer userUnblockedId) {
+        UserProfile userUnblocker = userRepository.findByEmail(email).orElseThrow(
+                () -> new UserNotFoundException("Không tìm thấy người dùng hiện tại")
+        );
+
+        UserProfile userUnlocked = userRepository.findById(userUnblockedId).orElseThrow(
+                () -> new UserNotFoundException("Không tìm thấy người dùng này: " + userUnblockedId)
+        );
+
+        if(!userBlockRepository.existsByBlockerIdAndBlockedId(userUnblocker.getId(), userUnlocked.getId())){
+            throw new UserBlockNotFoundException("Không tìm thấy lịch sử chặn người dùng này");
+        }
+        userBlockRepository.deleteByBlockerIdAndBlockedId(userUnblocker.getId(), userUnlocked.getId());
+
+        createBlockHistory(userUnblocker, userUnlocked, BlockAction.UNBLOCK, new Date());
+    }
+
+    private void createBlockHistory(UserProfile actor, UserProfile target, BlockAction action, Date timeBlock) {
+        UserBlockHistory history = new UserBlockHistory();
+        history.setBlocker(actor);
+        history.setBlocked(target);
+        history.setAction( action);
+        history.setCreatedAt(timeBlock);
+        userBlockHistoryRepository.save(history);
+    }
+}

connexa-parent/connexa-web/src/main/java/org/connexa/connexaweb/user/UserController.java

@@ -1,6 +1,7 @@
 package org.connexa.connexaweb.user;
 
 import jakarta.validation.Valid;
+import org.connexa.connexaweb.block.UserBlockService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
@@ -17,6 +18,8 @@ import org.springframework.web.multipart.MultipartFile;
 public class UserController {
     @Autowired
     private UserService userService;
+    @Autowired
+    private UserBlockService userBlockService;
 
     @GetMapping("/me")
     public ResponseEntity<?> getProfile(){
@@ -56,4 +59,18 @@ public class UserController {
 
         return new ResponseEntity<>(HttpStatus.OK);
     }
+
+    @PostMapping("/block/{id}")
+    public ResponseEntity<?> blockUser(@PathVariable("id") Integer userBlockedId){
+        String email = SecurityContextHolder.getContext().getAuthentication().getName();
+        userBlockService.blockUser(email, userBlockedId);
+        return new ResponseEntity<>(HttpStatus.OK);
+    }
+
+    @PostMapping("/unblock/{id}")
+    public ResponseEntity<?> unblockUser(@PathVariable("id") Integer userUnblockedId){
+        String email = SecurityContextHolder.getContext().getAuthentication().getName();
+        userBlockService.unblockUser(email, userUnblockedId);
+        return new ResponseEntity<>(HttpStatus.OK);
+    }
 }