diff --git a/business/jxstore/cms/store.go b/business/jxstore/cms/store.go index ebc0eecdc..0e9f16baf 100644 --- a/business/jxstore/cms/store.go +++ b/business/jxstore/cms/store.go @@ -1215,11 +1215,13 @@ func AddStoreVendorMap(ctx *jxcontext.Context, db *dao.DaoDB, vendorID int, vend outStoreMap = storeMap _, err = CurVendorSync.SyncStore(ctx, db, storeMap.VendorID, storeID, false, userName) } else { - fmt.Println("test1", err.Error()) dao.Rollback(db) } } } + if err != nil { + return outStoreMap, err + } if vendorID == model.VendorIDJDShop { //绑定京东商城后,需要对绑定的门店现有的和模板店相同且可售的商品设置京东商城的门店库存 //TODO SyncFlagSaleMask对京东商城来说,修改门店商品状态就是修改库存 diff --git a/controllers/cms_sync.go b/controllers/cms_sync.go index 5a01cec7a..3b15447e4 100644 --- a/controllers/cms_sync.go +++ b/controllers/cms_sync.go @@ -377,5 +377,11 @@ func (c *SyncController) SyncStoreSkusFromYb() { // @Failure 200 {object} controllers.CallResult // @router /SyncJdsStoresSkus [put] func (c *SyncController) SyncJdsStoresSkus() { - + c.callSyncJdsStoresSkus(func(params *tSyncSyncJdsStoresSkusParams) (retVal interface{}, errCode string, err error) { + var storeIDs []int + if err = jxutils.Strings2Objs(params.StoreIDs, &storeIDs); err == nil { + retVal, err = cms.CurVendorSync.SyncJdsStoresSkus(params.Ctx, storeIDs, params.IsAsync, params.IsContinueWhenError) + } + return retVal, "", err + }) } diff --git a/routers/commentsRouter_controllers.go b/routers/commentsRouter_controllers.go index 1250ecf20..cfbcedf1b 100644 --- a/routers/commentsRouter_controllers.go +++ b/routers/commentsRouter_controllers.go @@ -2232,6 +2232,15 @@ func init() { Filters: nil, Params: nil}) + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:SyncController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:SyncController"], + beego.ControllerComments{ + Method: "SyncJdsStoresSkus", + Router: `/SyncJdsStoresSkus`, + AllowHTTPMethods: []string{"put"}, + MethodParams: param.Make(), + Filters: nil, + Params: nil}) + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:SyncController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:SyncController"], beego.ControllerComments{ Method: "SyncSkuNames",