diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go index 9b9263f7c..08e4158a6 100644 --- a/business/jxstore/cms/sku.go +++ b/business/jxstore/cms/sku.go @@ -2205,7 +2205,7 @@ func RefreshJdDepot(ctx *jxcontext.Context) (err error) { db = dao.GetDB() pageList []int ) - for i := 165; i < 367; i++ { + for i := 175; i < 367; i++ { pageList = append(pageList, i) } task := tasksch.NewParallelTask("RefreshOrdersPriceInfo", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, @@ -2225,6 +2225,7 @@ func RefreshJdDepot(ctx *jxcontext.Context) (err error) { searchResults = append(searchResults, v.(*jdapi.SearchDeleteWareResult)) } for _, v := range searchResults { + time.Sleep(time.Second) param := &jdapi.OpSkuParam{ TraceID: ctx.GetTrackInfo(), OutSkuID: utils.Int2Str(v.SkuID), @@ -2235,7 +2236,7 @@ func RefreshJdDepot(ctx *jxcontext.Context) (err error) { globals.SugarLogger.Debugf("RefreshJdDepot UpdateSku2", err.Error()) continue } - time.Sleep(time.Second) + time.Sleep(time.Second * 2) api.JdAPI.RefreshJdDepot(v.JdID) sql := ` UPDATE thing_map SET vendor_thing_id = ?, sync_status = ? @@ -2248,6 +2249,7 @@ func RefreshJdDepot(ctx *jxcontext.Context) (err error) { globals.SugarLogger.Debugf("RefreshJdDepot SyncSkus", err.Error()) continue } + time.Sleep(time.Second) } return err }