1
This commit is contained in:
@@ -551,6 +551,9 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
|
|||||||
// if vendorID == model.VendorIDJDShop {
|
// if vendorID == model.VendorIDJDShop {
|
||||||
// formalizeStoreSkuListForJds(skus)
|
// formalizeStoreSkuListForJds(skus)
|
||||||
// }
|
// }
|
||||||
|
if storeID == 668428 {
|
||||||
|
globals.SugarLogger.Debugf("============skus : %s", utils.Format4Output(skus, false))
|
||||||
|
}
|
||||||
singleStoreHandler, _ := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.ISingleStoreStoreSkuHandler)
|
singleStoreHandler, _ := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.ISingleStoreStoreSkuHandler)
|
||||||
storeSkuHandler := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.IPurchasePlatformStoreSkuHandler)
|
storeSkuHandler := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.IPurchasePlatformStoreSkuHandler)
|
||||||
reorderHandler, _ := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.IStoreSkuSorter)
|
reorderHandler, _ := partner.GetPurchasePlatformFromVendorID(vendorID).(partner.IStoreSkuSorter)
|
||||||
@@ -751,6 +754,15 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if storeID == 668428 {
|
||||||
|
globals.SugarLogger.Debugf("============1 : %s", utils.Format4Output(createList, false))
|
||||||
|
globals.SugarLogger.Debugf("============2 : %s", utils.Format4Output(deleteList, false))
|
||||||
|
globals.SugarLogger.Debugf("============3 : %s", utils.Format4Output(updateList, false))
|
||||||
|
globals.SugarLogger.Debugf("============4 : %s", utils.Format4Output(stockList, false))
|
||||||
|
globals.SugarLogger.Debugf("============5 : %s", utils.Format4Output(onlineList, false))
|
||||||
|
globals.SugarLogger.Debugf("============6 : %s", utils.Format4Output(offlineList, false))
|
||||||
|
globals.SugarLogger.Debugf("============7 : %s", utils.Format4Output(priceList, false))
|
||||||
|
}
|
||||||
task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx,
|
task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx,
|
||||||
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
||||||
step := batchItemList[0].(int)
|
step := batchItemList[0].(int)
|
||||||
|
|||||||
Reference in New Issue
Block a user