Spaces:
Running
Running
Upload router_wallet.py
Browse files- router_wallet.py +3 -3
router_wallet.py
CHANGED
|
@@ -242,10 +242,10 @@ async def tip_user(req: TipRequest, db: Session = Depends(get_db)):
|
|
| 242 |
target_user = users_db[req.target_account]
|
| 243 |
tips_received = target_user.get("tips_received", {})
|
| 244 |
|
| 245 |
-
# 计算等级额度 (
|
| 246 |
current_tip = tips_received.get(req.sender_account, {}).get("amount", 0)
|
| 247 |
-
if current_tip + req.amount >
|
| 248 |
-
raise HTTPException(status_code=400, detail=f"您对该用户的打赏已达上限 (9个太阳/
|
| 249 |
|
| 250 |
# 1. 扣除打赏者余额 (悲观锁防并发)
|
| 251 |
sender_wallet = db.query(Wallet).filter(Wallet.account == req.sender_account).with_for_update().first()
|
|
|
|
| 242 |
target_user = users_db[req.target_account]
|
| 243 |
tips_received = target_user.get("tips_received", {})
|
| 244 |
|
| 245 |
+
# 计算等级额度 (100分=1星, 500分=1月, 2500分=1太阳。上限9太阳=22500分)
|
| 246 |
current_tip = tips_received.get(req.sender_account, {}).get("amount", 0)
|
| 247 |
+
if current_tip + req.amount > 22500:
|
| 248 |
+
raise HTTPException(status_code=400, detail=f"您对该用户的打赏已达上限 (9个太阳/22500积分),最多还能打赏 {22500 - current_tip} 积分")
|
| 249 |
|
| 250 |
# 1. 扣除打赏者余额 (悲观锁防并发)
|
| 251 |
sender_wallet = db.query(Wallet).filter(Wallet.account == req.sender_account).with_for_update().first()
|