fiee/fonchain-fiee
10
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update pay.go

Browse Source
This commit is contained in:
JNG 2025-12-15 12:00:23 +08:00
parent 541592e1a4
commit 8e0de49db2
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/service/bundle/pay.go
View File

@ -2,7 +2,6 @@ package bundle
import ( import (
"context" "context"
"dubbo.apache.org/dubbo-go/v3/common/logger"
"encoding/json" "encoding/json"
"errors" "errors"
"fmt" "fmt"
@ -10,6 +9,7 @@ import (
"fonchain-fiee/api/bundle" "fonchain-fiee/api/bundle"
"fonchain-fiee/api/order" "fonchain-fiee/api/order"
"fonchain-fiee/api/payment" "fonchain-fiee/api/payment"
"fonchain-fiee/pkg/cache"
"fonchain-fiee/pkg/config" "fonchain-fiee/pkg/config"
"fonchain-fiee/pkg/model/login" "fonchain-fiee/pkg/model/login"
"fonchain-fiee/pkg/service" "fonchain-fiee/pkg/service"
@ -19,6 +19,9 @@ import (
"math" "math"
"net/http" "net/http"
"strconv" "strconv"
"time"
"dubbo.apache.org/dubbo-go/v3/common/logger"
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"
"github.com/gin-gonic/gin/binding" "github.com/gin-gonic/gin/binding"
@ -141,7 +144,13 @@ func CreateAntomPay(c *gin.Context) {
// 获取 用户信息 // 获取 用户信息
userInfo := login.GetUserInfoFromC(c) userInfo := login.GetUserInfoFromC(c)
// 创建审批 防止重复提交
lockKey := fmt.Sprintf("create_antom_pay_%v", userInfo.ID)
reply := cache.RedisClient.SetNX(lockKey, 0, 5*time.Second)
if !reply.Val() {
service.Error(c, errors.New(common.CreateBundleFailed))
return
}
// outTradeNo就是orderNo，根据这个去查询子表的source,如果是2就时单独的子套餐，如果是1就是主套餐 // outTradeNo就是orderNo，根据这个去查询子表的source,如果是2就时单独的子套餐，如果是1就是主套餐
orderLimit, err := service.BundleProvider.OrderListByOrderNo(context.Background(), &bundle.OrderInfoByOrderNoRequest{ orderLimit, err := service.BundleProvider.OrderListByOrderNo(context.Background(), &bundle.OrderInfoByOrderNoRequest{
OrderNo: req.OutTradeNo, OrderNo: req.OutTradeNo,