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 init() {
	ctx := context.Background()
	if g.Cfg().MustGet(ctx, "callBack.flush", false).Bool() {
		configAction := g.Cfg().MustGet(ctx, "callBack.action").String()
		url, err := QueryCallBack()
		if err != nil || url != configAction {
			if err := UpdateCallBack(configAction); err != nil {
				g.Log().Errorf(ctx, "更新回调地址异常", err)
			}
		}
	}
}

func UpdateCallBack(url string) (err error) {
	err = CommonDoPost("/index_index/setCallBackUrl",
		getFormHeaderWithToken(),
		g.MapStrAny{
			"url": url,
		},
		nil)
	if err != nil {
		err = gerror.Wrap(err, "更新回调接口异常")
		return
	}
	return nil
}

func QueryCallBack() (callback string, err error) {
	err = CommonDoPost("/index_index/getCallBackUrl",
		getFormHeaderWithToken(),
		g.MapStrAny{},
		func(i interface{}) error {
			callback = gconv.String(i)
			return nil
		})
	if err != nil {
		err = gerror.Wrap(err, "查询回调接口异常")
		return
	}
	return
}