liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

京东恢复id

Browse Source
This commit is contained in:
suyl
2020-04-24 00:23:47 +08:00
parent c869a08194
commit e57eb21dfb
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
business/jxstore/cms/sku.go
View File

@@ -2204,6 +2204,7 @@ func RefreshJdDepot(ctx *jxcontext.Context) (err error) {
searchResultsInterface []interface{} searchResultsInterface []interface{}
db = dao.GetDB() db = dao.GetDB()
pageList []int pageList []int
skuIDs []int
) )
for i := 184; i < 367; i++ { for i := 184; i < 367; i++ {
pageList = append(pageList, i) pageList = append(pageList, i)
@@ -2225,18 +2226,17 @@ 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 * 3)
param := &jdapi.OpSkuParam{ param := &jdapi.OpSkuParam{
TraceID: ctx.GetTrackInfo(), TraceID: ctx.GetTrackInfo(),
OutSkuID: utils.Int2Str(v.SkuID), OutSkuID: utils.Int2Str(v.SkuID),
FixedStatus: jdapi.SkuFixedStatusDeleted, FixedStatus: jdapi.SkuFixedStatusDeleted,
} }
time.Sleep(time.Second * 1)
_, err = api.JdAPI.UpdateSku2(param) _, err = api.JdAPI.UpdateSku2(param)
if err != nil { if err != nil {
globals.SugarLogger.Debugf("RefreshJdDepot UpdateSku2", err.Error()) globals.SugarLogger.Debugf("RefreshJdDepot UpdateSku2", err.Error())
continue continue
} }
time.Sleep(time.Second * 3)
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 = ?
@@ -2244,11 +2244,8 @@ func RefreshJdDepot(ctx *jxcontext.Context) (err error) {
` `
sqlParams := []interface{}{v.JdID, model.SyncFlagModifiedMask, model.ThingTypeSku, model.VendorIDJD, "320406", utils.DefaultTimeValue, v.SkuID} sqlParams := []interface{}{v.JdID, model.SyncFlagModifiedMask, model.ThingTypeSku, model.VendorIDJD, "320406", utils.DefaultTimeValue, v.SkuID}
dao.ExecuteSQL(db, sql, sqlParams) dao.ExecuteSQL(db, sql, sqlParams)
_, err = SyncSkus(ctx, nil, []int{0}, []string{"320406"}, nil, []int{int(v.SkuID)}, true) skuIDs = append(skuIDs, v.SkuID)
if err != nil {
globals.SugarLogger.Debugf("RefreshJdDepot SyncSkus", err.Error())
continue
}
} }
_, err = SyncSkus(ctx, nil, []int{0}, []string{"320406"}, nil, skuIDs, true)
return err return err
} }