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:16:55 +08:00
parent 20dbfa5c29
commit b41d28ff30
1 changed files with 26 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1823,46 +1823,38 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
}
}
case 1:
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)
return nil, 1, err
}, ctx, task, v, 50, true)
}
}
case 2:
if len(statusList2) > 0 {
for k, v := range statusList1 {
_, err = putils.FreeBatchStoreSkuInfo("更新门店商品状态2", func(task tasksch.ITask, batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, successCount int, err error) {
handler.UpdateStoreSkusStatus(ctx, vendorOrgCode, 0, k, batchedStoreSkuList, batchedStoreSkuList[0].Status)
return nil, 1, err
}, ctx, task, v, 50, true)
}
}
case 3:
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)
return nil, 1, err
}, ctx, task, v, 50, true)
}
}
}
return retVal, err
}, []int{0, 1, 2, 3})
tasksch.HandleTask(task, nil, true).Run()
_, err = task.GetResult(0)
return err
// if len(priceList) > 0 {
// for k, v := range priceList {
// if len(v) > 50 {
// for i := 0; i < len(v)/50+1; i++ {
// j := i
// if i == len(v)/50+1 {
// handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, v[j:len(v)])
// } else {
// handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, v[j:50*(j+1)])
// }
// j += 50
// }
// }
// }
// }
if len(statusList1) > 0 {
// for k, v := range statusList1 {
// handler.UpdateStoreSkusStatus(ctx, vendorOrgCode, 0, k, v, v[0].Status)
// }
}
if len(statusList2) > 0 {
// for k, v := range statusList2 {
// handler.UpdateStoreSkusStatus(ctx, vendorOrgCode, 0, k, v, v[0].Status)
// }
}
if len(stockList) > 0 {
// for k, v := range stockList {
// handler.UpdateStoreSkusStock(ctx, vendorOrgCode, 0, k, v)
// }
}
return err
}
func storeSkuFullList2BareFilter(storeSkuFull []*partner.SkuNameInfo) (bareStoreSkuList []*partner.StoreSkuInfo) {