|
|
@@ -1,210 +0,0 @@
|
|
|
-// 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