123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137 |
- // Code generated by goctl. DO NOT EDIT!
- // Source: bxsubscribe.proto
- package server
- import (
- "context"
- "bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXSubscribe/rpc/internal/logic"
- "bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXSubscribe/rpc/internal/svc"
- "bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXSubscribe/rpc/type/bxsubscribe"
- )
- type BxsubscribeServer struct {
- svcCtx *svc.ServiceContext
- bxsubscribe.UnimplementedBxsubscribeServer
- }
- func NewBxsubscribeServer(svcCtx *svc.ServiceContext) *BxsubscribeServer {
- return &BxsubscribeServer{
- svcCtx: svcCtx,
- }
- }
- // 获取订阅推送列表
- func (s *BxsubscribeServer) GetSubList(ctx context.Context, in *bxsubscribe.SubscribeInfosReq) (*bxsubscribe.SubscribeInfosResp, error) {
- l := logic.NewGetSubListLogic(ctx, s.svcCtx)
- return l.GetSubList(in)
- }
- // 获取订阅推送相关信息
- func (s *BxsubscribeServer) GetSubSomeInfo(ctx context.Context, in *bxsubscribe.SomeInfoReq) (*bxsubscribe.SomeInfoResp, error) {
- l := logic.NewGetSubSomeInfoLogic(ctx, s.svcCtx)
- return l.GetSubSomeInfo(in)
- }
- // 修改订阅信息接口
- func (s *BxsubscribeServer) UpdateSubScribeInfo(ctx context.Context, in *bxsubscribe.UpdateSubScribeInfoReq) (*bxsubscribe.StatusResp, error) {
- l := logic.NewUpdateSubScribeInfoLogic(ctx, s.svcCtx)
- return l.UpdateSubScribeInfo(in)
- }
- // 推送页面筛选导出
- func (s *BxsubscribeServer) ByPushHistory(ctx context.Context, in *bxsubscribe.SubscribeInfosReq) (*bxsubscribe.ByPushHistoryResp, error) {
- l := logic.NewByPushHistoryLogic(ctx, s.svcCtx)
- return l.ByPushHistory(in)
- }
- // 推送数据浏览状态修改
- func (s *BxsubscribeServer) SetRead(ctx context.Context, in *bxsubscribe.SetReadReq) (*bxsubscribe.StatusResp, error) {
- l := logic.NewSetReadLogic(ctx, s.svcCtx)
- return l.SetRead(in)
- }
- // 关键词获取
- func (s *BxsubscribeServer) GetKey(ctx context.Context, in *bxsubscribe.GetKeyReq) (*bxsubscribe.KeyResp, error) {
- l := logic.NewGetKeyLogic(ctx, s.svcCtx)
- return l.GetKey(in)
- }
- // 订阅设置获取
- func (s *BxsubscribeServer) GetSubScribeInfo(ctx context.Context, in *bxsubscribe.UserReq) (*bxsubscribe.UserResq, error) {
- l := logic.NewGetSubScribeInfoLogic(ctx, s.svcCtx)
- return l.GetSubScribeInfo(in)
- }
- // 信息分发
- func (s *BxsubscribeServer) MsgDistributor(ctx context.Context, in *bxsubscribe.MsgDistributorReq) (*bxsubscribe.StatusResp, error) {
- l := logic.NewMsgDistributorLogic(ctx, s.svcCtx)
- return l.MsgDistributor(in)
- }
- // 手动分发人员查询
- func (s *BxsubscribeServer) GetDistributor(ctx context.Context, in *bxsubscribe.GetDistributorReq) (*bxsubscribe.DistributorResp, error) {
- l := logic.NewGetDistributorLogic(ctx, s.svcCtx)
- return l.GetDistributor(in)
- }
- // 查看状态
- func (s *BxsubscribeServer) GetViewStatus(ctx context.Context, in *bxsubscribe.GetViewStatusReq) (*bxsubscribe.ViewStatusResp, error) {
- l := logic.NewGetViewStatusLogic(ctx, s.svcCtx)
- return l.GetViewStatus(in)
- }
- // 用户推送信息查看
- func (s *BxsubscribeServer) UserInfo(ctx context.Context, in *bxsubscribe.GetUserInfoReq) (*bxsubscribe.GetUserInfoResq, error) {
- l := logic.NewUserInfoLogic(ctx, s.svcCtx)
- return l.UserInfo(in)
- }
- // 用户邮箱保存
- func (s *BxsubscribeServer) SetUser(ctx context.Context, in *bxsubscribe.SetUserInfoReq) (*bxsubscribe.StatusResp, error) {
- l := logic.NewSetUserLogic(ctx, s.svcCtx)
- return l.SetUser(in)
- }
- // 用户推送设置查看
- func (s *BxsubscribeServer) GetPushSet(ctx context.Context, in *bxsubscribe.GetPushSetReq) (*bxsubscribe.GetPushSetResp, error) {
- l := logic.NewGetPushSetLogic(ctx, s.svcCtx)
- return l.GetPushSet(in)
- }
- // 用户推送设置修改
- func (s *BxsubscribeServer) SetPushSet(ctx context.Context, in *bxsubscribe.SetPushSetReq) (*bxsubscribe.StatusResp, error) {
- l := logic.NewSetPushSetLogic(ctx, s.svcCtx)
- return l.SetPushSet(in)
- }
- // 查看企业员工用户订阅
- func (s *BxsubscribeServer) GetStaffSubscribeList(ctx context.Context, in *bxsubscribe.StaffSubscribeReq) (*bxsubscribe.StaffSubscribeListResp, error) {
- l := logic.NewGetStaffSubscribeListLogic(ctx, s.svcCtx)
- return l.GetStaffSubscribeList(in)
- }
- // 查看企业员工用户订阅详情
- func (s *BxsubscribeServer) GetStaffSubscribeDetail(ctx context.Context, in *bxsubscribe.StaffSubscribeDetailReq) (*bxsubscribe.StaffSubscribeDetail, error) {
- l := logic.NewGetStaffSubscribeDetailLogic(ctx, s.svcCtx)
- return l.GetStaffSubscribeDetail(in)
- }
- // 标讯信息分发
- func (s *BxsubscribeServer) BidDistributor(ctx context.Context, in *bxsubscribe.BidDistributorReq) (*bxsubscribe.StatusResp, error) {
- l := logic.NewBidDistributorLogic(ctx, s.svcCtx)
- return l.BidDistributor(in)
- }
- // 订阅推荐列表
- func (s *BxsubscribeServer) BidRecList(ctx context.Context, in *bxsubscribe.BidRecListReq) (*bxsubscribe.SubscribeInfosResp, error) {
- l := logic.NewBidRecListLogic(ctx, s.svcCtx)
- return l.BidRecList(in)
- }
- // 保存订阅向导设置
- func (s *BxsubscribeServer) SaveTSGuide(ctx context.Context, in *bxsubscribe.SaveTSGuideReq) (*bxsubscribe.StatusResp, error) {
- l := logic.NewSaveTSGuideLogic(ctx, s.svcCtx)
- return l.SaveTSGuide(in)
- }
|