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) }