142 lines
4.5 KiB
TypeScript
142 lines
4.5 KiB
TypeScript
import sqlite from "better-sqlite3";
|
|
|
|
import { lotOccupancyDB as databasePath } from "../../data/databasePaths.js";
|
|
|
|
import type * as recordTypes from "../../types/recordTypes";
|
|
|
|
interface GetFeeCategoriesFilters {
|
|
occupancyTypeId?: number | string;
|
|
lotTypeId?: number | string;
|
|
}
|
|
|
|
interface GetFeeCategoriesOptions {
|
|
includeFees?: boolean;
|
|
}
|
|
|
|
export const getFeeCategories = (
|
|
filters: GetFeeCategoriesFilters,
|
|
options: GetFeeCategoriesOptions
|
|
): recordTypes.FeeCategory[] => {
|
|
const updateOrderNumbers =
|
|
!(filters.lotTypeId || filters.occupancyTypeId) && options.includeFees;
|
|
|
|
const database = sqlite(databasePath, {
|
|
readonly: !updateOrderNumbers
|
|
});
|
|
|
|
let sql =
|
|
"select feeCategoryId, feeCategory, orderNumber" +
|
|
" from FeeCategories" +
|
|
" where recordDelete_timeMillis is null";
|
|
|
|
let sqlParameters = [];
|
|
|
|
if (filters.occupancyTypeId) {
|
|
sql +=
|
|
" and feeCategoryId in (" +
|
|
"select feeCategoryId from Fees" +
|
|
" where recordDelete_timeMillis is null" +
|
|
" and (occupancyTypeId is null or occupancyTypeId = ?))";
|
|
|
|
sqlParameters.push(filters.occupancyTypeId);
|
|
}
|
|
|
|
if (filters.lotTypeId) {
|
|
sql +=
|
|
" and feeCategoryId in (" +
|
|
"select feeCategoryId from Fees" +
|
|
" where recordDelete_timeMillis is null" +
|
|
" and (lotTypeId is null or lotTypeId = ?))";
|
|
|
|
sqlParameters.push(filters.lotTypeId);
|
|
}
|
|
|
|
const feeCategories: recordTypes.FeeCategory[] = database
|
|
.prepare(sql + " order by orderNumber, feeCategory")
|
|
.all(sqlParameters);
|
|
|
|
if (options.includeFees) {
|
|
let expectedFeeCategoryOrderNumber = -1;
|
|
|
|
for (const feeCategory of feeCategories) {
|
|
expectedFeeCategoryOrderNumber += 1;
|
|
|
|
if (updateOrderNumbers && feeCategory.orderNumber !== expectedFeeCategoryOrderNumber) {
|
|
database
|
|
.prepare(
|
|
"update FeeCategories" +
|
|
" set orderNumber = ?" +
|
|
" where feeCategoryId = ?"
|
|
)
|
|
.run(
|
|
expectedFeeCategoryOrderNumber,
|
|
feeCategory.feeCategoryId
|
|
);
|
|
|
|
feeCategory.orderNumber = expectedFeeCategoryOrderNumber;
|
|
}
|
|
|
|
sql =
|
|
"select f.feeId, f.feeName, f.feeDescription," +
|
|
" f.occupancyTypeId, o.occupancyType," +
|
|
" f.lotTypeId, l.lotType," +
|
|
" ifnull(f.feeAmount, 0) as feeAmount, f.feeFunction," +
|
|
" f.taxAmount, f.taxPercentage," +
|
|
" f.includeQuantity, f.quantityUnit," +
|
|
" f.isRequired, f.orderNumber" +
|
|
" from Fees f" +
|
|
" left join OccupancyTypes o on f.occupancyTypeId = o.occupancyTypeId" +
|
|
" left join LotTypes l on f.lotTypeId = l.lotTypeId" +
|
|
" where f.recordDelete_timeMillis is null" +
|
|
" and f.feeCategoryId = ?";
|
|
|
|
sqlParameters = [];
|
|
|
|
sqlParameters.push(feeCategory.feeCategoryId);
|
|
|
|
if (filters.occupancyTypeId) {
|
|
sql +=
|
|
" and (f.occupancyTypeId is null or f.occupancyTypeId = ?)";
|
|
|
|
sqlParameters.push(filters.occupancyTypeId);
|
|
}
|
|
|
|
if (filters.lotTypeId) {
|
|
sql += " and (f.lotTypeId is null or f.lotTypeId = ?)";
|
|
|
|
sqlParameters.push(filters.lotTypeId);
|
|
}
|
|
|
|
feeCategory.fees = database
|
|
.prepare(sql + " order by f.orderNumber, f.feeName")
|
|
.all(sqlParameters);
|
|
|
|
if (updateOrderNumbers) {
|
|
let expectedFeeOrderNumber = -1;
|
|
|
|
for (const fee of feeCategory.fees) {
|
|
expectedFeeOrderNumber += 1;
|
|
|
|
if (fee.orderNumber !== expectedFeeOrderNumber) {
|
|
database
|
|
.prepare(
|
|
"update Fees" +
|
|
" set orderNumber = ?" +
|
|
" where feeId = ?"
|
|
)
|
|
.run(expectedFeeOrderNumber, fee.feeId);
|
|
|
|
fee.orderNumber = expectedFeeOrderNumber;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
database.close();
|
|
|
|
return feeCategories;
|
|
};
|
|
|
|
export default getFeeCategories;
|