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