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