69 lines
1.9 KiB
TypeScript
69 lines
1.9 KiB
TypeScript
import { getSupabaseServerAdminClient } from "@/packages/supabase/src/clients/server-admin-client";
|
|
import { AnalysisOrderStatus } from '@/packages/shared/src/types/medipost-analysis';
|
|
|
|
import type { AnalysisResponseElement } from "../types/analysis-response-element";
|
|
|
|
export async function getExistingAnalysisResponseElements({
|
|
analysisResponseId,
|
|
}: {
|
|
analysisResponseId: number;
|
|
}): Promise<AnalysisResponseElement[]> {
|
|
const { data } = await getSupabaseServerAdminClient()
|
|
.schema('medreport')
|
|
.from('analysis_response_elements')
|
|
.select('*')
|
|
.eq('analysis_response_id', analysisResponseId)
|
|
.throwOnError();
|
|
|
|
return data as AnalysisResponseElement[];
|
|
}
|
|
|
|
export async function createAnalysisResponseElement({
|
|
element,
|
|
}: {
|
|
element: Omit<AnalysisResponseElement, 'created_at' | 'updated_at' | 'id'>;
|
|
}) {
|
|
await getSupabaseServerAdminClient()
|
|
.schema('medreport')
|
|
.from('analysis_response_elements')
|
|
.insert(element)
|
|
.throwOnError();
|
|
}
|
|
|
|
export async function upsertAnalysisResponse({
|
|
analysisOrderId,
|
|
orderNumber,
|
|
orderStatus,
|
|
userId,
|
|
}: {
|
|
analysisOrderId: number;
|
|
orderNumber: string;
|
|
orderStatus: typeof AnalysisOrderStatus[keyof typeof AnalysisOrderStatus];
|
|
userId: string;
|
|
}) {
|
|
const { data: analysisResponse } = await getSupabaseServerAdminClient()
|
|
.schema('medreport')
|
|
.from('analysis_responses')
|
|
.upsert(
|
|
{
|
|
analysis_order_id: analysisOrderId,
|
|
order_number: orderNumber,
|
|
order_status: orderStatus,
|
|
user_id: userId,
|
|
},
|
|
{ onConflict: 'order_number', ignoreDuplicates: false },
|
|
)
|
|
.select('id')
|
|
.throwOnError();
|
|
|
|
|
|
const analysisResponseId = analysisResponse?.[0]?.id;
|
|
if (!analysisResponseId) {
|
|
throw new Error(
|
|
`Failed to insert or update analysis order response (order id: ${analysisOrderId}, order number: ${orderNumber})`,
|
|
);
|
|
}
|
|
|
|
return { analysisResponseId };
|
|
}
|