42 lines
1.1 KiB
TypeScript
42 lines
1.1 KiB
TypeScript
import type { BurialSiteStatus } from '../types/recordTypes.js'
|
|
|
|
import { acquireConnection } from './pool.js'
|
|
|
|
interface GetFilters {
|
|
cemeteryId?: number | string
|
|
}
|
|
|
|
interface BurialSiteStatusSummary extends BurialSiteStatus {
|
|
burialSiteCount: number
|
|
}
|
|
|
|
export default async function getBurialSiteStatusSummary(
|
|
filters: GetFilters
|
|
): Promise<BurialSiteStatusSummary[]> {
|
|
const database = await acquireConnection()
|
|
|
|
let sqlWhereClause = ' where l.recordDelete_timeMillis is null'
|
|
const sqlParameters: unknown[] = []
|
|
|
|
if ((filters.cemeteryId ?? '') !== '') {
|
|
sqlWhereClause += ' and l.cemeteryId = ?'
|
|
sqlParameters.push(filters.cemeteryId)
|
|
}
|
|
|
|
const statuses = database
|
|
.prepare(
|
|
`select s.burialSiteStatusId, s.burialSiteStatus,
|
|
count(l.burialSiteId) as burialSiteCount
|
|
from BurialSites l
|
|
left join BurialSiteStatuses s on l.burialSiteStatusId = s.burialSiteStatusId
|
|
${sqlWhereClause}
|
|
group by s.burialSiteStatusId, s.burialSiteStatus, s.orderNumber
|
|
order by s.orderNumber`
|
|
)
|
|
.all(sqlParameters) as BurialSiteStatusSummary[]
|
|
|
|
database.release()
|
|
|
|
return statuses
|
|
}
|