diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go index 1eb68b9a0..f8368d69e 100644 --- a/business/jxstore/cms/sku.go +++ b/business/jxstore/cms/sku.go @@ -2206,7 +2206,7 @@ func RefreshJdDepot(ctx *jxcontext.Context) (err error) { pageList []int skuIDs []int ) - for i := 193; i < 367; i++ { + for i := 186; i < 367; i++ { pageList = append(pageList, i) } task := tasksch.NewParallelTask("RefreshOrdersPriceInfo", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, @@ -2231,7 +2231,7 @@ func RefreshJdDepot(ctx *jxcontext.Context) (err error) { OutSkuID: utils.Int2Str(v.SkuID), FixedStatus: jdapi.SkuFixedStatusDeleted, } - time.Sleep(time.Second * 1) + time.Sleep(time.Second * 2) _, err = api.JdAPI.UpdateSku2(param) if err != nil { globals.SugarLogger.Debugf("RefreshJdDepot UpdateSku2", err.Error()) @@ -2239,7 +2239,7 @@ func RefreshJdDepot(ctx *jxcontext.Context) (err error) { } api.JdAPI.RefreshJdDepot(v.JdID) sql := ` - UPDATE thing_map SET vendor_thing_id = ?, sync_status = ? + UPDATE thing_map SET vendor_thing_id = ?, sync_status = ?, updated_at = NOW() WHERE thing_type = ? AND vendor_id = ? AND vendor_org_code = ? AND deleted_at = ? AND thing_id = ? ` sqlParams := []interface{}{v.JdID, model.SyncFlagModifiedMask, model.ThingTypeSku, model.VendorIDJD, "320406", utils.DefaultTimeValue, v.SkuID}