京东恢复id

This commit is contained in:
suyl
2020-04-23 20:38:20 +08:00
parent 80b38f60ef
commit b0d64d7b99

View File

@@ -2225,7 +2225,6 @@ func RefreshJdDepot(ctx *jxcontext.Context) (err error) {
searchResults = append(searchResults, v.(*jdapi.SearchDeleteWareResult)) searchResults = append(searchResults, v.(*jdapi.SearchDeleteWareResult))
} }
for _, v := range searchResults { for _, v := range searchResults {
time.Sleep(time.Second)
param := &jdapi.OpSkuParam{ param := &jdapi.OpSkuParam{
TraceID: ctx.GetTrackInfo(), TraceID: ctx.GetTrackInfo(),
OutSkuID: utils.Int2Str(v.SkuID), OutSkuID: utils.Int2Str(v.SkuID),
@@ -2236,7 +2235,6 @@ func RefreshJdDepot(ctx *jxcontext.Context) (err error) {
globals.SugarLogger.Debugf("RefreshJdDepot UpdateSku2", err.Error()) globals.SugarLogger.Debugf("RefreshJdDepot UpdateSku2", err.Error())
continue continue
} }
time.Sleep(time.Second)
api.JdAPI.RefreshJdDepot(v.JdID) api.JdAPI.RefreshJdDepot(v.JdID)
sql := ` sql := `
UPDATE thing_map SET vendor_thing_id = ?, sync_status = ? UPDATE thing_map SET vendor_thing_id = ?, sync_status = ?
@@ -2249,7 +2247,6 @@ func RefreshJdDepot(ctx *jxcontext.Context) (err error) {
globals.SugarLogger.Debugf("RefreshJdDepot SyncSkus", err.Error()) globals.SugarLogger.Debugf("RefreshJdDepot SyncSkus", err.Error())
continue continue
} }
time.Sleep(time.Second)
} }
return err return err
} }