后台,应用通知地址

app/http/controllers/backend/app.go

@@ -34,7 +34,11 @@ func AppList(c *gin.Context) {
 
 func AppCreate(c *gin.Context) {
 	req, _ := controllers.GetRequest(c).(*backend.AppCreateRequest)
-	payChannel := req.RequestToDb()
+	payChannel, err := req.RequestToDb()
+	if err != nil {
+		controllers.Error(c, errorcode.ParamError, err.Error())
+		return
+	}
 	code := services.AppCreate(&payChannel)
 
 	data := backend.AppResponse{}
@@ -44,7 +48,11 @@ func AppCreate(c *gin.Context) {
 
 func AppUpdate(c *gin.Context) {
 	req, _ := controllers.GetRequest(c).(*backend.AppUpdateRequest)
-	payChannel := req.RequestToDb()
+	payChannel, err := req.RequestToDb()
+	if err != nil {
+		controllers.Error(c, errorcode.ParamError, err.Error())
+		return
+	}
 	code := services.AppUpdate(&payChannel)
 
 	data := backend.AppResponse{}

app/http/entities/backend/app.go

@@ -3,6 +3,8 @@ package backend
 import (
 	"PaymentCenter/app/http/entities"
 	"PaymentCenter/app/models/appmodel"
+	"errors"
+	"strings"
 )
 
 type AppListRequest struct {
@@ -54,17 +56,24 @@ type AppCreateRequest struct {
 	NotifyUrl         string `json:"notify_url" validate:"required" label:"通知地址"`
 }
 
-func (a *AppCreateRequest) RequestToDb() (db appmodel.App) {
+func (a *AppCreateRequest) RequestToDb() (db appmodel.App, err error) {
-	db.MerchantId = a.MerchantId
+	// 判断通知地址url是否合法
-	db.AppName = a.AppName
+	if a.NotifyUrl == "" || strings.HasPrefix(a.NotifyUrl, "http://") || strings.HasPrefix(a.NotifyUrl, "https://") {
-	db.AppRemark = a.AppRemark
+		db.MerchantId = a.MerchantId
-	db.Status = a.Status
+		db.AppName = a.AppName
-	db.KeyType = a.KeyType
+		db.AppRemark = a.AppRemark
-	db.PublicKey = a.PublicKey
+		db.Status = a.Status
-	db.PrivateKey = a.PrivateKey
+		db.KeyType = a.KeyType
-	db.MerchantPublicKey = a.MerchantPublicKey
+		db.PublicKey = a.PublicKey
-	db.WhiteIp = a.WhiteIp
+		db.PrivateKey = a.PrivateKey
-	db.NotifyUrl = a.NotifyUrl
+		db.MerchantPublicKey = a.MerchantPublicKey
+		db.WhiteIp = a.WhiteIp
+		db.NotifyUrl = a.NotifyUrl
+	} else {
+		err = errors.New("通知地址格式不正确")
+		return
+	}
+
 	return
 }
 
@@ -81,17 +90,23 @@ type AppUpdateRequest struct {
 	NotifyUrl         string `json:"notify_url"`
 }
 
-func (a *AppUpdateRequest) RequestToDb() (db appmodel.App) {
+func (a *AppUpdateRequest) RequestToDb() (db appmodel.App, err error) {
-	db.Id = a.Id
+	// 判断通知地址url是否合法
-	db.AppName = a.AppName
+	if a.NotifyUrl == "" || strings.HasPrefix(a.NotifyUrl, "http://") || strings.HasPrefix(a.NotifyUrl, "https://") {
-	db.AppRemark = a.AppRemark
+		db.Id = a.Id
-	db.Status = a.Status
+		db.AppName = a.AppName
-	db.KeyType = a.KeyType
+		db.AppRemark = a.AppRemark
-	db.PublicKey = a.PublicKey
+		db.Status = a.Status
-	db.PrivateKey = a.PrivateKey
+		db.KeyType = a.KeyType
-	db.MerchantPublicKey = a.MerchantPublicKey
+		db.PublicKey = a.PublicKey
-	db.WhiteIp = a.WhiteIp
+		db.PrivateKey = a.PrivateKey
-	db.NotifyUrl = a.NotifyUrl
+		db.MerchantPublicKey = a.MerchantPublicKey
+		db.WhiteIp = a.WhiteIp
+		db.NotifyUrl = a.NotifyUrl
+	} else {
+		err = errors.New("通知地址格式不正确")
+		return
+	}
 	return
 }
 

app/services/app.go

@@ -61,7 +61,7 @@ func AppUpdate(app *appmodel.App) (code int) {
 	conn = conn.And(builder.Eq{"Id": app.Id})
 	if app.AppName != "" {
 		// 编辑页面更新，备注和白名单IP可更新为空
-		_, err = repo.AppUpdate(app, conn, "app_remark", "white_ip")
+		_, err = repo.AppUpdate(app, conn, "app_remark", "white_ip", "notify_url")
 	} else {
 		_, err = repo.AppUpdate(app, conn)
 	}

app/services/thirdpay/thirdpay_notify/notify.go

@@ -96,6 +96,9 @@ func (o *OrderNotify) Handle() (res *OrderNotifyResp) {
 
 // 发送下游回调通知
 func (o *OrderNotify) sendNotify(body *OrderNotifySendContent) {
+	if o.app.NotifyUrl == "" {
+		return
+	}
 	var callbackStatus = common.STATUS_ENABLE
 	var response string