feat: 견적 제안 및 반려 알림 연동

src/modules/estimate/estimate.notification-policy.test.ts

@@ -0,0 +1,15 @@
+import assert from "node:assert/strict";
+import { describe, it } from "node:test";
+
+import { getRejectionNotificationExpiresAt } from "./estimate.notification-policy";
+
+describe("반려 알림 만료 정책", () => {
+  it("알림 생성 시점부터 7일 후에 만료합니다.", () => {
+    const createdAt = new Date("2026-07-31T06:30:00.000Z");
+
+    assert.equal(
+      getRejectionNotificationExpiresAt(createdAt).toISOString(),
+      "2026-08-07T06:30:00.000Z",
+    );
+  });
+});

src/modules/estimate/estimate.notification-policy.ts

@@ -0,0 +1,6 @@
+const REJECTION_NOTIFICATION_VISIBILITY_DAYS = 7;
+const DAY_MS = 24 * 60 * 60 * 1000;
+
+export function getRejectionNotificationExpiresAt(createdAt: Date): Date {
+  return new Date(createdAt.getTime() + REJECTION_NOTIFICATION_VISIBILITY_DAYS * DAY_MS);
+}

src/modules/estimate/estimate.repository.ts

@@ -232,6 +232,7 @@ export const moverEstimateRequestRepository = {
         },
       },
       select: {
+        nickname: true,
         serviceTypes: {
           select: {
             moveType: true,

src/modules/estimate/estimate.service.ts

@@ -4,7 +4,12 @@ import { AppError } from "../../lib/app-error";
 import { buildPagination } from "../../utils/pagination.util";
 import { runTransaction } from "../../utils/transaction";
 import { notificationService } from "../notification/notification.service";
-import { moverEstimateRequestRepository, receivedEstimateRepository } from "./estimate.repository";
+import { getRejectionNotificationExpiresAt } from "./estimate.notification-policy";
+import {
+  moverEstimateRequestRepository,
+  moverSentEstimateRepository,
+  receivedEstimateRepository,
+} from "./estimate.repository";
 import type {
   ConfirmReceivedEstimateParams,
   GetReceivedEstimateDetailParams,
@@ -15,6 +20,7 @@ import type {
   MoverEstimateRejectionListQuery,
   MoverEstimateRejectionListItem,
   MoverEstimateRejectionListResult,
+  MoverSentEstimateListQuery,
   PendingEstimateQuery,
   RejectEstimateParams,
   SendEstimateParams,
@@ -36,6 +42,11 @@ import type {
 */
 
 const KST_OFFSET_MS = 9 * 60 * 60 * 1000;
+const MOVE_TYPE_LABEL: Record<MoveType, string> = {
+  SMALL: "소형이사",
+  HOME: "가정이사",
+  OFFICE: "사무실이사",
+};
 
 // =============================================================================
 // 기사: 고객의 견적 요청 목록 조회
@@ -197,7 +208,7 @@ export const moverEstimateRequestService = {
 
   //견적 제안
   async sendEstimate({ estimateRequestId, moverId, input }: SendEstimateParams) {
-    return runTransaction(async (tx) => {
+    const result = await runTransaction(async (tx) => {
       const profile = await moverEstimateRequestRepository.findMoverProfile(moverId, tx);
 
       //기사 프로필 존재 확인
@@ -262,8 +273,8 @@ export const moverEstimateRequestService = {
 
       const isDesignated = estimateRequest.designatedMovers.length > 0;
 
-      //견적 셍성
-      return moverEstimateRequestRepository.createEstimate(
+      //견적 생성
+      const estimate = await moverEstimateRequestRepository.createEstimate(
         {
           estimateRequestId,
           moverId,
@@ -273,12 +284,31 @@ export const moverEstimateRequestService = {
         },
         tx,
       );
+
+      return {
+        estimate,
+        customerId: estimateRequest.customerId,
+        moverNickname: profile.nickname,
+        moveType: estimateRequest.moveType,
+        expiresAt: estimateRequest.expiresAt,
+      };
+    });
+
+    await notificationService.createNotification({
+      userId: result.customerId,
+      type: "ESTIMATE_RECEIVED",
+      title: "견적 도착",
+      content: `${result.moverNickname} 기사님의 ${MOVE_TYPE_LABEL[result.moveType]} 견적`,
+      linkUrl: null,
+      expiresAt: result.expiresAt,
     });
+
+    return result.estimate;
   },
 
   // 견적 요청 반려
   async rejectEstimate({ estimateRequestId, moverId, input }: RejectEstimateParams) {
-    return runTransaction(async (tx) => {
+    const result = await runTransaction(async (tx) => {
       //기사 프로필
       const profile = await moverEstimateRequestRepository.findMoverProfile(moverId, tx);
 
@@ -342,15 +372,33 @@ export const moverEstimateRequestService = {
       }
 
       //데이터 생성
-      return moverEstimateRequestRepository.createEstimateRejection(
+      const rejection = await moverEstimateRequestRepository.createEstimateRejection(
         {
           estimateRequestId,
           moverId,
           reason: input.reason,
         },
         tx,
       );
+
+      return {
+        rejection,
+        customerId: estimateRequest.customerId,
+        moverNickname: profile.nickname,
+      };
     });
+
+    const notificationCreatedAt = new Date();
+    await notificationService.createNotification({
+      userId: result.customerId,
+      type: "ESTIMATE_REQUEST_REJECTED",
+      title: "견적 요청 반려",
+      content: result.moverNickname,
+      linkUrl: null,
+      expiresAt: getRejectionNotificationExpiresAt(notificationCreatedAt),
+    });
+
+    return result.rejection;
   },
 };
 

src/modules/estimate/estimate.validator.ts

@@ -68,7 +68,10 @@ export const moverEstimateRequestListQuerySchema = z.object({
 
 //기사 견적 반려 내역 조회
 export const moverEstimateRejectionListQuerySchema = z.object({
-  cursor: z.string().regex(/^\d+$/, "커서는 양의 정수 형식이어야 합니다.").optional(),
+  cursor: z
+    .string()
+    .regex(/^[1-9]\d*$/, "커서는 1 이상의 정수여야 합니다.")
+    .optional(),
 
   limit: z.coerce
     .number("조회 개수는 숫자여야 합니다.")