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;