109 lines
4.2 KiB
JavaScript
109 lines
4.2 KiB
JavaScript
import sqlite from "better-sqlite3";
|
|
import { lotOccupancyDB as databasePath } from "../../data/databasePaths.js";
|
|
import { dateToInteger } from "@cityssm/expressjs-server-js/dateTimeFns.js";
|
|
import * as configFunctions from "../functions.config.js";
|
|
import { getLotNameWhereClause } from "../functions.sqlFilters.js";
|
|
function buildWhereClause(filters) {
|
|
let sqlWhereClause = " where l.recordDelete_timeMillis is null";
|
|
const sqlParameters = [];
|
|
const lotNameFilters = getLotNameWhereClause(filters.lotName, filters.lotNameSearchType, "l");
|
|
sqlWhereClause += lotNameFilters.sqlWhereClause;
|
|
sqlParameters.push(...lotNameFilters.sqlParameters);
|
|
if (filters.mapId) {
|
|
sqlWhereClause += " and l.mapId = ?";
|
|
sqlParameters.push(filters.mapId);
|
|
}
|
|
if (filters.lotTypeId) {
|
|
sqlWhereClause += " and l.lotTypeId = ?";
|
|
sqlParameters.push(filters.lotTypeId);
|
|
}
|
|
if (filters.lotStatusId) {
|
|
sqlWhereClause += " and l.lotStatusId = ?";
|
|
sqlParameters.push(filters.lotStatusId);
|
|
}
|
|
if (filters.occupancyStatus) {
|
|
if (filters.occupancyStatus === "occupied") {
|
|
sqlWhereClause += " and lotOccupancyCount > 0";
|
|
}
|
|
else if (filters.occupancyStatus === "unoccupied") {
|
|
sqlWhereClause += " and (lotOccupancyCount is null or lotOccupancyCount = 0)";
|
|
}
|
|
}
|
|
if (filters.workOrderId) {
|
|
sqlWhereClause +=
|
|
" and l.lotId in (select lotId from WorkOrderLots where recordDelete_timeMillis is null and workOrderId = ?)";
|
|
sqlParameters.push(filters.workOrderId);
|
|
}
|
|
return {
|
|
sqlWhereClause,
|
|
sqlParameters
|
|
};
|
|
}
|
|
export function getLots(filters, options, connectedDatabase) {
|
|
const database = connectedDatabase ||
|
|
sqlite(databasePath, {
|
|
readonly: true
|
|
});
|
|
const { sqlWhereClause, sqlParameters } = buildWhereClause(filters);
|
|
const currentDate = dateToInteger(new Date());
|
|
let count = 0;
|
|
if (options.limit !== -1) {
|
|
count = database
|
|
.prepare("select count(*) as recordCount" +
|
|
" from Lots l" +
|
|
(" left join (" +
|
|
"select lotId, count(lotOccupancyId) as lotOccupancyCount" +
|
|
" from LotOccupancies" +
|
|
" where recordDelete_timeMillis is null" +
|
|
" and occupancyStartDate <= " +
|
|
currentDate +
|
|
" and (occupancyEndDate is null or occupancyEndDate >= " +
|
|
currentDate +
|
|
")" +
|
|
" group by lotId" +
|
|
") o on l.lotId = o.lotId") +
|
|
sqlWhereClause)
|
|
.get(sqlParameters).recordCount;
|
|
}
|
|
let lots = [];
|
|
if (options.limit === -1 || count > 0) {
|
|
database.function("userFn_lotNameSortName", configFunctions.getProperty("settings.lot.lotNameSortNameFunction"));
|
|
lots = database
|
|
.prepare("select l.lotId, l.lotName," +
|
|
" t.lotType," +
|
|
" l.mapId, m.mapName, l.mapKey," +
|
|
" l.lotStatusId, s.lotStatus," +
|
|
" ifnull(o.lotOccupancyCount, 0) as lotOccupancyCount" +
|
|
" from Lots l" +
|
|
" left join LotTypes t on l.lotTypeId = t.lotTypeId" +
|
|
" left join LotStatuses s on l.lotStatusId = s.lotStatusId" +
|
|
" left join Maps m on l.mapId = m.mapId" +
|
|
(" left join (" +
|
|
"select lotId, count(lotOccupancyId) as lotOccupancyCount" +
|
|
" from LotOccupancies" +
|
|
" where recordDelete_timeMillis is null" +
|
|
" and occupancyStartDate <= " +
|
|
currentDate +
|
|
" and (occupancyEndDate is null or occupancyEndDate >= " +
|
|
currentDate +
|
|
")" +
|
|
" group by lotId" +
|
|
") o on l.lotId = o.lotId") +
|
|
sqlWhereClause +
|
|
" order by userFn_lotNameSortName(l.lotName), l.lotId" +
|
|
(options ? " limit " + options.limit + " offset " + options.offset : ""))
|
|
.all(sqlParameters);
|
|
if (options.limit === -1) {
|
|
count = lots.length;
|
|
}
|
|
}
|
|
if (!connectedDatabase) {
|
|
database.close();
|
|
}
|
|
return {
|
|
count,
|
|
lots
|
|
};
|
|
}
|
|
export default getLots;
|