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

更新商品前缀让他们自己同步把

Browse Source
This commit is contained in:
苏尹岚
2020-07-17 09:47:21 +08:00
parent cc70c1f6b2
commit 23833a6004
1 changed files with 17 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -2556,7 +2556,7 @@ func UpdateSkuExinfoMap(ctx *jxcontext.Context, nameIDs []int, imgWaterMark stri
fromTimeP time.Time fromTimeP time.Time
toTimeP time.Time toTimeP time.Time
db = dao.GetDB() db = dao.GetDB()
skuIDs []int // skuIDs []int
) )
if fromTime != "" { if fromTime != "" {
fromTimeP = utils.Time2Date(utils.Str2Time(fromTime)) fromTimeP = utils.Time2Date(utils.Str2Time(fromTime))
@@ -2605,6 +2605,8 @@ func UpdateSkuExinfoMap(ctx *jxcontext.Context, nameIDs []int, imgWaterMark stri
for _, v := range skuIDs { for _, v := range skuIDs {
OnUpdateThing(ctx, db, nil, int64(v), model.ThingTypeSku) OnUpdateThing(ctx, db, nil, int64(v), model.ThingTypeSku)
} }
} else {
SetStoreSkuSyncStatus2(db, nil, []int{vendorID}, skuIDs, model.SyncFlagModifiedMask)
} }
} }
} }
@@ -2613,21 +2615,21 @@ func UpdateSkuExinfoMap(ctx *jxcontext.Context, nameIDs []int, imgWaterMark stri
} }
taskParallel := tasksch.NewParallelTask("UpdateSkuExinfoMap", tasksch.NewParallelConfig().SetParallelCount(parallelCount), ctx, taskFunc, nameIDs) taskParallel := tasksch.NewParallelTask("UpdateSkuExinfoMap", tasksch.NewParallelConfig().SetParallelCount(parallelCount), ctx, taskFunc, nameIDs)
tasksch.HandleTask(taskParallel, nil, true).Run() tasksch.HandleTask(taskParallel, nil, true).Run()
result, err2 := task.GetResult(0) _, err = task.GetResult(0)
err = err2 // err = err2
if len(result) > 0 { // if len(result) > 0 {
for _, v := range result { // for _, v := range result {
skuIDs = append(skuIDs, int(utils.Interface2Int64WithDefault(v, 0))) // skuIDs = append(skuIDs, int(utils.Interface2Int64WithDefault(v, 0)))
} // }
} // }
case 1: case 1:
if len(skuIDs) > 0 { // if len(skuIDs) > 0 {
if partner.IsMultiStore(vendorID) { // if partner.IsMultiStore(vendorID) {
CurVendorSync.SyncSkus(ctx, db, nil, skuIDs, isAsync, isContinueWhenError, ctx.GetUserName()) // CurVendorSync.SyncSkus(ctx, db, nil, skuIDs, isAsync, isContinueWhenError, ctx.GetUserName())
} else { // } else {
CurVendorSync.SyncStoresSkus2(ctx, nil, 0, db, []int{vendorID}, nil, false, skuIDs, nil, model.SyncFlagModifiedMask, isAsync, isContinueWhenError) // CurVendorSync.SyncStoresSkus2(ctx, nil, 0, db, []int{vendorID}, nil, false, skuIDs, nil, model.SyncFlagModifiedMask, isAsync, isContinueWhenError)
} // }
} // }
} }
return result, err return result, err
} }