sunrise-cms/helpers/lotOccupancyDB/getLotOccupancies.ts

import sqlite from "better-sqlite3";

import { lotOccupancyDB as databasePath } from "../../data/databasePaths.js";

import {
    dateIntegerToString,
    dateStringToInteger,
    dateToInteger
} from "@cityssm/expressjs-server-js/dateTimeFns.js";

import { getLotOccupancyOccupants } from "./getLotOccupancyOccupants.js";

import type * as recordTypes from "../../types/recordTypes";

interface GetLotOccupanciesFilters {
    lotId?: number | string;
    occupancyTime?: "" | "past" | "current" | "future";
    occupancyStartDateString?: string;
    occupancyEffectiveDateString?: string;
    occupantName?: string;
    occupancyTypeId?: number | string;
    mapId?: number | string;
    lotNameSearchType?: "" | "startsWith" | "endsWith";
    lotName?: string;
    lotTypeId?: number | string;
    workOrderId?: number | string;
    notWorkOrderId?: number | string;
}

interface GetLotOccupanciesOptions {
    limit: -1 | number;
    offset: number;
    includeOccupants: boolean;
}

const buildWhereClause = (
    filters: GetLotOccupanciesFilters
): { sqlWhereClause: string; sqlParameters: unknown[] } => {
    let sqlWhereClause = " where o.recordDelete_timeMillis is null";
    const sqlParameters: unknown[] = [];

    if (filters.lotId) {
        sqlWhereClause += " and o.lotId = ?";
        sqlParameters.push(filters.lotId);
    }

    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.occupantName) {
        const occupantNamePieces = filters.occupantName.toLowerCase().split(" ");
        for (const occupantNamePiece of occupantNamePieces) {
            sqlWhereClause +=
                " and o.lotOccupancyId in (select oo.lotOccupancyId from LotOccupancyOccupants oo where oo.recordDelete_timeMillis is null and instr(lower(oo.occupantName), ?))";
            sqlParameters.push(occupantNamePiece);
        }
    }

    if (filters.occupancyTypeId) {
        sqlWhereClause += " and o.occupancyTypeId = ?";
        sqlParameters.push(filters.occupancyTypeId);
    }

    if (filters.occupancyTime) {
        const currentDateString = dateToInteger(new Date());

        switch (filters.occupancyTime) {
            case "current": {
                sqlWhereClause +=
                    " and o.occupancyStartDate <= ? and (o.occupancyEndDate is null or o.occupancyEndDate >= ?)";
                sqlParameters.push(currentDateString, currentDateString);
                break;
            }

            case "past": {
                sqlWhereClause += " and o.occupancyEndDate < ?";
                sqlParameters.push(currentDateString);
                break;
            }

            case "future": {
                sqlWhereClause += " and o.occupancyStartDate > ?";
                sqlParameters.push(currentDateString);
                break;
            }
        }
    }

    if (filters.occupancyStartDateString) {
        sqlWhereClause += " and o.occupancyStartDate = ?";
        sqlParameters.push(dateStringToInteger(filters.occupancyStartDateString));
    }

    if (filters.occupancyEffectiveDateString) {
        sqlWhereClause +=
            " and (o.occupancyStartDate <= ? and (o.occupancyEndDate is null or o.occupancyEndDate >= ?))";
        sqlParameters.push(
            dateStringToInteger(filters.occupancyEffectiveDateString),
            dateStringToInteger(filters.occupancyEffectiveDateString)
        );
    }

    if (filters.mapId) {
        sqlWhereClause += " and l.mapId = ?";
        sqlParameters.push(filters.mapId);
    }

    if (filters.lotTypeId) {
        sqlWhereClause += " and l.lotTypeId = ?";
        sqlParameters.push(filters.lotTypeId);
    }

    if (filters.workOrderId) {
        sqlWhereClause +=
            " and o.lotOccupancyId in (select lotOccupancyId from WorkOrderLotOccupancies where recordDelete_timeMillis is null and workOrderId = ?)";
        sqlParameters.push(filters.workOrderId);
    }

    if (filters.notWorkOrderId) {
        sqlWhereClause +=
            " and o.lotOccupancyId not in (select lotOccupancyId from WorkOrderLotOccupancies where recordDelete_timeMillis is null and workOrderId = ?)";
        sqlParameters.push(filters.notWorkOrderId);
    }

    return {
        sqlWhereClause,
        sqlParameters
    };
};

export const getLotOccupancies = (
    filters: GetLotOccupanciesFilters,
    options: GetLotOccupanciesOptions,
    connectedDatabase?: sqlite.Database
): {
    count: number;
    lotOccupancies: recordTypes.LotOccupancy[];
} => {
    const database =
        connectedDatabase ||
        sqlite(databasePath, {
            readonly: true
        });

    database.function("userFn_dateIntegerToString", dateIntegerToString);

    const { sqlWhereClause, sqlParameters } = buildWhereClause(filters);

    let count = 0;

    if (options.limit !== -1) {
        count = database
            .prepare(
                "select count(*) as recordCount" +
                    " from LotOccupancies o" +
                    " left join Lots l on o.lotId = l.lotId" +
                    sqlWhereClause
            )
            .get(sqlParameters).recordCount;
    }

    let lotOccupancies: recordTypes.LotOccupancy[] = [];

    if (options.limit === -1 || count > 0) {
        lotOccupancies = database
            .prepare(
                "select o.lotOccupancyId," +
                    " o.occupancyTypeId, t.occupancyType," +
                    " o.lotId, lt.lotType, l.lotName," +
                    " l.mapId, m.mapName," +
                    " o.occupancyStartDate, userFn_dateIntegerToString(o.occupancyStartDate) as occupancyStartDateString," +
                    " o.occupancyEndDate,  userFn_dateIntegerToString(o.occupancyEndDate) as occupancyEndDateString" +
                    " from LotOccupancies o" +
                    " left join OccupancyTypes t on o.occupancyTypeId = t.occupancyTypeId" +
                    " left join Lots l on o.lotId = l.lotId" +
                    " left join LotTypes lt on l.lotTypeId = lt.lotTypeId" +
                    " left join Maps m on l.mapId = m.mapId" +
                    sqlWhereClause +
                    " order by o.occupancyStartDate desc, ifnull(o.occupancyEndDate, 99999999) desc, l.lotName, o.lotId" +
                    (options.limit !== -1
                        ? " limit " + options.limit + " offset " + options.offset
                        : "")
            )
            .all(sqlParameters);

        if (options.limit === -1) {
            count = lotOccupancies.length;
        }

        if (options.includeOccupants) {
            for (const lotOccupancy of lotOccupancies) {
                lotOccupancy.lotOccupancyOccupants = getLotOccupancyOccupants(
                    lotOccupancy.lotOccupancyId as number,
                    database
                );
            }
        }
    }

    if (!connectedDatabase) {
        database.close();
    }

    return {
        count,
        lotOccupancies
    };
};

export default getLotOccupancies;