221 lines
7.8 KiB
Python
221 lines
7.8 KiB
Python
from fastapi import APIRouter, Depends, Response, Request
|
|
from sqlalchemy.orm import Session
|
|
from app.models.database import get_db
|
|
from app.models.user import UserInfo,UserDB, PhoneLoginRequest, generate_user_code
|
|
from app.models.order import ShippingOrderDB, OrderStatus
|
|
from app.core.response import success_response, error_response, ResponseModel
|
|
from app.core.wechat import WeChatClient,generate_random_string
|
|
from app.core.security import create_access_token, set_jwt_cookie
|
|
from pydantic import BaseModel, Field
|
|
import json
|
|
import time
|
|
from datetime import datetime, timezone
|
|
from app.api.deps import get_current_user
|
|
from app.core.config import settings
|
|
import random
|
|
import string
|
|
from app.models.merchant_order import MerchantOrderDB, MerchantOrderStatus
|
|
from app.models.merchant_pay_order import MerchantPayOrderDB, MerchantPayOrderStatus
|
|
import enum
|
|
|
|
router = APIRouter()
|
|
|
|
class PhoneNumberRequest(BaseModel):
|
|
login_code: str # 登录凭证
|
|
phone_code: str # 手机号验证码
|
|
referral_code: str = None # 推荐码（可选）
|
|
|
|
class OrderType(str, enum.Enum):
|
|
DELIVERY = "DELIVERY" # 配送订单
|
|
PRODUCT = "PRODUCT" # 商品订单
|
|
ONLINE_PAY = "ONLINE_PAY" # 在线支付
|
|
|
|
class WechatPayRequest(BaseModel):
|
|
"""微信支付请求"""
|
|
order_id: str
|
|
order_type: OrderType = Field(..., description="订单类型")
|
|
|
|
@router.post("/phone-login", response_model=ResponseModel)
|
|
async def wechat_phone_login(
|
|
request: PhoneNumberRequest,
|
|
db: Session = Depends(get_db),
|
|
response: Response = None
|
|
):
|
|
"""通过微信手机号登录/注册"""
|
|
try:
|
|
# 初始化微信客户端
|
|
wechat = WeChatClient()
|
|
|
|
# 获取用户 openid
|
|
session_info = await wechat.code2session(request.login_code)
|
|
openid = session_info["openid"]
|
|
|
|
# 获取用户手机号
|
|
phone_info = await wechat.get_phone_number(request.phone_code)
|
|
|
|
if not phone_info:
|
|
return error_response(code=400, message="获取手机号失败")
|
|
|
|
# 打印调试信息
|
|
print(f"获取到的手机号信息: {phone_info}")
|
|
|
|
phone = phone_info['phone_number']
|
|
if not phone:
|
|
return error_response(code=400, message="手机号为空")
|
|
|
|
# 查找或创建用户
|
|
user = db.query(UserDB).filter(UserDB.phone == phone).first()
|
|
if not user:
|
|
# 生成用户编码
|
|
user_code = generate_user_code(db)
|
|
|
|
user = UserDB(
|
|
nickname=f"蜂友{phone[-4:]}",
|
|
phone=phone,
|
|
user_code=user_code,
|
|
referral_code=request.referral_code,
|
|
openid=openid # 保存 openid
|
|
)
|
|
db.add(user)
|
|
db.flush()
|
|
|
|
# 发放优惠券
|
|
from app.api.endpoints.user import issue_register_coupons
|
|
issue_register_coupons(db, user.userid)
|
|
|
|
db.commit()
|
|
db.refresh(user)
|
|
else:
|
|
# 更新现有用户的 openid
|
|
user.openid = openid
|
|
db.commit()
|
|
|
|
# 创建访问令牌
|
|
access_token = create_access_token(
|
|
data={"phone": user.phone, "userid": user.userid}
|
|
)
|
|
|
|
# 设置JWT cookie
|
|
if response:
|
|
set_jwt_cookie(response, access_token)
|
|
|
|
return success_response(
|
|
message="登录成功",
|
|
data={
|
|
"user": UserInfo.model_validate(user),
|
|
"access_token": access_token,
|
|
"token_type": "bearer"
|
|
}
|
|
)
|
|
except Exception as e:
|
|
db.rollback()
|
|
return error_response(code=500, message=f"登录失败: {str(e)}")
|
|
|
|
@router.post("/create-payment", response_model=ResponseModel)
|
|
async def create_payment(
|
|
request: WechatPayRequest,
|
|
db: Session = Depends(get_db),
|
|
current_user: UserDB = Depends(get_current_user)
|
|
):
|
|
"""创建微信支付订单"""
|
|
# 查询订单
|
|
if request.order_type == OrderType.PRODUCT:
|
|
order = db.query(MerchantOrderDB).filter(
|
|
MerchantOrderDB.order_id == request.order_id,
|
|
MerchantOrderDB.user_id == current_user.userid,
|
|
MerchantOrderDB.status == MerchantOrderStatus.CREATED
|
|
).first()
|
|
if not order:
|
|
return error_response(code=404, message="订单不存在或状态不正确")
|
|
amount = order.pay_amount
|
|
description = "商家商品订单"
|
|
|
|
elif request.order_type == OrderType.ONLINE_PAY:
|
|
order = db.query(MerchantPayOrderDB).filter(
|
|
MerchantPayOrderDB.order_id == request.order_id,
|
|
MerchantPayOrderDB.user_id == current_user.userid,
|
|
MerchantPayOrderDB.status == MerchantPayOrderStatus.UNPAID
|
|
).first()
|
|
if not order:
|
|
return error_response(code=404, message="订单不存在或状态不正确")
|
|
amount = order.amount
|
|
description = "商家在线买单"
|
|
|
|
else:
|
|
return error_response(code=400, message="不支持的订单类型")
|
|
|
|
try:
|
|
# 初始化微信支付客户端
|
|
wechat = WeChatClient()
|
|
|
|
# 创建支付订单
|
|
result = await wechat.create_jsapi_payment(
|
|
openid=current_user.openid,
|
|
out_trade_no=request.order_id,
|
|
total_amount=int(float(amount) * 100), # 转换为分
|
|
description=description
|
|
)
|
|
|
|
if not result:
|
|
return error_response(code=500, message="创建支付订单失败")
|
|
|
|
return success_response(data={
|
|
"prepay_id": result.get("prepay_id"),
|
|
"payment_params": result.get("payment_params")
|
|
})
|
|
|
|
except Exception as e:
|
|
return error_response(code=500, message=f"创建支付订单失败: {str(e)}")
|
|
|
|
@router.post("/payment-notify")
|
|
async def payment_notify(
|
|
request: Request,
|
|
db: Session = Depends(get_db)
|
|
):
|
|
"""微信支付回调通知"""
|
|
try:
|
|
# 初始化微信支付客户端
|
|
wechat = WeChatClient()
|
|
|
|
# 验证并解析回调数据
|
|
data = await wechat.verify_payment_notify(request)
|
|
if not data:
|
|
print(f"回调数据验证失败: {data}")
|
|
return error_response(code=400, message="回调数据验证失败")
|
|
|
|
print(f"回调数据验证成功: {data}")
|
|
# 获取订单信息
|
|
out_trade_no = data.get("out_trade_no")
|
|
transaction_id = data.get("transaction_id")
|
|
trade_state = data.get("trade_state")
|
|
success_time = data.get("success_time")
|
|
|
|
if trade_state != "SUCCESS":
|
|
return error_response(code=400, message="支付未成功")
|
|
|
|
# 更新订单状态
|
|
if out_trade_no.startswith("M"): # 商家商品订单
|
|
order = db.query(MerchantOrderDB).filter(
|
|
MerchantOrderDB.order_id == out_trade_no
|
|
).first()
|
|
if order:
|
|
order.status = MerchantOrderStatus.UNVERIFIED
|
|
order.pay_time = datetime.fromisoformat(success_time)
|
|
order.transaction_id = transaction_id
|
|
|
|
elif out_trade_no.startswith("P"): # 商家在线买单
|
|
order = db.query(MerchantPayOrderDB).filter(
|
|
MerchantPayOrderDB.order_id == out_trade_no
|
|
).first()
|
|
if order:
|
|
order.status = MerchantPayOrderStatus.PAID
|
|
order.pay_time = datetime.fromisoformat(success_time)
|
|
order.transaction_id = transaction_id
|
|
|
|
db.commit()
|
|
|
|
return success_response(message="支付成功")
|
|
|
|
except Exception as e:
|
|
db.rollback()
|
|
return error_response(code=500, message=f"处理支付回调失败: {str(e)}") |