diff --git a/src/modules/chatRoom/chatRoom.service.ts b/src/modules/chatRoom/chatRoom.service.ts index 441118b..a2de95b 100644 --- a/src/modules/chatRoom/chatRoom.service.ts +++ b/src/modules/chatRoom/chatRoom.service.ts @@ -121,11 +121,13 @@ export default class ChatRoomService { return chatData; } - @Transactional() async deActive(planId: string): Promise { - const chatRoom = await this.getChatRoomDomain({ planId }); - chatRoom.update(); - await this.chatRoomRepository.update(chatRoom); + const chatRoom = await this.chatRoomRepository.findChatRoom({ planId }); + //NOTE. 일단 임시로 트랜젝션을 제외 + if (chatRoom) { + chatRoom.update(); + await this.chatRoomRepository.update(chatRoom); + } //NOTE. 채팅방 목데이터가 없어서 나는 에러 처리 } async deActiveMany(planIds: string[]): Promise { diff --git a/src/modules/plan/plan.service.ts b/src/modules/plan/plan.service.ts index 8bb2413..66fa280 100644 --- a/src/modules/plan/plan.service.ts +++ b/src/modules/plan/plan.service.ts @@ -231,8 +231,8 @@ export default class PlanService { plan.updateComplete(); const updatedPlan = await this.repository.update(plan); const planId = plan.getId(); - await this.chatRoomService.deActive(planId); + await this.chatRoomService.deActive(planId); await this.pointQueue.add('points', { userId: plan.getConfirmedMakerId(), event: PointEventEnum.EARN,