liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

beta

Browse Source
This commit is contained in:
苏尹岚
2020-11-12 15:30:31 +08:00
parent 75cba5dfb4
commit 7ad2c7508f
1 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
business/jxstore/tempop/tempop.go
View File

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