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

- remove useless comment

Browse Source
This commit is contained in:
gazebo
2019-03-19 10:29:09 +08:00
parent f07eeeb9c4
commit e906f0b159
1 changed files with 1 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
business/partner/purchase/ebai/store_sku.go
View File

@@ -237,7 +237,6 @@ func (p *PurchaseHandler) SyncStoreSkus(ctx *jxcontext.Context, parentTask tasks
task := tasksch.NewParallelTask("SyncStoreSkus饿百2", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), userName, func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { task := tasksch.NewParallelTask("SyncStoreSkus饿百2", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), userName, func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
storeSku := batchItemList[0].(*tStoreSkuFullInfo) storeSku := batchItemList[0].(*tStoreSkuFullInfo)
updateFields := []string{model.FieldEbaiSyncStatus} updateFields := []string{model.FieldEbaiSyncStatus}
isCreate := false
if globals.EnableStoreWrite && globals.EnableEbaiStoreWrite { if globals.EnableStoreWrite && globals.EnableEbaiStoreWrite {
if storeSku.EbaiSyncStatus&model.SyncFlagDeletedMask != 0 { if storeSku.EbaiSyncStatus&model.SyncFlagDeletedMask != 0 {
err = api.EbaiAPI.SkuDelete(strStoreID, utils.Int64ToStr(storeSku.EbaiID)) err = api.EbaiAPI.SkuDelete(strStoreID, utils.Int64ToStr(storeSku.EbaiID))
@@ -246,16 +245,6 @@ func (p *PurchaseHandler) SyncStoreSkus(ctx *jxcontext.Context, parentTask tasks
// todo 适当处理重复（即已经创建）的情况 // todo 适当处理重复（即已经创建）的情况
if storeSku.EbaiID, err = api.EbaiAPI.SkuCreate(strStoreID, storeSku.SkuID, genSkuParamsFromStoreSkuInfo(storeSku)); err == nil { if storeSku.EbaiID, err = api.EbaiAPI.SkuCreate(strStoreID, storeSku.SkuID, genSkuParamsFromStoreSkuInfo(storeSku)); err == nil {
updateFields = append(updateFields, model.FieldEbaiID) updateFields = append(updateFields, model.FieldEbaiID)
// https: //open-be.ele.me/dev/notice?id=116
// 饿百支持创建sku时绑定商家分类了
// isCreate = true
// // 创建SKU后马上绑定分类，会失败，所以延迟绑定
// utils.AfterFuncWithRecover(3*time.Second, func() {
// if err := api.EbaiAPI.SkuShopCategoryMap(strStoreID, storeSku.EbaiID, utils.Int64ToStr(storeSku.CatEbaiID)); err == nil {
// storeSku.EbaiSyncStatus = 0
// dao.UpdateEntity(nil, &storeSku.StoreSkuBind, updateFields...)
// }
// })
} }
} else if storeSku.EbaiSyncStatus&model.SyncFlagModifiedMask != 0 { } else if storeSku.EbaiSyncStatus&model.SyncFlagModifiedMask != 0 {
if jxutils.IsFakeID(storeSku.EbaiID) { if jxutils.IsFakeID(storeSku.EbaiID) {
@@ -268,11 +257,7 @@ func (p *PurchaseHandler) SyncStoreSkus(ctx *jxcontext.Context, parentTask tasks
} }
} }
if err == nil { if err == nil {
if isCreate { storeSku.EbaiSyncStatus = 0
storeSku.EbaiSyncStatus = model.SyncFlagModifiedMask
} else {
storeSku.EbaiSyncStatus = 0
}
_, err = dao.UpdateEntity(nil, &storeSku.StoreSkuBind, updateFields...) _, err = dao.UpdateEntity(nil, &storeSku.StoreSkuBind, updateFields...)
} }
return nil, err return nil, err