fastapi-payment-module-skill

FastAPI Payment Module Skill

面向已有 FastAPI 项目的开发者，快速集成支付能力。

能力清单

触发场景

用户说"帮我加支付"或"集成微信/支付宝"时触发。

核心实现

依赖配置

# 微信支付
pip install wechatpayv3

# 支付宝
pip install alipay-sdk-python

# 异步HTTP
pip install httpx

配置

# config.py
from pydantic_settings import BaseSettings

class Settings(BaseSettings):
    # 微信支付
    wechat_app_id: str = ""
    wechat_mch_id: str = ""
    wechat_api_key: str = ""
    wechat_cert_path: str = ""
    wechat_notify_url: str = ""
    
    # 支付宝
    alipay_app_id: str = ""
    alipay_private_key: str = ""
    alipay_public_key: str = ""
    alipay_notify_url: str = ""
    alipay_return_url: str = ""

settings = Settings()

数据模型

# models.py
from sqlalchemy import Column, BigInteger, String, Numeric, Integer, DateTime, Enum as SQLEnum, Text
from sqlalchemy.sql import func
from database import Base
import enum

class PayType(str, enum.Enum):
    WECHAT = "wechat"
    ALIPAY = "alipay"

class PayStatus(str, enum.Enum):
    PENDING = "pending"
    PAID = "paid"
    REFUNDED = "refunded"
    CLOSED = "closed"

class RefundStatus(str, enum.Enum):
    PENDING = "pending"
    SUCCESS = "success"
    FAILED = "failed"

class PayOrder(Base):
    __tablename__ = "wg_pay_order"
    
    id = Column(BigInteger, primary_key=True, autoincrement=True)
    order_no = Column(String(64), unique=True, nullable=False, index=True)
    pay_order_no = Column(String(64), index=True)
    pay_type = Column(SQLEnum(PayType))
    status = Column(SQLEnum(PayStatus), default=PayStatus.PENDING)
    amount = Column(Numeric(10, 2), nullable=False)
    subject = Column(String(200))
    body = Column(String(500))
    notify_url = Column(String(500))
    return_url = Column(String(500))
    user_id = Column(String(50), index=True)
    openid = Column(String(100))
    paid_at = Column(DateTime)
    created_at = Column(DateTime, server_default=func.now())
    updated_at = Column(DateTime, server_default=func.now(), onupdate=func.now())

class RefundOrder(Base):
    __tablename__ = "wg_refund_order"
    
    id = Column(BigInteger, primary_key=True, autoincrement=True)
    refund_no = Column(String(64), unique=True, nullable=False)
    pay_order_no = Column(String(64), index=True)
    refund_id = Column(String(64))
    refund_amount = Column(Numeric(10, 2), nullable=False)
    total_amount = Column(Numeric(10, 2), nullable=False)
    status = Column(SQLEnum(RefundStatus), default=RefundStatus.PENDING)
    reason = Column(String(200))
    refunded_at = Column(DateTime)
    created_at = Column(DateTime, server_default=func.now())