reduce complexity

deepsource-autofix-76c6eb20
Dan Gowans 2022-10-31 14:05:38 -04:00
parent 47387ac479
commit 8153368dde
2 changed files with 141 additions and 117 deletions

View File

@ -1,16 +1,10 @@
import sqlite from "better-sqlite3"; import sqlite from "better-sqlite3";
import { lotOccupancyDB as databasePath } from "../../data/databasePaths.js"; import { lotOccupancyDB as databasePath } from "../../data/databasePaths.js";
export const getFeeCategories = (filters, options) => { const buildFeeCategoryWhereClause = (filters) => {
const updateOrderNumbers = !(filters.lotTypeId || filters.occupancyTypeId) && options.includeFees; let sqlWhereClause = " where recordDelete_timeMillis is null";
const database = sqlite(databasePath, { const sqlParameters = [];
readonly: !updateOrderNumbers
});
let sql = "select feeCategoryId, feeCategory, orderNumber" +
" from FeeCategories" +
" where recordDelete_timeMillis is null";
let sqlParameters = [];
if (filters.occupancyTypeId) { if (filters.occupancyTypeId) {
sql += sqlWhereClause +=
" and feeCategoryId in (" + " and feeCategoryId in (" +
"select feeCategoryId from Fees" + "select feeCategoryId from Fees" +
" where recordDelete_timeMillis is null" + " where recordDelete_timeMillis is null" +
@ -18,64 +12,79 @@ export const getFeeCategories = (filters, options) => {
sqlParameters.push(filters.occupancyTypeId); sqlParameters.push(filters.occupancyTypeId);
} }
if (filters.lotTypeId) { if (filters.lotTypeId) {
sql += sqlWhereClause +=
" and feeCategoryId in (" + " and feeCategoryId in (" +
"select feeCategoryId from Fees" + "select feeCategoryId from Fees" +
" where recordDelete_timeMillis is null" + " where recordDelete_timeMillis is null" +
" and (lotTypeId is null or lotTypeId = ?))"; " and (lotTypeId is null or lotTypeId = ?))";
sqlParameters.push(filters.lotTypeId); sqlParameters.push(filters.lotTypeId);
} }
return {
sqlWhereClause,
sqlParameters
};
};
const buildFeeWhereClause = (filters, feeCategoryId) => {
let sqlWhereClause = " where f.recordDelete_timeMillis is null" + " and f.feeCategoryId = ?";
const sqlParameters = [];
sqlParameters.push(feeCategoryId);
if (filters.occupancyTypeId) {
sqlWhereClause += " and (f.occupancyTypeId is null or f.occupancyTypeId = ?)";
sqlParameters.push(filters.occupancyTypeId);
}
if (filters.lotTypeId) {
sqlWhereClause += " and (f.lotTypeId is null or f.lotTypeId = ?)";
sqlParameters.push(filters.lotTypeId);
}
return {
sqlWhereClause,
sqlParameters
};
};
export const getFeeCategories = (filters, options) => {
const updateOrderNumbers = !(filters.lotTypeId || filters.occupancyTypeId) && options.includeFees;
const database = sqlite(databasePath, {
readonly: !updateOrderNumbers
});
const feeCategorySqlFilter = buildFeeCategoryWhereClause(filters);
const feeCategories = database const feeCategories = database
.prepare(sql + " order by orderNumber, feeCategory") .prepare("select feeCategoryId, feeCategory, orderNumber" +
.all(sqlParameters); " from FeeCategories" +
feeCategorySqlFilter.sqlWhereClause +
" order by orderNumber, feeCategory")
.all(feeCategorySqlFilter.sqlParameters);
if (options.includeFees) { if (options.includeFees) {
let expectedFeeCategoryOrderNumber = -1; let expectedFeeCategoryOrderNumber = -1;
for (const feeCategory of feeCategories) { for (const feeCategory of feeCategories) {
expectedFeeCategoryOrderNumber += 1; expectedFeeCategoryOrderNumber += 1;
if (updateOrderNumbers && feeCategory.orderNumber !== expectedFeeCategoryOrderNumber) { if (updateOrderNumbers && feeCategory.orderNumber !== expectedFeeCategoryOrderNumber) {
database database
.prepare("update FeeCategories" + .prepare("update FeeCategories" + " set orderNumber = ?" + " where feeCategoryId = ?")
" set orderNumber = ?" +
" where feeCategoryId = ?")
.run(expectedFeeCategoryOrderNumber, feeCategory.feeCategoryId); .run(expectedFeeCategoryOrderNumber, feeCategory.feeCategoryId);
feeCategory.orderNumber = expectedFeeCategoryOrderNumber; feeCategory.orderNumber = expectedFeeCategoryOrderNumber;
} }
sql = const feeSqlFilter = buildFeeWhereClause(filters, feeCategory.feeCategoryId);
"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 feeCategory.fees = database
.prepare(sql + " order by f.orderNumber, f.feeName") .prepare("select f.feeId, f.feeName, f.feeDescription," +
.all(sqlParameters); " 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" +
feeSqlFilter.sqlWhereClause +
" order by f.orderNumber, f.feeName")
.all(feeSqlFilter.sqlParameters);
if (updateOrderNumbers) { if (updateOrderNumbers) {
let expectedFeeOrderNumber = -1; let expectedFeeOrderNumber = -1;
for (const fee of feeCategory.fees) { for (const fee of feeCategory.fees) {
expectedFeeOrderNumber += 1; expectedFeeOrderNumber += 1;
if (fee.orderNumber !== expectedFeeOrderNumber) { if (fee.orderNumber !== expectedFeeOrderNumber) {
database database
.prepare("update Fees" + .prepare("update Fees" + " set orderNumber = ?" + " where feeId = ?")
" set orderNumber = ?" +
" where feeId = ?")
.run(expectedFeeOrderNumber, fee.feeId); .run(expectedFeeOrderNumber, fee.feeId);
fee.orderNumber = expectedFeeOrderNumber; fee.orderNumber = expectedFeeOrderNumber;
} }

View File

@ -13,6 +13,66 @@ interface GetFeeCategoriesOptions {
includeFees?: boolean; includeFees?: boolean;
} }
const buildFeeCategoryWhereClause = (
filters: GetFeeCategoriesFilters
): { sqlWhereClause: string; sqlParameters: unknown[] } => {
let sqlWhereClause = " where recordDelete_timeMillis is null";
const sqlParameters: unknown[] = [];
if (filters.occupancyTypeId) {
sqlWhereClause +=
" 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) {
sqlWhereClause +=
" and feeCategoryId in (" +
"select feeCategoryId from Fees" +
" where recordDelete_timeMillis is null" +
" and (lotTypeId is null or lotTypeId = ?))";
sqlParameters.push(filters.lotTypeId);
}
return {
sqlWhereClause,
sqlParameters
};
};
const buildFeeWhereClause = (
filters: GetFeeCategoriesFilters,
feeCategoryId: number
): { sqlWhereClause: string; sqlParameters: unknown[] } => {
let sqlWhereClause = " where f.recordDelete_timeMillis is null" + " and f.feeCategoryId = ?";
const sqlParameters: unknown[] = [];
sqlParameters.push(feeCategoryId);
if (filters.occupancyTypeId) {
sqlWhereClause += " and (f.occupancyTypeId is null or f.occupancyTypeId = ?)";
sqlParameters.push(filters.occupancyTypeId);
}
if (filters.lotTypeId) {
sqlWhereClause += " and (f.lotTypeId is null or f.lotTypeId = ?)";
sqlParameters.push(filters.lotTypeId);
}
return {
sqlWhereClause,
sqlParameters
};
};
export const getFeeCategories = ( export const getFeeCategories = (
filters: GetFeeCategoriesFilters, filters: GetFeeCategoriesFilters,
options: GetFeeCategoriesOptions options: GetFeeCategoriesOptions
@ -24,36 +84,16 @@ export const getFeeCategories = (
readonly: !updateOrderNumbers readonly: !updateOrderNumbers
}); });
let sql = const feeCategorySqlFilter = buildFeeCategoryWhereClause(filters);
"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 const feeCategories: recordTypes.FeeCategory[] = database
.prepare(sql + " order by orderNumber, feeCategory") .prepare(
.all(sqlParameters); "select feeCategoryId, feeCategory, orderNumber" +
" from FeeCategories" +
feeCategorySqlFilter.sqlWhereClause +
" order by orderNumber, feeCategory"
)
.all(feeCategorySqlFilter.sqlParameters);
if (options.includeFees) { if (options.includeFees) {
let expectedFeeCategoryOrderNumber = -1; let expectedFeeCategoryOrderNumber = -1;
@ -64,52 +104,31 @@ export const getFeeCategories = (
if (updateOrderNumbers && feeCategory.orderNumber !== expectedFeeCategoryOrderNumber) { if (updateOrderNumbers && feeCategory.orderNumber !== expectedFeeCategoryOrderNumber) {
database database
.prepare( .prepare(
"update FeeCategories" + "update FeeCategories" + " set orderNumber = ?" + " where feeCategoryId = ?"
" set orderNumber = ?" +
" where feeCategoryId = ?"
) )
.run( .run(expectedFeeCategoryOrderNumber, feeCategory.feeCategoryId);
expectedFeeCategoryOrderNumber,
feeCategory.feeCategoryId
);
feeCategory.orderNumber = expectedFeeCategoryOrderNumber; feeCategory.orderNumber = expectedFeeCategoryOrderNumber;
} }
sql = const feeSqlFilter = buildFeeWhereClause(filters, feeCategory.feeCategoryId as number);
"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 feeCategory.fees = database
.prepare(sql + " order by f.orderNumber, f.feeName") .prepare(
.all(sqlParameters); "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" +
feeSqlFilter.sqlWhereClause +
" order by f.orderNumber, f.feeName"
)
.all(feeSqlFilter.sqlParameters);
if (updateOrderNumbers) { if (updateOrderNumbers) {
let expectedFeeOrderNumber = -1; let expectedFeeOrderNumber = -1;
@ -119,11 +138,7 @@ export const getFeeCategories = (
if (fee.orderNumber !== expectedFeeOrderNumber) { if (fee.orderNumber !== expectedFeeOrderNumber) {
database database
.prepare( .prepare("update Fees" + " set orderNumber = ?" + " where feeId = ?")
"update Fees" +
" set orderNumber = ?" +
" where feeId = ?"
)
.run(expectedFeeOrderNumber, fee.feeId); .run(expectedFeeOrderNumber, fee.feeId);
fee.orderNumber = expectedFeeOrderNumber; fee.orderNumber = expectedFeeOrderNumber;