1
This commit is contained in:
@@ -676,14 +676,12 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
|
||||
// api.JdShop2API.SetCookieWithStr(configs[0].Value)
|
||||
// }
|
||||
}
|
||||
if vendorID == model.VendorIDDD {
|
||||
//createList, updateList []*dao.StoreSkuSyncInfo
|
||||
//deleteList, stockList, onlineList, offlineList, priceList []*partner.StoreSkuInfo
|
||||
//updateItems []*dao.KVUpdateItem
|
||||
//reorderSkuMap map[string][]*dao.StoreSkuSyncInfo
|
||||
globals.SugarLogger.Debugf("createList len = %d ", len(createList))
|
||||
}
|
||||
|
||||
//createList, updateList []*dao.StoreSkuSyncInfo
|
||||
//deleteList, stockList, onlineList, offlineList, priceList []*partner.StoreSkuInfo
|
||||
//updateItems []*dao.KVUpdateItem
|
||||
//reorderSkuMap map[string][]*dao.StoreSkuSyncInfo
|
||||
globals.SugarLogger.Debugf("createList len = %d ", len(createList))
|
||||
globals.SugarLogger.Debugf("====skuList %s", utils.Format4Output(skus, false))
|
||||
task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx,
|
||||
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
||||
step := batchItemList[0].(int)
|
||||
|
||||
Reference in New Issue
Block a user