remove pycache from git tracking

.env.example

@@ -1,43 +0,0 @@
-# ========== 本地调试 ==========
-# BASE_URL 需为 ZPAY 可访问的回调地址。本地调试时 ZPAY 无法回调 localhost/内网，
-# 可用 ngrok 等隧道：BASE_URL=https://xxx.ngrok.io
-# 或直接使用生产地址测试回调（需 payjsapi 已部署到公网）
-# nomadvip/digital/cnomadcna/nomadlms 的 zpay_notify 均依赖此地址，未正确配置会导致 PocketBase/Memos 不更新
-# 本地调试：ngrok 暴露 8700 后设置 BASE_URL=https://xxx.ngrok.io
-# 线上部署：BASE_URL=https://api.hackrobot.cn
-
-# ========== 生产部署（Ubuntu 等）==========
-# 线上部署必须正确配置，否则会显示「支付失败」：
-# 1. BASE_URL 必须为 payjsapi 公网地址，ZPAY 需能访问此地址做异步回调
-#    错误示例：http://127.0.0.1:8700、http://localhost（ZPAY 无法访问）
-#    正确示例：https://api.hackrobot.cn（域名需解析到本机并配置 nginx 反向代理）
-# 2. 服务器需能访问 zpayz.cn（检查防火墙、DNS），可访问 /health?check_zpay=1 自检
-BASE_URL=https://api.hackrobot.cn
-
-# 支付渠道：zpay（已替代 xorpay）| xorpay
-PAYMENT_PROVIDER=zpay
-
-# XorPay
-XORPAY_AID=8220
-XORPAY_SECRET=your_secret
-
-# ZPAY（网关: https://zpayz.cn/）
-ZPAY_PID=2025121809351743
-ZPAY_KEY=tpEi7wWIWI2kXiYVTpIG6j7it0mjVW89
-
-# PocketBase
-PB_URL=https://pocketbase.hackrobot.cn
-PB_ADMIN_EMAIL=your@email.com
-PB_ADMIN_PASSWORD=your_password
-
-# Memos（仅 nomadvip 使用）
-MEMOS_API=https://qun.hackrobot.cn/api/v1/users
-MEMOS_TOKEN=your_token
-
-# MinIO 对象存储（可选）
-MINIO_ENDPOINT=minioweb.hackrobot.cn
-MINIO_PORT=443
-MINIO_ACCESS_KEY=
-MINIO_SECRET_KEY=
-MINIO_BUCKET=hackrobot
-MINIO_UPLOAD_PREFIX=joins

.gitignore

@@ -1,13 +1,7 @@
-# 日志文件（不产生，避免 git 本地/线上不一致）
-*.log
-payment_notify.log
-xorpay_notify.log
 
-# Python
+# Python bytecode
 __pycache__/
 *.pyc
-*.py[cod]
-venv/
-.venv/
-.env
-.env.local
+*.pyo
+*.pyd
+*$py.class

README.md

@@ -1,96 +1,6 @@
-# PayJS API
+# androidh5api
 
-支付 API 服务，支持多支付渠道（XorPay、ZPAY），按项目模块化拆分。
 
-## 路由与项目对应
-
-| 项目 | 路由前缀 | 说明 |
-|------|----------|------|
-| nomadvip | `/nomadvip/*` | 固定 ZPAY，独立实例 |
-| digital | `/digital/*` | 使用 PAYMENT_PROVIDER |
-| cnomadcna | `/cnomadcna/*` | 使用 PAYMENT_PROVIDER |
-| nomadlms | `/nomadlms/*` | 使用 PAYMENT_PROVIDER |
-| legacy | `/payh5`、`/zpay_notify` 等 | 向后兼容 |
-
-各项目业务互不影响，可单独配置。
-
-## 环境
-
-本地调试：`BASE_URL` 需为 ZPAY 可访问地址（如 ngrok 暴露 8700 端口）  
-线上部署：`BASE_URL=https://api.hackrobot.cn`
-
-## 模块结构
-
-```
-app/
-├── config.py          # 配置（环境变量）
-├── main.py            # FastAPI 入口，挂载路由
-├── sdk/               # SDK 组件化封装
-│   ├── payment/       # 支付网关（ZPAY/XorPay）
-│   ├── pocketbase.py  # PocketBase 数据库
-│   ├── minio.py       # MinIO 对象存储
-│   └── memos.py       # Memos 用户（仅 nomadvip 使用）
-├── services/          # 共享业务逻辑（基于 SDK）
-│   ├── pb.py          # PocketBase 客户端
-│   ├── memos.py       # Memos 用户创建
-│   ├── minio.py       # MinIO 上传
-│   └── payment.py     # 支付成功处理
-├── routers/           # 项目路由
-│   ├── nomadvip.py    # /nomadvip/*
-│   ├── digital.py    # /digital/*
-│   ├── cnomadcna.py  # /cnomadcna/*
-│   ├── nomadlms.py   # /nomadlms/*
-│   ├── legacy.py     # /payh5 等（向后兼容）
-│   └── common.py     # /submit_meetup_application、/create_user
-└── payment/
-    ├── base.py        # 支付抽象基类
-    ├── xorpay.py      # XorPay 实现
-    ├── zpay.py        # ZPAY 实现（易支付兼容）
-    └── factory.py     # 渠道工厂
-```
-
-## 支付渠道
-
-| 渠道 | 环境变量 | 说明 |
-|------|----------|------|
-| XorPay | `PAYMENT_PROVIDER=xorpay` | 默认 |
-| ZPAY | `PAYMENT_PROVIDER=zpay` | 需配置 `ZPAY_PID`、`ZPAY_KEY` |
-
-切换渠道：设置环境变量 `PAYMENT_PROVIDER=xorpay` 或 `zpay`，参考 `.env.example`。
-
-## 本地调试
-
-```bash
-# 复制配置
-cp .env.example .env
-
-# 本地调试时 BASE_URL 需 ZPAY 可访问，可用 ngrok：
-# ngrok http 8700  -> 将 BASE_URL 设为 ngrok 提供的 https 地址
-
-python run.py
-# 或 uvicorn app.main:app --host 0.0.0.0 --port 8700 --reload
-```
-
-## 线上部署
-
-域名：`https://api.hackrobot.cn`
-
-```bash
-# .env 中设置
-BASE_URL=https://api.hackrobot.cn
-PAYMENT_PROVIDER=zpay
-# 其他 ZPAY、PocketBase、Memos 配置见 .env.example
-```
-
-## 线上「支付失败」排查
-
-本地正常、Ubuntu 部署后显示支付失败，常见原因：
-
-1. **BASE_URL 配置错误**：必须为 ZPAY 可公网访问的地址。错误示例：`http://127.0.0.1:8700`、`http://localhost`。正确：`https://api.hackrobot.cn`（域名需解析到本机，nginx 反向代理 8700 端口）。
-
-2. **服务器无法访问 zpayz.cn**：防火墙、DNS 或网络限制。访问 `https://你的域名/health?check_zpay=1` 自检，若 `zpayz_reachable: false` 则需开放出站或检查网络。
-
-3. **启动时控制台有 BASE_URL 警告**：说明配置了内网地址，需修改 `.env` 中的 `BASE_URL` 为公网地址后重启。
 
 ## Getting started
 

app/config.py

@@ -1,47 +0,0 @@
-"""
-应用配置
-支付渠道可通过 PAYMENT_PROVIDER 切换：xorpay | zpay
-"""
-import os
-from typing import Literal
-
-PaymentChannel = Literal["xorpay", "zpay"]
-
-# 当前使用的支付渠道（zpay 替代 xorpay，payjs2 接口业务保留）
-PAYMENT_PROVIDER: PaymentChannel = os.getenv("PAYMENT_PROVIDER", "zpay").lower()
-
-# XorPay 配置
-XORPAY_AID = os.getenv("XORPAY_AID", "8220")
-XORPAY_SECRET = os.getenv("XORPAY_SECRET", "afcacd99570945f88de62624aaa3578e")
-XORPAY_CASHIER_URL = os.getenv("XORPAY_CASHIER_URL", "https://xorpay.com/api/cashier")
-
-# ZPAY 配置（网关: https://zpayz.cn/）
-ZPAY_PID = os.getenv("ZPAY_PID", "2025121809351743")
-ZPAY_KEY = os.getenv("ZPAY_KEY", "tpEi7wWIWI2kXiYVTpIG6j7it0mjVW89")
-
-# PocketBase
-PB_URL = os.getenv("PB_URL", "https://pocketbase.hackrobot.cn")
-PB_ADMIN_EMAIL = os.getenv("PB_ADMIN_EMAIL", "xiaoshuang.eric@gmail.com")
-PB_ADMIN_PASSWORD = os.getenv("PB_ADMIN_PASSWORD", "Xiao4669805@")
-
-# Memos
-MEMOS_API = os.getenv("MEMOS_API", "https://qun.hackrobot.cn/api/v1/users")
-MEMOS_TOKEN = os.getenv(
-    "MEMOS_TOKEN",
-    "eyJhbGciOiJIUzI1NiIsImtpZCI6InYxIiwidHlwIjoiSldUIn0.eyJuYW1lIjoiaGFja3JvYm90IiwiaXNzIjoibWVtb3MiLCJzdWIiOiIxIiwiYXVkIjpbInVzZXIuYWNjZXNzLXRva2VuIl0sImlhdCI6MTc1NzQwNTE0OX0.Idn7kBlxE-CoSOXwWuZ1tHGIRKHAIeDyXSafGS5OHsg",
-)
-
-# 回调地址（用于生成 notify_url）
-BASE_URL = os.getenv("BASE_URL", "https://api.hackrobot.cn")
-
-# MinIO 对象存储
-MINIO_ENDPOINT = os.getenv("MINIO_ENDPOINT", "minioweb.hackrobot.cn")
-MINIO_PORT = int(os.getenv("MINIO_PORT", "443"))
-MINIO_ACCESS_KEY = os.getenv("MINIO_ACCESS_KEY", "")
-MINIO_SECRET_KEY = os.getenv("MINIO_SECRET_KEY", "")
-MINIO_BUCKET = os.getenv("MINIO_BUCKET", "hackrobot")
-MINIO_USE_SSL = os.getenv("MINIO_USE_SSL", "true").lower() == "true"
-_minio_ep = os.getenv("MINIO_ENDPOINT", "minioweb.hackrobot.cn")
-_minio_bucket = os.getenv("MINIO_BUCKET", "hackrobot")
-MINIO_PUBLIC_URL = os.getenv("MINIO_PUBLIC_URL", f"https://{_minio_ep}/{_minio_bucket}")
-MINIO_UPLOAD_PREFIX = os.getenv("MINIO_UPLOAD_PREFIX", "joins")

app/main.py

@@ -1,40 +1,16 @@
-"""
-支付 API 主入口
-支持多支付渠道（XorPay、ZPAY），通过 PAYMENT_PROVIDER 环境变量切换
-
-路由模块化，按项目拆分：
-- nomadvip: /nomadvip/*     - 固定 ZPAY
-- digital:  /digital/*      - 使用 PAYMENT_PROVIDER
-- cnomadcna: /cnomadcna/*   - 使用 PAYMENT_PROVIDER
-- nomadlms: /nomadlms/*     - 使用 PAYMENT_PROVIDER
-- legacy:   /payh5、/zpay_notify 等（向后兼容）
-- common:   /submit_meetup_application、/create_user
-
-本地调试：BASE_URL 需为 ZPAY 可访问地址（如 ngrok）
-线上部署：BASE_URL=https://api.hackrobot.cn（必须为 ZPAY 可公网访问的地址）
-"""
-import logging
-
-import requests
-from fastapi import FastAPI, Request, HTTPException
+from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
-from fastapi.responses import JSONResponse
+from pydantic import BaseModel
+import hashlib
+import time
+import random
+import string
+import requests
+from fastapi import Request, HTTPException
+import logging
+from pocketbase import PocketBase
 
-from .config import BASE_URL
-from .routers import (
-    nomadvip_router,
-    digital_router,
-    cnomadcna_router,
-    nomadlms_router,
-    legacy_router,
-    common_router,
-)
-
-app = FastAPI(
-    title="PayJS API",
-    description="nomadvip / digital / cnomadcna / nomadlms 支付接口",
-    version="2.0",
-)
+app = FastAPI()
 
 app.add_middleware(
     CORSMiddleware,
@@ -44,75 +20,291 @@ app.add_middleware(
     allow_headers=["*"],
 )
 
+# ==================== PocketBase 配置 ====================
+PB_URL = "https://pocketbase.hackrobot.cn"
+PB_ADMIN_EMAIL = "xiaoshuang.eric@gmail.com"
+PB_ADMIN_PASSWORD = "Xiao4669805@"
+# ========================================================
 
-@app.exception_handler(Exception)
-async def global_exception_handler(request: Request, exc: Exception):
-    """捕获未处理异常，记录日志后返回 500（HTTPException 交由 FastAPI 默认处理）"""
-    if isinstance(exc, HTTPException):
-        raise exc
-    logging.error(f"未处理异常: {request.url.path} - {exc}", exc_info=True)
-    return JSONResponse(status_code=500, content={"detail": str(exc)})
+def get_pb_client():
+    client = PocketBase(PB_URL)
+    try:
+        client.admins.auth_with_password(PB_ADMIN_EMAIL, PB_ADMIN_PASSWORD)
+        print("PocketBase admin 登录成功（动态）")
+    except Exception as e:
+        print("PocketBase admin 登录失败:", e)
+        raise e
+    return client
 
-# 日志（仅控制台，不写文件，避免 git 本地/线上不一致）
+# 配置日志（添加控制台输出，便于调试）
 logging.basicConfig(
     level=logging.INFO,
-    format="%(asctime)s - %(message)s",
-    handlers=[logging.StreamHandler()],
+    format='%(asctime)s - %(message)s',
+    handlers=[
+        logging.FileHandler('xorpay_notify.log'),
+        logging.StreamHandler()  # 新增：同时输出到控制台
+    ]
 )
 
-# 启动时校验 BASE_URL（线上部署必须为公网可访问地址，否则 ZPAY 无法回调）
-def _check_base_url():
-    url = (BASE_URL or "").strip().lower()
-    if not url:
-        logging.warning("BASE_URL 未设置，将使用默认值。线上部署请务必设置 BASE_URL 为公网地址")
-        return
-    if "localhost" in url or "127.0.0.1" in url or url.startswith("http://192.168.") or url.startswith("http://10."):
-        logging.warning(
-            "BASE_URL=%s 疑似内网地址，ZPAY 无法回调！线上部署请设置 BASE_URL 为公网地址，如 https://api.hackrobot.cn",
-            BASE_URL,
-        )
+# 全局已处理订单
+processed_orders = set()
 
+# ==================== XorPay 配置 ====================
+AID = "8220"
+SECRET = "afcacd99570945f88de62624aaa3578e"
+# ====================================================
 
-@app.on_event("startup")
-async def startup_event():
-    _check_base_url()
+# memos 配置
+MEMOS_API = "https://qun.hackrobot.cn/api/v1/users"
+MEMOS_TOKEN = "eyJhbGciOiJIUzI1NiIsImtpZCI6InYxIiwidHlwIjoiSldUIn0.eyJuYW1lIjoiaGFja3JvYm90IiwiaXNzIjoibWVtb3MiLCJzdWIiOiIxIiwiYXVkIjpbInVzZXIuYWNjZXNzLXRva2VuIl0sImlhdCI6MTc1NzQwNTE0OX0.Idn7kBlxE-CoSOXwWuZ1tHGIRKHAIeDyXSafGS5OHsg"
 
+def xorpay_sign(name: str, pay_type: str, price: str, order_id: str, notify_url: str) -> str:
+    raw = name + pay_type + price + order_id + notify_url + SECRET
+    return hashlib.md5(raw.encode('utf-8')).hexdigest().lower()
 
-@app.get("/health")
-async def health(check_zpay: str = ""):
-    """健康检查。check_zpay=1 时额外检测 zpayz.cn 连通性"""
-    out = {"status": "ok", "service": "payjsapi", "base_url": BASE_URL}
-    if str(check_zpay).lower() in ("1", "true", "yes"):
-        try:
-            r = requests.get("https://zpayz.cn", timeout=5)
-            out["zpayz_reachable"] = r.status_code in (200, 301, 302, 404)
-        except Exception as e:
-            out["zpayz_reachable"] = False
-            out["zpayz_error"] = str(e)
-    return out
+def verify_xorpay_notify(data: dict) -> bool:
+    received_sign = data.get("sign", "")
+    aoid = data.get("aoid", "")
+    order_id = data.get("order_id", "")
+    pay_price = data.get("pay_price", "")
+    pay_time = data.get("pay_time", "")
+    raw = aoid + order_id + pay_price + pay_time + SECRET
+    calculated_sign = hashlib.md5(raw.encode('utf-8')).hexdigest().lower()
+    return calculated_sign == received_sign
 
+def create_memos_user(user_id: str, password: str = "123456"):
+    try:
+        if user_id.startswith("user_"):
+            cleaned_username = "user" + user_id.split("user_", 1)[1]
+        elif "_" in user_id:
+            cleaned_username = user_id.replace("_", "")
+        else:
+            cleaned_username = user_id
 
-# 挂载路由
-app.include_router(nomadvip_router)
-app.include_router(digital_router)
-app.include_router(cnomadcna_router)
-app.include_router(nomadlms_router)
-app.include_router(legacy_router)
-app.include_router(common_router)
+        username = cleaned_username
+        print(f"正在为用户创建 memos 账号: {username}")
 
+        memos_data = {
+            "username": username,
+            "password": password,
+            "role": "USER",
+            "state": "NORMAL"
+        }
+        memos_headers = {
+            "Content-Type": "application/json",
+            "Authorization": f"Bearer {MEMOS_TOKEN}"
+        }
+
+        response = requests.post(MEMOS_API, json=memos_data, headers=memos_headers, timeout=10)
+
+        if response.status_code in (200, 201):
+            result = response.json()
+            print(f"memos 用户创建成功: {username}")
+            logging.info(f"memos 用户创建成功: {username}")
+            return {"success": True, "data": result}
+        else:
+            error_text = response.text
+            print(f"memos 创建失败: {response.status_code} {error_text}")
+            logging.error(f"memos 创建失败 - username: {username}, status: {response.status_code}, response: {error_text}")
+            return {"success": False, "error": error_text}
+
+    except Exception as e:
+        print(f"创建 memos 用户异常: {e}")
+        logging.error(f"创建 memos 用户异常 - username: {user_id}, error: {e}")
+        return {"success": False, "error": str(e)}
+
+@app.post("/payh5")
+async def payh5(item: dict):
+    print('payh5 item:', item)
+
+    total_fee_yuan = f"{item['total_fee'] / 100:.2f}"
+    user_id = item.get('user_id', 'unknown')
+    pay_type = item.get('type', 'unknown').lower()
+
+    random_suffix = ''.join(random.choices(string.hexdigits.lower(), k=8))
+    timestamp = int(time.time())
+    order_id = f"{user_id}_{pay_type}_order_{timestamp}_{random_suffix}"
+
+    type_map = {
+        "book": "购买书籍",
+        "meetup": "数字游民社区报名",
+        "video": "视频解锁",
+        "vip": "VIP会员充值",
+    }
+    name = type_map.get(pay_type, "商品支付")
+
+    notify_url = "https://api.hackrobot.cn/xorpay_notify"
+
+    params = {
+        "name": name,
+        "pay_type": "jsapi",
+        "price": total_fee_yuan,
+        "order_id": order_id,
+        "notify_url": notify_url,
+    }
+
+    params["sign"] = xorpay_sign(
+        params["name"],
+        params["pay_type"],
+        params["price"],
+        params["order_id"],
+        params["notify_url"]
+    )
+
+    print("生成的参数:", params)
 
-@app.get("/")
-async def root():
-    """健康检查"""
     return {
         "status": "ok",
-        "service": "payjsapi",
-        "routes": {
-            "nomadvip": "/nomadvip/payh5, /nomadvip/payh5/redirect, /nomadvip/zpay_order_status, /nomadvip/zpay_notify, /nomadvip/xorpay_notify",
-            "digital": "/digital/payh5, /digital/payh5/redirect, /digital/zpay_order_status, /digital/zpay_notify, /digital/xorpay_notify",
-            "cnomadcna": "/cnomadcna/payh5, ...",
-            "nomadlms": "/nomadlms/payh5, ...",
-            "legacy": "/payh5, /payh5/redirect, /zpay_notify, /xorpay_notify, /zpay_order_status",
-            "common": "/submit_meetup_application, /create_user",
-        },
+        "xorpay_params": params,
+        "xorpay_url": f"https://xorpay.com/api/cashier/{AID}"
     }
+
+@app.post("/submit_meetup_application")
+async def submit_meetup_application(item: dict):
+    print('submit_meetup_application item:', item)
+
+    user_id = item.get('user_id')
+    if not user_id:
+        raise HTTPException(status_code=400, detail="missing user_id")
+
+    try:
+        pb_client = get_pb_client()
+        solan = pb_client.collection("solan")
+
+        pb_data = {
+            "user_id": user_id,
+            "nickname": item.get("nickname", ""),
+            "occupation": item.get("occupation", ""),
+            "reason": item.get("reason", ""),
+            "wechatId": item.get("wechatId", ""),
+            "gender": item.get("gender", ""),
+            "education": item.get("education", ""),
+            "gradYear": item.get("gradYear", ""),
+            "phone": item.get("phone", ""),
+            "calculated_age": item.get("calculated_age", 0),
+            "type": "",
+            "order_id": "",
+            "amount": 0,
+        }
+
+        record = solan.create(pb_data)
+        logging.info(f"meetup 申请表单提交成功（待支付） - user_id: {user_id}, record_id: {record.id}")
+
+        return {"status": "ok", "record_id": record.id}
+    except Exception as e:
+        print(f"meetup 申请提交失败: {e}")
+        logging.error(f"meetup 申请提交失败 - user_id: {user_id}, error: {e}")
+        raise HTTPException(status_code=500, detail="submit failed")
+
+@app.post("/xorpay_notify")
+async def xorpay_notify(request: Request):
+    form_data = await request.form()
+    data = {key: value for key, value in form_data.items()}
+    
+    logging.info(f"XorPay 异步通知原始数据: {data}")
+    print("XorPay 异步通知:", data)
+
+    order_id = data.get("order_id", "")
+    
+    if order_id in processed_orders:
+        print(f"订单 {order_id} 已处理过，跳过")
+        return "ok"
+
+    if not verify_xorpay_notify(data):
+        print("验签失败")
+        logging.error(f"验签失败: {data}")
+        raise HTTPException(status_code=400, detail="sign error")
+
+    if "_order_" not in order_id:
+        raise HTTPException(status_code=400, detail="invalid order_id format")
+
+    prefix = order_id.split("_order_")[0]
+    
+    if "_" in prefix:
+        parts = prefix.rsplit("_", 1)
+        user_id = parts[0]
+        pay_type = parts[1].lower()
+    else:
+        user_id = prefix
+        pay_type = "unknown"
+
+    print(f"支付成功，用户ID: {user_id}，类型: {pay_type}，订单: {order_id}")
+
+    if pay_type == "vip":
+        create_memos_user(user_id)
+
+    if pay_type == "meetup":
+        logging.info(f"meetup 类型支付成功（独立逻辑），不创建 memos 用户 - user_id: {user_id}")
+
+    try:
+        pb_client = get_pb_client()
+
+        valid_types = ["vip", "book", "meetup", "video"]
+        if pay_type not in valid_types:
+            print(f"无效的 pay_type: {pay_type}，强制设为 vip")
+            pay_type = "vip"
+
+        amount_cents = int(float(data.get("pay_price", 0)) * 100)
+
+        if pay_type == "meetup":
+            solan = pb_client.collection("solan")
+            # 修复 filter 语法：添加空格和 '=' 操作符（PocketBase 要求）
+            # 同时添加 sort 以取最新记录（防止同一 user_id 多条）
+            existing = solan.get_list(1, 1, {
+                "filter": f'user_id = "{user_id}"',
+                "sort": "-created"  # 按创建时间倒序，取最新一条
+            })
+            if existing.items:
+                record_id = existing.items[0].id
+                solan.update(record_id, {
+                    "type": "meetup",
+                    "order_id": order_id,
+                    "amount": amount_cents,
+                })
+                logging.info(f"meetup 支付字段补齐成功 - user_id: {user_id}, record_id: {record_id}")
+            else:
+                solan.create({
+                    "user_id": user_id,
+                    "type": "meetup",
+                    "order_id": order_id,
+                    "amount": amount_cents,
+                })
+                logging.info(f"meetup 完整记录创建（兜底） - user_id: {user_id}")
+        else:
+            pb_client.collection("payments").create({
+                "user_id": user_id,
+                "type": pay_type,
+                "order_id": order_id,
+                "amount": amount_cents,
+            })
+
+        processed_orders.add(order_id)
+
+    except Exception as e:
+        print(f"PocketBase 操作失败: {e}")
+        logging.error(f"PocketBase 操作失败 - order_id: {order_id}, error: {e}")
+        processed_orders.add(order_id)  # 防止重复通知
+
+    return "ok"
+
+class CreateUserRequest(BaseModel):
+    username: str = None
+    password: str = None
+
+@app.post("/create_user")
+async def create_user(item: CreateUserRequest):
+    timenew = str(int(time.time()))
+    memos_data = {
+        "username": item.username or f"user{timenew}",
+        "password": item.password or "123456",
+        "role": "USER",
+        "state": "NORMAL"
+    }
+    memos_headers = {
+        "Content-Type": "application/json",
+        "Authorization": f"Bearer {MEMOS_TOKEN}"
+    }
+    memos_resp = requests.post(MEMOS_API, json=memos_data, headers=memos_headers)
+    memos_result = memos_resp.json()
+    print('memos_result-', memos_result)
+    return memos_result

app/payment/__init__.py

@@ -1,17 +0,0 @@
-"""
-支付模块
-支持多支付渠道，可通过配置切换
-"""
-from .base import PaymentProvider
-from .xorpay import XorPayProvider
-from .zpay import ZPayProvider
-from .factory import get_payment_provider, get_payment_provider_by_name, reset_provider
-
-__all__ = [
-    "PaymentProvider",
-    "XorPayProvider",
-    "ZPayProvider",
-    "get_payment_provider",
-    "get_payment_provider_by_name",
-    "reset_provider",
-]

app/payment/base.py

@@ -1,59 +0,0 @@
-"""
-支付渠道抽象基类
-定义统一的支付接口，便于切换不同支付渠道（XorPay、ZPAY 等）
-"""
-from abc import ABC, abstractmethod
-from typing import Any, Dict, Optional
-
-
-class PaymentProvider(ABC):
-    """支付渠道抽象基类"""
-
-    @property
-    @abstractmethod
-    def name(self) -> str:
-        """支付渠道名称"""
-        pass
-
-    @abstractmethod
-    def create_order(
-        self,
-        *,
-        order_id: str,
-        name: str,
-        total_fee_yuan: str,
-        pay_type: str,
-        notify_url: str,
-        return_url: Optional[str] = None,
-        client_ip: Optional[str] = None,
-        extra: Optional[Dict[str, Any]] = None,
-    ) -> Dict[str, Any]:
-        """
-        创建支付订单
-        :return: 包含支付跳转信息等，格式由各渠道自定义
-        """
-        pass
-
-    @abstractmethod
-    def verify_notify(self, data: Dict[str, Any]) -> bool:
-        """验证异步通知签名"""
-        pass
-
-    @abstractmethod
-    def parse_notify(self, data: Dict[str, Any]) -> Dict[str, Any]:
-        """
-        解析异步通知，提取统一字段
-        :return: {
-            "order_id": str,      # 商户订单号
-            "trade_no": str,      # 渠道订单号
-            "pay_price": str,     # 实付金额（元）
-            "pay_time": str,      # 支付时间
-            "trade_status": str,  # 支付状态
-        }
-        """
-        pass
-
-    @abstractmethod
-    def success_response(self) -> str:
-        """异步通知成功时需返回的字符串（如 'ok' 或 'success'）"""
-        pass

app/payment/factory.py

@@ -1,51 +0,0 @@
-"""
-支付渠道工厂
-根据配置返回对应的支付 Provider
-默认使用 zpay 替代 xorpay
-"""
-from ..config import (
-    PAYMENT_PROVIDER,
-    XORPAY_AID,
-    XORPAY_SECRET,
-    XORPAY_CASHIER_URL,
-    ZPAY_PID,
-    ZPAY_KEY,
-)
-from .base import PaymentProvider
-from .xorpay import XorPayProvider
-from .zpay import ZPayProvider
-
-_provider_instance: PaymentProvider | None = None
-
-
-def get_payment_provider() -> PaymentProvider:
-    """获取当前配置的支付渠道实例（单例）"""
-    global _provider_instance
-    if _provider_instance is not None:
-        return _provider_instance
-    if PAYMENT_PROVIDER == "zpay":
-        _provider_instance = ZPayProvider(pid=ZPAY_PID, key=ZPAY_KEY)
-    else:
-        _provider_instance = XorPayProvider(
-            aid=XORPAY_AID,
-            secret=XORPAY_SECRET,
-            cashier_url=XORPAY_CASHIER_URL,
-        )
-    return _provider_instance
-
-
-def get_payment_provider_by_name(name: str) -> PaymentProvider:
-    """按名称获取 Provider（用于 per-request 覆盖）"""
-    if name == "xorpay":
-        return XorPayProvider(
-            aid=XORPAY_AID,
-            secret=XORPAY_SECRET,
-            cashier_url=XORPAY_CASHIER_URL,
-        )
-    return ZPayProvider(pid=ZPAY_PID, key=ZPAY_KEY)
-
-
-def reset_provider():
-    """重置 Provider（用于测试或切换渠道）"""
-    global _provider_instance
-    _provider_instance = None

app/payment/xorpay.py

@@ -1,82 +0,0 @@
-"""
-XorPay 支付渠道实现
-文档: https://xorpay.com
-"""
-import hashlib
-from typing import Any, Dict, Optional
-
-from .base import PaymentProvider
-
-
-class XorPayProvider(PaymentProvider):
-    """XorPay 支付"""
-
-    def __init__(self, aid: str, secret: str, cashier_url: str = "https://xorpay.com/api/cashier"):
-        self.aid = aid
-        self.secret = secret
-        self.cashier_url = cashier_url.rstrip("/")
-
-    @property
-    def name(self) -> str:
-        return "xorpay"
-
-    def _sign(self, name: str, pay_type: str, price: str, order_id: str, notify_url: str) -> str:
-        raw = name + pay_type + price + order_id + notify_url + self.secret
-        return hashlib.md5(raw.encode("utf-8")).hexdigest().lower()
-
-    def create_order(
-        self,
-        *,
-        order_id: str,
-        name: str,
-        total_fee_yuan: str,
-        pay_type: str,
-        notify_url: str,
-        return_url: Optional[str] = None,
-        client_ip: Optional[str] = None,
-        extra: Optional[Dict[str, Any]] = None,
-    ) -> Dict[str, Any]:
-        # XorPay 使用 jsapi 表示 H5/JSAPI 支付
-        channel_pay_type = "jsapi"
-        params = {
-            "name": name,
-            "pay_type": channel_pay_type,
-            "price": total_fee_yuan,
-            "order_id": order_id,
-            "notify_url": notify_url,
-        }
-        params["sign"] = self._sign(
-            params["name"],
-            params["pay_type"],
-            params["price"],
-            params["order_id"],
-            params["notify_url"],
-        )
-        return {
-            "status": "ok",
-            "provider": self.name,
-            "params": params,
-            "pay_url": f"{self.cashier_url}/{self.aid}",
-        }
-
-    def verify_notify(self, data: Dict[str, Any]) -> bool:
-        received_sign = data.get("sign", "")
-        aoid = data.get("aoid", "")
-        order_id = data.get("order_id", "")
-        pay_price = data.get("pay_price", "")
-        pay_time = data.get("pay_time", "")
-        raw = aoid + order_id + pay_price + pay_time + self.secret
-        calculated = hashlib.md5(raw.encode("utf-8")).hexdigest().lower()
-        return calculated == received_sign
-
-    def parse_notify(self, data: Dict[str, Any]) -> Dict[str, Any]:
-        return {
-            "order_id": data.get("order_id", ""),
-            "trade_no": data.get("aoid", ""),
-            "pay_price": data.get("pay_price", ""),
-            "pay_time": data.get("pay_time", ""),
-            "trade_status": "success",  # XorPay 验签通过即视为成功
-        }
-
-    def success_response(self) -> str:
-        return "ok"

app/payment/zpay.py

@@ -1,207 +0,0 @@
-"""
-ZPAY 支付渠道实现
-文档: https://z-pay.cn/doc.html
-支持：页面跳转支付、API 接口支付、异步通知验签
-"""
-import hashlib
-import json
-from typing import Any, Dict, Optional
-
-import requests
-
-from .base import PaymentProvider
-
-
-class ZPayProvider(PaymentProvider):
-    """ZPAY 支付（易支付兼容接口）"""
-
-    # API 地址
-    SUBMIT_URL = "https://zpayz.cn/submit.php"  # 页面跳转
-    MAPI_URL = "https://zpayz.cn/mapi.php"  # API 接口
-
-    def __init__(self, pid: str, key: str):
-        self.pid = pid
-        self.key = key
-
-    @property
-    def name(self) -> str:
-        return "zpay"
-
-    def _md5_sign(self, params: Dict[str, Any], exclude: Optional[set] = None) -> str:
-        """
-        ZPAY MD5 签名算法：
-        1. 参数按 ASCII 排序，sign/sign_type/空值不参与
-        2. 拼接为 a=b&c=d
-        3. sign = md5(拼接串 + KEY)，小写
-        """
-        exclude = exclude or {"sign", "sign_type"}
-        filtered = {k: v for k, v in params.items() if k not in exclude and v is not None and v != ""}
-        sorted_keys = sorted(filtered.keys())
-        parts = [f"{k}={filtered[k]}" for k in sorted_keys]
-        raw = "&".join(parts) + self.key
-        return hashlib.md5(raw.encode("utf-8")).hexdigest().lower()
-
-    def create_order(
-        self,
-        *,
-        order_id: str,
-        name: str,
-        total_fee_yuan: str,
-        pay_type: str,
-        notify_url: str,
-        return_url: Optional[str] = None,
-        client_ip: Optional[str] = None,
-        extra: Optional[Dict[str, Any]] = None,
-    ) -> Dict[str, Any]:
-        # ZPAY: alipay / wxpay（pay_type 可为业务类型或支付方式，此处按支付方式解析）
-        channel_type = "wxpay" if str(pay_type).lower() in ("wx", "wechat", "wxpay") else "alipay"
-        params = {
-            "pid": self.pid,
-            "type": channel_type,
-            "out_trade_no": order_id,
-            "notify_url": notify_url,
-            "name": name,
-            "money": total_fee_yuan,
-            "return_url": return_url or notify_url,
-        }
-        if client_ip:
-            params["clientip"] = client_ip
-        if extra and extra.get("param"):
-            params["param"] = str(extra["param"])
-        params["sign_type"] = "MD5"
-        params["sign"] = self._md5_sign(params)
-
-        # 页面跳转方式：返回 form 提交 URL 和参数
-        return {
-            "status": "ok",
-            "provider": self.name,
-            "params": params,
-            "pay_url": self.SUBMIT_URL,
-            "submit_method": "POST",
-        }
-
-    def create_order_api(
-        self,
-        *,
-        order_id: str,
-        name: str,
-        total_fee_yuan: str,
-        pay_type: str,
-        notify_url: str,
-        return_url: Optional[str] = None,
-        client_ip: str = "127.0.0.1",
-        device: str = "pc",
-        extra: Optional[Dict[str, Any]] = None,
-    ) -> Dict[str, Any]:
-        """
-        ZPAY API 接口支付（返回 payurl/qrcode 等）
-        适用于需要二维码或 H5 跳转的场景
-        """
-        channel_type = "wxpay" if pay_type.lower() in ("wx", "wechat", "wxpay") else "alipay"
-        params = {
-            "pid": self.pid,
-            "type": channel_type,
-            "out_trade_no": order_id,
-            "notify_url": notify_url,
-            "name": name,
-            "money": total_fee_yuan,
-            "clientip": client_ip or "127.0.0.1",
-            "device": device,
-        }
-        if return_url:
-            params["return_url"] = return_url
-        if extra and extra.get("param"):
-            params["param"] = str(extra["param"])
-        params["sign_type"] = "MD5"
-        params["sign"] = self._md5_sign(params)
-
-        try:
-            resp = requests.post(self.MAPI_URL, data=params, timeout=15)
-        except requests.RequestException as e:
-            return {
-                "status": "error",
-                "provider": self.name,
-                "msg": f"连接 zpayz.cn 失败: {e}。请检查服务器网络、防火墙或 DNS。",
-            }
-
-        try:
-            result = resp.json()
-        except Exception:
-            result = {}
-        # ZPAY 可能返回二次编码的 JSON（body 为 JSON 字符串），需再次解析
-        if isinstance(result, str):
-            try:
-                result = json.loads(result)
-            except Exception:
-                result = {}
-        if not isinstance(result, dict):
-            result = {}
-        # 部分环境下 ZPAY 将成功数据放在 msg 中（msg 为 JSON 字符串）
-        msg_val = result.get("msg")
-        if isinstance(msg_val, str) and msg_val.strip().startswith("{"):
-            try:
-                inner = json.loads(msg_val)
-                if isinstance(inner, dict) and int(float(inner.get("code", 0))) == 1:
-                    result = inner
-            except Exception:
-                pass
-        try:
-            code = int(float(result.get("code", 0)))
-        except (TypeError, ValueError):
-            code = 0
-        if code == 1:
-            return {
-                "status": "ok",
-                "provider": self.name,
-                "payurl": result.get("payurl"),
-                "payurl2": result.get("payurl2"),  # 微信 H5，手机浏览器打开可唤醒微信
-                "qrcode": result.get("qrcode"),
-                "img": result.get("img"),
-                "O_id": result.get("O_id"),
-                "trade_no": result.get("trade_no"),
-            }
-        return {
-            "status": "error",
-            "provider": self.name,
-            "msg": result.get("msg", resp.text),
-        }
-
-    def verify_notify(self, data: Dict[str, Any]) -> bool:
-        received = data.get("sign", "")
-        calculated = self._md5_sign(data)
-        return calculated == received
-
-    def parse_notify(self, data: Dict[str, Any]) -> Dict[str, Any]:
-        # ZPAY 通知：trade_status 为 TRADE_SUCCESS 表示成功
-        status = "success" if data.get("trade_status") == "TRADE_SUCCESS" else "pending"
-        return {
-            "order_id": data.get("out_trade_no", ""),
-            "trade_no": data.get("trade_no", ""),
-            "pay_price": data.get("money", ""),
-            "pay_time": "",  # ZPAY 通知未明确返回
-            "trade_status": status,
-        }
-
-    def success_response(self) -> str:
-        return "success"
-
-    def query_order_status(self, out_trade_no: str, timeout: int = 15) -> Dict[str, Any]:
-        """查询 ZPAY 订单支付状态（供 nomadvip/digital/cnomadcna/nomadlms 共用）"""
-        url = f"https://zpayz.cn/api.php?act=order&pid={self.pid}&key={self.key}&out_trade_no={out_trade_no}"
-        try:
-            resp = requests.get(url, timeout=timeout)
-            result = resp.json() if resp.ok else {}
-        except Exception as e:
-            return {"paid": False, "error": str(e)}
-        try:
-            code = result.get("code", 0)
-            code = int(code) if isinstance(code, (int, float)) or str(code).isdigit() else 0
-        except (ValueError, TypeError):
-            code = 0
-        if code != 1:
-            return {"paid": False, "msg": result.get("msg", "查询失败")}
-        try:
-            status = int(result.get("status", 0))
-        except (ValueError, TypeError):
-            status = 0
-        return {"paid": status == 1, "status": status}

app/routers/__init__.py

@@ -1,23 +0,0 @@
-"""
-项目路由模块
-- nomadvip: /nomadvip/*
-- digital:   /digital/*
-- cnomadcna: /cnomadcna/*
-- nomadlms:  /nomadlms/*
-- legacy:    /payh5, /zpay_notify 等（向后兼容 digital/cnomadcna）
-"""
-from .nomadvip import router as nomadvip_router
-from .digital import router as digital_router
-from .cnomadcna import router as cnomadcna_router
-from .nomadlms import router as nomadlms_router
-from .legacy import router as legacy_router
-from .common import router as common_router
-
-__all__ = [
-    "nomadvip_router",
-    "digital_router",
-    "cnomadcna_router",
-    "nomadlms_router",
-    "legacy_router",
-    "common_router",
-]

app/routers/_digital_base.py

@@ -1,210 +0,0 @@
-"""
-digital/cnomadcna/nomadlms 共享的支付逻辑
-根据 prefix 生成对应 notify_path，业务互不影响
-"""
-import logging
-import random
-import string
-import time
-
-from fastapi import APIRouter, Request, HTTPException
-
-from ..config import BASE_URL
-from ..payment import get_payment_provider
-from ..payment.zpay import ZPayProvider
-from ..services import handle_payment_success, processed_orders
-
-
-def create_digital_router(prefix: str, project_name: str, site_id: str | None = None) -> APIRouter:
-    """
-    创建 digital/cnomadcna/nomadlms 的支付路由
-    prefix: 如 "/digital", "/cnomadcna", "/nomadlms" 或 ""（legacy）
-    project_name: 用于日志，如 "digital", "cnomadcna", "nomadlms", "legacy"
-    site_id: 站点标识，用于 site_vip（digital/meetup/vip）
-    """
-    router = APIRouter(prefix=prefix, tags=[project_name])
-
-    def _notify_path(path: str) -> str:
-        base = BASE_URL.rstrip("/")
-        if prefix:
-            return f"{base}{prefix}{path}"
-        return f"{base}{path}"
-
-    @router.post("/payh5")
-    async def payh5(item: dict):
-        """创建 H5 支付订单"""
-        print(f"{project_name}/payh5 item:", item)
-        total_fee_yuan = f"{item['total_fee'] / 100:.2f}"
-        user_id = item.get("user_id", "unknown")
-        pay_type = item.get("type", "unknown").lower()
-        random_suffix = "".join(random.choices(string.hexdigits.lower(), k=8))
-        timestamp = int(time.time())
-        order_id = f"{user_id}_{pay_type}_order_{timestamp}_{random_suffix}"
-        type_map = {
-            "book": "购买书籍",
-            "meetup": "数字游民社区报名",
-            "video": "视频解锁",
-            "vip": "VIP会员充值",
-        }
-        name = type_map.get(pay_type, "商品支付")
-        provider = get_payment_provider()
-        notify_path = "/xorpay_notify" if provider.name == "xorpay" else "/zpay_notify"
-        notify_url = _notify_path(notify_path)
-        channel = item.get("channel", "alipay")
-        result = provider.create_order(
-            order_id=order_id,
-            name=name,
-            total_fee_yuan=total_fee_yuan,
-            pay_type=channel,
-            notify_url=notify_url,
-            return_url=item.get("return_url"),
-            client_ip=item.get("client_ip"),
-        )
-        if provider.name == "xorpay":
-            return {
-                "status": "ok",
-                "xorpay_params": result.get("params", {}),
-                "xorpay_url": result.get("pay_url", ""),
-                "provider": provider.name,
-            }
-        params = result.get("params", {})
-        params_str = {k: str(v) for k, v in params.items() if v is not None and str(v).strip() != ""}
-        return {
-            "status": "ok",
-            "params": params_str,
-            "pay_url": result.get("pay_url", ""),
-            "provider": provider.name,
-            "submit_method": "POST",
-        }
-
-    @router.post("/payh5/redirect")
-    async def payh5_redirect(item: dict, request: Request):
-        """ZPAY mapi 接口，返回 302 或二维码"""
-        from fastapi.responses import RedirectResponse, JSONResponse
-
-        provider = get_payment_provider()
-        if provider.name != "zpay":
-            raise HTTPException(status_code=400, detail="payh5/redirect 仅支持 zpay 渠道")
-        total_fee = float(item.get("total_fee", 80))
-        total_fee_yuan = f"{total_fee / 100:.2f}"
-        user_id = item.get("user_id", "unknown")
-        pay_type = item.get("type", "unknown").lower()
-        channel = item.get("channel", "alipay")
-        return_url = item.get("return_url")
-        device = item.get("device", "pc")
-        client_ip = item.get("client_ip") or (request.client.host if request.client else "127.0.0.1")
-        forwarded = request.headers.get("x-forwarded-for")
-        if forwarded:
-            client_ip = forwarded.split(",")[0].strip()
-        random_suffix = "".join(random.choices(string.hexdigits.lower(), k=8))
-        timestamp = int(time.time())
-        order_id = f"{user_id}_{pay_type}_order_{timestamp}_{random_suffix}"
-        type_map = {
-            "book": "购买书籍",
-            "meetup": "数字游民社区报名",
-            "video": "视频解锁",
-            "vip": "VIP会员充值",
-        }
-        name = type_map.get(pay_type, "商品支付")
-        notify_url = _notify_path("/zpay_notify")
-        if not isinstance(provider, ZPayProvider):
-            raise HTTPException(status_code=400, detail="payh5/redirect 仅支持 zpay")
-        result = provider.create_order_api(
-            order_id=order_id,
-            name=name,
-            total_fee_yuan=total_fee_yuan,
-            pay_type=channel,
-            notify_url=notify_url,
-            return_url=return_url,
-            client_ip=client_ip,
-            device=device,
-        )
-        if result.get("status") != "ok":
-            raise HTTPException(status_code=500, detail=result.get("msg", "ZPAY mapi 创建订单失败"))
-        payurl = result.get("payurl")
-        payurl2 = result.get("payurl2")
-        img = result.get("img")
-        if device == "pc" and img:
-            return JSONResponse(status_code=200, content={
-                "status": "ok", "qrcode_mode": True, "order_id": order_id,
-                "img": img, "payurl": payurl, "return_url": return_url, "channel": channel,
-            })
-        if device == "wechat" and channel.lower() in ("wxpay", "wx", "wechat"):
-            return JSONResponse(status_code=200, content={"use_form": True, "order_id": order_id})
-        headers = {"X-Pay-Order-Id": order_id}
-        if device == "h5" and channel.lower() in ("wxpay", "wx", "wechat") and payurl2:
-            return RedirectResponse(url=payurl2, status_code=302, headers=headers)
-        if payurl:
-            return RedirectResponse(url=payurl, status_code=302, headers=headers)
-        raise HTTPException(status_code=500, detail="ZPAY 未返回支付链接")
-
-    @router.get("/zpay_order_status")
-    async def zpay_order_status(out_trade_no: str):
-        """查询 ZPAY 订单支付状态"""
-        provider = get_payment_provider()
-        if not isinstance(provider, ZPayProvider):
-            raise HTTPException(status_code=400, detail="仅 zpay 渠道支持")
-        result = provider.query_order_status(out_trade_no, timeout=15)
-        if result.get("error"):
-            logging.warning(f"{project_name} ZPAY 订单查询失败: {result.get('error')}")
-        return result
-
-    @router.post("/xorpay_notify")
-    async def xorpay_notify(request: Request):
-        """XorPay 异步通知"""
-        form_data = await request.form()
-        data = {k: v for k, v in form_data.items()}
-        logging.info(f"{project_name} XorPay 异步通知: {data}")
-        order_id = data.get("order_id", "")
-        if order_id in processed_orders:
-            return "ok"
-        provider = get_payment_provider()
-        if provider.name != "xorpay":
-            raise HTTPException(status_code=400, detail="xorpay_notify only for xorpay")
-        if not provider.verify_notify(data):
-            logging.error(f"{project_name} XorPay 验签失败: {data}")
-            raise HTTPException(status_code=400, detail="sign error")
-        parsed = provider.parse_notify(data)
-        if parsed.get("trade_status") != "success":
-            return "ok"
-        handle_payment_success(
-            order_id,
-            parsed.get("pay_price", data.get("pay_price", "")),
-            f"{project_name}-xorpay",
-            use_memos=False,
-            site_id=site_id,
-        )
-        return provider.success_response()
-
-    @router.get("/zpay_notify")
-    @router.post("/zpay_notify")
-    async def zpay_notify(request: Request):
-        """ZPAY 异步通知"""
-        if request.method == "GET":
-            data = dict(request.query_params)
-        else:
-            form_data = await request.form()
-            data = {k: v for k, v in form_data.items()}
-        logging.info(f"{project_name} ZPAY 异步通知: {data}")
-        order_id = data.get("out_trade_no", "")
-        if order_id in processed_orders:
-            return "success"
-        provider = get_payment_provider()
-        if provider.name != "zpay":
-            raise HTTPException(status_code=400, detail="zpay_notify only for zpay")
-        if not provider.verify_notify(data):
-            logging.error(f"{project_name} ZPAY 验签失败: {data}")
-            raise HTTPException(status_code=400, detail="sign error")
-        parsed = provider.parse_notify(data)
-        if parsed.get("trade_status") != "success":
-            return "success"
-        handle_payment_success(
-            order_id,
-            parsed.get("pay_price", data.get("money", "")),
-            f"{project_name}-zpay",
-            use_memos=False,
-            site_id=site_id,
-        )
-        return provider.success_response()
-
-    return router

app/routers/cnomadcna.py

@@ -1,4 +0,0 @@
-"""cnomadcna 项目支付接口：/cnomadcna/*"""
-from ._digital_base import create_digital_router
-
-router = create_digital_router(prefix="/cnomadcna", project_name="cnomadcna", site_id="meetup")

app/routers/common.py

@@ -1,65 +0,0 @@
-"""共享接口：meetup 申请、create_user 等"""
-import logging
-import time
-
-from fastapi import APIRouter, HTTPException
-from pydantic import BaseModel
-
-from ..services import get_pb_client
-from ..sdk.memos import MemosSDK
-from ..config import MEMOS_API, MEMOS_TOKEN
-
-router = APIRouter(tags=["common"])
-
-
-@router.post("/submit_meetup_application")
-async def submit_meetup_application(item: dict):
-    """数字游民社区报名表单"""
-    print("submit_meetup_application item:", item)
-    user_id = item.get("user_id")
-    if not user_id:
-        raise HTTPException(status_code=400, detail="missing user_id")
-    try:
-        pb_client = get_pb_client()
-        solan = pb_client.collection("solan")
-        pb_data = {
-            "user_id": user_id,
-            "nickname": item.get("nickname", ""),
-            "occupation": item.get("occupation", ""),
-            "reason": item.get("reason", ""),
-            "wechatId": item.get("wechatId", ""),
-            "gender": item.get("gender", ""),
-            "education": item.get("education", ""),
-            "gradYear": item.get("gradYear", ""),
-            "phone": item.get("phone", ""),
-            "calculated_age": item.get("calculated_age", 0),
-            "type": "",
-            "order_id": "",
-            "amount": 0,
-        }
-        record = solan.create(pb_data)
-        logging.info(f"meetup 申请表单提交成功（待支付） - user_id: {user_id}, record_id: {record.id}")
-        return {"status": "ok", "record_id": record.id}
-    except Exception as e:
-        print(f"meetup 申请提交失败: {e}")
-        logging.error(f"meetup 申请提交失败 - user_id: {user_id}, error: {e}")
-        raise HTTPException(status_code=500, detail="submit failed")
-
-
-class CreateUserRequest(BaseModel):
-    username: str | None = None
-    password: str | None = None
-
-
-@router.post("/create_user")
-async def create_user(item: CreateUserRequest):
-    """创建 Memos 用户（基于 MemosSDK）"""
-    sdk = MemosSDK(api_url=MEMOS_API, token=MEMOS_TOKEN, enabled=bool(MEMOS_API and MEMOS_TOKEN))
-    if not sdk.enabled:
-        return {"error": "Memos 未配置"}
-    timenew = str(int(time.time()))
-    username = item.username or f"user{timenew}"
-    password = item.password or "123456"
-    result = sdk.create_user_by_username(username=username, password=password)
-    print("memos_result-", result)
-    return result

app/routers/digital.py

@@ -1,4 +0,0 @@
-"""digital 项目支付接口：/digital/*"""
-from ._digital_base import create_digital_router
-
-router = create_digital_router(prefix="/digital", project_name="digital", site_id="digital")

app/routers/legacy.py

@@ -1,4 +0,0 @@
-"""向后兼容：/payh5、/zpay_notify 等（digital/cnomadcna/nomadlms 旧版调用）"""
-from ._digital_base import create_digital_router
-
-router = create_digital_router(prefix="", project_name="legacy")

app/routers/nomadlms.py

@@ -1,4 +0,0 @@
-"""nomadlms 项目支付接口：/nomadlms/*"""
-from ._digital_base import create_digital_router
-
-router = create_digital_router(prefix="/nomadlms", project_name="nomadlms")

app/routers/nomadvip.py

@@ -1,224 +0,0 @@
-"""nomadvip 项目支付接口：/nomadvip/*，支持 xorpay/zpay（PAYMENT_PROVIDER）"""
-import logging
-import random
-import string
-import time
-
-from fastapi import APIRouter, Request, HTTPException
-from fastapi.responses import RedirectResponse, JSONResponse
-
-from ..config import BASE_URL
-from ..payment import get_payment_provider, get_payment_provider_by_name
-from ..payment.zpay import ZPayProvider
-from ..services import handle_payment_success, processed_orders
-
-router = APIRouter(prefix="/nomadvip", tags=["nomadvip"])
-
-
-def _get_notify_path(provider_name: str) -> str:
-    return f"{BASE_URL.rstrip('/')}/nomadvip/xorpay_notify" if provider_name == "xorpay" else f"{BASE_URL.rstrip('/')}/nomadvip/zpay_notify"
-
-
-@router.post("/payh5")
-async def nomadvip_payh5(item: dict):
-    """nomadvip 专用：创建支付订单，支持 per-request provider 覆盖（微信用 xorpay，PC/H5 用 zpay）"""
-    print("nomadvip/payh5 item:", item)
-    req_provider = (item.get("provider") or "").strip().lower()
-    provider = get_payment_provider_by_name(req_provider) if req_provider in ("xorpay", "zpay") else get_payment_provider()
-    total_fee = int(item.get("total_fee", 880))
-    total_fee_yuan = f"{total_fee / 100:.2f}"
-    user_id = item.get("user_id", "unknown")
-    pay_type = (item.get("type") or "vip").lower()
-    random_suffix = "".join(random.choices(string.hexdigits.lower(), k=8))
-    timestamp = int(time.time())
-    order_id = f"{user_id}_{pay_type}_order_{timestamp}_{random_suffix}"
-    type_map = {
-        "book": "购买书籍",
-        "meetup": "数字游民社区报名",
-        "video": "视频解锁",
-        "vip": "VIP会员充值",
-    }
-    name = type_map.get(pay_type, "VIP会员充值")
-    notify_url = _get_notify_path(provider.name)
-    channel = item.get("channel", "alipay")
-    result = provider.create_order(
-        order_id=order_id,
-        name=name,
-        total_fee_yuan=total_fee_yuan,
-        pay_type=channel,
-        notify_url=notify_url,
-        return_url=item.get("return_url"),
-        client_ip=item.get("client_ip"),
-    )
-    if provider.name == "xorpay":
-        return {
-            "status": "ok",
-            "xorpay_params": result.get("params", {}),
-            "xorpay_url": result.get("pay_url", ""),
-            "provider": provider.name,
-        }
-    params = result.get("params", {})
-    params_str = {k: str(v) for k, v in params.items() if v is not None and str(v).strip() != ""}
-    return {
-        "status": "ok",
-        "params": params_str,
-        "pay_url": result.get("pay_url", ""),
-        "provider": provider.name,
-        "submit_method": "POST",
-    }
-
-
-@router.post("/payh5/redirect")
-async def nomadvip_payh5_redirect(item: dict, request: Request):
-    """nomadvip 专用：ZPAY mapi 接口（xorpay 无需 redirect，直接 payh5 即可）"""
-    req_provider = (item.get("provider") or "").strip().lower()
-    provider = get_payment_provider_by_name("zpay") if req_provider == "zpay" else get_payment_provider()
-    if not isinstance(provider, ZPayProvider):
-        raise HTTPException(status_code=400, detail="payh5/redirect 仅支持 zpay，xorpay 请直接使用 payh5")
-    logging.info(f"nomadvip payh5/redirect 请求: item={item}")
-    try:
-        total_fee = float(item.get("total_fee", 880))
-    except (TypeError, ValueError):
-        logging.warning(f"nomadvip payh5/redirect 无效 total_fee: {item.get('total_fee')}")
-        total_fee = 880.0
-    total_fee_yuan = f"{total_fee / 100:.2f}"
-    user_id = item.get("user_id", "unknown")
-    pay_type = (item.get("type") or "vip").lower()
-    channel = item.get("channel", "alipay")
-    return_url = item.get("return_url")
-    device = item.get("device", "pc")
-    client_ip = item.get("client_ip") or (request.client.host if request.client else "127.0.0.1")
-    forwarded = request.headers.get("x-forwarded-for")
-    if forwarded:
-        client_ip = forwarded.split(",")[0].strip()
-    random_suffix = "".join(random.choices(string.hexdigits.lower(), k=8))
-    timestamp = int(time.time())
-    order_id = f"{user_id}_{pay_type}_order_{timestamp}_{random_suffix}"
-    type_map = {"book": "购买书籍", "meetup": "数字游民社区报名", "video": "视频解锁", "vip": "VIP会员充值"}
-    name = type_map.get(pay_type, "VIP会员充值")
-    notify_url = f"{BASE_URL.rstrip('/')}/nomadvip/zpay_notify"
-    if not isinstance(provider, ZPayProvider):
-        raise HTTPException(status_code=400, detail="payh5/redirect 仅支持 zpay")
-    result = provider.create_order_api(
-        order_id=order_id,
-        name=name,
-        total_fee_yuan=total_fee_yuan,
-        pay_type=channel,
-        notify_url=notify_url,
-        return_url=return_url,
-        client_ip=client_ip,
-        device=device,
-    )
-    if result.get("status") != "ok":
-        err_msg = result.get("msg", "ZPAY mapi 创建订单失败")
-        logging.error(f"nomadvip payh5/redirect ZPAY 创建订单失败: {err_msg}, result={result}")
-        raise HTTPException(status_code=500, detail=err_msg)
-    payurl = result.get("payurl")
-    payurl2 = result.get("payurl2")
-    img = result.get("img")
-    if device == "pc" and img:
-        return JSONResponse(status_code=200, content={
-            "status": "ok", "qrcode_mode": True, "order_id": order_id,
-            "img": img, "payurl": payurl, "return_url": return_url, "channel": channel,
-        })
-    if device == "wechat" and channel.lower() in ("wxpay", "wx", "wechat"):
-        return JSONResponse(status_code=200, content={"use_form": True, "order_id": order_id})
-    headers = {"X-Pay-Order-Id": order_id}
-    if device == "h5" and channel.lower() in ("wxpay", "wx", "wechat") and payurl2:
-        return RedirectResponse(url=payurl2, status_code=302, headers=headers)
-    if payurl:
-        return RedirectResponse(url=payurl, status_code=302, headers=headers)
-    logging.error(f"nomadvip payh5/redirect ZPAY 未返回支付链接: device={device}, channel={channel}, result keys={list(result.keys())}")
-    raise HTTPException(status_code=500, detail="ZPAY 未返回支付链接")
-
-
-@router.get("/zpay_order_status")
-async def nomadvip_zpay_order_status(out_trade_no: str):
-    """nomadvip 专用：查询 ZPAY 订单支付状态（xorpay 无此接口）"""
-    provider = get_payment_provider()
-    if not isinstance(provider, ZPayProvider):
-        raise HTTPException(status_code=400, detail="zpay_order_status 仅支持 zpay")
-    result = provider.query_order_status(out_trade_no, timeout=15)
-    if result.get("error"):
-        logging.warning(f"nomadvip ZPAY 订单查询失败: {result.get('error')}")
-    return result
-
-
-@router.get("/order_status")
-async def nomadvip_order_status(order_id: str):
-    """nomadvip 通用：查询订单支付状态。zpay 先查 ZPAY 实时，xorpay 或失败时查 PocketBase"""
-    zpay = get_payment_provider_by_name("zpay")
-    if isinstance(zpay, ZPayProvider):
-        result = zpay.query_order_status(order_id, timeout=15)
-        if not result.get("error") and result.get("paid"):
-            return result
-    # zpay 查不到或 xorpay：查 PocketBase（notify 后写入）
-    try:
-        from ..services.pb import get_pb_client
-
-        pb = get_pb_client()
-        records = pb.collection("payments").get_list(1, 1, {"filter": f'order_id = "{order_id}"'})
-        return {"paid": len(records.items) > 0}
-    except Exception as e:
-        logging.warning(f"nomadvip PocketBase 查询失败: {e}")
-        return {"paid": False, "error": str(e)}
-
-
-@router.post("/xorpay_notify")
-async def nomadvip_xorpay_notify(request: Request):
-    """nomadvip 专用：XorPay 异步通知（路径即渠道，不依赖全局 PAYMENT_PROVIDER）"""
-    form_data = await request.form()
-    data = {k: v for k, v in form_data.items()}
-    logging.info(f"nomadvip XorPay 异步通知: {data}")
-    order_id = data.get("order_id", "")
-    if order_id in processed_orders:
-        logging.info(f"nomadvip 订单已处理，跳过: {order_id}")
-        return "ok"
-    provider = get_payment_provider_by_name("xorpay")
-    if not provider.verify_notify(data):
-        logging.error(f"nomadvip XorPay 验签失败: {data}")
-        raise HTTPException(status_code=400, detail="sign error")
-    parsed = provider.parse_notify(data)
-    if parsed.get("trade_status") != "success":
-        return "ok"
-    pay_price = parsed.get("pay_price", data.get("pay_price", ""))
-    try:
-        handle_payment_success(order_id, pay_price, "nomadvip-xorpay", use_memos=True, site_id="vip")
-        logging.info(f"nomadvip 业务处理完成: order_id={order_id}")
-    except Exception as e:
-        logging.error(f"nomadvip PocketBase/Memos 处理异常: {e}", exc_info=True)
-        raise
-    return provider.success_response()
-
-
-@router.get("/zpay_notify")
-@router.post("/zpay_notify")
-async def nomadvip_zpay_notify(request: Request):
-    """nomadvip 专用：ZPAY 异步通知（路径即渠道，不依赖全局 PAYMENT_PROVIDER）"""
-    provider = get_payment_provider_by_name("zpay")
-    if request.method == "GET":
-        data = dict(request.query_params)
-    else:
-        form_data = await request.form()
-        data = {k: v for k, v in form_data.items()}
-    logging.info(f"nomadvip ZPAY 异步通知: {data}")
-    order_id = data.get("out_trade_no", "")
-    if order_id in processed_orders:
-        logging.info(f"nomadvip 订单已处理，跳过: {order_id}")
-        return "success"
-    if not provider.verify_notify(data):
-        logging.error(f"nomadvip ZPAY 验签失败: {data}")
-        raise HTTPException(status_code=400, detail="sign error")
-    parsed = provider.parse_notify(data)
-    trade_status = parsed.get("trade_status") or data.get("trade_status", "")
-    if trade_status != "success" and trade_status != "TRADE_SUCCESS":
-        logging.info(f"nomadvip 非成功状态，跳过: trade_status={trade_status}")
-        return "success"
-    pay_price = parsed.get("pay_price") or data.get("money", "")
-    try:
-        handle_payment_success(order_id, pay_price, "nomadvip-zpay", use_memos=True, site_id="vip")
-        logging.info(f"nomadvip 业务处理完成: order_id={order_id}")
-    except Exception as e:
-        logging.error(f"nomadvip PocketBase/Memos 处理异常: {e}", exc_info=True)
-        raise
-    return provider.success_response()

app/routers/wxh5.py

@@ -1,270 +0,0 @@
-"""wxH5 项目支付接口：/wxh5/*，支持 xorpay/zpay，支付成功后同步 Supabase wxgzh_vip_users"""
-import logging
-import random
-import string
-import time
-from datetime import datetime, timedelta
-
-from fastapi import APIRouter, Request, HTTPException
-from fastapi.responses import RedirectResponse, JSONResponse
-
-from ..config import BASE_URL
-from ..payment import get_payment_provider, get_payment_provider_by_name
-from ..payment.zpay import ZPayProvider
-from ..services import handle_payment_success, processed_orders
-
-router = APIRouter(prefix="/wxh5", tags=["wxh5"])
-
-# 套餐金额（分）与有效期映射
-PLAN_MAP = {
-    "month": (2900, 30),   # 月卡 29 元，30 天
-    "year": (19900, 365),  # 年卡 199 元，365 天
-    "lifetime": (39900, 36500),  # 终身 399 元，100 年
-}
-
-
-def _infer_plan_from_amount(amount_cents: int) -> str:
-    """根据支付金额（分）推断套餐"""
-    if amount_cents >= 39900:
-        return "lifetime"
-    if amount_cents >= 19900:
-        return "year"
-    return "month"
-
-
-def _get_notify_path(provider_name: str) -> str:
-    base = BASE_URL.rstrip("/")
-    return f"{base}/wxh5/xorpay_notify" if provider_name == "xorpay" else f"{base}/wxh5/zpay_notify"
-
-
-def _sync_wxh5_vip_to_supabase(user_id: str, plan: str):
-    """支付成功后同步 VIP 到 Supabase wxgzh_vip_users"""
-    try:
-        from supabase import create_client
-        from ..config import SUPABASE_URL, SUPABASE_SERVICE_KEY
-        url = SUPABASE_URL
-        key = SUPABASE_SERVICE_KEY
-        if not url or not key:
-            logging.warning("wxh5: SUPABASE_URL/SUPABASE_SERVICE_KEY 未配置，跳过 Supabase 同步")
-            return
-        days = PLAN_MAP.get(plan, PLAN_MAP["year"])[1]
-        expire_at = (datetime.utcnow() + timedelta(days=days)).strftime("%Y-%m-%dT%H:%M:%S+00:00")
-        client = create_client(url, key)
-        # upsert: 存在则更新 expire_at，不存在则插入
-        client.table("wxgzh_vip_users").upsert(
-            {"user_id": user_id, "expire_at": expire_at},
-            on_conflict="user_id",
-        ).execute()
-        logging.info(f"wxh5 Supabase VIP 同步成功: user_id={user_id}, plan={plan}")
-    except Exception as e:
-        logging.error(f"wxh5 Supabase 同步失败: {e}", exc_info=True)
-
-
-@router.post("/payh5")
-async def wxh5_payh5(item: dict):
-    """wxH5 专用：创建支付订单，支持 per-request provider 覆盖"""
-    req_provider = (item.get("provider") or "").strip().lower()
-    provider = get_payment_provider_by_name(req_provider) if req_provider in ("xorpay", "zpay") else get_payment_provider()
-    plan = (item.get("plan") or "year").lower()
-    total_fee = PLAN_MAP.get(plan, PLAN_MAP["year"])[0]
-    total_fee = int(item.get("total_fee", total_fee))
-    total_fee_yuan = f"{total_fee / 100:.2f}"
-    user_id = item.get("user_id", "unknown")
-    pay_type = (item.get("type") or "vip").lower()
-    random_suffix = "".join(random.choices(string.hexdigits.lower(), k=8))
-    timestamp = int(time.time())
-    order_id = f"{user_id}_{pay_type}_order_{timestamp}_{random_suffix}"
-    return_url = item.get("return_url", "")
-    if return_url and "order_id=" not in return_url:
-        sep = "&" if "?" in return_url else "?"
-        return_url = f"{return_url}{sep}order_id={order_id}"
-    type_map = {"book": "购买书籍", "meetup": "社区报名", "video": "视频解锁", "vip": "VIP会员充值"}
-    name = type_map.get(pay_type, "VIP会员充值")
-    notify_url = _get_notify_path(provider.name)
-    channel = item.get("channel", "alipay")
-    result = provider.create_order(
-        order_id=order_id,
-        name=name,
-        total_fee_yuan=total_fee_yuan,
-        pay_type=channel,
-        notify_url=notify_url,
-        return_url=return_url,
-        client_ip=item.get("client_ip"),
-    )
-    if provider.name == "xorpay":
-        return {
-            "status": "ok",
-            "xorpay_params": result.get("params", {}),
-            "xorpay_url": result.get("pay_url", ""),
-            "provider": provider.name,
-        "order_id": order_id,
-    }
-    params = result.get("params", {})
-    params_str = {k: str(v) for k, v in params.items() if v is not None and str(v).strip() != ""}
-    return {
-        "status": "ok",
-        "params": params_str,
-        "pay_url": result.get("pay_url", ""),
-        "provider": provider.name,
-        "submit_method": "POST",
-        "order_id": order_id,
-    }
-
-
-@router.post("/payh5/redirect")
-async def wxh5_payh5_redirect(item: dict, request: Request):
-    """wxH5 专用：ZPAY mapi 接口（xorpay 无需 redirect）"""
-    req_provider = (item.get("provider") or "").strip().lower()
-    provider = get_payment_provider_by_name("zpay") if req_provider == "zpay" else get_payment_provider()
-    if not isinstance(provider, ZPayProvider):
-        raise HTTPException(status_code=400, detail="payh5/redirect 仅支持 zpay")
-    plan = (item.get("plan") or "year").lower()
-    total_fee = PLAN_MAP.get(plan, PLAN_MAP["year"])[0]
-    try:
-        total_fee = int(item.get("total_fee", total_fee))
-    except (TypeError, ValueError):
-        total_fee = PLAN_MAP["year"][0]
-    total_fee_yuan = f"{total_fee / 100:.2f}"
-    user_id = item.get("user_id", "unknown")
-    pay_type = (item.get("type") or "vip").lower()
-    channel = item.get("channel", "alipay")
-    device = item.get("device", "pc")
-    client_ip = item.get("client_ip") or (request.client.host if request.client else "127.0.0.1")
-    forwarded = request.headers.get("x-forwarded-for")
-    if forwarded:
-        client_ip = forwarded.split(",")[0].strip()
-    random_suffix = "".join(random.choices(string.hexdigits.lower(), k=8))
-    order_id = f"{user_id}_{pay_type}_order_{int(time.time())}_{random_suffix}"
-    return_url_raw = item.get("return_url", "")
-    if return_url_raw and "order_id=" not in return_url_raw:
-        sep = "&" if "?" in return_url_raw else "?"
-        return_url = f"{return_url_raw}{sep}order_id={order_id}"
-    else:
-        return_url = return_url_raw
-    type_map = {"book": "购买书籍", "meetup": "社区报名", "video": "视频解锁", "vip": "VIP会员充值"}
-    name = type_map.get(pay_type, "VIP会员充值")
-    notify_url = f"{BASE_URL.rstrip('/')}/wxh5/zpay_notify"
-    result = provider.create_order_api(
-        order_id=order_id,
-        name=name,
-        total_fee_yuan=total_fee_yuan,
-        pay_type=channel,
-        notify_url=notify_url,
-        return_url=return_url,
-        client_ip=client_ip,
-        device=device,
-    )
-    if result.get("status") != "ok":
-        err_msg = result.get("msg", "ZPAY mapi 创建订单失败")
-        raise HTTPException(status_code=500, detail=err_msg)
-    payurl = result.get("payurl")
-    payurl2 = result.get("payurl2")
-    img = result.get("img")
-    if device == "pc" and img:
-        return JSONResponse(status_code=200, content={
-            "status": "ok", "qrcode_mode": True, "order_id": order_id,
-            "img": img, "payurl": payurl, "return_url": return_url, "channel": channel,
-        })
-    if device == "wechat" and channel.lower() in ("wxpay", "wx", "wechat"):
-        return JSONResponse(status_code=200, content={"use_form": True, "order_id": order_id})
-    headers = {"X-Pay-Order-Id": order_id}
-    prefer_json = str(item.get("prefer_json", "")).lower() in ("1", "true", "yes")
-    if prefer_json:
-        target = payurl2 if (device == "h5" and channel.lower() in ("wxpay", "wx", "wechat")) else payurl
-        if target:
-            return JSONResponse(status_code=200, content={
-                "status": "ok", "redirect_url": target, "order_id": order_id, "provider": "zpay",
-            })
-    if device == "h5" and channel.lower() in ("wxpay", "wx", "wechat") and payurl2:
-        return RedirectResponse(url=payurl2, status_code=302, headers=headers)
-    if payurl:
-        return RedirectResponse(url=payurl, status_code=302, headers=headers)
-    raise HTTPException(status_code=500, detail="ZPAY 未返回支付链接")
-
-
-def _parse_wxh5_user_id(order_id: str) -> str:
-    """从 order_id 解析 user_id，格式: user_id_vip_order_ts"""
-    if "_order_" not in order_id:
-        return ""
-    prefix = order_id.split("_order_")[0]
-    if "_" in prefix:
-        return prefix.rsplit("_", 1)[0]
-    return prefix
-
-
-def _handle_wxh5_payment_success(order_id: str, pay_price: str, provider_name: str):
-    """wxH5 支付成功：PocketBase + Supabase"""
-    user_id = _parse_wxh5_user_id(order_id)
-    if not user_id:
-        return
-    handle_payment_success(order_id, pay_price, provider_name, use_memos=False)
-    amount_cents = int(float(pay_price or 0) * 100)
-    plan = _infer_plan_from_amount(amount_cents)
-    _sync_wxh5_vip_to_supabase(user_id, plan)
-
-
-@router.get("/order_status")
-async def wxh5_order_status(order_id: str):
-    """wxH5 通用：查询订单支付状态"""
-    zpay = get_payment_provider_by_name("zpay")
-    if isinstance(zpay, ZPayProvider):
-        result = zpay.query_order_status(order_id, timeout=15)
-        if not result.get("error") and result.get("paid"):
-            return result
-    try:
-        from ..services.pb import get_pb_client
-        pb = get_pb_client()
-        records = pb.collection("payments").get_list(1, 1, {"filter": f'order_id = "{order_id}"'})
-        return {"paid": len(records.items) > 0}
-    except Exception as e:
-        logging.warning(f"wxh5 PocketBase 查询失败: {e}")
-        return {"paid": False, "error": str(e)}
-
-
-@router.post("/xorpay_notify")
-async def wxh5_xorpay_notify(request: Request):
-    """wxH5 XorPay 异步通知"""
-    form_data = await request.form()
-    data = {k: v for k, v in form_data.items()}
-    order_id = data.get("order_id", "")
-    if order_id in processed_orders:
-        return "ok"
-    provider = get_payment_provider_by_name("xorpay")
-    if not provider.verify_notify(data):
-        raise HTTPException(status_code=400, detail="sign error")
-    parsed = provider.parse_notify(data)
-    if parsed.get("trade_status") != "success":
-        return "ok"
-    try:
-        _handle_wxh5_payment_success(order_id, parsed.get("pay_price", ""), "wxh5-xorpay")
-    except Exception as e:
-        logging.error(f"wxh5 业务处理异常: {e}", exc_info=True)
-        raise
-    return provider.success_response()
-
-
-@router.get("/zpay_notify")
-@router.post("/zpay_notify")
-async def wxh5_zpay_notify(request: Request):
-    """wxH5 ZPAY 异步通知"""
-    provider = get_payment_provider_by_name("zpay")
-    if request.method == "GET":
-        data = dict(request.query_params)
-    else:
-        form_data = await request.form()
-        data = {k: v for k, v in form_data.items()}
-    order_id = data.get("out_trade_no", "")
-    if order_id in processed_orders:
-        return "success"
-    if not provider.verify_notify(data):
-        raise HTTPException(status_code=400, detail="sign error")
-    parsed = provider.parse_notify(data)
-    trade_status = parsed.get("trade_status") or data.get("trade_status", "")
-    if trade_status not in ("success", "TRADE_SUCCESS"):
-        return "success"
-    try:
-        _handle_wxh5_payment_success(order_id, parsed.get("pay_price") or data.get("money", ""), "wxh5-zpay")
-    except Exception as e:
-        logging.error(f"wxh5 业务处理异常: {e}", exc_info=True)
-        raise
-    return provider.success_response()

app/sdk/__init__.py

@@ -1,20 +0,0 @@
-"""
-PayJS API SDK 模块
-- payment: 支付网关（ZPAY/XorPay）
-- pocketbase: PocketBase 数据库
-- minio: MinIO 对象存储
-- memos: Memos 用户（仅 nomadvip 使用）
-"""
-from .payment import get_payment_provider, ZPayProvider, XorPayProvider
-from .pocketbase import PocketBaseSDK
-from .minio import MinioSDK
-from .memos import MemosSDK
-
-__all__ = [
-    "get_payment_provider",
-    "ZPayProvider",
-    "XorPayProvider",
-    "PocketBaseSDK",
-    "MinioSDK",
-    "MemosSDK",
-]

app/sdk/memos.py

@@ -1,95 +0,0 @@
-"""
-Memos SDK
-用户创建等操作，仅 nomadvip 使用
-"""
-import logging
-from typing import Optional
-
-import requests
-
-
-class MemosSDK:
-    """Memos 用户管理 SDK"""
-
-    def __init__(
-        self,
-        api_url: str,
-        token: str,
-        enabled: bool = True,
-    ):
-        self.api_url = api_url.rstrip("/")
-        self.token = token
-        self.enabled = enabled and bool(api_url and token)
-
-    def create_user(
-        self,
-        user_id: str,
-        password: str = "123456",
-    ) -> dict:
-        """
-        创建 Memos 用户
-        :param user_id: PocketBase 用户 ID，如 user1766043770158
-        :return: {"success": bool, "data"?: dict, "error"?: str}
-        """
-        if not self.enabled:
-            return {"success": False, "error": "Memos 未启用"}
-
-        try:
-            if user_id.startswith("user_"):
-                cleaned = "user" + user_id.split("user_", 1)[1]
-            elif "_" in user_id:
-                cleaned = user_id.replace("_", "")
-            else:
-                cleaned = user_id
-
-            username = cleaned
-            data = {
-                "username": username,
-                "password": password,
-                "role": "USER",
-                "state": "NORMAL",
-            }
-            headers = {
-                "Content-Type": "application/json",
-                "Authorization": f"Bearer {self.token}",
-            }
-            resp = requests.post(
-                self.api_url,
-                json=data,
-                headers=headers,
-                timeout=10,
-            )
-            if resp.status_code in (200, 201):
-                logging.info(f"memos 用户创建成功: {username}")
-                return {"success": True, "data": resp.json()}
-            else:
-                logging.error(f"memos 创建失败 - username: {username}, status: {resp.status_code}, response: {resp.text}")
-                return {"success": False, "error": resp.text}
-        except Exception as e:
-            logging.error(f"创建 memos 用户异常 - user_id: {user_id}, error: {e}")
-            return {"success": False, "error": str(e)}
-
-    def create_user_by_username(
-        self,
-        username: str,
-        password: str = "123456",
-    ) -> dict:
-        """按用户名直接创建（用于 /create_user 接口）"""
-        if not self.enabled:
-            return {"success": False, "error": "Memos 未启用"}
-        try:
-            data = {
-                "username": username,
-                "password": password,
-                "role": "USER",
-                "state": "NORMAL",
-            }
-            headers = {
-                "Content-Type": "application/json",
-                "Authorization": f"Bearer {self.token}",
-            }
-            resp = requests.post(self.api_url, json=data, headers=headers, timeout=10)
-            return resp.json()
-        except Exception as e:
-            logging.error(f"创建 memos 用户异常 - username: {username}, error: {e}")
-            return {"error": str(e)}

app/sdk/minio.py

@@ -1,92 +0,0 @@
-"""
-MinIO SDK
-对象存储封装，支持配置注入
-"""
-import os
-import time
-import random
-import string
-from typing import Optional
-
-try:
-    from minio import Minio
-    MINIO_AVAILABLE = True
-except ImportError:
-    MINIO_AVAILABLE = False
-    Minio = None
-
-
-class MinioSDK:
-    """MinIO 对象存储 SDK"""
-
-    def __init__(
-        self,
-        end_point: str,
-        access_key: str,
-        secret_key: str,
-        bucket: str = "hackrobot",
-        use_ssl: bool = True,
-        port: Optional[int] = None,
-        region: str = "china",
-        public_url: Optional[str] = None,
-        upload_prefix: str = "joins",
-    ):
-        if not MINIO_AVAILABLE:
-            raise ImportError("minio 未安装，请执行: pip install minio")
-        self.end_point = end_point
-        self.port = port or (443 if use_ssl else 80)
-        self.access_key = access_key
-        self.secret_key = secret_key
-        self.bucket = bucket
-        self.use_ssl = use_ssl
-        self.region = region
-        self.public_url = public_url or f"https://{end_point}/{bucket}"
-        self.upload_prefix = upload_prefix.rstrip("/")
-        self._client: Optional[Minio] = None
-
-    def get_client(self) -> "Minio":
-        """获取 MinIO 客户端"""
-        if self._client is None:
-            endpoint = f"{self.end_point}:{self.port}" if self.port not in (80, 443) else self.end_point
-            self._client = Minio(
-                endpoint,
-                access_key=self.access_key,
-                secret_key=self.secret_key,
-                secure=self.use_ssl,
-                region=self.region,
-            )
-        return self._client
-
-    def generate_object_key(self, ext: str) -> str:
-        """生成上传用的对象键"""
-        ext = ext.lstrip(".")
-        suffix = "".join(random.choices(string.ascii_lowercase + string.digits, k=8))
-        return f"{self.upload_prefix}/{int(time.time() * 1000)}_{suffix}.{ext}"
-
-    def upload_buffer(
-        self,
-        data: bytes,
-        object_key: str,
-        content_type: str = "application/octet-stream",
-    ) -> dict:
-        """
-        上传文件到 MinIO
-        :return: {"url": str, "object_key": str}
-        """
-        client = self.get_client()
-        from io import BytesIO
-        stream = BytesIO(data)
-        client.put_object(
-            self.bucket,
-            object_key,
-            stream,
-            len(data),
-            content_type=content_type,
-        )
-        url = f"{self.public_url.rstrip('/')}/{object_key}"
-        return {"url": url, "object_key": object_key}
-
-    @property
-    def enabled(self) -> bool:
-        """是否启用（需配置 access_key/secret_key）"""
-        return bool(self.end_point and self.access_key and self.secret_key)

app/sdk/payment/__init__.py

@@ -1,15 +0,0 @@
-"""
-支付网关 SDK
-支持 ZPAY、XorPay，通过配置切换
-"""
-from app.payment.base import PaymentProvider
-from app.payment.zpay import ZPayProvider
-from app.payment.xorpay import XorPayProvider
-from app.payment.factory import get_payment_provider
-
-__all__ = [
-    "PaymentProvider",
-    "ZPayProvider",
-    "XorPayProvider",
-    "get_payment_provider",
-]

app/sdk/pocketbase.py

@@ -1,69 +0,0 @@
-"""
-PocketBase SDK
-数据库操作封装，支持配置注入
-"""
-from typing import Optional
-
-from pocketbase import PocketBase
-
-
-class PocketBaseSDK:
-    """PocketBase 客户端 SDK"""
-
-    def __init__(
-        self,
-        url: str,
-        admin_email: str,
-        admin_password: str,
-    ):
-        self.url = url
-        self.admin_email = admin_email
-        self.admin_password = admin_password
-        self._client: Optional[PocketBase] = None
-
-    def get_client(self) -> PocketBase:
-        """获取已认证的 PocketBase 客户端"""
-        if self._client is None:
-            self._client = PocketBase(self.url)
-            self._client.admins.auth_with_password(self.admin_email, self.admin_password)
-        return self._client
-
-    def collection(self, name: str):
-        """获取集合"""
-        return self.get_client().collection(name)
-
-    def create_payment(self, user_id: str, pay_type: str, order_id: str, amount: int) -> dict:
-        """创建支付记录"""
-        return self.collection("payments").create({
-            "user_id": user_id,
-            "type": pay_type,
-            "order_id": order_id,
-            "amount": amount,
-        })
-
-    def update_meetup_payment(
-        self,
-        user_id: str,
-        order_id: str,
-        amount: int,
-    ) -> None:
-        """更新或创建 meetup 支付记录"""
-        solan = self.collection("solan")
-        existing = solan.get_list(1, 1, {
-            "filter": f'user_id = "{user_id}"',
-            "sort": "-created",
-        })
-        if existing.items:
-            record_id = existing.items[0].id
-            solan.update(record_id, {
-                "type": "meetup",
-                "order_id": order_id,
-                "amount": amount,
-            })
-        else:
-            solan.create({
-                "user_id": user_id,
-                "type": "meetup",
-                "order_id": order_id,
-                "amount": amount,
-            })

app/services/__init__.py

@@ -1,16 +0,0 @@
-"""
-共享业务逻辑，基于 SDK 封装
-- PocketBase、Memos 通过 app.sdk 使用
-- 仅 nomadvip 涉及 Memos
-"""
-from .pb import get_pb_client
-from .memos import create_memos_user
-from .payment import handle_payment_success, parse_order_id, processed_orders
-
-__all__ = [
-    "get_pb_client",
-    "create_memos_user",
-    "handle_payment_success",
-    "parse_order_id",
-    "processed_orders",
-]

app/services/memos.py

@@ -1,21 +0,0 @@
-"""Memos 用户创建（基于 SDK，仅 nomadvip 使用）"""
-from app.config import MEMOS_API, MEMOS_TOKEN
-from app.sdk.memos import MemosSDK
-
-_memos_sdk: MemosSDK | None = None
-
-
-def _get_memos_sdk() -> MemosSDK:
-    global _memos_sdk
-    if _memos_sdk is None:
-        _memos_sdk = MemosSDK(
-            api_url=MEMOS_API,
-            token=MEMOS_TOKEN,
-            enabled=bool(MEMOS_API and MEMOS_TOKEN),
-        )
-    return _memos_sdk
-
-
-def create_memos_user(user_id: str, password: str = "123456"):
-    """创建 Memos 用户"""
-    return _get_memos_sdk().create_user(user_id=user_id, password=password)

app/services/minio.py

@@ -1,51 +0,0 @@
-"""MinIO 对象存储（基于 SDK）"""
-from app.config import (
-    MINIO_ENDPOINT,
-    MINIO_PORT,
-    MINIO_ACCESS_KEY,
-    MINIO_SECRET_KEY,
-    MINIO_BUCKET,
-    MINIO_USE_SSL,
-    MINIO_PUBLIC_URL,
-    MINIO_UPLOAD_PREFIX,
-)
-from app.sdk.minio import MinioSDK
-
-_minio_sdk: MinioSDK | None = None
-
-
-def _get_minio_sdk() -> MinioSDK:
-    global _minio_sdk
-    if _minio_sdk is None:
-        _minio_sdk = MinioSDK(
-            end_point=MINIO_ENDPOINT,
-            access_key=MINIO_ACCESS_KEY,
-            secret_key=MINIO_SECRET_KEY,
-            bucket=MINIO_BUCKET,
-            use_ssl=MINIO_USE_SSL,
-            port=MINIO_PORT,
-            public_url=MINIO_PUBLIC_URL,
-            upload_prefix=MINIO_UPLOAD_PREFIX,
-        )
-    return _minio_sdk
-
-
-def get_minio_client():
-    """获取 MinIO 客户端（未配置时返回 None）"""
-    sdk = _get_minio_sdk()
-    if not sdk.enabled:
-        return None
-    return sdk.get_client()
-
-
-def upload_buffer(data: bytes, object_key: str, content_type: str = "application/octet-stream"):
-    """上传文件到 MinIO（未配置时抛出异常）"""
-    sdk = _get_minio_sdk()
-    if not sdk.enabled:
-        raise RuntimeError("MinIO 未配置，请设置 MINIO_ACCESS_KEY、MINIO_SECRET_KEY")
-    return sdk.upload_buffer(data, object_key, content_type)
-
-
-def generate_object_key(ext: str) -> str:
-    """生成上传用的对象键"""
-    return _get_minio_sdk().generate_object_key(ext)

app/services/payment.py

@@ -1,114 +0,0 @@
-"""支付成功后的统一业务处理（基于 SDK）"""
-import logging
-
-from .pb import get_pb_client
-from .memos import create_memos_user
-
-# 已处理订单（防重复）
-processed_orders: set[str] = set()
-
-
-def parse_order_id(order_id: str) -> tuple[str, str]:
-    """从 order_id 解析 user_id 和 pay_type"""
-    if "_order_" not in order_id:
-        return "", "unknown"
-    prefix = order_id.split("_order_")[0]
-    if "_" in prefix:
-        parts = prefix.rsplit("_", 1)
-        return parts[0], parts[1].lower()
-    return prefix, "unknown"
-
-
-def handle_payment_success(
-    order_id: str,
-    pay_price: str,
-    provider_name: str,
-    *,
-    use_memos: bool = False,
-    site_id: str | None = None,
-):
-    """
-    支付成功后的统一业务处理
-    :param use_memos: 是否创建 Memos 用户，仅 nomadvip 为 True
-    :param site_id: 站点标识（digital/meetup/vip），用于写入 site_vip
-    """
-    user_id, pay_type = parse_order_id(order_id)
-    if not user_id:
-        return
-
-    print(f"支付成功 [{provider_name}] 用户ID: {user_id}，类型: {pay_type}，站点: {site_id}，订单: {order_id}")
-
-    if pay_type == "vip" and use_memos:
-        create_memos_user(user_id)
-
-    if pay_type == "meetup":
-        logging.info(f"meetup 类型支付成功，不创建 memos 用户 - user_id: {user_id}")
-
-    valid_types = ["vip", "book", "meetup", "video"]
-    if pay_type not in valid_types:
-        pay_type = "vip"
-
-    amount_cents = int(float(pay_price or 0) * 100)
-
-    try:
-        pb_client = get_pb_client()
-        if pay_type == "meetup":
-            solan = pb_client.collection("solan")
-            existing = solan.get_list(1, 1, {
-                "filter": f'user_id = "{user_id}"',
-                "sort": "-created",
-            })
-            if existing.items:
-                record_id = existing.items[0].id
-                solan.update(record_id, {
-                    "type": "meetup",
-                    "order_id": order_id,
-                    "amount": amount_cents,
-                })
-                logging.info(f"meetup 支付字段补齐成功 - user_id: {user_id}, record_id: {record_id}")
-            else:
-                solan.create({
-                    "user_id": user_id,
-                    "type": "meetup",
-                    "order_id": order_id,
-                    "amount": amount_cents,
-                })
-                logging.info(f"meetup 完整记录创建（兜底） - user_id: {user_id}")
-        else:
-            pb_client.collection("payments").create({
-                "user_id": user_id,
-                "type": pay_type,
-                "order_id": order_id,
-                "amount": amount_cents,
-            })
-
-        # 写入 site_vip（站点独立 VIP）。meetup 类型统一写 site_id=meetup
-        effective_site_id = "meetup" if pay_type == "meetup" else site_id
-        if effective_site_id:
-            try:
-                site_vip = pb_client.collection("site_vip")
-                existing_vip = site_vip.get_list(1, 1, {
-                    "filter": f'user_id = "{user_id}" && site_id = "{effective_site_id}"',
-                })
-                if existing_vip.items:
-                    site_vip.update(existing_vip.items[0].id, {
-                        "order_id": order_id,
-                        "expires_at": "",
-                    })
-                    logging.info(f"site_vip 更新成功 - user_id: {user_id}, site_id: {effective_site_id}")
-                else:
-                    site_vip.create({
-                        "user_id": user_id,
-                        "site_id": effective_site_id,
-                        "order_id": order_id,
-                        "expires_at": "",
-                    })
-                    logging.info(f"site_vip 创建成功 - user_id: {user_id}, site_id: {effective_site_id}")
-            except Exception as e:
-                logging.warning(f"site_vip 写入失败（不影响主流程）: {e}")
-
-        processed_orders.add(order_id)
-    except Exception as e:
-        print(f"PocketBase 操作失败: {e}")
-        logging.error(f"PocketBase 操作失败 - order_id: {order_id}, error: {e}")
-        raise

app/services/pb.py

@@ -1,24 +0,0 @@
-"""PocketBase 客户端（基于 SDK）"""
-from app.config import PB_URL, PB_ADMIN_EMAIL, PB_ADMIN_PASSWORD
-from app.sdk.pocketbase import PocketBaseSDK
-
-_pb_sdk: PocketBaseSDK | None = None
-
-
-def _get_pb_sdk() -> PocketBaseSDK:
-    global _pb_sdk
-    if _pb_sdk is None:
-        _pb_sdk = PocketBaseSDK(
-            url=PB_URL,
-            admin_email=PB_ADMIN_EMAIL,
-            admin_password=PB_ADMIN_PASSWORD,
-        )
-    return _pb_sdk
-
-
-def get_pb_client():
-    """获取已认证的 PocketBase 客户端"""
-    sdk = _get_pb_sdk()
-    client = sdk.get_client()
-    print("PocketBase admin 登录成功")
-    return client

payment_notify.log

@@ -1,17 +0,0 @@
-2026-03-08 03:04:04,172 - ZPAY 땐데꿴璂呵겨: HTTPSConnectionPool(host='zpayz.cn', port=443): Read timed out. (read timeout=10)
-2026-03-08 06:25:51,919 - ZPAY 땐데꿴璂呵겨: HTTPSConnectionPool(host='zpayz.cn', port=443): Read timed out. (read timeout=10)
-2026-03-08 06:28:42,212 - ZPAY 땐데꿴璂呵겨: HTTPSConnectionPool(host='zpayz.cn', port=443): Read timed out. (read timeout=10)
-2026-03-08 06:31:18,405 - ZPAY 땐데꿴璂呵겨: HTTPSConnectionPool(host='zpayz.cn', port=443): Read timed out. (read timeout=10)
-2026-03-08 06:39:41,805 - ZPAY 땐데꿴璂呵겨: HTTPSConnectionPool(host='zpayz.cn', port=443): Read timed out. (read timeout=10)
-2026-03-08 06:40:22,362 - ZPAY 땐데꿴璂呵겨: ('Connection aborted.', RemoteDisconnected('Remote end closed connection without response'))
-2026-03-10 05:01:08,564 - nomadvip payh5/redirect 헝헹: item={'user_id': 'user1773135567826', 'total_fee': 18800, 'type': 'vip', 'channel': 'wxpay', 'return_url': 'http://192.168.41.222:3000/paid', 'device': 'pc', 'client_ip': '192.168.41.222'}
-2026-03-10 05:02:23,523 - nomadvip ZPAY 땐데꿴璂呵겨: HTTPSConnectionPool(host='zpayz.cn', port=443): Read timed out. (read timeout=10)
-2026-03-10 05:02:46,901 - nomadvip payh5/redirect 헝헹: item={'user_id': 'user1773136912337', 'total_fee': 18800, 'type': 'vip', 'channel': 'wxpay', 'return_url': 'http://192.168.41.222:3000/paid', 'device': 'wechat', 'client_ip': '192.168.41.34'}
-2026-03-10 05:03:26,325 - nomadvip payh5/redirect 헝헹: item={'user_id': 'user1773136912337', 'total_fee': 18800, 'type': 'vip', 'channel': 'wxpay', 'return_url': 'http://192.168.41.222:3000/paid', 'device': 'wechat', 'client_ip': '192.168.41.34'}
-2026-03-10 05:04:54,606 - nomadvip ZPAY 땐데꿴璂呵겨: ('Connection aborted.', ConnectionResetError(10054, 'An existing connection was forcibly closed by the remote host', None, 10054, None))
-2026-03-10 05:06:39,639 - nomadvip payh5/redirect 헝헹: item={'user_id': 'user1773136912337', 'total_fee': 18800, 'type': 'vip', 'channel': 'wxpay', 'return_url': 'http://192.168.41.222:3000/paid', 'device': 'wechat', 'client_ip': '192.168.41.34'}
-2026-03-10 05:07:03,035 - nomadvip payh5/redirect 헝헹: item={'user_id': 'user1773136912337', 'total_fee': 18800, 'type': 'vip', 'channel': 'wxpay', 'return_url': 'http://192.168.41.222:3000/paid', 'device': 'wechat', 'client_ip': '192.168.41.34'}
-2026-03-10 05:07:37,981 - nomadvip ZPAY 땐데꿴璂呵겨: ('Connection aborted.', RemoteDisconnected('Remote end closed connection without response'))
-2026-03-10 05:08:31,484 - nomadvip payh5/redirect 헝헹: item={'user_id': 'user1773136912337', 'total_fee': 18800, 'type': 'vip', 'channel': 'wxpay', 'return_url': 'http://192.168.41.222:3000/paid', 'device': 'wechat', 'client_ip': '192.168.41.34'}
-2026-03-10 05:15:55,977 - nomadvip payh5/redirect 헝헹: item={'user_id': 'user1773136912337', 'total_fee': 18800, 'type': 'vip', 'channel': 'wxpay', 'return_url': 'http://192.168.41.222:3000/paid', 'device': 'wechat', 'client_ip': '192.168.41.34'}
-2026-03-10 05:22:16,735 - nomadvip payh5/redirect 헝헹: item={'user_id': 'user1773131395284', 'total_fee': 18800, 'type': 'vip', 'channel': 'wxpay', 'return_url': 'http://localhost:3000/paid', 'device': 'pc', 'client_ip': '127.0.0.1'}

requirements.txt

@@ -3,6 +3,4 @@ uvicorn
 sqlalchemy
 pydantic
 python-multipart
-pocketbase
-requests
-minio
+pocketbase

手机微信支付调试说明.md

@@ -1,44 +0,0 @@
-# 手机微信支付调试说明
-
-前端（vipgroup 等）与 payjsapi 同机时，支付请求由服务端发起，应使用 `127.0.0.1:8700`。
-
-## 1. 同机部署（vipgroup + payjsapi 都在本机）
-
-**无需配置**。默认使用 `http://127.0.0.1:8700`。
-
-若 `.env.local` 中有 `PAYMENT_API_URL=http://0.0.0.0:8700`，请删除或改为：
-```bash
-PAYMENT_API_URL=http://127.0.0.1:8700
-```
-（0.0.0.0 无法作为连接目标，会导致立即失败）
-
-## 2. 确认 payjsapi 已启动
-
-```bash
-cd C:\project\payjsapi
-python run.py
-```
-
-应监听 `0.0.0.0:8700`，可从局域网访问。
-
-## 3. 确认防火墙放行 8700 端口
-
-Windows 防火墙可能阻止手机访问 8700。若 vipgroup 与 payjsapi 同机，请求是服务端内部调用，一般无问题。
-
-## 4. 查看控制台日志
-
-支付失败时，vipgroup 的 Next.js 控制台会输出：
-
-```
-[pay] 请求失败: ... apiUrl: http://xxx:8700 requestHost: xxx
-```
-
-- 若 `apiUrl` 为 `http://0.0.0.0:8700` → 在 `.env.local` 中设置 `PAYMENT_API_URL=http://192.168.41.222:8700`
-- 若 `apiUrl` 正确但仍失败 → 检查 payjsapi 是否运行、网络是否可达
-
-## 5. vipgroup 需包含的配置逻辑
-
-若 vipgroup 与 lms/nomadlms 结构不同，需确保：
-
-1. 调用 `/api/pay` 或直接调用 payjsapi 时，使用正确的 `PAYMENT_API_URL`
-2. 本地开发时 `PAYMENT_API_URL` 指向 `http://{你的局域网IP}:8700`