import sqlite from "better-sqlite3";

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

import { calculateFeeAmount, calculateTaxAmount } from "../functions.fee.js";

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

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

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

interface AddLotOccupancyFeeForm {
    lotOccupancyId: number | string;
    feeId: number | string;
    quantity: number | string;
    feeAmount?: number | string;
    taxAmount?: number | string;
}

export const addLotOccupancyFee = (
    lotOccupancyFeeForm: AddLotOccupancyFeeForm,
    requestSession: recordTypes.PartialSession
): boolean => {
    const database = sqlite(databasePath);

    const rightNowMillis = Date.now();

    // Calculate fee and tax (if not set)

    let feeAmount: number;
    let taxAmount: number;

    if (lotOccupancyFeeForm.feeAmount) {
        feeAmount =
            typeof lotOccupancyFeeForm.feeAmount === "string"
                ? Number.parseFloat(lotOccupancyFeeForm.feeAmount)
                : feeAmount;
        taxAmount =
            typeof lotOccupancyFeeForm.taxAmount === "string"
                ? Number.parseFloat(lotOccupancyFeeForm.taxAmount)
                : taxAmount;
    } else {
        const lotOccupancy = getLotOccupancy(
            lotOccupancyFeeForm.lotOccupancyId
        );
        const fee = getFee(lotOccupancyFeeForm.feeId);

        feeAmount = calculateFeeAmount(fee, lotOccupancy);
        taxAmount = calculateTaxAmount(fee, feeAmount);
    }

    // Check if record already exists

    const record: {
        feeAmount?: number;
        taxAmount?: number;
        recordDelete_timeMillis?: number;
    } = database
        .prepare(
            "select feeAmount, taxAmount, recordDelete_timeMillis" +
                " from LotOccupancyFees" +
                " where lotOccupancyId = ?" +
                " and feeId = ?"
        )
        .get(lotOccupancyFeeForm.lotOccupancyId, lotOccupancyFeeForm.feeId);

    if (record) {
        if (record.recordDelete_timeMillis) {
            database
                .prepare(
                    "delete from LotOccupancyFees" +
                        " where recordDelete_timeMillis is not null" +
                        " and lotOccupancyId = ?" +
                        " and feeId = ?"
                )
                .run(
                    lotOccupancyFeeForm.lotOccupancyId,
                    lotOccupancyFeeForm.feeId
                );
        } else if (
            record.feeAmount === feeAmount &&
            record.taxAmount === taxAmount
        ) {
            database
                .prepare(
                    "update LotOccupancyFees" +
                        " set quantity = quantity + ?," +
                        " recordUpdate_userName = ?," +
                        " recordUpdate_timeMillis = ?" +
                        " where lotOccupancyId = ?" +
                        " and feeId = ?"
                )
                .run(
                    lotOccupancyFeeForm.quantity,
                    requestSession.user.userName,
                    rightNowMillis,
                    lotOccupancyFeeForm.lotOccupancyId,
                    lotOccupancyFeeForm.feeId
                );

            database.close();

            return true;
        } else {
            const quantity =
                typeof lotOccupancyFeeForm.quantity === "string"
                    ? Number.parseFloat(lotOccupancyFeeForm.quantity)
                    : lotOccupancyFeeForm.quantity;

            database
                .prepare(
                    "update LotOccupancyFees" +
                        " set feeAmount = (feeAmount * quantity) + ?," +
                        " taxAmount = (taxAmount * quantity) + ?," +
                        " quantity = 1," +
                        " recordUpdate_userName = ?," +
                        " recordUpdate_timeMillis = ?" +
                        " where lotOccupancyId = ?" +
                        " and feeId = ?"
                )
                .run(
                    feeAmount * quantity,
                    taxAmount * quantity,
                    requestSession.user.userName,
                    rightNowMillis,
                    lotOccupancyFeeForm.lotOccupancyId,
                    lotOccupancyFeeForm.feeId
                );

            database.close();

            return true;
        }
    }

    // Create new record

    const result = database
        .prepare(
            "insert into LotOccupancyFees (" +
                "lotOccupancyId, feeId," +
                " quantity, feeAmount, taxAmount," +
                " recordCreate_userName, recordCreate_timeMillis," +
                " recordUpdate_userName, recordUpdate_timeMillis)" +
                " values (?, ?, ?, ?, ?, ?, ?, ?, ?)"
        )
        .run(
            lotOccupancyFeeForm.lotOccupancyId,
            lotOccupancyFeeForm.feeId,
            lotOccupancyFeeForm.quantity,
            feeAmount,
            taxAmount,
            requestSession.user.userName,
            rightNowMillis,
            requestSession.user.userName,
            rightNowMillis
        );

    database.close();

    return result.changes > 0;
};

export default addLotOccupancyFee;