Upload 5 files

router_items.py

@@ -77,7 +77,7 @@ async def get_items(type: str = "tool", sort: str = "time", limit: int = 50): #
     return {"status": "success", "data": filtered_items[:limit]}
 
 @router.get("/api/creators")
-async def get_creators(sort: str = "downloads", limit: int = 1000):
+async def get_creators(sort: str = "downloads", limit: int = 100):
     """
     获取创作者列表
     🚀 P1性能优化：预构建 author->items 索引，避免 N+1 查询

router_wallet.py

@@ -178,39 +178,44 @@ async def check_order(order_id: str, account: str = None, db: Session = Depends(
     tx = db.query(Transaction).filter(Transaction.tx_id == order_id).first()
     if tx:
         return {"status": "SUCCESS"}
-        
+
     # 防线 2：主动向支付宝发起查单（解决 Hugging Face 收不到回调的绝杀技）
     if alipay and account:
         try:
             # 拿着订单号去问支付宝：这笔钱到底付了没？
             result = alipay.api_alipay_trade_query(out_trade_no=order_id)
             if result.get("code") == "10000" and result.get("trade_status") in ("TRADE_SUCCESS", "TRADE_FINISHED"):
-                
+
+                # 🔒 防重检查：支付宝查单成功后，再次检查是否已被回调处理过
+                existing_check = db.query(Transaction).filter(Transaction.tx_id == order_id).first()
+                if existing_check:
+                    return {"status": "SUCCESS"}  # 已被回调入账，不重复处理
+
                 # 钱真的到了！立刻加锁入账
                 amount = int(float(result.get("total_amount", 0)))
-                
+
                 wallet = db.query(Wallet).filter(Wallet.account == account).with_for_update().first()
                 if not wallet:
                     wallet = Wallet(account=account, balance=0, earn_balance=0, tip_balance=0, frozen_balance=0)
                     db.add(wallet)
-                
+
                 wallet.balance = (wallet.balance or 0) + amount
-                
+
                 last_tx = db.query(Transaction).filter(Transaction.account == account).order_by(Transaction.created_at.desc()).first()
                 prev_hash = last_tx.tx_hash if last_tx else "GENESIS_HASH"
                 tx_hash = calculate_tx_hash(order_id, account, "RECHARGE", amount, prev_hash)
-                
+
                 new_tx = Transaction(
                     tx_id=order_id, account=account, tx_type="RECHARGE", amount=amount,
                     prev_hash=prev_hash, tx_hash=tx_hash
                 )
                 db.add(new_tx)
                 db.commit()
-                
+
                 return {"status": "SUCCESS"}
         except Exception as e:
             print(f"主动查单发生异常: {e}")
-            
+
     # 如果没查到支付成功状态，继续让前端等
     return {"status": "PENDING"}