智能硬件服务平台限时秒杀

import time
from flask import Flask, request, jsonify
from flask_sqlalchemy import SQLAlchemy
from sqlalchemy import Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker
from sqlalchemy import create_engine
import threading

app = Flask(__name__)
engine = create_engine('sqlite:///秒杀.db')
Session = sessionmaker(bind=engine)
Base = declarative_base()

class Product(Base):
    __tablename__ = 'products'
    id = Column(Integer, primary_key=True)
    name = Column(String)
    stock = Column(Integer)

Base.metadata.create_all(engine)

lock = threading.Lock()

@app.route('/seckill', methods=['POST'])
def seckill():
    product_id = request.json.get('product_id')
    session = Session()
    product = session.query(Product).filter_by(id=product_id).first()
    if not product:
        return jsonify({'status': 'error', 'message': 'Product not found'}), 404
    
    with lock:
        if product.stock > 0:
            product.stock -= 1
            session.commit()
            return jsonify({'status': 'success', 'message': 'Seckill successful'}), 200
        else:
            return jsonify({'status': 'error', 'message': 'Out of stock'}), 400

if __name__ == '__main__':
    app.run(debug=True)