mysql 数据重复提交

const express = require('express');
const app = express();
const bodyParser = require('body-parser');
const crypto = require('crypto');

app.use(bodyParser.json());

// 模拟数据库
let dataStore = {};

// 防重复提交中间件
function preventDuplicateSubmission(req, res, next) {
  const { id } = req.body;
  const clientIp = req.ip;
  const timestamp = Date.now();
  const hash = crypto.createHash('sha256').update(`${id}${clientIp}${timestamp}`).digest('hex');

  if (dataStore[hash]) {
    return res.status(400).send('Duplicate submission detected');
  }

  dataStore[hash] = { id, clientIp, timestamp };
  setTimeout(() => {
    delete dataStore[hash];
  }, 60 * 1000); // 1分钟后清理缓存

  next();
}

app.post('/submit', preventDuplicateSubmission, (req, res) => {
  // 处理数据提交逻辑
  res.send('Data submitted successfully');
});

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