京东恢复id

This commit is contained in:
suyl
2020-04-24 00:34:28 +08:00
parent 945eb8b1e0
commit 106335b34f

View File

@@ -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}