速达建站 - 专业网站建设与反波胆系统开发

// 反波胆系统 - 实时赔率计算示例
class OddsCalculator {
    constructor() {
        this.baseOdds = {
            homeWin: 2.10,
            draw: 3.25,
            awayWin: 3.50
        };
        this.volatility = 0.05;
    }
    
    // 根据投注量调整赔率
    adjustOdds(betAmounts) {
        const total = betAmounts.home + betAmounts.draw + betAmounts.away;
        const ratios = {
            home: betAmounts.home / total,
            draw: betAmounts.draw / total,
            away: betAmounts.away / total
        };
        
        // 计算新赔率
        return {
            home: this.calculateNewOdds(this.baseOdds.homeWin, ratios.home),
            draw: this.calculateNewOdds(this.baseOdds.draw, ratios.draw),
            away: this.calculateNewOdds(this.baseOdds.awayWin, ratios.away)
        };
    }
    
    calculateNewOdds(baseOdd, ratio) {
        // 简化版的赔率调整算法
        const adjustment = ratio * this.volatility;
        return baseOdd * (1 - adjustment);
    }
    
    // 获取实时赔率
    getLiveOdds(matchId) {
        return fetch(`/api/odds/${matchId}`)
            .then(response => response.json())
            .then(data => {
                return this.adjustOdds(data.betAmounts);
            })
            .catch(error => {
                console.error('获取赔率失败:', error);
                return this.baseOdds;
            });
    }
}

// 使用示例
const oddsCalculator = new OddsCalculator();
const betAmounts = {
    home: 15000,
    draw: 8000,
    away: 12000
};

const currentOdds = oddsCalculator.adjustOdds(betAmounts);
console.log('当前赔率:', currentOdds);
                    

// 反波胆系统API示例
const express = require('express');
const app = express();
app.use(express.json());

// 用户认证中间件
const authenticateUser = (req, res, next) => {
    const token = req.headers.authorization;
    if (!token) {
        return res.status(401).json({ error: '需要认证令牌' });
    }
    
    try {
        const decoded = jwt.verify(token.replace('Bearer ', ''), process.env.JWT_SECRET);
        req.user = decoded;
        next();
    } catch (error) {
        return res.status(401).json({ error: '无效的认证令牌' });
    }
};

// 获取比赛列表
app.get('/api/matches', async (req, res) {
    try {
        const { page = 1, limit = 10, league } = req.query;
        let query = {};
        
        if (league) {
            query.league = league;
        }
        
        const matches = await Match.find(query)
            .skip((page - 1) * limit)
            .limit(parseInt(limit))
            .sort({ startTime: 1 });
            
        const total = await Match.countDocuments(query);
        
        res.json({
            matches,
            totalPages: Math.ceil(total / limit),
            currentPage: parseInt(page)
        });
    } catch (error) {
        res.status(500).json({ error: '获取比赛列表失败' });
    }
});

// 下注接口
app.post('/api/bet', authenticateUser, async (req, res) => {
    try {
        const { matchId, betType, amount, odds } = req.body;
        
        // 检查用户余额
        const user = await User.findById(req.user.id);
        if (user.balance < amount) {
            return res.status(400).json({ error: '余额不足' });
        }
        
        // 创建投注记录
        const bet = new Bet({
            userId: req.user.id,
            matchId,
            betType,
            amount,
            odds,
            status: 'pending'
        });
        
        await bet.save();
        
        // 扣除用户余额
        user.balance -= amount;
        await user.save();
        
        res.json({ 
            success: true, 
            message: '投注成功',
            newBalance: user.balance
        });
    } catch (error) {
        res.status(500).json({ error: '投注失败' });
    }
});

// 启动服务器
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
    console.log(`服务器运行在端口 ${PORT}`);
});