1
This commit is contained in:
@@ -182,12 +182,16 @@ func SyncStoreSkuNew2(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFla
|
||||
}
|
||||
task := tasksch.NewSeqTask(fmt.Sprintf("SyncStoreSkuNew, storeID:%d", storeID), ctx,
|
||||
func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
|
||||
globals.SugarLogger.Debug("==============step",step)
|
||||
switch step {
|
||||
case 0:
|
||||
globals.SugarLogger.Debug("==============step==0",step)
|
||||
globals.SugarLogger.Debug("==============step==0",singleStoreHandler != nil)
|
||||
if singleStoreHandler != nil {
|
||||
_, err = SyncStoreCategories(ctx, task, vendorID, storeID, vendorStoreID, nameIDs, skuIDs, false, isContinueWhenError)
|
||||
}
|
||||
case 1:
|
||||
globals.SugarLogger.Debug("==============step==1",step)
|
||||
err = syncStoreSkuNew(ctx, task, causeFlag, false, vendorID, storeID, vendorOrgCode, nameIDs, skuIDs, excludeSkuIDs, useVendorPriceDirectly, isContinueWhenError)
|
||||
}
|
||||
return result, err
|
||||
|
||||
Reference in New Issue
Block a user