// Code generated by goctl. DO NOT EDIT!
// Source: bxsubscribe.proto

package server

import (
	"context"

	"jyBXSubscribe/rpc/internal/logic"
	"jyBXSubscribe/rpc/internal/svc"
	"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) DeriveShow(ctx context.Context, in *bxsubscribe.DeriveReq) (*bxsubscribe.DeriveRes, error) {
	l := logic.NewDeriveShowLogic(ctx, s.svcCtx)
	return l.DeriveShow(in)
}

// 删除自动数据导出筛选条件
func (s *BxsubscribeServer) DeriveDel(ctx context.Context, in *bxsubscribe.DeriveReq) (*bxsubscribe.StatusResp, error) {
	l := logic.NewDeriveDelLogic(ctx, s.svcCtx)
	return l.DeriveDel(in)
}