sunrise-cms/helpers/lotOccupancyDB/getLots.ts

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 type * as recordTypes from "../../types/recordTypes";

interface GetLotsFilters {
    lotNameSearchType?: "" | "startsWith" | "endsWith";
    lotName?: string;
    mapId?: number | string;
    lotTypeId?: number | string;
    lotStatusId?: number | string;
    occupancyStatus?: "" | "occupied" | "unoccupied";
    workOrderId?: number | string;
}

interface GetLotsOptions {
    limit: -1 | number;
    offset: number;
}

const buildWhereClause = (filters: GetLotsFilters): { sqlWhereClause: string; sqlParameters: unknown[];} => {
    let sqlWhereClause = " where l.recordDelete_timeMillis is null";
    const sqlParameters: unknown[] = [];
    
    if (filters.lotName) {
        if (filters.lotNameSearchType === "startsWith") {
            sqlWhereClause += " and l.lotName like ? || '%'";
            sqlParameters.push(filters.lotName);
        } else if (filters.lotNameSearchType === "endsWith") {
            sqlWhereClause += " and l.lotName like '%' || ?";
            sqlParameters.push(filters.lotName);
        } else {
            const lotNamePieces = filters.lotName.toLowerCase().split(" ");
            for (const lotNamePiece of lotNamePieces) {
                sqlWhereClause += " and instr(lower(l.lotName), ?)";
                sqlParameters.push(lotNamePiece);
            }
        }
    }


    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 const getLots = (
    filters: GetLotsFilters,
    options: GetLotsOptions,
    connectedDatabase?: sqlite.Database
): {
    count: number;
    lots: recordTypes.Lot[];
} => {
    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: recordTypes.Lot[] = [];

    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;