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