Merge branch 'jng-1127' into dev

pkg/service/bundle/pay.go

@@ -2,7 +2,6 @@ package bundle
 
 import (
 	"context"
-	"dubbo.apache.org/dubbo-go/v3/common/logger"
 	"encoding/json"
 	"errors"
 	"fmt"
@@ -10,6 +9,7 @@ import (
 	"fonchain-fiee/api/bundle"
 	"fonchain-fiee/api/order"
 	"fonchain-fiee/api/payment"
+	"fonchain-fiee/pkg/cache"
 	"fonchain-fiee/pkg/config"
 	"fonchain-fiee/pkg/model/login"
 	"fonchain-fiee/pkg/service"
@@ -19,6 +19,9 @@ import (
 	"math"
 	"net/http"
 	"strconv"
+	"time"
+
+	"dubbo.apache.org/dubbo-go/v3/common/logger"
 
 	"github.com/gin-gonic/gin"
 	"github.com/gin-gonic/gin/binding"
@@ -141,7 +144,13 @@ func CreateAntomPay(c *gin.Context) {
 
 	// 获取 用户信息
 	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就是主套餐
 	orderLimit, err := service.BundleProvider.OrderListByOrderNo(context.Background(), &bundle.OrderInfoByOrderNoRequest{
 		OrderNo: req.OutTradeNo,