const Card = require('../models/Card');
const Admin = require('../models/Admin');
const setJson = require('../until/SetJson');
const fs = require('fs');
const path = require('path');
const moment = require('moment');

const comparePasswordPromise = (card, password) => {
    return new Promise((resolve, reject) => {
        card.comparePassword(password, (err, data) => {
            if (err) {
                reject(err)
            } else {
                resolve(data)
            }
        })
    })
};

const readFilePromise = (path) => {
    return new Promise((resolve, reject) => {
        fs.readFile(path, (err, data) => {
            if (err) {
                reject(err)
            } else {
                resolve(data)
            }
        })
    })
};

const writeFilePromise = (file, data) => {
    return new Promise((resolve, reject) => {
        fs.writeFile(file, data, (err, data) => {
            if (err) {
                reject(err)
            } else {
                resolve(data)
            }
        })
    })
};
const unlinkPromise = (path) => {
    return new Promise((resolve, reject) => {
        fs.unlink(path, (err, data) => {
            if (err) {
                reject(err)
            } else {
                resolve(data)
            }
        })
    })
};

//用户登录
exports.login = async (req, res) => {
    let _card = req.body;
    let code = _card.code;
    let password = _card.password;
    try {
        let card = await Card.findOne({code});
        //首先检查用户是否存在
        if (!card) {
            console.log('用户名不存在');
            res.json(setJson(false, '用户名不存在，请联系管理员', null));
        } else {
            let isMatch = await comparePasswordPromise(card, password);
            //密码是否正确
            if (isMatch) {
                console.log(`${code}(${card.cardholder}):登陆成功`);
                req.session.user = card;
                res.json(setJson(true, '登陆成功', card));
            } else {
                res.json(setJson(false, '密码错误', null));
            }
        }
    }
    catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null));
    }
};

//退出登录
exports.logout = (req, res) => {
    try {
        delete req.session.user;
        res.json(setJson(true, '退出登陆成功', null));
    } catch (e) {
        res.json(setJson(false, e.message, null));
    }
};

//新增卡
exports.register = async (req, res) => {
    const _card = req.body;
    try {
        let card = await Card.find({code: _card.code});
        if (card.length) {
            console.log('一卡通账号重复');
            res.json(setJson(false, '一卡通账号重复,请刷新页面', null));
        }
        _card.bills = [{time: Date.now(), place: '校园一卡通平台', amount: 80.00, type: '充值'}];
        card = new Card(_card);
        await card.save();
        res.json(setJson(true, '新增卡成功', null));
    }
    catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null));
    }
};

//上传图片预处理
exports.beforeUpload = async (req, res) => {
    try {
        let photoData = req.files.photo;
        let originalFilename = photoData ? photoData.originalFilename : '';
        if (originalFilename) {
            res.json(setJson(true, '服务端已准备好接收图片', photoData));
        } else {
            res.json(setJson(false, '请选择需要上传的图片', null));
        }
    }
    catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null));
    }
};

//上传图片
exports.upload = async (req, res, next) => {
    try {
        let isOldPhoto = ((typeof req.body.photo) === 'string');
        //第一次上传头像且头像存在
        if (!isOldPhoto && req.body.photo) {
            let photoData = req.body.photo.file.response.backData;
            let filePath = photoData ? photoData.path : '';
            let originalFilename = photoData ? photoData.originalFilename : '';
            //存在上传的文件则保存到服务器
            if (originalFilename) {
                let data = await readFilePromise(filePath);
                let timestamp = Date.now();
                let type = photoData.type.split('/')[1];
                let photo = `${timestamp}.${type}`;
                let newPath = path.join(__dirname, '../../', '/server/public/upload/imgs/' + photo);
                await  writeFilePromise(newPath, data);
                req.body.photo = photo;
                //删除原头像
                let card = await Card.findOne({code: req.body.code});
                if (card && card.photo) {
                    let oldPath = path.join(__dirname, '../../', `/server/public/upload/imgs/${card.photo}`);
                    await unlinkPromise(oldPath)
                }
            }
        }
        next()
    }
    catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null));
    }
};


//更新卡
exports.update = async (req, res) => {
    const _card = req.body;
    try {
        // let card = await Card.findOne({code: _card.code});
        let card = await Card.findOneAndUpdate({code: _card.code}, _card, {new: true});
        // card = await card.save();
        res.json(setJson(true, '更新成功', card));
    }
    catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null));
    }
};

//获取卡号
exports.getCode = async (req, res) => {
    try {
        let card = await Card.find();
        let len = (parseInt((card[card.length - 1]).code, 10) + 1).toString();
        let code = len.padStart(6, '0');
        res.json(setJson(true, '获取卡号成功', code));
    }
    catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null));
    }
};

//获取持卡人列表
exports.cardList = async (req, res) => {
    try {
        let cards = await Card.find({})
            .sort({'meta.updateAt': -1});
        res.json(setJson(true, '查询列表情成功', cards))
    } catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null))
    }
};

//删除卡
exports.deleteCard = async (req, res) => {
    let _id = req.body._id;
    try {
        let card = await Card.findOneAndRemove({_id});
        if (card.photo) {
            let oldPath = path.join(__dirname, '../../', `/server/public/upload/imgs/${card.photo}`);
            unlinkPromise(oldPath);
        }
        res.json(setJson(true, `删除持卡人${card.cardholder}成功`, null))
    } catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null))
    }
};

//卡片信息详情
exports.detail = async (req, res) => {
    let code = req.query.code;
    try {
        let card = await Card.findOne({code}, 'code cardholder sex type isFrozen balance photo');
        if (card) {
            res.json(setJson(true, '查看详情成功', card))
        } else {
            res.json(setJson(false, 'not found，请确认一卡通账号是否正确', null))
        }
    } catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null))
    }
};

//挂失操作
exports.frozen = async (req, res) => {
    let code = req.body.code;
    try {
        let card = await Card.findOne({code});
        card.isFrozen = !card.isFrozen;
        card = await Card.findOneAndUpdate({code}, card, {new: true});
        delete card.bills;
        let str = card.isFrozen ? '挂失' : '解挂';
        res.json(setJson(true, `${str}成功`, card))
    } catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null))
    }
};

//重置密码操作
exports.resetPassword = async (req, res) => {
    let code = req.body.code;
    try {
        let card = await Card.findOne({code});
        card.password = '666666';
        card = await card.save();
        res.json(setJson(true, `重置成功`, card))
    } catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null))
    }
};

//修改密码操作
exports.changePassword = async (req, res) => {
    let code = req.session.user.code;
    let oldPassword = req.body.oldPassword;
    let password = req.body.password;
    try {
        let card = await Card.findOne({code});
        if (!card) {
            console.log('用户名不存在');
            res.json(setJson(false, '登录状态异常，请重新登录系统', null));
        } else {
            let isMatch = await comparePasswordPromise(card, oldPassword);
            //密码是否正确
            if (isMatch) {
                card.password = password;
                card = await card.save();
                res.json(setJson(true, `修改成功`, null))
            } else {
                res.json(setJson(false, '修改失败，原密码错误', null));
            }
        }
    } catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null))
    }
};

//充值操作
exports.recharge = async (req, res) => {
    let code = req.body.code,
        password = req.body.password,
        rechargeAmount = parseFloat(req.body.rechargeAmount),
        isAdmin = req.session.user.isAdmin;
    try {
        let card, admin, isMatch;
        //从session中判断是否为管理员,是则找出管理员
        if (isAdmin) {
            let adminCode = req.session.user.code;
            admin = await Admin.findOne({code: adminCode});
        }
        //找到需要充值的卡
        card = await Card.findOne({code});

        if (!card) {
            res.json(setJson(false, `登录信息错误，请重新登录`, card));
        } else {
            if (card.isFrozen) {
                res.json(setJson(false, `校园卡已挂失，请先解除挂失`, null))
            }
            //验证管理员密码或者是用户密码
            if (isAdmin) {
                isMatch = await comparePasswordPromise(admin, password);
            } else {
                isMatch = await comparePasswordPromise(card, password);
            }
            //密码是否正确
            if (isMatch) {
                card = await Card.findOneAndUpdate({code}, {
                    $inc: {balance: rechargeAmount},
                    $addToSet: {bills: {time: Date.now(), place: '校园一卡通平台', amount: rechargeAmount, type: '充值'}}
                }, {new: true});
                res.json(setJson(true, `充值成功`, card))
            } else {
                res.json(setJson(false, '密码错误', null));
            }
        }

    } catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null))
    }
};

//购物
exports.shop = async (req, res) => {
    try {
        let price = parseFloat(req.body.price);
        let place = req.body.name;
        let code = req.session.user.code;
        let card = await Card.findOne({code});
        //首先判断是否挂失
        if (card.isFrozen) {
            res.json(setJson(false, `校园卡已挂失，请先解除挂失`, null))
        }
        //判断余额是否充足
        else if (card.balance >= price) {
            card = await Card.findOneAndUpdate({code}, {
                $inc: {balance: -price},
                $addToSet: {bills: {time: Date.now(), place: place, amount: price, type: '消费'}}
            }, {new: true});
            res.json(setJson(true, `消费成功`, card))
        } else {
            res.json(setJson(false, `余额不足，请充值`, null))
        }
    } catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null))
    }
};

//流水列表
exports.billList = async (req, res) => {
    let code = req.body.code,
        date = req.body.date;
    try {
        let card = await Card.findOne({code}, 'cardholder bills balance');
        if (card) {
            if (date) {
                card.bills = card.bills.filter(bill => {
                    let startTime = moment(date[0].substr(0, 10)),
                        endTime = moment(date[1].substr(0, 10)),
                        currentTime = moment(moment(bill.time).format('YYYY-MM-DD'));
                    return !startTime.isAfter(currentTime) && !endTime.isBefore(currentTime)
                });
            }
            //消费时间倒序排序
            card.bills.sort((a, b) => b.time - a.time);
            res.json(setJson(true, '', card))
        } else {
            res.json(setJson(false, 'not found，请确认一卡通账号是否正确', null))
        }
    } catch (e) {
        console.log(e.stack);
        res.json(setJson(false, e.message, null))
    }
};