|
|
@@ -0,0 +1,210 @@
|
|
|
+// Code generated by goctl. DO NOT EDIT.
|
|
|
+// Source: bxsubscribe.proto
|
|
|
+
|
|
|
+package bxsubscribeclient
|
|
|
+
|
|
|
+import (
|
|
|
+ "context"
|
|
|
+
|
|
|
+ "jyBXSubscribe/rpc/type/bxsubscribe"
|
|
|
+
|
|
|
+ "github.com/zeromicro/go-zero/zrpc"
|
|
|
+ "google.golang.org/grpc"
|
|
|
+)
|
|
|
+
|
|
|
+type (
|
|
|
+ BidDistributorReq = bxsubscribe.BidDistributorReq
|
|
|
+ ByPushHistoryResp = bxsubscribe.ByPushHistoryResp
|
|
|
+ CityList = bxsubscribe.CityList
|
|
|
+ DistributorResp = bxsubscribe.DistributorResp
|
|
|
+ GetDistributorReq = bxsubscribe.GetDistributorReq
|
|
|
+ GetKeyReq = bxsubscribe.GetKeyReq
|
|
|
+ GetPushSetReq = bxsubscribe.GetPushSetReq
|
|
|
+ GetPushSetResp = bxsubscribe.GetPushSetResp
|
|
|
+ GetUserInfo = bxsubscribe.GetUserInfo
|
|
|
+ GetUserInfoReq = bxsubscribe.GetUserInfoReq
|
|
|
+ GetUserInfoResq = bxsubscribe.GetUserInfoResq
|
|
|
+ GetViewStatusReq = bxsubscribe.GetViewStatusReq
|
|
|
+ Items = bxsubscribe.Items
|
|
|
+ Key = bxsubscribe.Key
|
|
|
+ KeyItems = bxsubscribe.KeyItems
|
|
|
+ KeyResp = bxsubscribe.KeyResp
|
|
|
+ Keys = bxsubscribe.Keys
|
|
|
+ List = bxsubscribe.List
|
|
|
+ MsgDistributorReq = bxsubscribe.MsgDistributorReq
|
|
|
+ PushSet = bxsubscribe.PushSet
|
|
|
+ SetPushSetReq = bxsubscribe.SetPushSetReq
|
|
|
+ SetReadReq = bxsubscribe.SetReadReq
|
|
|
+ SetUserInfoReq = bxsubscribe.SetUserInfoReq
|
|
|
+ SomeInfo = bxsubscribe.SomeInfo
|
|
|
+ SomeInfoReq = bxsubscribe.SomeInfoReq
|
|
|
+ SomeInfoResp = bxsubscribe.SomeInfoResp
|
|
|
+ StaffSubscribe = bxsubscribe.StaffSubscribe
|
|
|
+ StaffSubscribeDetail = bxsubscribe.StaffSubscribeDetail
|
|
|
+ StaffSubscribeDetailReq = bxsubscribe.StaffSubscribeDetailReq
|
|
|
+ StaffSubscribeListResp = bxsubscribe.StaffSubscribeListResp
|
|
|
+ StaffSubscribeReq = bxsubscribe.StaffSubscribeReq
|
|
|
+ StatusResp = bxsubscribe.StatusResp
|
|
|
+ Subscribe = bxsubscribe.Subscribe
|
|
|
+ SubscribeData = bxsubscribe.SubscribeData
|
|
|
+ SubscribeInfo = bxsubscribe.SubscribeInfo
|
|
|
+ SubscribeInfosReq = bxsubscribe.SubscribeInfosReq
|
|
|
+ SubscribeInfosResp = bxsubscribe.SubscribeInfosResp
|
|
|
+ TimeJson = bxsubscribe.TimeJson
|
|
|
+ UpdateSubScribeInfoReq = bxsubscribe.UpdateSubScribeInfoReq
|
|
|
+ UserReq = bxsubscribe.UserReq
|
|
|
+ UserResp = bxsubscribe.UserResp
|
|
|
+ UserResq = bxsubscribe.UserResq
|
|
|
+ UserStatus = bxsubscribe.UserStatus
|
|
|
+ ViewStatusResp = bxsubscribe.ViewStatusResp
|
|
|
+ WinnerInfo = bxsubscribe.WinnerInfo
|
|
|
+
|
|
|
+ Bxsubscribe interface {
|
|
|
+ // 获取订阅推送列表
|
|
|
+ GetSubList(ctx context.Context, in *SubscribeInfosReq, opts ...grpc.CallOption) (*SubscribeInfosResp, error)
|
|
|
+ // 获取订阅推送相关信息
|
|
|
+ GetSubSomeInfo(ctx context.Context, in *SomeInfoReq, opts ...grpc.CallOption) (*SomeInfoResp, error)
|
|
|
+ // 修改订阅信息接口
|
|
|
+ UpdateSubScribeInfo(ctx context.Context, in *UpdateSubScribeInfoReq, opts ...grpc.CallOption) (*StatusResp, error)
|
|
|
+ // 推送页面筛选导出
|
|
|
+ ByPushHistory(ctx context.Context, in *SubscribeInfosReq, opts ...grpc.CallOption) (*ByPushHistoryResp, error)
|
|
|
+ // 推送数据浏览状态修改
|
|
|
+ SetRead(ctx context.Context, in *SetReadReq, opts ...grpc.CallOption) (*StatusResp, error)
|
|
|
+ // 关键词获取
|
|
|
+ GetKey(ctx context.Context, in *GetKeyReq, opts ...grpc.CallOption) (*KeyResp, error)
|
|
|
+ // 订阅设置获取
|
|
|
+ GetSubScribeInfo(ctx context.Context, in *UserReq, opts ...grpc.CallOption) (*UserResq, error)
|
|
|
+ // 信息分发
|
|
|
+ MsgDistributor(ctx context.Context, in *MsgDistributorReq, opts ...grpc.CallOption) (*StatusResp, error)
|
|
|
+ // 手动分发人员查询
|
|
|
+ GetDistributor(ctx context.Context, in *GetDistributorReq, opts ...grpc.CallOption) (*DistributorResp, error)
|
|
|
+ // 查看状态
|
|
|
+ GetViewStatus(ctx context.Context, in *GetViewStatusReq, opts ...grpc.CallOption) (*ViewStatusResp, error)
|
|
|
+ // 用户推送信息查看
|
|
|
+ UserInfo(ctx context.Context, in *GetUserInfoReq, opts ...grpc.CallOption) (*GetUserInfoResq, error)
|
|
|
+ // 用户邮箱保存
|
|
|
+ SetUser(ctx context.Context, in *SetUserInfoReq, opts ...grpc.CallOption) (*StatusResp, error)
|
|
|
+ // 用户推送设置查看
|
|
|
+ GetPushSet(ctx context.Context, in *GetPushSetReq, opts ...grpc.CallOption) (*GetPushSetResp, error)
|
|
|
+ // 用户推送设置修改
|
|
|
+ SetPushSet(ctx context.Context, in *SetPushSetReq, opts ...grpc.CallOption) (*StatusResp, error)
|
|
|
+ // 查看企业员工用户订阅
|
|
|
+ GetStaffSubscribeList(ctx context.Context, in *StaffSubscribeReq, opts ...grpc.CallOption) (*StaffSubscribeListResp, error)
|
|
|
+ // 查看企业员工用户订阅详情
|
|
|
+ GetStaffSubscribeDetail(ctx context.Context, in *StaffSubscribeDetailReq, opts ...grpc.CallOption) (*StaffSubscribeDetail, error)
|
|
|
+ // 标讯信息分发
|
|
|
+ BidDistributor(ctx context.Context, in *BidDistributorReq, opts ...grpc.CallOption) (*StatusResp, error)
|
|
|
+ }
|
|
|
+
|
|
|
+ defaultBxsubscribe struct {
|
|
|
+ cli zrpc.Client
|
|
|
+ }
|
|
|
+)
|
|
|
+
|
|
|
+func NewBxsubscribe(cli zrpc.Client) Bxsubscribe {
|
|
|
+ return &defaultBxsubscribe{
|
|
|
+ cli: cli,
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+// 获取订阅推送列表
|
|
|
+func (m *defaultBxsubscribe) GetSubList(ctx context.Context, in *SubscribeInfosReq, opts ...grpc.CallOption) (*SubscribeInfosResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.GetSubList(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 获取订阅推送相关信息
|
|
|
+func (m *defaultBxsubscribe) GetSubSomeInfo(ctx context.Context, in *SomeInfoReq, opts ...grpc.CallOption) (*SomeInfoResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.GetSubSomeInfo(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 修改订阅信息接口
|
|
|
+func (m *defaultBxsubscribe) UpdateSubScribeInfo(ctx context.Context, in *UpdateSubScribeInfoReq, opts ...grpc.CallOption) (*StatusResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.UpdateSubScribeInfo(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 推送页面筛选导出
|
|
|
+func (m *defaultBxsubscribe) ByPushHistory(ctx context.Context, in *SubscribeInfosReq, opts ...grpc.CallOption) (*ByPushHistoryResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.ByPushHistory(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 推送数据浏览状态修改
|
|
|
+func (m *defaultBxsubscribe) SetRead(ctx context.Context, in *SetReadReq, opts ...grpc.CallOption) (*StatusResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.SetRead(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 关键词获取
|
|
|
+func (m *defaultBxsubscribe) GetKey(ctx context.Context, in *GetKeyReq, opts ...grpc.CallOption) (*KeyResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.GetKey(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 订阅设置获取
|
|
|
+func (m *defaultBxsubscribe) GetSubScribeInfo(ctx context.Context, in *UserReq, opts ...grpc.CallOption) (*UserResq, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.GetSubScribeInfo(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 信息分发
|
|
|
+func (m *defaultBxsubscribe) MsgDistributor(ctx context.Context, in *MsgDistributorReq, opts ...grpc.CallOption) (*StatusResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.MsgDistributor(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 手动分发人员查询
|
|
|
+func (m *defaultBxsubscribe) GetDistributor(ctx context.Context, in *GetDistributorReq, opts ...grpc.CallOption) (*DistributorResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.GetDistributor(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 查看状态
|
|
|
+func (m *defaultBxsubscribe) GetViewStatus(ctx context.Context, in *GetViewStatusReq, opts ...grpc.CallOption) (*ViewStatusResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.GetViewStatus(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 用户推送信息查看
|
|
|
+func (m *defaultBxsubscribe) UserInfo(ctx context.Context, in *GetUserInfoReq, opts ...grpc.CallOption) (*GetUserInfoResq, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.UserInfo(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 用户邮箱保存
|
|
|
+func (m *defaultBxsubscribe) SetUser(ctx context.Context, in *SetUserInfoReq, opts ...grpc.CallOption) (*StatusResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.SetUser(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 用户推送设置查看
|
|
|
+func (m *defaultBxsubscribe) GetPushSet(ctx context.Context, in *GetPushSetReq, opts ...grpc.CallOption) (*GetPushSetResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.GetPushSet(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 用户推送设置修改
|
|
|
+func (m *defaultBxsubscribe) SetPushSet(ctx context.Context, in *SetPushSetReq, opts ...grpc.CallOption) (*StatusResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.SetPushSet(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 查看企业员工用户订阅
|
|
|
+func (m *defaultBxsubscribe) GetStaffSubscribeList(ctx context.Context, in *StaffSubscribeReq, opts ...grpc.CallOption) (*StaffSubscribeListResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.GetStaffSubscribeList(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 查看企业员工用户订阅详情
|
|
|
+func (m *defaultBxsubscribe) GetStaffSubscribeDetail(ctx context.Context, in *StaffSubscribeDetailReq, opts ...grpc.CallOption) (*StaffSubscribeDetail, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.GetStaffSubscribeDetail(ctx, in, opts...)
|
|
|
+}
|
|
|
+
|
|
|
+// 标讯信息分发
|
|
|
+func (m *defaultBxsubscribe) BidDistributor(ctx context.Context, in *BidDistributorReq, opts ...grpc.CallOption) (*StatusResp, error) {
|
|
|
+ client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
|
|
|
+ return client.BidDistributor(ctx, in, opts...)
|
|
|
+}
|
WH01243