shop_order.go 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121
  1. package api
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/gin-gonic/gin"
  6. "github.com/shopspring/decimal"
  7. "go_zh/model"
  8. "go_zh/pkg/validator"
  9. "go_zh/request/api"
  10. "go_zh/server"
  11. )
  12. type ShopOrderController struct {
  13. BaseController
  14. }
  15. func (shopOrder ShopOrderController) GetOrderSn(c *gin.Context) {
  16. mId := c.GetInt("mId")
  17. //数据验证
  18. var data api.CreateOrderRequest
  19. msg, ok := validator.ValidatorData(c, &data)
  20. if !ok {
  21. shopOrder.responseError(c, 400, msg)
  22. return
  23. }
  24. if data.PayType == 1 {
  25. if mId == 0 {
  26. shopOrder.responseError(c, 401, "缺少登陆信息")
  27. return
  28. }
  29. }
  30. //对金额进行精度处理
  31. money, err := decimal.NewFromString(data.PayMoney)
  32. if err != nil {
  33. shopOrder.responseError(c, 400, "金额错误")
  34. return
  35. }
  36. //对最小金额做判断
  37. minMoney, _ := decimal.NewFromString("0.01")
  38. if money.LessThan(minMoney) { //当 money小于minMoney时
  39. shopOrder.responseError(c, 400, "金额不合法")
  40. return
  41. }
  42. redisServer := server.GetRedisServerInstance()
  43. //获取商户银联信息
  44. shopMchidModel := model.XShopMchid{}
  45. var shopMchidInfo = model.XShopMchid{}
  46. shopMchidKey := fmt.Sprintf("%s%s", "shopMachidInfo", data.ShopId)
  47. shopMchidJson := redisServer.GetStr(shopMchidKey)
  48. if len(shopMchidJson) == 0 { //没缓存信息
  49. shopMchidInfo, err = shopMchidModel.GetShopBankMchid(data.ShopId)
  50. if err != nil {
  51. shopOrder.responseError(c, 400, "商户号信息错误"+err.Error())
  52. return
  53. }
  54. //存入缓存
  55. jsonData, _ := json.Marshal(shopMchidInfo)
  56. redisServer.SetStr(shopMchidKey, string(jsonData), 120)
  57. } else {
  58. _ = json.Unmarshal([]byte(shopMchidJson), &shopMchidInfo)
  59. }
  60. isBank := 0
  61. if shopMchidInfo.ID > 0 { //如果有银联信息就是银联支付
  62. isBank = 1
  63. }
  64. //获取商户配置
  65. shopSetModel := model.XShopSet{}
  66. var shopSetInfo = model.XShopSet{}
  67. shopSetKey := fmt.Sprintf("%s%s", "shopSetInfo", data.ShopId)
  68. shopSetJson := redisServer.GetStr(shopSetKey)
  69. if len(shopSetJson) == 0 { //没缓存信息
  70. shopSetInfo, err = shopSetModel.GetShopSetInfo(data.ShopId)
  71. if err != nil {
  72. shopOrder.responseError(c, 400, "商户配置信息错误")
  73. return
  74. }
  75. //存入缓存
  76. shopSetJsonData, _ := json.Marshal(shopSetInfo)
  77. redisServer.SetStr(shopSetKey, string(shopSetJsonData), 120)
  78. } else {
  79. _ = json.Unmarshal([]byte(shopSetJson), &shopSetInfo)
  80. }
  81. var discount decimal.Decimal
  82. if shopSetInfo.ID <= 0 { //如果没有
  83. discount, _ = decimal.NewFromString("0")
  84. } else {
  85. discount = shopSetInfo.Discount
  86. }
  87. orderSnServer := server.GetOrderSnServerInstance(1)
  88. orderSn := orderSnServer.GenerateString("382FS")
  89. //创建订单信息
  90. shopOrderModel := model.XShopOrder{}
  91. shopOrderModel.ShopID = data.ShopId
  92. shopOrderModel.PayType = data.PayType
  93. shopOrderModel.MID = mId
  94. shopOrderModel.RsSn = orderSn
  95. shopOrderModel.PayMoney = money
  96. shopOrderModel.Status = 1
  97. shopOrderModel.Discount = discount
  98. shopOrderModel.IsClearing = 0
  99. shopOrderModel.IsReport = 0
  100. shopOrderModel.PayCodeSource = data.PayCodeSource
  101. shopOrderModel.IsBank = isBank
  102. err = shopOrderModel.CreateShopOrder()
  103. if err != nil {
  104. shopOrder.responseError(c, 400, "订单创建失败")
  105. return
  106. }
  107. shopOrder.responseSuccess(c, shopOrderModel.ID)
  108. }