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

- fix some store to stores.

Browse Source
This commit is contained in:
gazebo
2018-10-11 16:11:48 +08:00
parent ed00165527
commit 5ec12fbbf1
7 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
business/jxstore/cms/sync.go
View File

@@ -163,7 +163,7 @@ func (v *VendorSync) SyncStoresSkus(db *dao.DaoDB, storeIDs []int, skuIDs []int,
err = v.LoopStoreVendors(db, "SyncStoresSkus", userName, func(batchItemList []interface{}, params ...interface{}) (interface{}, error) { err = v.LoopStoreVendors(db, "SyncStoresSkus", userName, func(batchItemList []interface{}, params ...interface{}) (interface{}, error) {
vendorID := batchItemList[0].(int) vendorID := batchItemList[0].(int)
if handler := GetPurchaseHandler(vendorID); handler != nil { if handler := GetPurchaseHandler(vendorID); handler != nil {
err = handler.SyncStoreSkus(db, storeIDs, skuIDs, isForce, userName) err = handler.SyncStoresSkus(db, storeIDs, skuIDs, isForce, userName)
} }
return nil, err return nil, err
}) })

4
business/partner/partner.go
View File

@@ -75,7 +75,7 @@ type IPurchasePlatformHandler interface {
// OpenStore(vendorStoreID string, userName string) error // OpenStore(vendorStoreID string, userName string) error
// CloseStore(vendorStoreID, closeNotice, userName string) error // CloseStore(vendorStoreID, closeNotice, userName string) error
SyncStoreSkus(db *dao.DaoDB, storeIDs []int, skuIDs []int, isSync bool, userName string) (err error) SyncStoresSkus(db *dao.DaoDB, storeIDs []int, skuIDs []int, isSync bool, userName string) (err error)
GetFieldIDName() string GetFieldIDName() string
GetFieldSyncStatusName() string GetFieldSyncStatusName() string
@@ -102,7 +102,7 @@ type IMultipleStoresHandler interface {
type ISingleStoreHandler interface { type ISingleStoreHandler interface {
IPurchasePlatformHandler IPurchasePlatformHandler
SyncStoreCategories(db *dao.DaoDB, storeIDs []int, userName string) (err error) SyncStoresCategories(db *dao.DaoDB, storeIDs []int, userName string) (err error)
ReadStoreCategories(storeID int) (cats []*model.SkuCategory, err error) ReadStoreCategories(storeID int) (cats []*model.SkuCategory, err error)
ReadStoreSku(storeID, skuID int) (skuNameExt *model.SkuNameExt, err error) ReadStoreSku(storeID, skuID int) (skuNameExt *model.SkuNameExt, err error)

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

@@ -71,7 +71,7 @@ var (
} }
) )
func (p *PurchaseHandler) SyncStoreSkus(db *dao.DaoDB, storeIDs []int, skuIDs []int, isSync bool, userName string) (err error) { func (p *PurchaseHandler) SyncStoresSkus(db *dao.DaoDB, storeIDs []int, skuIDs []int, isSync bool, userName string) (err error) {
for _, storeID := range storeIDs { for _, storeID := range storeIDs {
err = p.syncOneStoreSkus(db, storeID, skuIDs, isSync, userName) err = p.syncOneStoreSkus(db, storeID, skuIDs, isSync, userName)
if err != nil { if err != nil {

2
business/partner/purchase/ebai/store_sku_test.go
View File

@@ -10,7 +10,7 @@ import (
func TestSyncStoreSkus(t *testing.T) { func TestSyncStoreSkus(t *testing.T) {
db := dao.GetDB() db := dao.GetDB()
err := new(PurchaseHandler).SyncStoreSkus(db, []int{100077}, []int{7}, false, "autotest") err := new(PurchaseHandler).SyncStoresSkus(db, []int{100077}, []int{7}, false, "autotest")
if err != nil { if err != nil {
t.Fatal(err.Error()) t.Fatal(err.Error())
} }

2
business/partner/purchase/elm/store_sku.go
View File

@@ -16,6 +16,6 @@ func (p *PurchaseHandler) ReadStoreSku(storeID, skuID int) (skuNameExt *model.Sk
return nil, nil return nil, nil
} }
func (p *PurchaseHandler) SyncStoreSkus(db *dao.DaoDB, storeIDs []int, skuIDs []int, isSync bool, userName string) (err error) { func (p *PurchaseHandler) SyncStoresSkus(db *dao.DaoDB, storeIDs []int, skuIDs []int, isSync bool, userName string) (err error) {
return nil return nil
} }

2
business/partner/purchase/jd/store_sku.go
View File

@@ -22,7 +22,7 @@ type tStoreSkuBindExt struct {
} }
// 京东到家，以有库存表示关注（认领） // 京东到家，以有库存表示关注（认领）
func (p *PurchaseHandler) SyncStoreSkus(db *dao.DaoDB, storeIDs []int, skuIDs []int, isForce bool, userName string) (err error) { func (p *PurchaseHandler) SyncStoresSkus(db *dao.DaoDB, storeIDs []int, skuIDs []int, isForce bool, userName string) (err error) {
parallelCount := 1 parallelCount := 1
if len(skuIDs) < MaxSkuBatchSize { if len(skuIDs) < MaxSkuBatchSize {
parallelCount = 10 parallelCount = 10

8
controllers/cms_store_sku.go
View File

@@ -84,9 +84,9 @@ func (c *StoreSkuController) UpdateStoreSkus() {
// @Param skuIDs formData string false "SKU ID列表，缺省为全部" // @Param skuIDs formData string false "SKU ID列表，缺省为全部"
// @Success 200 {object} controllers.CallResult // @Success 200 {object} controllers.CallResult
// @Failure 200 {object} controllers.CallResult // @Failure 200 {object} controllers.CallResult
// @router /SyncStoreSkus [put] // @router /SyncStoresSkus [put]
func (c *StoreSkuController) SyncStoreSkus() { func (c *StoreSkuController) SyncStoresSkus() {
c.callSyncStoreSkus(func(params *tStoreSkuSyncStoreSkusParams) (retVal interface{}, errCode string, err error) { c.callSyncStoresSkus(func(params *tStoreSkuSyncStoresSkusParams) (retVal interface{}, errCode string, err error) {
db := dao.GetDB() db := dao.GetDB()
var storeIDs []int var storeIDs []int
var skuIDs []int var skuIDs []int
@@ -95,7 +95,7 @@ func (c *StoreSkuController) SyncStoreSkus() {
err = utils.UnmarshalUseNumber([]byte(params.SkuIDs), &skuIDs) err = utils.UnmarshalUseNumber([]byte(params.SkuIDs), &skuIDs)
} }
if err == nil { if err == nil {
err = basesch.FixedBaseScheduler.GetPurchasePlatformFromVendorID(params.VendorID).SyncStoreSkus(db, storeIDs, skuIDs, params.IsSync, GetUserNameFromToken(params.Token)) err = basesch.FixedBaseScheduler.GetPurchasePlatformFromVendorID(params.VendorID).SyncStoresSkus(db, storeIDs, skuIDs, params.IsSync, GetUserNameFromToken(params.Token))
} }
} }
return retVal, "", err return retVal, "", err