提交

jyBXSubscribe/rpc/internal/server/bxsubscribeserver.go

@@ -0,0 +1,83 @@
+// 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)
+}