wip:初始化提交

internal/service/tripartiteCallback.go

@@ -0,0 +1,50 @@
+package service
+
+import (
+	"context"
+	"github.com/gogf/gf/v2/errors/gerror"
+	"github.com/gogf/gf/v2/frame/g"
+	"github.com/gogf/gf/v2/util/gconv"
+)
+
+func (t *TripartiteAuth) CallBackInit() {
+	ctx := context.Background()
+	if g.Cfg().MustGet(ctx, "callBack.flush", false).Bool() {
+		configAction := g.Cfg().MustGet(ctx, "callBack.action").String()
+		url, err := t.QueryCallBack()
+		if err != nil || url != configAction {
+			if err := t.UpdateCallBack(configAction); err != nil {
+				g.Log().Errorf(ctx, "更新回调地址异常", err)
+			}
+		}
+	}
+}
+
+func (t *TripartiteAuth) UpdateCallBack(url string) (err error) {
+	err = CommonDoPost("/index_index/setCallBackUrl",
+		t.GetFormHeaderWithToken(),
+		g.MapStrAny{
+			"url": url,
+		},
+		nil)
+	if err != nil {
+		err = gerror.Wrap(err, "更新回调接口异常")
+		return
+	}
+	return nil
+}
+
+func (t *TripartiteAuth) QueryCallBack() (callback string, err error) {
+	err = CommonDoPost("/index_index/getCallBackUrl",
+		t.GetFormHeaderWithToken(),
+		g.MapStrAny{},
+		func(i interface{}) error {
+			callback = gconv.String(i)
+			return nil
+		})
+	if err != nil {
+		err = gerror.Wrap(err, "查询回调接口异常")
+		return
+	}
+	return
+}