Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@
import com.assu.server.global.util.PresenceTracker;
import com.assu.server.global.util.PrincipalDetails;
import io.swagger.v3.oas.annotations.Operation;
import jakarta.transaction.Transactional;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.messaging.handler.annotation.MessageMapping;
Expand Down Expand Up @@ -70,6 +71,7 @@ public BaseResponse<List<com.assu.server.domain.chat.dto.ChatRoomListResultDTO>>
"- receiverId: Request Body, Long\n" +
"- message: Request Body, String\n"
)
@Transactional
@MessageMapping("/send")
public void handleMessage(@Payload ChatRequestDTO.ChatMessageRequestDTO request) {
// 먼저 접속 여부 확인 후 unreadCount 계산
Expand Down Expand Up @@ -99,14 +101,16 @@ public void handleMessage(@Payload ChatRequestDTO.ChatMessageRequestDTO request)
updateDTO
);
Member sender = memberRepository.findById(request.getSenderId()).orElse(null);
String senderName = "";
String senderName;
if (sender.getRole()== UserRole.ADMIN) {
senderName = sender.getAdminProfile().getName();
} else {
senderName = sender.getPartnerProfile().getName();
}

log.info(">>>>>>>>메시지 전송은 될걸");
notificationCommandService.sendChat(request.getReceiverId(), request.getRoomId(), senderName, request.getMessage());
log.info(">>>>>>>>알림이 가나");
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,6 @@ public ChatResponseDTO.SendMessageResponseDTO sendGuideMessage(ChatRequestDTO.Ch

ChatResponseDTO.SendMessageResponseDTO responseDTO = ChatConverter.toSendMessageDTO(saved);
simpMessagingTemplate.convertAndSend("/sub/chat/" + request.getRoomId(), responseDTO);
notificationCommandService.sendChat(receiver.getId(), room.getId(), sender.getAdminProfile().getName(), "제안서 초안이 도착했습니다. 확인해 주세요");

return responseDTO;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -311,6 +311,7 @@ public PartnershipResponseDTO.UpdateResponseDTO updatePartnershipStatus(Long par
0
);
chatService.sendGuideMessage(guideMessageRequest);
notificationService.sendChat(adminId, chattingRoom.getId(), partner.getName(), guideMessage);

} else if (next.equals(ActivationStatus.ACTIVE)) {
String guideMessage = "축하드립니다!\n" + "제휴 계약이 성립되었습니다. 제휴 계약서를 다시한번 확인해 보세요!";
Expand All @@ -322,6 +323,7 @@ public PartnershipResponseDTO.UpdateResponseDTO updatePartnershipStatus(Long par
0
);
chatService.sendGuideMessage(guideMessageRequest);
notificationService.sendChat(partnerId, chattingRoom.getId(), admin.getName(), guideMessage);
}

return PartnershipResponseDTO.UpdateResponseDTO.builder()
Expand Down Expand Up @@ -452,6 +454,7 @@ public PartnershipResponseDTO.CreateDraftResponseDTO createDraftPartnership(Part

// 5. 완성된 DTO를 사용해서 안내 메시지를 전송합니다.
chatService.sendGuideMessage(guideMessageRequest);
notificationService.sendChat(partner.getId(), chattingRoom.getId(), admin.getName(), guideMessage);

return PartnershipConverter.toCreateDraftResponseDTO(draftPaper);
}
Expand Down