Java를 사용하여 CMS 시스템의 현장 메시징 기능을 개발하는 방법

CREATE TABLE User (
  id INT PRIMARY KEY,
  username VARCHAR(50) NOT NULL,
  password VARCHAR(50) NOT NULL
);

CREATE TABLE Message (
  id INT PRIMARY KEY,
  sender_id INT NOT NULL,
  receiver_id INT NOT NULL,
  subject VARCHAR(100) NOT NULL,
  content TEXT NOT NULL,
  sent_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
  FOREIGN KEY (sender_id) REFERENCES User(id),
  FOREIGN KEY (receiver_id) REFERENCES User(id)
);

CREATE TABLE Mailbox (
  id INT PRIMARY KEY,
  user_id INT NOT NULL,
  message_id INT NOT NULL,
  is_sent BOOLEAN DEFAULT false,
  is_deleted BOOLEAN DEFAULT false,
  FOREIGN KEY (user_id) REFERENCES User(id),
  FOREIGN KEY (message_id) REFERENCES Message(id)
);

public class Message {
  private int id;
  private String sender;
  private String receiver;
  private String subject;
  private String content;
  private Date sentDate;

  // 省略构造方法和其他 getter/setter 方法
}

public class Mailbox {
  private int id;
  private int userId;
  private int messageId;
  private boolean isSent;
  private boolean isDeleted;

  // 省略构造方法和其他 getter/setter 方法
}

public class MessageService {
  private UserRepository userRepository;
  private MessageRepository messageRepository;
  private MailboxRepository mailboxRepository;

  // 构造函数省略

  public void sendMessage(String sender, String receiver, String subject, String content) {
    User senderUser = userRepository.findByUsername(sender);
    User receiverUser = userRepository.findByUsername(receiver);

    if (senderUser == null || receiverUser == null) {
      throw new IllegalArgumentException("Sender or receiver does not exist");
    }

    Message message = new Message(senderUser.getId(), receiverUser.getId(), subject, content, new Date());

    messageRepository.save(message);

    Mailbox senderMailbox = new Mailbox(senderUser.getId(), message.getId(), true, false);
    Mailbox receiverMailbox = new Mailbox(receiverUser.getId(), message.getId(), false, false);

    mailboxRepository.save(senderMailbox);
    mailboxRepository.save(receiverMailbox);
  }

  public List<Message> getInbox(String username) {
    User user = userRepository.findByUsername(username);

    if (user == null) {
      throw new IllegalArgumentException("User does not exist");
    }

    List<Message> messages = new ArrayList<>();
    List<Mailbox> mailboxes = mailboxRepository.findByUserId(user.getId());

    for (Mailbox mailbox : mailboxes) {
      if (!mailbox.isDeleted() && !mailbox.isSent()) {
        Message message = messageRepository.findById(mailbox.getMessageId());

        if (message != null) {
          messages.add(message);
        }
      }
    }

    return messages;
  }

  public List<Message> getSentbox(String username) {
    User user = userRepository.findByUsername(username);

    if (user == null) {
      throw new IllegalArgumentException("User does not exist");
    }

    List<Message> messages = new ArrayList<>();
    List<Mailbox> mailboxes = mailboxRepository.findByUserId(user.getId());

    for (Mailbox mailbox : mailboxes) {
      if (!mailbox.isDeleted() && mailbox.isSent()) {
        Message message = messageRepository.findById(mailbox.getMessageId());

        if (message != null) {
          messages.add(message);
        }
      }
    }

    return messages;
  }
}

public class CMSApp {
  private MessageService messageService;

  // 省略构造函数

  public void sendInternalMessage(String sender, String receiver, String subject, String content) {
    messageService.sendMessage(sender, receiver, subject, content);
  }

  public List<Message> getInbox(String username) {
    return messageService.getInbox(username);
  }

  public List<Message> getSentbox(String username) {
    return messageService.getSentbox(username);
  }

  // 省略其他相关方法
}