1
This commit is contained in:
@@ -678,6 +678,15 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
|
||||
// }
|
||||
}
|
||||
|
||||
globals.SugarLogger.Debugf("== createList %s", utils.Format4Output(createList, false))
|
||||
globals.SugarLogger.Debugf("== updateList %s", utils.Format4Output(updateList, false))
|
||||
globals.SugarLogger.Debugf("== deleteList %s", utils.Format4Output(deleteList, false))
|
||||
globals.SugarLogger.Debugf("== stockList %s", utils.Format4Output(stockList, false))
|
||||
globals.SugarLogger.Debugf("== onlineList %s", utils.Format4Output(onlineList, false))
|
||||
globals.SugarLogger.Debugf("== priceList %s", utils.Format4Output(priceList, false))
|
||||
globals.SugarLogger.Debugf("== updateItems %s", utils.Format4Output(updateItems, false))
|
||||
globals.SugarLogger.Debugf("== reorderSkuMap %s", utils.Format4Output(reorderSkuMap, false))
|
||||
globals.SugarLogger.Debugf("== updateItems %s", utils.Format4Output(updateItems, 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)
|
||||
@@ -823,8 +832,6 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
|
||||
var failedList []*partner.StoreSkuInfoWithErr
|
||||
failedList, err = storeSkuHandler.UpdateStoreSkusPrice(ctx, storeDetail.VendorOrgCode, storeID, vendorStoreID, batchedStoreSkuList)
|
||||
failedList, err = buildFailedListAndErr(failedList, err, batchedStoreSkuList, nil, storeID, vendorID, "更新门店商品价格")
|
||||
globals.SugarLogger.Debugf("====================batchedStoreSkuList %s", utils.Format4Output(batchedStoreSkuList, false))
|
||||
globals.SugarLogger.Debugf("====================eer %s", utils.Format4Output(failedList, false))
|
||||
if len(failedList) > 0 {
|
||||
task.AddFailedList(failedList)
|
||||
}
|
||||
|
||||
@@ -189,6 +189,7 @@ func (p *PurchaseHandler) UpdateStoreSkusPrice(ctx *jxcontext.Context, vendorOrg
|
||||
if err = api.EditPrice(price); err != nil {
|
||||
failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], "更新价格异常")...)
|
||||
}
|
||||
globals.SugarLogger.Debugf("v.VendorPrice ============= %d", v.VendorPrice)
|
||||
globals.SugarLogger.Debugf("看看走这儿了没,是不是更新 参数 %s", utils.Format4Output(price, false))
|
||||
globals.SugarLogger.Debugf("看看走这儿了没,是不是更新 返回值 %s", utils.Format4Output(failedList, false))
|
||||
globals.SugarLogger.Debugf("看看走这儿了没,是不是更新 结构体 %s", utils.Format4Output(v, false))
|
||||
|
||||
Reference in New Issue
Block a user