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

pdd绑定

Browse Source
This commit is contained in:
suyl
2021-04-27 18:14:51 +08:00
parent e58964633c
commit 270eef92ef
4 changed files with 159 additions and 120 deletions
Download Patch File Download Diff File Expand all files Collapse all files

113
controllers/job_controller.go
View File

@@ -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
})
}

138
controllers/union_controller.go Normal file
View File

@@ -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
})
}

23
routers/commentsRouter_controllers.go
View File

@@ -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",

5
routers/router.go
View File

@@ -56,6 +56,11 @@ func init() {
&controllers.CmsController{},
),
),
web.NSNamespace("/union",
web.NSInclude(
&controllers.UnionController{},
),
),
)
web.AddNamespace(ns)
web.AutoRouter(&controllers.WXPayController{})