From 270eef92efbaa56b542e852a102f567cd2a7352a Mon Sep 17 00:00:00 2001 From: suyl <770236076@qq.com> Date: Tue, 27 Apr 2021 18:14:51 +0800 Subject: [PATCH] =?UTF-8?q?pdd=E7=BB=91=E5=AE=9A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- controllers/job_controller.go | 113 --------------------- controllers/union_controller.go | 138 ++++++++++++++++++++++++++ routers/commentsRouter_controllers.go | 23 +++-- routers/router.go | 5 + 4 files changed, 159 insertions(+), 120 deletions(-) create mode 100644 controllers/union_controller.go diff --git a/controllers/job_controller.go b/controllers/job_controller.go index d60f35c80..711dd4c46 100644 --- a/controllers/job_controller.go +++ b/controllers/job_controller.go @@ -550,116 +550,3 @@ func (c *JobController) TempJob() { return retVal, "", err }) } - -// @Title 查询联盟活动 -// @Description 查询联盟活动 -// @Param token header string true "认证token" -// @Param vendorID query int true "平台ID" -// @Param actType query int true "活动类型ID" -// @Success 200 {object} controllers.CallResult -// @Failure 200 {object} controllers.CallResult -// @router /GetUnionActList [get] -func (c *JobController) GetUnionActList() { - c.callGetUnionActList(func(params *tJobGetUnionActListParams) (retVal interface{}, errCode string, err error) { - retVal, err = cms.GetUnionActList(params.Ctx, params.VendorID, params.ActType) - return retVal, "", err - }) -} - -// @Title 分享联盟链接 -// @Description 分享联盟链接 -// @Param token header string true "认证token" -// @Param jobID formData int false "任务ID" -// @Param shareType formData int true "分享类型，1为当前用户分享给别人，2为当前用户自己领取" -// @Param resourceType formData int false "资源类型" -// @Param linkType formData int true "链接类型，1 h5链接 2 deeplink(唤起)链接 3 中间页唤起链接 4 微信小程序唤起路径， 5为小程序二维码" -// @Success 200 {object} controllers.CallResult -// @Failure 200 {object} controllers.CallResult -// @router /ShareUnionLink [post] -func (c *JobController) ShareUnionLink() { - c.callShareUnionLink(func(params *tJobShareUnionLinkParams) (retVal interface{}, errCode string, err error) { - retVal, err = cms.ShareUnionLink(params.Ctx, params.JobID, params.ShareType, params.LinkType, params.ResourceType) - return retVal, "", err - }) -} - -// @Title 查看接取的联盟任务执行情况 -// @Description 查看接取的联盟任务执行情况 -// @Param token header string true "认证token" -// @Param jobOrderID query int true "接取任务ID" -// @Success 200 {object} controllers.CallResult -// @Failure 200 {object} controllers.CallResult -// @router /GetUnionJobOrderInfo [get] -func (c *JobController) GetUnionJobOrderInfo() { - c.callGetUnionJobOrderInfo(func(params *tJobGetUnionJobOrderInfoParams) (retVal interface{}, errCode string, err error) { - retVal, err = cms.GetUnionJobOrderInfo(params.Ctx, params.JobOrderID) - return retVal, "", err - }) -} - -// @Title 查询平台物料分类 -// @Description 查询平台物料分类 -// @Param token header string true "认证token" -// @Param vendorID query int true "平台ID" -// @Success 200 {object} controllers.CallResult -// @Failure 200 {object} controllers.CallResult -// @router /GetVendorMatterCategory [get] -func (c *JobController) GetVendorMatterCategory() { - c.callGetVendorMatterCategory(func(params *tJobGetVendorMatterCategoryParams) (retVal interface{}, errCode string, err error) { - retVal, err = dao.GetVendorMatterCategory(dao.GetDB(), params.VendorID) - return retVal, "", err - }) -} - -// @Title 查询平台物料 -// @Description 查询平台物料 -// @Param token header string true "认证token" -// @Param vendorID query int true "平台ID" -// @Param vendorCatID query string false "平台分类ID" -// @Param keyword query string false "关键字" -// @Param offset query int false "页码" -// @Param pageSize query int false "页大小" -// @Param listID query string false "分页用" -// @Param sortType query int false "排序类型" -// @Success 200 {object} controllers.CallResult -// @Failure 200 {object} controllers.CallResult -// @router /GetVendorMatters [get] -func (c *JobController) GetVendorMatters() { - c.callGetVendorMatters(func(params *tJobGetVendorMattersParams) (retVal interface{}, errCode string, err error) { - retVal, err = cms.GetVendorMatters(params.Ctx, params.VendorID, params.VendorCatID, params.Keyword, params.Offset, params.PageSize, params.SortType, params.ListID) - return retVal, "", err - }) -} - -// @Title 查询平台物料详情 -// @Description 查询平台物料详情 -// @Param token header string true "认证token" -// @Param vendorID query int true "平台ID" -// @Param goodsID query string true "平台商品ID" -// @Success 200 {object} controllers.CallResult -// @Failure 200 {object} controllers.CallResult -// @router /GetVendorMatterDetail [get] -func (c *JobController) GetVendorMatterDetail() { - c.callGetVendorMatterDetail(func(params *tJobGetVendorMatterDetailParams) (retVal interface{}, errCode string, err error) { - retVal, err = cms.GetVendorMatterDetail(params.Ctx, params.VendorID, params.GoodsID) - return retVal, "", err - }) -} - -// @Title 查询平台物料推荐 -// @Description 查询平台物料推荐 -// @Param token header string true "认证token" -// @Param vendorID query int true "平台ID" -// @Param goodsID query string true "平台商品ID" -// @Param rcmmdType query int true "推荐类型，1为今日销量榜，3为相似商品，5为实时热销榜" -// @Param offset query int false "页码" -// @Param pageSize query int false "页大小" -// @Success 200 {object} controllers.CallResult -// @Failure 200 {object} controllers.CallResult -// @router /GetVendorMatterRcmmd [get] -func (c *JobController) GetVendorMatterRcmmd() { - c.callGetVendorMatterRcmmd(func(params *tJobGetVendorMatterRcmmdParams) (retVal interface{}, errCode string, err error) { - retVal, err = cms.GetVendorMatterRcmmd(params.Ctx, params.VendorID, params.GoodsID, params.RcmmdType, params.Offset, params.PageSize) - return retVal, "", err - }) -} diff --git a/controllers/union_controller.go b/controllers/union_controller.go new file mode 100644 index 000000000..9b16fc804 --- /dev/null +++ b/controllers/union_controller.go @@ -0,0 +1,138 @@ +package controllers + +import ( + "git.rosy.net.cn/jx-callback/business/jxstore/cms" + "git.rosy.net.cn/jx-callback/business/model/dao" + "git.rosy.net.cn/jx-callback/globals/api" + "github.com/astaxie/beego/server/web" +) + +type UnionController struct { + web.Controller +} + +// @Title 查询联盟活动 +// @Description 查询联盟活动 +// @Param token header string true "认证token" +// @Param vendorID query int true "平台ID" +// @Param actType query int true "活动类型ID" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /GetUnionActList [get] +func (c *UnionController) GetUnionActList() { + c.callGetUnionActList(func(params *tUnionGetUnionActListParams) (retVal interface{}, errCode string, err error) { + retVal, err = cms.GetUnionActList(params.Ctx, params.VendorID, params.ActType) + return retVal, "", err + }) +} + +// @Title 分享联盟链接 +// @Description 分享联盟链接 +// @Param token header string true "认证token" +// @Param jobID formData int false "任务ID" +// @Param shareType formData int true "分享类型，1为当前用户分享给别人，2为当前用户自己领取" +// @Param resourceType formData int false "资源类型" +// @Param linkType formData int true "链接类型，1 h5链接 2 deeplink(唤起)链接 3 中间页唤起链接 4 微信小程序唤起路径， 5为小程序二维码" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /ShareUnionLink [post] +func (c *UnionController) ShareUnionLink() { + c.callShareUnionLink(func(params *tUnionShareUnionLinkParams) (retVal interface{}, errCode string, err error) { + retVal, err = cms.ShareUnionLink(params.Ctx, params.JobID, params.ShareType, params.LinkType, params.ResourceType) + return retVal, "", err + }) +} + +// @Title 查看接取的联盟任务执行情况 +// @Description 查看接取的联盟任务执行情况 +// @Param token header string true "认证token" +// @Param jobOrderID query int true "接取任务ID" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /GetUnionJobOrderInfo [get] +func (c *UnionController) GetUnionJobOrderInfo() { + c.callGetUnionJobOrderInfo(func(params *tUnionGetUnionJobOrderInfoParams) (retVal interface{}, errCode string, err error) { + retVal, err = cms.GetUnionJobOrderInfo(params.Ctx, params.JobOrderID) + return retVal, "", err + }) +} + +// @Title 查询平台物料分类 +// @Description 查询平台物料分类 +// @Param token header string true "认证token" +// @Param vendorID query int true "平台ID" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /GetVendorMatterCategory [get] +func (c *UnionController) GetVendorMatterCategory() { + c.callGetVendorMatterCategory(func(params *tUnionGetVendorMatterCategoryParams) (retVal interface{}, errCode string, err error) { + retVal, err = dao.GetVendorMatterCategory(dao.GetDB(), params.VendorID) + return retVal, "", err + }) +} + +// @Title 查询平台物料 +// @Description 查询平台物料 +// @Param token header string true "认证token" +// @Param vendorID query int true "平台ID" +// @Param vendorCatID query string false "平台分类ID" +// @Param keyword query string false "关键字" +// @Param offset query int false "页码" +// @Param pageSize query int false "页大小" +// @Param listID query string false "分页用" +// @Param sortType query int false "排序类型" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /GetVendorMatters [get] +func (c *UnionController) GetVendorMatters() { + c.callGetVendorMatters(func(params *tUnionGetVendorMattersParams) (retVal interface{}, errCode string, err error) { + retVal, err = cms.GetVendorMatters(params.Ctx, params.VendorID, params.VendorCatID, params.Keyword, params.Offset, params.PageSize, params.SortType, params.ListID) + return retVal, "", err + }) +} + +// @Title 查询平台物料详情 +// @Description 查询平台物料详情 +// @Param token header string true "认证token" +// @Param vendorID query int true "平台ID" +// @Param goodsID query string true "平台商品ID" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /GetVendorMatterDetail [get] +func (c *UnionController) GetVendorMatterDetail() { + c.callGetVendorMatterDetail(func(params *tUnionGetVendorMatterDetailParams) (retVal interface{}, errCode string, err error) { + retVal, err = cms.GetVendorMatterDetail(params.Ctx, params.VendorID, params.GoodsID) + return retVal, "", err + }) +} + +// @Title 查询平台物料推荐 +// @Description 查询平台物料推荐 +// @Param token header string true "认证token" +// @Param vendorID query int true "平台ID" +// @Param goodsID query string true "平台商品ID" +// @Param rcmmdType query int true "推荐类型，1为今日销量榜，3为相似商品，5为实时热销榜" +// @Param offset query int false "页码" +// @Param pageSize query int false "页大小" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /GetVendorMatterRcmmd [get] +func (c *UnionController) GetVendorMatterRcmmd() { + c.callGetVendorMatterRcmmd(func(params *tUnionGetVendorMatterRcmmdParams) (retVal interface{}, errCode string, err error) { + retVal, err = cms.GetVendorMatterRcmmd(params.Ctx, params.VendorID, params.GoodsID, params.RcmmdType, params.Offset, params.PageSize) + return retVal, "", err + }) +} + +// @Title 查询拼多多分享前，推广位有没有绑定授权 +// @Description 查询拼多多分享前，推广位有没有绑定授权 +// @Param token header string true "认证token" +// @Success 200 {object} controllers.CallResult +// @Failure 200 {object} controllers.CallResult +// @router /GetPddBindInfo [get] +func (c *UnionController) GetPddBindInfo() { + c.callGetPddBindInfo(func(params *tUnionGetPddBindInfoParams) (retVal interface{}, errCode string, err error) { + retVal, err = api.PddAPI.MemberAuthorityQuery(params.Ctx.GetUserID()) + return retVal, "", err + }) +} diff --git a/routers/commentsRouter_controllers.go b/routers/commentsRouter_controllers.go index 796305e62..1c802d180 100644 --- a/routers/commentsRouter_controllers.go +++ b/routers/commentsRouter_controllers.go @@ -529,7 +529,7 @@ func init() { Filters: nil, Params: nil}) - beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"], + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"], beego.ControllerComments{ Method: "GetUnionActList", Router: "/GetUnionActList", @@ -601,7 +601,7 @@ func init() { Filters: nil, Params: nil}) - beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"], + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"], beego.ControllerComments{ Method: "ShareUnionLink", Router: "/ShareUnionLink", @@ -610,7 +610,7 @@ func init() { Filters: nil, Params: nil}) - beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"], + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"], beego.ControllerComments{ Method: "GetUnionJobOrderInfo", Router: "/GetUnionJobOrderInfo", @@ -619,7 +619,7 @@ func init() { Filters: nil, Params: nil}) - beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"], + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"], beego.ControllerComments{ Method: "GetVendorMatterCategory", Router: "/GetVendorMatterCategory", @@ -628,7 +628,7 @@ func init() { Filters: nil, Params: nil}) - beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"], + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"], beego.ControllerComments{ Method: "GetVendorMatters", Router: "/GetVendorMatters", @@ -637,7 +637,7 @@ func init() { Filters: nil, Params: nil}) - beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"], + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"], beego.ControllerComments{ Method: "GetVendorMatterDetail", Router: "/GetVendorMatterDetail", @@ -646,7 +646,7 @@ func init() { Filters: nil, Params: nil}) - beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"], + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"], beego.ControllerComments{ Method: "GetVendorMatterRcmmd", Router: "/GetVendorMatterRcmmd", @@ -655,6 +655,15 @@ func init() { Filters: nil, Params: nil}) + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UnionController"], + beego.ControllerComments{ + Method: "GetPddBindInfo", + Router: "/GetPddBindInfo", + AllowHTTPMethods: []string{"get"}, + MethodParams: param.Make(), + Filters: nil, + Params: nil}) + beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:JobController"], beego.ControllerComments{ Method: "SubmitJob", diff --git a/routers/router.go b/routers/router.go index 6e06f3c0e..9ed8d39de 100644 --- a/routers/router.go +++ b/routers/router.go @@ -56,6 +56,11 @@ func init() { &controllers.CmsController{}, ), ), + web.NSNamespace("/union", + web.NSInclude( + &controllers.UnionController{}, + ), + ), ) web.AddNamespace(ns) web.AutoRouter(&controllers.WXPayController{})