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

try

Browse Source
This commit is contained in:
苏尹岚
2020-11-26 17:07:53 +08:00
parent 728c907ac1
commit ae65790f08
1 changed files with 8 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
business/jxstore/cms/sync_store_sku.go
View File

@@ -683,24 +683,16 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
//jds2创商品太快了。。 //jds2创商品太快了。。
if vendorID == model.VendorIDJDShop && storeID == model.JdShopMainStoreID2 { if vendorID == model.VendorIDJDShop && storeID == model.JdShopMainStoreID2 {
var failedList []*partner.StoreSkuInfoWithErr var failedList []*partner.StoreSkuInfoWithErr
for _, v := range createList { failedList, err = singleStoreHandler.CreateStoreSkus(ctx, storeID, vendorStoreID, createList)
failedList, err = singleStoreHandler.CreateStoreSkus(ctx, storeID, vendorStoreID, []*dao.StoreSkuSyncInfo{ failedList, err = buildFailedListAndErr(failedList, err, nil, createList, storeID, vendorID, "创建门店商品")
v,
})
failedList, err = buildFailedListAndErr(failedList, err, nil, []*dao.StoreSkuSyncInfo{
v,
}, storeID, vendorID, "创建门店商品")
if len(failedList) > 0 { if len(failedList) > 0 {
task.AddFailedList(failedList) task.AddFailedList(failedList)
} }
successList := putils.UnselectStoreSkuSyncListByVendorSkuIDs([]*dao.StoreSkuSyncInfo{ successList := putils.UnselectStoreSkuSyncListByVendorSkuIDs(createList, GetVendorSkuIDList(failedList))
v,
}, GetVendorSkuIDList(failedList))
if len(successList) > 0 { if len(successList) > 0 {
updateStoreSku(dao.GetDB(), vendorID, successList, model.SyncFlagNewMask) updateStoreSku(dao.GetDB(), vendorID, successList, model.SyncFlagNewMask)
} }
} }
}
_, err = putils.FreeBatchStoreSkuSyncInfo("创建门店商品", func(task tasksch.ITask, batchedStoreSkuList []*dao.StoreSkuSyncInfo) (result interface{}, successCount int, err error) { _, err = putils.FreeBatchStoreSkuSyncInfo("创建门店商品", func(task tasksch.ITask, batchedStoreSkuList []*dao.StoreSkuSyncInfo) (result interface{}, successCount int, err error) {
var failedList []*partner.StoreSkuInfoWithErr var failedList []*partner.StoreSkuInfoWithErr