liulei/baseapi
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'master' of https://e.coding.net/rosydev/baseapi

Browse Source
This commit is contained in:
richboo111
2023-02-16 10:05:25 +08:00
parent 5a3cb1926d b014217e29
commit 9f022a8784
6 changed files with 680 additions and 233 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
platformapi/ebaiapi/shop_sku_test.go
View File

@@ -1,6 +1,7 @@
package ebaiapi
import (
"fmt"
"testing"
"git.rosy.net.cn/baseapi/utils"
@@ -16,7 +17,7 @@ func TestShopCategoryCreate(t *testing.T) {
}
func TestShopCategoryGet(t *testing.T) {
result, err := api.ShopCategoryGet("300034")
result, err := api.ShopCategoryGet("100274")
if err != nil {
t.Fatal(err)
} else {
@@ -271,3 +272,8 @@ func TestGetEbaiSkuIDFromCustomID(t *testing.T) {
ebaiCatID := api.GetEbaiSkuIDFromCustomID("300001", "31554")
t.Log(ebaiCatID)
}
func TestDeleteStoreSku(t *testing.T) {
fmt.Println((49 & 4) == 0)
}

634
platformapi/tiktok_shop/222/dd_test.go
View File

File diff suppressed because one or more lines are too long

2
platformapi/tiktok_shop/tiktok_api/afs_test.go
View File

@@ -18,7 +18,7 @@ import (
// "authority_id": ""
//}`
var token = `{"access_token":"7bb849c5-4270-44c5-a5dc-a02d78532d46","expires_in":1676246698,"scope":"SCOPE","shop_id":57939570,"shop_name":"京西菜市速食","refresh_token":"b0e98248-89bd-4cf2-9968-bb6e61d7845d","authority_id":""}`
var token = `{"access_token":"0befdbfe-b086-49f1-b539-dc39b8bebea0","expires_in":1676494406,"scope":"SCOPE","shop_id":68023619,"shop_name":"京西到家","refresh_token":"9ff5b722-77bf-486f-9f26-1751e768aff3","authority_id":""}`
//var token = `{"access_token":"e3173e9f-266f-4d87-88e7-e7cd837bc9d9","expires_in":1672882632,"scope":"SCOPE","shop_id":68023619,"shop_name":"京西到家","refresh_token":"5070aae2-493f-46bd-b5d6-6ea0cd64729f","authority_id":""}`

2
platformapi/tiktok_shop/tiktok_api/order_type.go
View File

@@ -18,7 +18,7 @@ type PublicOrderCallback struct {
type OrderCallback struct {
Tag string `json:"tag"` // 消息种类，订单创建消息的tag值为"100"
MsgId string `json:"msg_id"` //消息记录id
MsgId string `json:"msg_id"` // 消息记录id
Data string `json:"data"` // 消息正文
FormData url.Values
}

4
platformapi/tiktok_shop/tiktok_api/order_utils.go
View File

@@ -4,6 +4,7 @@ import (
"crypto/md5"
"fmt"
"git.rosy.net.cn/baseapi/utils"
beego "github.com/astaxie/beego/server/web"
"io/ioutil"
"net/http"
"net/url"
@@ -17,6 +18,9 @@ func GetCmd(request *http.Request) (cmd string) {
// EventSignChange 回调消息防伪标签校验
func (a *API) EventSignChange(c *http.Request) (*CallbackResponse, []byte) {
body, _ := ioutil.ReadAll(c.Body)
if beego.BConfig.RunMode == "jxgy" {
return CallbackResponseErr(true), body
}
signParam := a.appKey + string(body) + a.appSecret
sign := fmt.Sprintf("%X", md5.Sum([]byte(signParam)))
return CallbackResponseErr(sign != c.Header.Get("event-sign")), body

263
platformapi/tiktok_shop/tiktok_api/sku_delete_test.go
View File

@@ -2,243 +2,50 @@ package tiktok_api
import (
"fmt"
product_listV2_request "git.rosy.net.cn/baseapi/platformapi/tiktok_shop/sdk-golang/api/product_listV2/request"
"git.rosy.net.cn/baseapi/utils"
"git.rosy.net.cn/jx-callback/globals"
"strings"
"testing"
)
// 删除已经创建商品,重新同步
func TestDeleteSkuAndUploadSku2(t *testing.T) {
var errList = make([]error, 0, 0)
var storeList = make([]string, 0, 0)
for _, v := range c {
for i := 1; i < 100; i++ {
result, err := a.GetSkuDetailList(&product_listV2_request.ProductListV2Param{
Status: 0,
CheckStatus: 4, // 1-未提交；2-待审核；3-审核通过；4-审核未通过；5-封禁；7-审核通过待上架
Page: int64(i),
Size: 100,
StoreId: v,
})
if err != nil {
globals.SugarLogger.Debugf("=index := %d ,err := %s", i, utils.Format4Output(err, false))
continue
}
if len(result.Data) == 0 {
globals.SugarLogger.Debugf("====没有商品的门店 %d", v)
break
}
storeList = append(storeList, utils.Int64ToStr(v))
for _, v := range result.Data {
err := a.DeleteStoreCommodity(v.ProductId)
if err != nil {
errList = append(errList, err)
}
}
}
}
for _, v := range errList {
globals.SugarLogger.Debugf("err := %s", utils.Format4Output(v, false))
}
fmt.Println(strings.Join(storeList, ","))
func TestGetRecommendCategory(t *testing.T) {
img, _, err := GetTiktokImgListTest(a, "668707", "", "", "http://img20.360buyimg.com/vc/jfs/t1/8979/39/8591/236012/5c0e45f3E1537c120/a66aafc95cf66977.jpg", "http://img20.360buyimg.com/vc/jfs/t1/23027/3/955/82830/5c0e45f3E0855eeae/ae65ee9555a29579.jpg")
fmt.Println(err)
a.GetRecommendCategory(strings.Split(img, "|"))
}
// 删除已经创建商品,重新同步
func TestDeleteSkuAndUploadSku5(t *testing.T) {
var errList = make([]error, 0, 0)
for i := 1; i < 100; i++ {
result, err := a.GetSkuDetailList(&product_listV2_request.ProductListV2Param{
Status: 0,
CheckStatus: 3, // 1-未提交；2-待审核；3-审核通过；4-审核未通过；5-封禁；7-审核通过待上架
Page: int64(i),
Size: 100,
// GetTiktokImgList 获取抖音图片链接
func GetTiktokImgListTest(api *API, storeId, appOrgCode string, detailImg string, img ...string) (string, string, error) {
imgs := make([]Imgs, 0, 0)
for _, v := range img {
if v != "" {
imgs = append(imgs, Imgs{
Name: storeId + "_" + v[21:54],
Url: v,
})
}
}
if detailImg != "" {
imgs = append(imgs, Imgs{
Name: "detail_" + storeId + "_" + detailImg[21:54],
Url: detailImg,
})
if err != nil {
globals.SugarLogger.Debugf("=index := %d ,err := %s", i, utils.Format4Output(err, false))
}
tiktokImgList, err := api.BatchUploadImages(imgs)
if err != nil {
return "", "", err
}
detailTiktok := ""
var tiktokImg []string
for k, v := range tiktokImgList {
if strings.Contains(k, "detail_") {
detailTiktok = v.ByteUrl
continue
}
if len(result.Data) == 0 {
globals.SugarLogger.Debugf("====没有商品的门店 %d", 1)
break
}
for _, v := range result.Data {
err := a.DeleteStoreCommodity(v.ProductId)
if err != nil {
errList = append(errList, err)
}
}
tiktokImg = append(tiktokImg, v.ByteUrl)
}
if detailTiktok == "" {
detailTiktok = tiktokImg[0]
}
for _, v := range errList {
globals.SugarLogger.Debugf("err := %s", utils.Format4Output(v, false))
}
}
// 删除已经创建商品,重新同步
func TestDeleteSkuAndUploadSku3(t *testing.T) {
var errList = make([]error, 0, 0)
for v := len(c) - 1; v > 0; v-- {
for i := 1; i < 100; i++ {
result, err := a.GetSkuDetailList(&product_listV2_request.ProductListV2Param{
CheckStatus: 1, // 1-未提交；2-待审核；3-审核通过；4-审核未通过；5-封禁；7-审核通过待上架
Page: int64(i),
Size: 100,
StoreId: c[v],
})
if err != nil {
globals.SugarLogger.Debugf("=index := %d ,err := %s", i, utils.Format4Output(err, false))
continue
}
if len(result.Data) == 0 {
globals.SugarLogger.Debugf("====没有商品的门店 %d", c[v])
break
}
for _, v := range result.Data {
err := a.DeleteStoreCommodity(v.ProductId)
if err != nil {
errList = append(errList, err)
}
}
}
}
for _, v := range errList {
globals.SugarLogger.Debugf("err := %s", utils.Format4Output(v, false))
}
}
/**/
// 删除已经创建商品,重新同步
func TestDeleteSkuAndUploadSku4(t *testing.T) {
var errList = make([]error, 0, 0)
for v := len(c) - 1; v > 0; v-- {
for i := 1; i < 100; i++ {
result, err := a.GetSkuDetailList(&product_listV2_request.ProductListV2Param{
Status: 1,
CheckStatus: 5, // 1-未提交；2-待审核；3-审核通过；4-审核未通过；5-封禁；7-审核通过待上架
Page: int64(i),
Size: 100,
StoreId: c[v],
})
if err != nil {
globals.SugarLogger.Debugf("=index := %d ,err := %s", i, utils.Format4Output(err, false))
continue
}
if len(result.Data) == 0 {
globals.SugarLogger.Debugf("====没有商品的门店 %d", c[v])
break
}
for _, v := range result.Data {
err := a.DeleteStoreCommodity(v.ProductId)
if err != nil {
errList = append(errList, err)
}
}
}
}
for _, v := range errList {
globals.SugarLogger.Debugf("err := %s", utils.Format4Output(v, false))
}
}
var storeList2GD = []int64{
65402632,
63841927,
63841426,
63825967,
63783027,
63783026,
63783025,
63783023,
63783021,
63521502,
63521394,
63520894,
63520826,
63517652,
63517290,
63504497,
63504222,
63503537,
63503199,
63463365,
63463026,
63462817,
63179331,
62493432,
}
// 删除已经创建商品,重新同步
func TestDeleteSkuAndUploadSku666(t *testing.T) {
var errList = make([]error, 0, 0)
for _, v := range storeList2GD {
for i := 1; i < 100; i++ {
result, err := a.GetSkuDetailList(&product_listV2_request.ProductListV2Param{
CheckStatus: 3, // 1-未提交；2-待审核；3-审核通过；4-审核未通过；5-封禁；7-审核通过待上架
Page: int64(i),
Size: 100,
StoreId: v,
})
if err != nil {
globals.SugarLogger.Debugf("=index := %d ,err := %s", i, utils.Format4Output(err, false))
continue
}
if len(result.Data) == 0 {
globals.SugarLogger.Debugf("====没有商品的门店 %d", v)
break
}
for _, v := range result.Data {
err := a.DeleteStoreCommodity(v.ProductId)
if err != nil {
errList = append(errList, err)
}
}
}
}
for _, v := range errList {
globals.SugarLogger.Debugf("err := %s", utils.Format4Output(v, false))
}
}
// 删除已经创建商品,重新同步
func TestDeleteSkuAndUploadSku7777(t *testing.T) {
var errList = make([]error, 0, 0)
for _, v := range storeList2GD {
for i := 1; i < 100; i++ {
result, err := a.GetSkuDetailList(&product_listV2_request.ProductListV2Param{
CheckStatus: 3, // 1-未提交；2-待审核；3-审核通过；4-审核未通过；5-封禁；7-审核通过待上架
Page: int64(i),
Size: 100,
StoreId: v,
})
if err != nil {
globals.SugarLogger.Debugf("=index := %d ,err := %s", i, utils.Format4Output(err, false))
continue
}
if len(result.Data) == 0 {
globals.SugarLogger.Debugf("====没有商品的门店 %d", v)
break
}
for _, v := range result.Data {
err := a.DeleteStoreCommodity(v.ProductId)
if err != nil {
errList = append(errList, err)
}
}
}
}
for _, v := range errList {
globals.SugarLogger.Debugf("err := %s", utils.Format4Output(v, false))
}
}
func Test22(t *testing.T) {
fmt.Println(17 & 16)
return strings.Join(tiktokImg, "|"), detailTiktok, nil
}