APP搜索 秒杀

// 秒杀按钮点击事件
document.getElementById('seckill-btn').addEventListener('click', function() {
    // 发送秒杀请求
    fetch('/api/seckill', {
        method: 'POST',
        headers: {
            'Content-Type': 'application/json'
        },
        body: JSON.stringify({ productId: '12345' })
    })
    .then(response => response.json())
    .then(data => {
        if (data.success) {
            alert('秒杀成功，请尽快支付！');
        } else {
            alert('秒杀失败，请重试！');
        }
    })
    .catch(error => {
        console.error('Error:', error);
        alert('网络错误，请稍后再试！');
    });
});

const express = require('express');
const app = express();
const bodyParser = require('body-parser');
const { Pool } = require('pg');

app.use(bodyParser.json());

const pool = new Pool({
    user: 'your_db_user',
    host: 'your_db_host',
    database: 'your_db_name',
    password: 'your_db_password',
    port: 5432,
});

app.post('/api/seckill', async (req, res) => {
    const { productId } = req.body;
    const client = await pool.connect();
    try {
        await client.query('BEGIN');
        const { rows } = await client.query('SELECT stock FROM products WHERE id = $1 FOR UPDATE', [productId]);
        if (rows[0].stock > 0) {
            await client.query('UPDATE products SET stock = stock - 1 WHERE id = $1', [productId]);
            await client.query('COMMIT');
            res.json({ success: true });
        } else {
            await client.query('ROLLBACK');
            res.json({ success: false });
        }
    } catch (e) {
        await client.query('ROLLBACK');
        res.status(500).json({ success: false, error: e.message });
    } finally {
        client.release();
    }
});

app.listen(3000, () => {
    console.log('Server is running on port 3000');
});