From 7ad2c7508fa8702949dcc254467ba3901e375e4f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Thu, 12 Nov 2020 15:30:31 +0800 Subject: [PATCH] beta --- business/jxstore/tempop/tempop.go | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index e988093d7..76292ddd0 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1817,7 +1817,10 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { if len(priceList) > 0 { for k, v := range priceList { _, err = putils.FreeBatchStoreSkuInfo("更新门店商品价格", func(task tasksch.ITask, batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, successCount int, err error) { - handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, batchedStoreSkuList) + failedList, err := handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, batchedStoreSkuList) + if len(failedList) > 0 { + task.AddFailedList(failedList) + } return nil, 1, err }, ctx, task, v, 50, true) } @@ -1826,7 +1829,10 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { if len(statusList1) > 0 { for k, v := range statusList1 { _, err = putils.FreeBatchStoreSkuInfo("更新门店商品状态", func(task tasksch.ITask, batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, successCount int, err error) { - handler.UpdateStoreSkusStatus(ctx, vendorOrgCode, 0, k, batchedStoreSkuList, batchedStoreSkuList[0].Status) + failedList, err := handler.UpdateStoreSkusStatus(ctx, vendorOrgCode, 0, k, batchedStoreSkuList, batchedStoreSkuList[0].Status) + if len(failedList) > 0 { + task.AddFailedList(failedList) + } return nil, 1, err }, ctx, task, v, 50, true) } @@ -1844,7 +1850,10 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { if len(stockList) > 0 { for k, v := range stockList { _, err = putils.FreeBatchStoreSkuInfo("更新门店商品库存", func(task tasksch.ITask, batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, successCount int, err error) { - handler.UpdateStoreSkusStock(ctx, vendorOrgCode, 0, k, batchedStoreSkuList) + failedList, err := handler.UpdateStoreSkusStock(ctx, vendorOrgCode, 0, k, batchedStoreSkuList) + if len(failedList) > 0 { + task.AddFailedList(failedList) + } return nil, 1, err }, ctx, task, v, 50, true) }