接口防抖

service/payment/payment_service.go

@@ -66,6 +66,11 @@ func DealWechatSDKParams(sdk WechatSDKParams) (err error) {
 			continue
 		}
 		if paymentParam.PayOrderNo == sdk.OrderNo {
+			if paymentParam.Status != payment.PENDING {
+				logger.Error("重复的推送消息")
+				err = fmt.Errorf("当前订单正在处理中,请勿重复推送")
+				return
+			}
 			paymentParam.PrepayId = sdk.PrepayId
 			paymentParam.Timestamp = sdk.Timestamp
 			paymentParam.NonceStr = sdk.NonceStr