try
This commit is contained in:
@@ -680,6 +680,28 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
|
||||
}
|
||||
case 1:
|
||||
if len(createList) > 0 {
|
||||
//jds2创商品太快了。。
|
||||
if vendorID == model.VendorIDJDShop && storeID == model.JdShopMainStoreID2 {
|
||||
var failedList []*partner.StoreSkuInfoWithErr
|
||||
for _, v := range createList {
|
||||
failedList, err = singleStoreHandler.CreateStoreSkus(ctx, storeID, vendorStoreID, []*dao.StoreSkuSyncInfo{
|
||||
v,
|
||||
})
|
||||
failedList, err = buildFailedListAndErr(failedList, err, nil, []*dao.StoreSkuSyncInfo{
|
||||
v,
|
||||
}, storeID, vendorID, "创建门店商品")
|
||||
if len(failedList) > 0 {
|
||||
task.AddFailedList(failedList)
|
||||
}
|
||||
successList := putils.UnselectStoreSkuSyncListByVendorSkuIDs([]*dao.StoreSkuSyncInfo{
|
||||
v,
|
||||
}, GetVendorSkuIDList(failedList))
|
||||
if len(successList) > 0 {
|
||||
updateStoreSku(dao.GetDB(), vendorID, successList, model.SyncFlagNewMask)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
_, err = putils.FreeBatchStoreSkuSyncInfo("创建门店商品", func(task tasksch.ITask, batchedStoreSkuList []*dao.StoreSkuSyncInfo) (result interface{}, successCount int, err error) {
|
||||
var failedList []*partner.StoreSkuInfoWithErr
|
||||
if failedList, err = singleStoreHandler.CreateStoreSkus(ctx, storeID, vendorStoreID, batchedStoreSkuList); singleStoreHandler.IsErrSkuExist(err) {
|
||||
|
||||
Reference in New Issue
Block a user