bot/admin/controllers/transactionController.js

const Transaction = require('../models/Transaction');
const Group = require('../models/Group');

// @desc    获取交易列表
// @route   GET /api/transactions
// @access  Private
const getTransactions = async (req, res) => {
    try {
        const { page = 1, limit = 10, startDate, endDate, type, groupId } = req.query;
        const result = await Transaction.findAll(
            { startDate, endDate, type, groupId },
            parseInt(page),
            parseInt(limit)
        );
        res.json(result);
    } catch (error) {
        res.status(500).json({ message: '服务器错误' });
    }
};

// @desc    创建交易
// @route   POST /api/transactions
// @access  Private
const createTransaction = async (req, res) => {
    try {
        const { groupId, type, amount } = req.body;
        const group = await Group.findByGroupId(groupId);

        if (!group) {
            return res.status(404).json({ message: '群组不存在' });
        }

        const id = await Transaction.create({
            groupId,
            groupName: group.group_name,
            type,
            amount
        });

        const transaction = await Transaction.findById(id);
        res.status(201).json(transaction);
    } catch (error) {
        res.status(500).json({ message: '服务器错误' });
    }
};

// @desc    删除交易
// @route   DELETE /api/transactions/:id
// @access  Private
const deleteTransaction = async (req, res) => {
    try {
        const transaction = await Transaction.findById(req.params.id);
        if (!transaction) {
            return res.status(404).json({ message: '交易不存在' });
        }

        await Transaction.delete(req.params.id);
        res.json({ message: '交易已删除' });
    } catch (error) {
        res.status(500).json({ message: '服务器错误' });
    }
};

// @desc    获取仪表板数据
// @route   GET /api/transactions/dashboard
// @access  Private
const getDashboardData = async (req, res) => {
    try {
        const data = await Transaction.getDashboardData();
        res.json(data);
    } catch (error) {
        res.status(500).json({ message: '服务器错误' });
    }
};

// @desc    导出交易数据
// @route   GET /api/transactions/export
// @access  Private
const exportTransactions = async (req, res) => {
    try {
        const { startDate, endDate, type, groupId } = req.query;
        const result = await Transaction.findAll(
            { startDate, endDate, type, groupId },
            1,
            1000000 // 导出所有数据
        );

        // 生成 CSV 数据
        const csvData = [
            ['时间', '群组', '类型', '金额'].join(','),
            ...result.transactions.map(t => [
                new Date(t.time).toLocaleString(),
                t.group_name,
                t.type === 'deposit' ? '入款' : '下发',
                t.amount.toFixed(2)
            ].join(','))
        ].join('\n');

        res.setHeader('Content-Type', 'text/csv');
        res.setHeader('Content-Disposition', 'attachment; filename=transactions.csv');
        res.send(csvData);
    } catch (error) {
        res.status(500).json({ message: '服务器错误' });
    }
};

module.exports = {
    getTransactions,
    createTransaction,
    deleteTransaction,
    getDashboardData,
    exportTransactions
};