huang
623a622298
Some checks failed
构建并部署到测试环境（无 SSH） / build-and-deploy (push) Has been cancelled
F-1: 佣金链断裂时创建 status=99 零额待审记录，新增修正接口 POST /commission-records/:id/resolve F-4: C端订单查询从 Handler 迁移至 Service 层，移除 SkipPermissionCtx J-1: 富友支付 JSAPI/MiniApp 预下单实现，回调补全签名验证 J-2: 平台钱包代购支持（buyerType 为空时使用资产所属代理钱包） J-3: 套餐激活后自动更新卡/设备 status=3，最后套餐过期后更新 status=4 支付抽象: 引入 PaymentProvider 接口 + 微信/富友适配器，CreateOrder 支持多支付渠道 修复: 设备/IoT卡响应 DTO 移除 omitempty，空值字段返回 null 而非省略
106 lines
2.7 KiB
Go
106 lines
2.7 KiB
Go
package app
|
|
|
|
import (
|
|
"strconv"
|
|
|
|
"github.com/break/junhong_cmp_fiber/internal/middleware"
|
|
"github.com/break/junhong_cmp_fiber/internal/model/dto"
|
|
clientorder "github.com/break/junhong_cmp_fiber/internal/service/client_order"
|
|
"github.com/break/junhong_cmp_fiber/pkg/constants"
|
|
"github.com/break/junhong_cmp_fiber/pkg/errors"
|
|
"github.com/break/junhong_cmp_fiber/pkg/response"
|
|
"github.com/gofiber/fiber/v2"
|
|
"go.uber.org/zap"
|
|
)
|
|
|
|
// ClientOrderHandler C 端订单处理器
|
|
// 提供 D1~D3 下单、列表、详情接口。
|
|
type ClientOrderHandler struct {
|
|
clientOrderService *clientorder.Service
|
|
logger *zap.Logger
|
|
}
|
|
|
|
// NewClientOrderHandler 创建 C 端订单处理器。
|
|
func NewClientOrderHandler(
|
|
clientOrderService *clientorder.Service,
|
|
logger *zap.Logger,
|
|
) *ClientOrderHandler {
|
|
return &ClientOrderHandler{
|
|
clientOrderService: clientOrderService,
|
|
logger: logger,
|
|
}
|
|
}
|
|
|
|
// CreateOrder D1 创建订单。
|
|
// POST /api/c/v1/orders/create
|
|
func (h *ClientOrderHandler) CreateOrder(c *fiber.Ctx) error {
|
|
var req dto.ClientCreateOrderRequest
|
|
if err := c.BodyParser(&req); err != nil {
|
|
return errors.New(errors.CodeInvalidParam)
|
|
}
|
|
|
|
customerID, ok := middleware.GetCustomerID(c)
|
|
if !ok || customerID == 0 {
|
|
return errors.New(errors.CodeUnauthorized)
|
|
}
|
|
|
|
resp, err := h.clientOrderService.CreateOrder(c.UserContext(), customerID, &req)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return response.Success(c, resp)
|
|
}
|
|
|
|
// ListOrders D2 订单列表。
|
|
// GET /api/c/v1/orders
|
|
func (h *ClientOrderHandler) ListOrders(c *fiber.Ctx) error {
|
|
var req dto.ClientOrderListRequest
|
|
if err := c.QueryParser(&req); err != nil {
|
|
return errors.New(errors.CodeInvalidParam)
|
|
}
|
|
|
|
if req.Page < 1 {
|
|
req.Page = 1
|
|
}
|
|
if req.PageSize < 1 {
|
|
req.PageSize = constants.DefaultPageSize
|
|
}
|
|
if req.PageSize > constants.MaxPageSize {
|
|
req.PageSize = constants.MaxPageSize
|
|
}
|
|
|
|
customerID, ok := middleware.GetCustomerID(c)
|
|
if !ok || customerID == 0 {
|
|
return errors.New(errors.CodeUnauthorized)
|
|
}
|
|
|
|
list, total, err := h.clientOrderService.ListOrders(c.UserContext(), customerID, &req)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return response.SuccessWithPagination(c, list, total, req.Page, req.PageSize)
|
|
}
|
|
|
|
// GetOrderDetail D3 订单详情。
|
|
// GET /api/c/v1/orders/:id
|
|
func (h *ClientOrderHandler) GetOrderDetail(c *fiber.Ctx) error {
|
|
customerID, ok := middleware.GetCustomerID(c)
|
|
if !ok || customerID == 0 {
|
|
return errors.New(errors.CodeUnauthorized)
|
|
}
|
|
|
|
orderID, err := strconv.ParseUint(c.Params("id"), 10, 64)
|
|
if err != nil || orderID == 0 {
|
|
return errors.New(errors.CodeInvalidParam)
|
|
}
|
|
|
|
resp, err := h.clientOrderService.GetOrderDetail(c.UserContext(), customerID, uint(orderID))
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return response.Success(c, resp)
|
|
}
|