322 lines
11 KiB
Go
322 lines
11 KiB
Go
package handler
|
||
|
||
import (
|
||
"dianshang/internal/service"
|
||
"dianshang/pkg/response"
|
||
"dianshang/pkg/utils"
|
||
"fmt"
|
||
|
||
"github.com/gin-gonic/gin"
|
||
)
|
||
|
||
// OrderSettleHandler 订单结算处理器
|
||
type OrderSettleHandler struct {
|
||
orderService *service.OrderService
|
||
productService *service.ProductService
|
||
userService *service.UserService
|
||
}
|
||
|
||
// NewOrderSettleHandler 创建订单结算处理器
|
||
func NewOrderSettleHandler(orderService *service.OrderService, productService *service.ProductService, userService *service.UserService) *OrderSettleHandler {
|
||
return &OrderSettleHandler{
|
||
orderService: orderService,
|
||
productService: productService,
|
||
userService: userService,
|
||
}
|
||
}
|
||
|
||
// SettleOrderRequest 订单结算请求
|
||
type SettleOrderRequest struct {
|
||
UserAddressReq *UserAddressRequest `json:"userAddressReq"`
|
||
CouponList []CouponRequest `json:"couponList"`
|
||
GoodsRequestList []GoodsRequest `json:"goodsRequestList"`
|
||
StoreInfoList []StoreInfo `json:"storeInfoList"` // 添加门店信息列表
|
||
}
|
||
|
||
// UserAddressRequest 用户地址请求
|
||
type UserAddressRequest struct {
|
||
AddressID uint `json:"addressId"`
|
||
Name string `json:"name"`
|
||
Phone string `json:"phone"`
|
||
Address string `json:"address"`
|
||
DetailAddress string `json:"detailAddress"` // 添加详细地址字段，支持前端address-card组件
|
||
ProvinceCode string `json:"provinceCode"`
|
||
CityCode string `json:"cityCode"`
|
||
DistrictCode string `json:"districtCode"`
|
||
}
|
||
|
||
// CouponRequest 优惠券请求
|
||
type CouponRequest struct {
|
||
CouponID uint `json:"couponId"` // 优惠券模板ID
|
||
UserCouponID uint `json:"userCouponId"` // 用户优惠券ID (ai_user_coupons表的id)
|
||
Type int `json:"type"`
|
||
Value int `json:"value"`
|
||
Status string `json:"status"`
|
||
}
|
||
|
||
// StoreInfo 门店信息
|
||
type StoreInfo struct {
|
||
StoreID string `json:"storeId"`
|
||
StoreName string `json:"storeName"`
|
||
}
|
||
|
||
// GoodsRequest 商品请求
|
||
type GoodsRequest struct {
|
||
StoreID string `json:"storeId"`
|
||
SpuID string `json:"spuId"`
|
||
SkuID interface{} `json:"skuId"` // 改为interface{}以支持数字和字符串
|
||
Title string `json:"title"`
|
||
GoodsName string `json:"goodsName"` // 添加商品名称字段
|
||
PrimaryImage string `json:"primaryImage"`
|
||
Thumb string `json:"thumb"` // 添加缩略图字段
|
||
Quantity int `json:"quantity"`
|
||
Price int `json:"price"`
|
||
OriginPrice int `json:"originPrice"`
|
||
Available int `json:"available"` // 添加可用性字段
|
||
SpecInfo []SpecInfo `json:"specInfo"`
|
||
RoomID interface{} `json:"roomId"`
|
||
}
|
||
|
||
// SpecInfo 规格信息
|
||
type SpecInfo struct {
|
||
SpecID string `json:"specId"`
|
||
SpecTitle string `json:"specTitle"`
|
||
SpecValue string `json:"specValue"`
|
||
}
|
||
|
||
// SettleOrder 订单结算
|
||
func (h *OrderSettleHandler) SettleOrder(c *gin.Context) {
|
||
_, exists := c.Get("user_id")
|
||
if !exists {
|
||
response.Unauthorized(c)
|
||
return
|
||
}
|
||
|
||
var req SettleOrderRequest
|
||
if err := c.ShouldBindJSON(&req); err != nil {
|
||
response.BadRequest(c, "参数错误: "+err.Error())
|
||
return
|
||
}
|
||
|
||
// 验证商品信息并计算价格
|
||
var totalAmount float64
|
||
var totalGoodsCount int
|
||
var skuDetailVos []map[string]interface{}
|
||
|
||
for _, goods := range req.GoodsRequestList {
|
||
// 转换SkuID为字符串
|
||
var skuIDStr string
|
||
switch v := goods.SkuID.(type) {
|
||
case string:
|
||
skuIDStr = v
|
||
case float64:
|
||
skuIDStr = fmt.Sprintf("%.0f", v)
|
||
case int:
|
||
skuIDStr = fmt.Sprintf("%d", v)
|
||
default:
|
||
skuIDStr = fmt.Sprintf("%v", v)
|
||
}
|
||
|
||
spuID := utils.StringToUint(goods.SpuID)
|
||
if spuID == 0 {
|
||
response.BadRequest(c, "无效的商品ID: "+goods.SpuID)
|
||
return
|
||
}
|
||
|
||
// 获取商品信息
|
||
product, err := h.productService.GetProductDetail(spuID)
|
||
if err != nil {
|
||
response.BadRequest(c, "商品不存在: "+goods.SpuID)
|
||
return
|
||
}
|
||
|
||
// 检查库存
|
||
if product.Stock < goods.Quantity {
|
||
response.BadRequest(c, "商品库存不足: "+product.Name)
|
||
return
|
||
}
|
||
|
||
// 获取实际价格：优先使用SKU价格，如果没有SKU则使用SPU价格
|
||
var actualPrice float64
|
||
skuID := utils.StringToUint(skuIDStr)
|
||
if skuID > 0 {
|
||
// 根据SKU ID获取SKU详情和价格
|
||
sku, err := h.productService.GetSKUByID(skuID)
|
||
if err != nil {
|
||
// 如果SKU不存在，使用SPU价格
|
||
actualPrice = product.Price
|
||
} else {
|
||
// 使用SKU价格
|
||
actualPrice = sku.Price
|
||
}
|
||
} else {
|
||
// 没有SKU ID，使用SPU价格
|
||
actualPrice = product.Price
|
||
}
|
||
|
||
// 计算商品总价（数据库中价格以分为单位存储，直接计算）
|
||
itemTotal := actualPrice * float64(goods.Quantity)
|
||
totalAmount += itemTotal
|
||
totalGoodsCount += goods.Quantity
|
||
|
||
// 构建商品详情
|
||
skuDetail := map[string]interface{}{
|
||
"storeId": goods.StoreID,
|
||
"spuId": goods.SpuID,
|
||
"skuId": skuIDStr,
|
||
"goodsName": product.Name,
|
||
"image": product.MainImage,
|
||
"reminderStock": product.Stock,
|
||
"quantity": goods.Quantity,
|
||
"payPrice": actualPrice,
|
||
"totalSkuPrice": itemTotal,
|
||
"discountSettlePrice": actualPrice,
|
||
"realSettlePrice": actualPrice,
|
||
"settlePrice": actualPrice,
|
||
"oriPrice": actualPrice,
|
||
"tagPrice": nil,
|
||
"tagText": nil,
|
||
"skuSpecLst": goods.SpecInfo,
|
||
"promotionIds": nil,
|
||
"weight": 0.0,
|
||
"unit": "KG",
|
||
"volume": nil,
|
||
"masterGoodsType": 0,
|
||
"viceGoodsType": 0,
|
||
"roomId": goods.RoomID,
|
||
"egoodsName": nil,
|
||
}
|
||
skuDetailVos = append(skuDetailVos, skuDetail)
|
||
}
|
||
|
||
// 计算优惠券折扣
|
||
var totalCouponAmount float64
|
||
for _, coupon := range req.CouponList {
|
||
if coupon.Status == "default" {
|
||
if coupon.Type == 1 {
|
||
// 固定金额优惠券（数据库中value以分为单位存储，直接累加）
|
||
totalCouponAmount += float64(coupon.Value)
|
||
} else if coupon.Type == 2 {
|
||
// 折扣优惠券 - 修复：计算折扣金额而不是最终价格
|
||
// 例如：8折券(value=80)，9900分商品的折扣金额 = 9900 * (100-80) / 100 = 1980分
|
||
totalCouponAmount += totalAmount * (100 - float64(coupon.Value)) / 100
|
||
}
|
||
}
|
||
}
|
||
|
||
// 计算最终支付金额
|
||
totalPromotionAmount := 0.0 // 暂时没有促销活动
|
||
totalDeliveryFee := 0.0 // 免运费
|
||
totalPayAmount := totalAmount - totalCouponAmount - totalPromotionAmount + totalDeliveryFee
|
||
|
||
// 获取用户地址信息
|
||
var userAddress interface{}
|
||
settleType := 0
|
||
if req.UserAddressReq != nil {
|
||
settleType = 1
|
||
|
||
// 如果有地址ID，从数据库获取完整的地址信息
|
||
if req.UserAddressReq.AddressID > 0 {
|
||
userID, exists := c.Get("user_id")
|
||
if exists {
|
||
// 获取完整的地址信息
|
||
fullAddress, err := h.userService.GetAddressByID(userID.(uint), req.UserAddressReq.AddressID)
|
||
if err == nil && fullAddress != nil {
|
||
// 构建包含完整信息的地址对象
|
||
userAddress = map[string]interface{}{
|
||
"addressId": fullAddress.ID,
|
||
"name": fullAddress.Name,
|
||
"phone": fullAddress.Phone,
|
||
"address": fmt.Sprintf("%s%s%s%s", fullAddress.ProvinceName, fullAddress.CityName, fullAddress.DistrictName, fullAddress.DetailAddress),
|
||
"detailAddress": fullAddress.DetailAddress,
|
||
"provinceName": fullAddress.ProvinceName,
|
||
"cityName": fullAddress.CityName,
|
||
"districtName": fullAddress.DistrictName,
|
||
"provinceCode": req.UserAddressReq.ProvinceCode,
|
||
"cityCode": req.UserAddressReq.CityCode,
|
||
"districtCode": req.UserAddressReq.DistrictCode,
|
||
"isDefault": fullAddress.IsDefault,
|
||
}
|
||
} else {
|
||
// 如果获取失败，使用原始请求数据
|
||
userAddress = req.UserAddressReq
|
||
}
|
||
} else {
|
||
// 如果没有用户ID，使用原始请求数据
|
||
userAddress = req.UserAddressReq
|
||
}
|
||
} else {
|
||
// 如果没有地址ID，使用原始请求数据
|
||
userAddress = req.UserAddressReq
|
||
}
|
||
}
|
||
|
||
// 获取店铺信息
|
||
storeID := uint(1000) // 默认店铺ID，实际应该从商品信息中获取
|
||
if len(req.GoodsRequestList) > 0 {
|
||
// 从第一个商品获取店铺ID
|
||
if storeIDFromGoods := utils.StringToUint(req.GoodsRequestList[0].StoreID); storeIDFromGoods > 0 {
|
||
storeID = storeIDFromGoods
|
||
}
|
||
}
|
||
|
||
// 动态获取店铺名称
|
||
storeName := "默认店铺" // 默认店铺名
|
||
store, err := h.productService.GetStoreByID(storeID)
|
||
if err == nil && store != nil {
|
||
storeName = store.Name
|
||
}
|
||
|
||
// 构建返回数据（前端期望接收以分为单位的金额字符串）
|
||
result := map[string]interface{}{
|
||
"settleType": settleType,
|
||
"userAddress": userAddress,
|
||
"totalGoodsCount": totalGoodsCount,
|
||
"packageCount": 1,
|
||
"totalAmount": utils.FloatToString(totalAmount), // 已经是分为单位
|
||
"totalPayAmount": utils.FloatToString(totalPayAmount), // 已经是分为单位
|
||
"totalDiscountAmount": "0",
|
||
"totalPromotionAmount": utils.FloatToString(totalPromotionAmount), // 已经是分为单位
|
||
"totalCouponAmount": utils.FloatToString(totalCouponAmount), // 已经是分为单位
|
||
"totalSalePrice": utils.FloatToString(totalAmount), // 已经是分为单位
|
||
"totalGoodsAmount": utils.FloatToString(totalAmount), // 已经是分为单位
|
||
"totalDeliveryFee": utils.FloatToString(totalDeliveryFee), // 已经是分为单位
|
||
"invoiceRequest": nil,
|
||
"skuImages": nil,
|
||
"deliveryFeeList": nil,
|
||
"storeGoodsList": []map[string]interface{}{
|
||
{
|
||
"storeId": fmt.Sprintf("%d", storeID),
|
||
"storeName": storeName,
|
||
"remark": nil,
|
||
"goodsCount": totalGoodsCount,
|
||
"deliveryFee": utils.FloatToString(totalDeliveryFee), // 已经是分为单位
|
||
"deliveryWords": nil,
|
||
"storeTotalAmount": utils.FloatToString(totalAmount), // 已经是分为单位
|
||
"storeTotalPayAmount": utils.FloatToString(totalPayAmount), // 已经是分为单位
|
||
"storeTotalDiscountAmount": "0",
|
||
"storeTotalCouponAmount": utils.FloatToString(totalCouponAmount), // 已经是分为单位
|
||
"skuDetailVos": skuDetailVos,
|
||
"couponList": func() []map[string]interface{} {
|
||
var couponList []map[string]interface{}
|
||
for _, coupon := range req.CouponList {
|
||
if coupon.Status == "default" {
|
||
couponList = append(couponList, map[string]interface{}{
|
||
"couponId": coupon.UserCouponID, // 使用用户优惠券ID
|
||
"storeId": fmt.Sprintf("%d", storeID),
|
||
})
|
||
}
|
||
}
|
||
return couponList
|
||
}(),
|
||
},
|
||
},
|
||
"inValidGoodsList": nil,
|
||
"outOfStockGoodsList": nil,
|
||
"limitGoodsList": nil,
|
||
"abnormalDeliveryGoodsList": nil,
|
||
"invoiceSupport": 1,
|
||
}
|
||
|
||
response.Success(c, result)
|
||
} |