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

gy灵异

Browse Source
This commit is contained in:
苏尹岚
2020-08-25 11:48:26 +08:00
parent b1913e8f26
commit 90f6969e03
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -86,7 +86,6 @@ func SyncStoreCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendo
storeCatMap := &model.StoreSkuCategoryMap{} storeCatMap := &model.StoreSkuCategoryMap{}
storeCatMap.ID = catInfo.MapID storeCatMap.ID = catInfo.MapID
var failedList []*partner.StoreSkuInfoWithErr var failedList []*partner.StoreSkuInfoWithErr
fmt.Println("4444444444444444444444444444444444444444444444")
if catInfo.IsExdSpec == model.YES { if catInfo.IsExdSpec == model.YES {
if vendorID != model.VendorIDEBAI { if vendorID != model.VendorIDEBAI {
return nil, err return nil, err
@@ -98,7 +97,6 @@ func SyncStoreCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendo
catInfo.Seq = catInfo.StoreCatSeq catInfo.Seq = catInfo.StoreCatSeq
} }
} }
fmt.Println("3333333333333333333333333333333333333333333333")
if model.IsSyncStatusDelete(catInfo.CatSyncStatus) { // 删除 if model.IsSyncStatusDelete(catInfo.CatSyncStatus) { // 删除
if model.IsSyncStatusDelete(catInfo.CatSyncStatus) && !dao.IsVendorThingIDEmpty(catInfo.VendorCatID) { if model.IsSyncStatusDelete(catInfo.CatSyncStatus) && !dao.IsVendorThingIDEmpty(catInfo.VendorCatID) {
err = handler.DeleteStoreCategory(ctx, storeID, vendorStoreID, catInfo.VendorCatID, level) err = handler.DeleteStoreCategory(ctx, storeID, vendorStoreID, catInfo.VendorCatID, level)
@@ -139,14 +137,12 @@ func SyncStoreCategories(ctx *jxcontext.Context, parentTask tasksch.ITask, vendo
} }
task.AddFailedList(failedList) task.AddFailedList(failedList)
} }
fmt.Println("2222222222222222222222222222222222222222222222")
if err == nil { if err == nil {
if vendorID == model.VendorIDMTWM { if vendorID == model.VendorIDMTWM {
refutil.SetObjFieldByName(storeCatMap, idFieldName, catInfo.VendorCatID) refutil.SetObjFieldByName(storeCatMap, idFieldName, catInfo.VendorCatID)
} else { } else {
refutil.SetObjFieldByName(storeCatMap, idFieldName, utils.Str2Int64WithDefault(catInfo.VendorCatID, 0)) refutil.SetObjFieldByName(storeCatMap, idFieldName, utils.Str2Int64WithDefault(catInfo.VendorCatID, 0))
} }
fmt.Println("11111111111111111111111111111111111111111111111111111111111")
_, err = dao.UpdateEntity(db, storeCatMap, updateFields...) _, err = dao.UpdateEntity(db, storeCatMap, updateFields...)
} }
return nil, err return nil, err
@@ -418,6 +414,7 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
globals.SugarLogger.Debugf("syncStoreSkuNew causeFlag:%d", causeFlag) globals.SugarLogger.Debugf("syncStoreSkuNew causeFlag:%d", causeFlag)
db := dao.GetDB() db := dao.GetDB()
storeDetail, err := dao.GetStoreDetail(db, storeID, vendorID) storeDetail, err := dao.GetStoreDetail(db, storeID, vendorID)
fmt.Println("1111111111111111111111111111111111111111111111111111111111111111111111111111111")
if err != nil { if err != nil {
return err return err
} }
@@ -428,9 +425,13 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
} else { } else {
skus, err = dao.GetStoreSkus(db, vendorID, storeID, skuIDs) skus, err = dao.GetStoreSkus(db, vendorID, storeID, skuIDs)
} }
fmt.Println("22222222222222222222222222222222222222222222222222222222222222222222222222")
if err != nil || len(skus) == 0 { if err != nil || len(skus) == 0 {
return err return err
} }
fmt.Println("3333333333333333333333333333333333333333333333333333333333333333333333333")
if len(excludeSkuIDs) > 0 { if len(excludeSkuIDs) > 0 {
excludeSkuMap := jxutils.IntList2Map(excludeSkuIDs) excludeSkuMap := jxutils.IntList2Map(excludeSkuIDs)
var skus2 []*dao.StoreSkuSyncInfo var skus2 []*dao.StoreSkuSyncInfo