OrderRouter.go 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
  1. package router
  2. import (
  3. "demo/data/dao"
  4. "demo/data/dao/manage"
  5. "demo/data/domain"
  6. "demo/data/domain/vo"
  7. "demo/share"
  8. "fmt"
  9. "github.com/gin-gonic/gin"
  10. "github.com/spf13/cast"
  11. "time"
  12. )
  13. func OrderRouter(engine *gin.RouterGroup) {
  14. order := engine.Group("/order")
  15. {
  16. //根据用户登录id获取用户登录信息
  17. order.POST("/submit", GetOrderData)
  18. }
  19. }
  20. // GetOrderData 创建订单
  21. func GetOrderData(c *gin.Context) {
  22. id := GetUserIdByToken(c)
  23. if id == 0 {
  24. return
  25. }
  26. data := share.GetJsonAnyParam(c)
  27. skuId, _ := data("skuId")
  28. count, _ := data("count")
  29. couponUserId, _ := data("couponUserId")
  30. contactInformation, _ := data("contactInformation")
  31. sku, err := dao.SelectSkuBySkuId(cast.ToInt(skuId))
  32. fmt.Println(sku)
  33. if err != nil {
  34. c.JSON(200, CreateResultError(1000, "商品规格不存在"))
  35. return
  36. }
  37. //查询库存数量
  38. if sku.InventoryNumber < cast.ToInt(count) {
  39. c.JSON(200, CreateResultError(1000, "库存不足"))
  40. }
  41. order := &domain.GoodsOrder{}
  42. order.SkuId = cast.ToInt(skuId)
  43. order.Count = cast.ToInt(count)
  44. order.CouponUserId = cast.ToInt64(couponUserId)
  45. order.ContactInformation = cast.ToString(contactInformation)
  46. order.OrderName = fmt.Sprint(sku.SkuName, "【x", count, "】")
  47. order.Price = sku.Price
  48. order.TotalPrice = sku.Price * float64(cast.ToInt(count))
  49. order.CreateBy = id
  50. order.CreateTime = time.Now()
  51. order, err = dao.CreateOrder(order)
  52. if err != nil {
  53. c.JSON(200, CreateResultError(1000, "创建订单失败"))
  54. return
  55. }
  56. c.JSON(200, CreateResultData(*order))
  57. }
  58. // 支付回调模拟
  59. func PayBuyTest(c *gin.Context) {
  60. id := GetUserIdByToken(c)
  61. if id == 0 {
  62. return
  63. }
  64. data := share.GetJsonAnyParam(c)
  65. orderId, _ := data("orderId")
  66. dao.OrderPaySuccess(cast.ToInt(orderId))
  67. }
  68. // 订单列表
  69. func GetOrderList(c *gin.Context) {
  70. id := GetUserIdByToken(c)
  71. if id == 0 {
  72. return
  73. }
  74. orders, err := dao.GetOrderByUserId(id)
  75. var ids = make([]int64, 0)
  76. for _, order := range orders {
  77. ids = append(ids, order.CouponUserId)
  78. }
  79. skus, err := manage.GetInIdListGoodsSku(ids)
  80. if err != nil {
  81. c.JSON(200, CreateResultError(1000, "查询失败"))
  82. }
  83. var vos = make([]vo.OrderVo, 0)
  84. for _, order := range orders {
  85. var vo vo.OrderVo
  86. vo.Order = order
  87. for _, sku := range skus {
  88. if order.CouponUserId == sku.Id {
  89. vo.Sku = sku
  90. break
  91. }
  92. }
  93. vos = append(vos, vo)
  94. }
  95. c.JSON(200, CreateResultData(map[string]interface{}{
  96. "vos": vos,
  97. "len": len(vos),
  98. }))
  99. }