wangjia
b3c9d98eae
- 后端：payPlans 新增 promo_first_month（¥1/30 天/标准版权益）；下单强校验每店限购一次（仅 paid 计数，弃单可重下），已享用返回 409；新增 GET /license/promo-status 供前端置灰 - 官网：checkout 套餐段第二位插「🔥 首月特惠 ¥1」+ 推广横幅 + 划线原价 ¥299；首页价格区第二位插特惠卡（5 列）；已享用自动置灰 - App：购买弹窗套餐段改三档（标准/特惠/高级），特惠选中显示推广横幅与划线价，已享用置灰并禁用提交 - 实付金额以 pay 侧为准，pay 需 seed promo_first_month 产品后生效 Co-Authored-By: Claude Fable 5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01JJ1g8XV1YhhmHRzhwWEW7o
103 lines
3.5 KiB
Go
103 lines
3.5 KiB
Go
package handler
|
|
|
|
import (
|
|
"errors"
|
|
"log"
|
|
"net/http"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
|
|
"github.com/wangjia/jiu/backend/internal/middleware"
|
|
"github.com/wangjia/jiu/backend/internal/service"
|
|
"github.com/wangjia/jiu/backend/internal/util"
|
|
)
|
|
|
|
type PayHandler struct {
|
|
svc *service.PayService
|
|
}
|
|
|
|
func NewPayHandler(svc *service.PayService) *PayHandler {
|
|
return &PayHandler{svc: svc}
|
|
}
|
|
|
|
// Purchase POST /api/v1/license/purchase — 在线购买/续费下单，返回收银台 pay_url。
|
|
// 仅管理员可购买（handler 内判权，同 withdraw 模式）。
|
|
func (h *PayHandler) Purchase(c *gin.Context) {
|
|
role := middleware.GetRole(c)
|
|
if role != "admin" && role != "superadmin" {
|
|
c.JSON(http.StatusForbidden, gin.H{"error": "仅管理员可购买授权"})
|
|
return
|
|
}
|
|
var req struct {
|
|
BizCode string `json:"biz_code" binding:"required"`
|
|
}
|
|
if err := c.ShouldBindJSON(&req); err != nil {
|
|
c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
|
|
return
|
|
}
|
|
|
|
res, err := h.svc.CreatePurchase(middleware.GetShopID(c), middleware.GetUserID(c), req.BizCode)
|
|
if err != nil {
|
|
switch {
|
|
case errors.Is(err, service.ErrPayNotConfigured):
|
|
c.JSON(http.StatusServiceUnavailable, gin.H{"error": err.Error()})
|
|
case errors.Is(err, service.ErrUnknownPlan):
|
|
c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
|
|
case errors.Is(err, service.ErrPromoUsed):
|
|
c.JSON(http.StatusConflict, gin.H{"error": err.Error()})
|
|
default:
|
|
log.Printf("[pay] purchase failed shop=%d biz_code=%s: %v", middleware.GetShopID(c), req.BizCode, err)
|
|
c.JSON(http.StatusBadGateway, gin.H{"error": "下单失败，请稍后重试"})
|
|
}
|
|
return
|
|
}
|
|
util.RespondSuccess(c, res)
|
|
}
|
|
|
|
// PurchaseStatus GET /api/v1/license/purchase/:out_trade_no — 结果页轮询购买单状态。
|
|
func (h *PayHandler) PurchaseStatus(c *gin.Context) {
|
|
st, err := h.svc.Status(middleware.GetShopID(c), c.Param("out_trade_no"))
|
|
if err != nil {
|
|
if errors.Is(err, service.ErrPurchaseNotFound) {
|
|
c.JSON(http.StatusNotFound, gin.H{"error": err.Error()})
|
|
return
|
|
}
|
|
c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
|
|
return
|
|
}
|
|
util.RespondSuccess(c, st)
|
|
}
|
|
|
|
// PromoStatus GET /api/v1/license/promo-status — 本店首月特惠是否已享用（前端据此置灰特惠档）。
|
|
func (h *PayHandler) PromoStatus(c *gin.Context) {
|
|
used, err := h.svc.PromoUsed(middleware.GetShopID(c))
|
|
if err != nil {
|
|
c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
|
|
return
|
|
}
|
|
util.RespondSuccess(c, gin.H{"used": used})
|
|
}
|
|
|
|
// Callback POST /api/v1/pay/callback — pay 支付成功 webhook（公开路由，HMAC 验签）。
|
|
// 契约：验签失败回 401；受理成功回 200 + {"code":"SUCCESS"}，否则 pay 每 60s 重试 24h。
|
|
func (h *PayHandler) Callback(c *gin.Context) {
|
|
rawBody, err := c.GetRawData()
|
|
if err != nil {
|
|
c.JSON(http.StatusBadRequest, gin.H{"code": "FAIL", "message": "read body failed"})
|
|
return
|
|
}
|
|
err = h.svc.HandleCallback(rawBody,
|
|
c.GetHeader("X-Pay-Timestamp"), c.GetHeader("X-Pay-Nonce"), c.GetHeader("X-Pay-Sign"))
|
|
if err != nil {
|
|
if errors.Is(err, service.ErrPaySignature) {
|
|
c.JSON(http.StatusUnauthorized, gin.H{"code": "FAIL", "message": "signature verification failed"})
|
|
return
|
|
}
|
|
// 其余错误（暂时性/金额不符/单不存在）回非 SUCCESS，让 pay 重试；金额不符会持续失败并留日志告警
|
|
log.Printf("[pay] callback rejected: %v", err)
|
|
c.JSON(http.StatusOK, gin.H{"code": "FAIL", "message": err.Error()})
|
|
return
|
|
}
|
|
c.JSON(http.StatusOK, gin.H{"code": "SUCCESS"})
|
|
}
|