From e23f7a62920ea2d78a6f82fac02828bc55a730a7 Mon Sep 17 00:00:00 2001 From: huangjiajun <582604932@qq.com> Date: Tue, 4 Apr 2023 17:10:22 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tik_tok/api.go | 15 ++- tik_tok/svc_tik_tok_open_api.go | 159 +++++++++++++++++++++++++++++++ tik_tok/svc_tik_tok_open_auth.go | 61 ------------ 3 files changed, 173 insertions(+), 62 deletions(-) create mode 100644 tik_tok/svc_tik_tok_open_api.go delete mode 100644 tik_tok/svc_tik_tok_open_auth.go diff --git a/tik_tok/api.go b/tik_tok/api.go index 597375a..c99d297 100644 --- a/tik_tok/api.go +++ b/tik_tok/api.go @@ -52,7 +52,7 @@ func GetSign(appSecret string, param map[string]string) string { } func OpenSend(appkey, appSecret, method string, params map[string]string, acctoken string) (string, error) { - url := "https://open.douyin.com/oauth/" + method + "/" + url := "https://open.douyin.com/" + method + "/" param := map[string]string{ "client_key": appkey, "client_secret": appSecret, @@ -66,3 +66,16 @@ func OpenSend(appkey, appSecret, method string, params map[string]string, acctok data, err := zhios_third_party_utils.CurlPost(url, param, nil) return string(data), err } +func OpenSendApi(method string, params map[string]interface{}, acctoken string) (string, error) { + url := "https://open.douyinec.com/" + method + param := params + headers := map[string]string{ + "Content-Type": "application/json", + } + if acctoken != "" { + headers["access-token"] = acctoken + } + paramStr := zhios_third_party_utils.SerializeStr(param) + data, err := zhios_third_party_utils.CurlPost(url, paramStr, headers) + return string(data), err +} diff --git a/tik_tok/svc_tik_tok_open_api.go b/tik_tok/svc_tik_tok_open_api.go new file mode 100644 index 0000000..ded5523 --- /dev/null +++ b/tik_tok/svc_tik_tok_open_api.go @@ -0,0 +1,159 @@ +package tik_tok + +import ( + zhios_third_party_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/utils" + "fmt" + "github.com/tidwall/gjson" + "time" +) + +//第一次授权 +func OpenFirstAuth(args map[string]string) map[string]string { + params := map[string]string{"code": args["code"], "grant_type": args["grantType"]} + send, err := OpenSend(args["appkey"], args["appSecret"], "oauth/access_token", params, args["acctoken"]) + var data = map[string]string{} + if err != nil { + return data + } + endTime := time.Now().Unix() + gjson.Get(send, "data.expires_in").Int() + refreshEndTime := time.Now().Unix() + gjson.Get(send, "data.refresh_expires_in").Int() + data = map[string]string{ + "tik_tok_acc_token": gjson.Get(send, "data.access_token").String(), + "tik_tok_acc_token_time": zhios_third_party_utils.Int64ToStr(endTime), + "tik_tok_acc_refresh_token_time": zhios_third_party_utils.Int64ToStr(refreshEndTime), + "tik_tok_acc_refresh_token": gjson.Get(send, "data.refresh_token").String(), + "tik_tok_open_id": gjson.Get(send, "data.open_id").String(), + "tik_tok_scope": gjson.Get(send, "data.scope").String(), + } + return data +} +func OpenRefreshAccessAuth(args map[string]string) map[string]string { + params := map[string]string{"refresh_token": args["refresh_token"], "grant_type": "refresh_token"} + send, err := OpenSend(args["appkey"], args["appSecret"], "oauth/refresh_token", params, args["acctoken"]) + var data = map[string]string{} + if err != nil { + return data + } + endTime := time.Now().Unix() + gjson.Get(send, "data.expires_in").Int() + refreshEndTime := time.Now().Unix() + gjson.Get(send, "data.refresh_expires_in").Int() + data = map[string]string{ + "tik_tok_acc_token": gjson.Get(send, "data.access_token").String(), + "tik_tok_acc_token_time": zhios_third_party_utils.Int64ToStr(endTime), + "tik_tok_acc_refresh_token_time": zhios_third_party_utils.Int64ToStr(refreshEndTime), + "tik_tok_acc_refresh_token": gjson.Get(send, "data.refresh_token").String(), + "tik_tok_open_id": gjson.Get(send, "data.open_id").String(), + "tik_tok_scope": gjson.Get(send, "data.scope").String(), + } + return data +} +func OpenRefreshAuth(args map[string]string) map[string]string { + params := map[string]string{"refresh_token": args["refresh_token"]} + send, err := OpenSend(args["appkey"], args["appSecret"], "oauth/renew_refresh_token", params, args["acctoken"]) + var data = map[string]string{} + if err != nil { + return data + } + endTime := time.Now().Unix() + gjson.Get(send, "data.expires_in").Int() + data = map[string]string{ + "tik_tok_acc_token": gjson.Get(send, "data.refresh_token").String(), + "tik_tok_acc_token_time": zhios_third_party_utils.Int64ToStr(endTime), + } + return data +} + +//商品加橱窗 +func OpenStoreAdd(args map[string]interface{}) (string, error) { + /** + products []AddStoreProductInfo + 商品信息，最多20个商品 + need_hide bool false 是否隐藏（true代表隐藏，false代表显示） + pick_extra string fasdfkl 自定义参数，携带到订单（只允许 数字、字母和_，限制长度为20） + keep_picksource bool true 是否保留商品链接原有选品来源，默认不保留（加橱窗时默认会生成新的选品来源参数覆盖旧参数，转链的自定义参数也会失效，此时选品来源为当前加橱窗应用），keep_picksource 为 true 时保留原有选品来源 + */ + fmt.Println(args) + params := map[string]interface{}{"products": args["products"], "keep_picksource": args["keep_picksource"], "need_hide": args["need_hide"], "pick_extra": args["pick_extra"]} + send, err := OpenSendApi("alliance/store/add/?open_id="+zhios_third_party_utils.AnyToString(args["open_id"]), params, zhios_third_party_utils.AnyToString(args["acctoken"])) + fmt.Println(send) + fmt.Println(err) + return send, err +} + +//达人订单 +func OpenKolOrders(args map[string]interface{}) (string, error) { + /** + size int64 是 10 每页订单数目，取值区间： [1, 20] + cursor string 否 3425049063563865812 下一页索引（首次请求时参数不传） + start_time string 否 2006-01-02 15:04:05 支付时间开始，最早支持90天前 + end_time string 否 2006-01-02 15:04:05 支付时间结束 + time_type string 否 pay 查询时间类型。pay: 支付时间（默认）; update：联盟侧更新时间，非订单状态更新时间 + order_ids + string 否 4737996432465788974,4737996432465780075 订单号。多个订单号用英文,分隔，最多支持10个订单号 + */ + fmt.Println(args) + params := map[string]interface{}{"size": args["size"], "start_time": args["start_time"], "end_time": args["end_time"], "time_type": args["time_type"]} + if args["cursor"] != "" { + params["cursor"] = args["cursor"] + } + send, err := OpenSendApi("alliance/kol/orders/?open_id="+zhios_third_party_utils.AnyToString(args["open_id"]), params, zhios_third_party_utils.AnyToString(args["acctoken"])) + fmt.Println(send) + fmt.Println(err) + return send, err +} + +//达人带货口碑分和橱窗销量查询 +func OpenKolReputation(args map[string]interface{}) (string, error) { + /** + + */ + fmt.Println(args) + params := map[string]interface{}{} + send, err := OpenSendApi("alliance/kol/reputation/?open_id="+zhios_third_party_utils.AnyToString(args["open_id"]), params, zhios_third_party_utils.AnyToString(args["acctoken"])) + fmt.Println(send) + fmt.Println(err) + return send, err +} + +//橱窗商品隐藏/显示接口 +func OpenStoreHideStatus(args map[string]interface{}) (string, error) { + /** + products []BatchHideEditProductInfo + 商品信息，最多20个商品 + need_hide bool false 是否隐藏（true代表隐藏，false代表显示） + product_id int64 商品id + promotion_id int64 推广id + */ + fmt.Println(args) + params := map[string]interface{}{"products": args["products"], "need_hide": args["need_hide"]} + send, err := OpenSendApi("alliance/store/hide_status/?open_id="+zhios_third_party_utils.AnyToString(args["open_id"]), params, zhios_third_party_utils.AnyToString(args["acctoken"])) + fmt.Println(send) + fmt.Println(err) + return send, err +} + +//达人橱窗商品列表 +func OpenKolStoreList(args map[string]interface{}) (string, error) { + /** + page int64 1 分页[1,20] + page_size int64 20 每页的数量（小于等于20） + */ + fmt.Println(args) + params := map[string]interface{}{"page": args["page"], "page_size": args["page_size"]} + send, err := OpenSendApi("alliance/kol/store/list/?open_id="+zhios_third_party_utils.AnyToString(args["open_id"]), params, zhios_third_party_utils.AnyToString(args["acctoken"])) + fmt.Println(send) + fmt.Println(err) + return send, err +} + +//达人橱窗商品删除 +func OpenKolStoreRemove(args map[string]interface{}) (string, error) { + /** + product_id int64 3450632721376902816 商品ID + promotion_id int64 3450632721374033833 推广ID + */ + fmt.Println(args) + params := map[string]interface{}{"products": args["products"]} + send, err := OpenSendApi("alliance/kol/store/remove/?open_id="+zhios_third_party_utils.AnyToString(args["open_id"]), params, zhios_third_party_utils.AnyToString(args["acctoken"])) + fmt.Println(send) + fmt.Println(err) + return send, err +} diff --git a/tik_tok/svc_tik_tok_open_auth.go b/tik_tok/svc_tik_tok_open_auth.go deleted file mode 100644 index e59e5ae..0000000 --- a/tik_tok/svc_tik_tok_open_auth.go +++ /dev/null @@ -1,61 +0,0 @@ -package tik_tok - -import ( - zhios_third_party_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/utils" - "github.com/tidwall/gjson" - "time" -) - -//第一次授权 -func OpenFirstAuth(args map[string]string) map[string]string { - params := map[string]string{"code": args["code"], "grant_type": args["grantType"]} - send, err := OpenSend(args["appkey"], args["appSecret"], "access_token", params, args["acctoken"]) - var data = map[string]string{} - if err != nil { - return data - } - endTime := time.Now().Unix() + gjson.Get(send, "data.expires_in").Int() - refreshEndTime := time.Now().Unix() + gjson.Get(send, "data.refresh_expires_in").Int() - data = map[string]string{ - "tik_tok_acc_token": gjson.Get(send, "data.access_token").String(), - "tik_tok_acc_token_time": zhios_third_party_utils.Int64ToStr(endTime), - "tik_tok_acc_refresh_token_time": zhios_third_party_utils.Int64ToStr(refreshEndTime), - "tik_tok_acc_refresh_token": gjson.Get(send, "data.refresh_token").String(), - "tik_tok_open_id": gjson.Get(send, "data.open_id").String(), - "tik_tok_scope": gjson.Get(send, "data.scope").String(), - } - return data -} -func OpenRefreshAccessAuth(args map[string]string) map[string]string { - params := map[string]string{"refresh_token": args["refresh_token"], "grant_type": "refresh_token"} - send, err := OpenSend(args["appkey"], args["appSecret"], "refresh_token", params, args["acctoken"]) - var data = map[string]string{} - if err != nil { - return data - } - endTime := time.Now().Unix() + gjson.Get(send, "data.expires_in").Int() - refreshEndTime := time.Now().Unix() + gjson.Get(send, "data.refresh_expires_in").Int() - data = map[string]string{ - "tik_tok_acc_token": gjson.Get(send, "data.access_token").String(), - "tik_tok_acc_token_time": zhios_third_party_utils.Int64ToStr(endTime), - "tik_tok_acc_refresh_token_time": zhios_third_party_utils.Int64ToStr(refreshEndTime), - "tik_tok_acc_refresh_token": gjson.Get(send, "data.refresh_token").String(), - "tik_tok_open_id": gjson.Get(send, "data.open_id").String(), - "tik_tok_scope": gjson.Get(send, "data.scope").String(), - } - return data -} -func OpenRefreshAuth(args map[string]string) map[string]string { - params := map[string]string{"refresh_token": args["refresh_token"]} - send, err := OpenSend(args["appkey"], args["appSecret"], "renew_refresh_token", params, args["acctoken"]) - var data = map[string]string{} - if err != nil { - return data - } - endTime := time.Now().Unix() + gjson.Get(send, "data.expires_in").Int() - data = map[string]string{ - "tik_tok_acc_token": gjson.Get(send, "data.refresh_token").String(), - "tik_tok_acc_token_time": zhios_third_party_utils.Int64ToStr(endTime), - } - return data -}