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 {
    lotName?: string;
    mapId?: number | string;
    lotTypeId?: number | string;
    lotStatusId?: number | string;
    occupancyStatus?: "" | "occupied" | "unoccupied";
    workOrderId?: number | string;
}

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

export const getLots = (
    filters: GetLotsFilters,
    options: GetLotsOptions,
    connectedDatabase?: sqlite.Database
): {
    count: number;
    lots: recordTypes.Lot[];
} => {
    const database =
        connectedDatabase ||
        sqlite(databasePath, {
            readonly: true
        });

    let sqlWhereClause = " where l.recordDelete_timeMillis is null";
    const sqlParameters = [];

    if (filters.lotName) {
        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);
    }

    const currentDate = dateToInteger(new Date());

    let count: number;

    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;