const express = require('express');
const router = express.Router();
const dotenv = require('dotenv');
const mysql = require('mysql');

const socket = require('../socket');
// const socket_client = socket.socket_client;
const io = socket.getIO();

// const io_sock = require("socket.io-client");


dotenv.config();

// const socket = io_sock("http://localhost:"+process.env.PORT);

// Connect to the MySQL database
const connection = mysql.createConnection({
    host: process.env.DB_HOST,
    user: process.env.DB_USER,
    password: process.env.DB_PASS,
    database: process.env.DB_NAME
});

router.post('/', async (req, res) => {
    let { uid } = req.body;
    try {
        console.log('Emitting scan_dia event: ' + uid);
        io.emit('scan', uid); // Emitting event using the io instance
        // socket.emit('scan_dia', uid);
        // socket_client.emit('scan_dia', uid);
        return res.status(200).json({ success: true, uid: uid });
    } catch (error) {
        console.log('error scan', error);
        return res.status(500).json({ message: 'Internal server error', status: false });
    }

});

router.get('/tempat_sewa', async (req, res) => {
    try {
        const query = 'SELECT * FROM tb_tempat_sewa a join tb_penyewa b on a.nik=b.nik;';
        connection.query(query, (error, results) => {
            if (error) {
                console.log('error cek tempat sewa', error);
                return res.status(500).json({ message: 'Internal server error', status: false });
            }
            return res.status(200).json({ success: true, data: results, status: true });
        })
    } catch (error) {
        console.log('error cek tempat sewa', error);
        return res.status(500).json({ message: 'Internal server error', status: false });
    }

})

router.get('/id/:id', async (req, res) => {
    const { id } = req.params;
    try {
        const query = 'SELECT * FROM tb_tempat_sewa a join tb_penyewa b on a.nik=b.nik where b.rfid = ?';
        connection.query(query, [id], (error, results) => {
            if (error) {
                console.log('error cek id rfid', error);
                return res.status(500).json({ message: 'Internal server error', status: false });
            }
            return res.status(200).json({ success: true, data: results, status: true });
        })
    } catch (error) {
        console.log('error cek id rfid', error);
        return res.status(500).json({ message: 'Internal server error', status: false });
    }

})

router.post('/bayar', async (req, res) => {
    const { nik, id_tempat_sewa, rfid } = req.body;
    console.log(nik, id_tempat_sewa, rfid);
    try {
        const query_select = 'SELECT * FROM tb_tempat_sewa a join tb_penyewa b on a.nik=b.nik where b.rfid = ? and a.id_tempat_serwa = ? and b.nik = ?';
        connection.query(query_select, [rfid, id_tempat_sewa, nik], (error, results) => {
            if (error) {
                console.log('error cek id rfid', error);
                return res.status(500).json({ message: 'Internal server error', status: false });
            }
            if (results.length === 0) {
                return res.status(401).json({ message: 'Data tidak ditemukan', status: false });
            }
            // console.log(results[0]);
            const saldo_terdahulu = results[0].saldo;
            if (results[0].harga_sewa > saldo_terdahulu) {
                return res.status(401).json({ message: 'Saldo tidak mencukupi', status: false });
            }
            const saldo_terkini = saldo_terdahulu - results[0].harga_sewa;
            const query_update = 'UPDATE tb_penyewa SET saldo = ? WHERE nik = ?';
            connection.query(query_update, [saldo_terkini, nik], (error, results_update) => {
                if (error) {
                    console.log('error bayar', error);
                    return res.status(500).json({ message: 'Internal server error', status: false });
                }
                // console.log(results_update);
                const ket = 'Pembayaran Retribusi Dilakukan oleh penyewa : ' + results[0].nik + ' - ' + results[0].nama + ' - ' + results[0].rfid + ' dengan tempat sewa : ' + results[0].nama_tempat_sewa + '\nSaldo sebelumnya : ' + saldo_terdahulu + '\nSaldo setelah bayar : ' + saldo_terkini;
                const jenis = 'Pembayaran Retribusi';
                const query_log = 'INSERT INTO tb_log_history (nik, id_tempat_serwa, ket,jenis) VALUES (?, ?, ?, ?)';
                connection.query(query_log, [nik, id_tempat_sewa, ket, jenis], (error, results) => {
                    if (error) {
                        console.log('error log', error);
                        return res.status(500).json({ message: 'Internal server error', status: false });
                    }
                    return res.status(200).json({ success: true, data: results, status: true, message: 'Pembayaran retribusi berhasil dilakukan' });
                })
            })
        })
    } catch (error) {
        console.log('error bayar', error);
        return res.status(500).json({ message: 'Internal server error', status: false });
    }

})

router.get('/log', (req, res) => {
    const query_log = 'SELECT * FROM tb_log_history a join tb_penyewa b on a.nik = b.nik'
    connection.query(query_log, (error, results) => {
        if (error) {
            console.log('error log', error);
            return res.status(500).json({ message: 'Internal server error', status: false });
        }
        return res.json({ success: true, data: results, status: true });
    })
})

router.get('/penyewa', async (req, res) => {
    try {
        const query_penyewa = 'SELECT * FROM tb_penyewa';
        connection.query(query_penyewa, (error, results) => {
            if (error) {
                console.log('error log', error);
                return res.status(500).json({ message: 'Internal server error', status: false });
            }
            return res.status(200).json({ success: true, data: results, status: true });
        })
    } catch (error) {
        console.log('error log', error);
        return res.status(500).json({ message: 'Internal server error', status: false });
    }

})

router.post('/penyewa/:nik', async (req, res) => {
    const { nik } = req.params;
    const { topup } = req.body;
    try {
        const query_penyewa = 'SELECT * FROM tb_penyewa where nik = ?';
        // console.log(nik, topup);
        connection.query(query_penyewa, [nik], (error, results) => {
            if (error) {
                console.log('error log', error);
                return res.status(500).json({ message: 'Internal server error', status: false });
            }
            if (results.length === 0) {
                return res.status(401).json({ message: 'Data tidak ditemukan', status: false });
            }
            const saldo_terdahulu = results[0].saldo;
            // parse integer
            const saldo_terkini = parseInt(saldo_terdahulu) + parseInt(topup);
            // console.log(saldo_terkini, saldo_terdahulu);
            // console.log(results);

            const query_update = 'UPDATE tb_penyewa SET saldo = ? WHERE nik = ?';
            connection.query(query_update, [saldo_terkini, nik], (error, results_update) => {
                if (error) {
                    console.log('error bayar', error);
                    return res.status(500).json({ message: 'Internal server error', status: false });
                }
                const query_log = 'INSERT INTO tb_log_history (nik, ket,jenis) VALUES (?, ?, ?)';
                const jenis = 'Top Up Saldo';
                const ket = 'Top Up Saldo dilakukan oleh penyewa : ' + results[0].nik + ' - ' + results[0].nama + ' - ' + results[0].rfid + ' dengan nominal : ' + topup + '\nSaldo sebelumnya : ' + saldo_terdahulu + '\nSaldo setelah topup : ' + saldo_terkini;

                console.log(ket);
                console.log(jenis);


                connection.query(query_log, [nik, ket, jenis], (error, results_log) => {
                    if (error) {
                        console.log('error log', error);
                        return res.status(500).json({ message: 'Internal server error', status: false });
                    }
                    return res.status(200).json({ success: true, status: true, message: 'Top Up Saldo berhasil dilakukan' });
                })


            })
        })
    } catch (error) {
        console.log('error bayar', error);
        return res.status(500).json({ message: 'Internal server error', status: false });
    }

})

router.put('/penyewa/:nik', async (req, res) => {
    const { nik } = req.params;
    const { nik_baru, nama } = req.body;
    try {
        const query_select = 'SELECT * FROM tb_penyewa where nik = ?';

        connection.query(query_select, [nik], (error, results) => {
            if (error) {
                console.log('error select', error);
                return res.status(500).json({ message: 'Internal server error', status: false });
            }
            if (results.length === 0) {
                return res.status(401).json({ message: 'Data tidak ditemukan', status: false });
            }
            const query_update = 'UPDATE tb_penyewa SET nik = ? , nama = ? WHERE nik = ?';
            connection.query(query_update, [nik_baru, nama, nik], (error, results_update) => {
                if (error) {
                    console.log('error update data penyewa', error);
                    return res.status(500).json({ message: 'Internal server error', status: false });
                }
                return res. status(200).json({ success: true, status: true, message: 'Perubahan data penyewa berhasil dilakukan' });
            })
        })
    } catch (error) {
        console.log('error update data penyewa', error);
        return res.status(500).json({ message: 'Internal server error', status: false });
    }

})



module.exports = router;