asan-service/server/controllers/GPS.Withdraw.js

const { body, param, validationResult } = require('express-validator');
const { _sr } = require('../plugins/serverResponses');
const { checkValidations } = require('../plugins/controllersHelperFunctions');
const User = require('../models/GPS.User');
const Withdraw = require('../models/GPS.Withdraw');
const { notifyAdmin } = require('../WebSocket/controllers/admin_EventsController')


module.exports.createRequest = [
    [
        body('card').notEmpty().isObject().withMessage('گارت ورودی خود را انتخاب کنید'),
    ],
    checkValidations(validationResult),
    async (req, res) => {
        try {
            const withdraw = await Withdraw.findOne({ userId: req.user_id, status: 0 })
            if (withdraw) {
                res.status(400).json({ msg: 'شما درخواست درحال بررسی دارید' })
            } else {
                const user = await User.findById(req.user_id)
                if (user.walletBalance < 50000) {
                    const data = {
                        card: req.body.card,
                        userId: req.user_id,
                        amount: user.walletBalance,
                        dollarAmount: user.dollarBalance,
                        status: 0
                    }

                    const request = await Withdraw.create(data)
                    user.dollarBalance = 0;
                    user.walletBalance = 0;
                    user.save()
                    // res.status(201).json({ msg: _sr.fa.response.success_save, data: request })
                    notifyAdmin('newWithdrawRequest')
                    res.status(201).json(request)
                } else {
                    res.status(400).json({ msg: 'حداقل موجودی باید 50 هزار تومان باشد' })
                }

            }

        } catch (error) {
            res.status(500).json({ msg: error })

        }
    }
]


module.exports.getAllForUser = async (req, res) => {
    const rows = (!req.query?.rows || req.query?.rows <= 5) ? 10 : parseInt(req.query.rows);

    let page = 0;
    if (req.query?.page && req.query.page > 1) {
        page = (req.query.page - 1) * rows;
    }

    const search = req.query?.search || null;

    let sort = {};

    if (req.query?.created_at) {
        sort.created_at = parseInt(req.query.created_at);
    }

    if (req.query?.updated_at) {
        sort.updated_at = parseInt(req.query.updated_at);
    }

    if (req.query?.amount) {
        sort.amount = parseInt(req.query.amount);
    }

    if (req.query?.status) {
        sort.status = parseInt(req.query.status);
    }

    if (Object.keys(sort).length === 0) {
        sort = { created_at: 1 };
    }

    const filter = {
        userId: req.user_id,
    };

    if (search) {
        filter.$or = [
            { amount: search },
            { dollarAmount: search },
            { trackingNumber: { $regex: search, $options: 'i' } },
        ];
    }

    try {
        const data = await Withdraw.find(filter).skip(page).limit(rows).sort(sort);
        const total = await Withdraw.countDocuments(filter);

        res.status(200).json({ data, total });
    } catch (error) {
        res.status(500).json({ message: 'خطای سرور', error });
    }
};

module.exports.getAllForAdmin = async (req, res) => {
    try {
        const page = parseInt(req.query.page) || 1;
        const rows = parseInt(req.query.rows) || 10;
        const search = req.query.search || "";
        const sortField = req.query.sortField || "status";
        const sortOrder = req.query.sortOrder === "desc" ? -1 : 1;
        const skip = (page - 1) * rows;

        const matchStage = search ? {
            $or: [
                { IMEI: new RegExp(search, 'i') },
                { trackingNumber: new RegExp(search, 'i') }
            ]
        } : {};

        const aggregationPipeline = [
            { $match: matchStage },
            {
                $lookup: {
                    from: 'users',
                    localField: 'userId',
                    foreignField: '_id',
                    as: 'userId'
                }
            },
            { $unwind: "$userId" },
            { $sort: { [sortField]: sortOrder } },
            { $skip: skip },
            { $limit: rows }
        ];

        const [data, totalDocuments] = await Promise.all([
            Withdraw.aggregate(aggregationPipeline),
            Withdraw.countDocuments(matchStage)
        ]);

        const totalPages = Math.ceil(totalDocuments / rows);

        res.status(200).json({ data, totalDocuments, totalPages });
    } catch (error) {
        res.status(500).json({ message: "An error occurred, please try again.", error: error.message });
    }
}


module.exports.updateReq = [
    [
        param('id').notEmpty().isMongoId().withMessage('ایدی را باید وارد کنید'),
        param('type').notEmpty().isString().withMessage('وضعیت را باید وارد کنید'),
    ],
    checkValidations(validationResult),
    async (req, res) => {
        const request = await Withdraw.findById(req.params.id)
        if (!request) {
            res.status(404).json({ msg: _sr.fa.not_found.item_id })
        } else {
            switch (req.params.type) {
                case "accept": {
                    request.status = 1;
                    request.save()
                    notifyAdmin('newWithdrawRequest')

                    res.status(201).json({ msg: _sr.fa.response.success_save, data: request })

                    break;
                }
                case "deposit": {
                    request.status = 2;
                    request.depositDate = new Date();
                    request.trackingNumber = req.body.trackingNumber || 0;
                    request.save()
                    notifyAdmin('newWithdrawRequest')

                    res.status(201).json({ msg: _sr.fa.response.success_save, data: request })

                    break;
                }
                default: {
                    res.status(404).json({ msg: "استاتوس اشتباه است" })
                    break;
                }
            }
        }
    }
]