summaryrefslogtreecommitdiff
path: root/lib/evaluation/service.ts
diff options
context:
space:
mode:
Diffstat (limited to 'lib/evaluation/service.ts')
-rw-r--r--lib/evaluation/service.ts18
1 files changed, 16 insertions, 2 deletions
diff --git a/lib/evaluation/service.ts b/lib/evaluation/service.ts
index 8e394f88..3e85b4a2 100644
--- a/lib/evaluation/service.ts
+++ b/lib/evaluation/service.ts
@@ -136,7 +136,6 @@ export async function getPeriodicEvaluations(input: GetEvaluationTargetsSchema)
const pageCount = Math.ceil(total / input.perPage);
- console.log(periodicEvaluationsData, "periodicEvaluationsData")
return { data: periodicEvaluationsData, pageCount, total };
} catch (err) {
@@ -359,6 +358,20 @@ export async function requestDocumentsFromVendors(data: RequestDocumentsData[])
})
)
+ // periodic_evaluations 테이블의 status를 PENDING_SUBMISSION으로 업데이트
+ const periodicEvaluationIds = [...new Set(data.map(item => item.periodicEvaluationId))]
+
+ await Promise.all(
+ periodicEvaluationIds.map(async (periodicEvaluationId) => {
+ await db
+ .update(periodicEvaluations)
+ .set({
+ status: 'PENDING_SUBMISSION',
+ updatedAt: new Date()
+ })
+ .where(eq(periodicEvaluations.id, periodicEvaluationId))
+ })
+ )
return {
success: true,
@@ -375,7 +388,6 @@ export async function requestDocumentsFromVendors(data: RequestDocumentsData[])
}
}
}
-
// 기존 요청 상태 확인 함수 추가
export async function checkExistingSubmissions(periodicEvaluationIds: number[]) {
try {
@@ -397,6 +409,8 @@ export async function checkExistingSubmissions(periodicEvaluationIds: number[])
}
})
+ console.log(existingSubmissions, "existingSubmissions")
+
return existingSubmissions
} catch (error) {
console.error("Error checking existing submissions:", error)