share

api/ai/ai.proto

@@ -107,14 +107,40 @@ service Ai {
   // 用户已读
   rpc GetIsRead (GetIsReadRequest) returns (google.protobuf.Empty){};
   
-  // 获取AI信息
+  // 获取AI升级信息
   rpc GetAIShareMessage (GetAIShareMessageRequest) returns (GetAIShareMessageReply){
     option (google.api.http) = {
       post: "/api/share/ai/message",
       body:"*"
     };
   };
+  // 获取二维码
+  rpc GetShareQrcode (GetAIShareMessageRequest) returns (GetShareQrcodeReply){
+    option (google.api.http) = {
+      post: "/api/share/ai/qrcode",
+      body:"*"
+    };
+  };
+  // 保存视频链接
+  rpc SetVideoLink (SetVideoLinkRequest) returns (google.protobuf.Empty){
+    option (google.api.http) = {
+      post: "/api/share/ai/link",
+      body:"*"
+    };
+  };
+  // 用户受到邀请
+  rpc ShareUserInto (GetAIShareMessageRequest) returns (google.protobuf.Empty){};
+}
+
+message SetVideoLinkRequest{
+  string videoUrl = 1;
+  string pictureUrl = 2;
 }
+
+message GetShareQrcodeReply{
+  string qrcodeUrl = 1;
+}
+
 message GetAIShareMessageRequest{
   string userId = 1;// 用户ID
   int64 robotId = 2;// 机器人ID

api/ai/ai_grpc.pb.go

@@ -49,8 +49,14 @@ type AiClient interface {
 	CronAdditionalService(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
 	// 用户已读
 	GetIsRead(ctx context.Context, in *GetIsReadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
-	// 获取AI信息
+	// 获取AI升级信息
 	GetAIShareMessage(ctx context.Context, in *GetAIShareMessageRequest, opts ...grpc.CallOption) (*GetAIShareMessageReply, error)
+	// 获取二维码
+	GetShareQrcode(ctx context.Context, in *GetAIShareMessageRequest, opts ...grpc.CallOption) (*GetShareQrcodeReply, error)
+	// 保存视频链接
+	SetVideoLink(ctx context.Context, in *SetVideoLinkRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
+	// 用户受到邀请
+	ShareUserInto(ctx context.Context, in *GetAIShareMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
 }
 
 type aiClient struct {
@@ -205,6 +211,33 @@ func (c *aiClient) GetAIShareMessage(ctx context.Context, in *GetAIShareMessageR
 	return out, nil
 }
 
+func (c *aiClient) GetShareQrcode(ctx context.Context, in *GetAIShareMessageRequest, opts ...grpc.CallOption) (*GetShareQrcodeReply, error) {
+	out := new(GetShareQrcodeReply)
+	err := c.cc.Invoke(ctx, "/api.ai.Ai/GetShareQrcode", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *aiClient) SetVideoLink(ctx context.Context, in *SetVideoLinkRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
+	out := new(emptypb.Empty)
+	err := c.cc.Invoke(ctx, "/api.ai.Ai/SetVideoLink", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *aiClient) ShareUserInto(ctx context.Context, in *GetAIShareMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
+	out := new(emptypb.Empty)
+	err := c.cc.Invoke(ctx, "/api.ai.Ai/ShareUserInto", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
 // AiServer is the server API for Ai service.
 // All implementations must embed UnimplementedAiServer
 // for forward compatibility
@@ -239,8 +272,14 @@ type AiServer interface {
 	CronAdditionalService(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
 	// 用户已读
 	GetIsRead(context.Context, *GetIsReadRequest) (*emptypb.Empty, error)
-	// 获取AI信息
+	// 获取AI升级信息
 	GetAIShareMessage(context.Context, *GetAIShareMessageRequest) (*GetAIShareMessageReply, error)
+	// 获取二维码
+	GetShareQrcode(context.Context, *GetAIShareMessageRequest) (*GetShareQrcodeReply, error)
+	// 保存视频链接
+	SetVideoLink(context.Context, *SetVideoLinkRequest) (*emptypb.Empty, error)
+	// 用户受到邀请
+	ShareUserInto(context.Context, *GetAIShareMessageRequest) (*emptypb.Empty, error)
 	mustEmbedUnimplementedAiServer()
 }
 
@@ -296,6 +335,15 @@ func (UnimplementedAiServer) GetIsRead(context.Context, *GetIsReadRequest) (*emp
 func (UnimplementedAiServer) GetAIShareMessage(context.Context, *GetAIShareMessageRequest) (*GetAIShareMessageReply, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method GetAIShareMessage not implemented")
 }
+func (UnimplementedAiServer) GetShareQrcode(context.Context, *GetAIShareMessageRequest) (*GetShareQrcodeReply, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetShareQrcode not implemented")
+}
+func (UnimplementedAiServer) SetVideoLink(context.Context, *SetVideoLinkRequest) (*emptypb.Empty, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method SetVideoLink not implemented")
+}
+func (UnimplementedAiServer) ShareUserInto(context.Context, *GetAIShareMessageRequest) (*emptypb.Empty, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method ShareUserInto not implemented")
+}
 func (UnimplementedAiServer) mustEmbedUnimplementedAiServer() {}
 
 // UnsafeAiServer may be embedded to opt out of forward compatibility for this service.
@@ -597,6 +645,60 @@ func _Ai_GetAIShareMessage_Handler(srv interface{}, ctx context.Context, dec fun
 	return interceptor(ctx, in, info, handler)
 }
 
+func _Ai_GetShareQrcode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetAIShareMessageRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(AiServer).GetShareQrcode(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/api.ai.Ai/GetShareQrcode",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(AiServer).GetShareQrcode(ctx, req.(*GetAIShareMessageRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Ai_SetVideoLink_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(SetVideoLinkRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(AiServer).SetVideoLink(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/api.ai.Ai/SetVideoLink",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(AiServer).SetVideoLink(ctx, req.(*SetVideoLinkRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Ai_ShareUserInto_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetAIShareMessageRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(AiServer).ShareUserInto(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/api.ai.Ai/ShareUserInto",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(AiServer).ShareUserInto(ctx, req.(*GetAIShareMessageRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
 // Ai_ServiceDesc is the grpc.ServiceDesc for Ai service.
 // It's only intended for direct use with grpc.RegisterService,
 // and not to be introspected or modified (even as a copy)
@@ -668,6 +770,18 @@ var Ai_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "GetAIShareMessage",
 			Handler:    _Ai_GetAIShareMessage_Handler,
 		},
+		{
+			MethodName: "GetShareQrcode",
+			Handler:    _Ai_GetShareQrcode_Handler,
+		},
+		{
+			MethodName: "SetVideoLink",
+			Handler:    _Ai_SetVideoLink_Handler,
+		},
+		{
+			MethodName: "ShareUserInto",
+			Handler:    _Ai_ShareUserInto_Handler,
+		},
 	},
 	Streams:  []grpc.StreamDesc{},
 	Metadata: "ai.proto",

api/ai/ai_http.pb.go

@@ -38,7 +38,9 @@ type AiHTTPServer interface {
 	GetAIRobot(context.Context, *AIRobotIDRequest) (*AIRobotInfo, error)
 	GetAIShareMessage(context.Context, *GetAIShareMessageRequest) (*GetAIShareMessageReply, error)
 	GetAdditionalService(context.Context, *GetAdditionalServiceRequest) (*GetAdditionalServiceReply, error)
+	GetShareQrcode(context.Context, *GetAIShareMessageRequest) (*GetShareQrcodeReply, error)
 	SendAIChat(context.Context, *SendAIChatRequest) (*emptypb.Empty, error)
+	SetVideoLink(context.Context, *SetVideoLinkRequest) (*emptypb.Empty, error)
 	UpdateAIRobot(context.Context, *UpdateAIRobotRequest) (*AIRobotIDReply, error)
 	UpdateAdditionalService(context.Context, *UpdateAdditionalServiceRequest) (*emptypb.Empty, error)
 }
@@ -59,6 +61,8 @@ func RegisterAiHTTPServer(s *http.Server, srv AiHTTPServer) {
 	r.POST("/api/ai/service/update", _Ai_UpdateAdditionalService0_HTTP_Handler(srv))
 	r.POST("/api/ai/message", _Ai_FindUserAIMessage0_HTTP_Handler(srv))
 	r.POST("/api/share/ai/message", _Ai_GetAIShareMessage0_HTTP_Handler(srv))
+	r.POST("/api/share/ai/qrcode", _Ai_GetShareQrcode0_HTTP_Handler(srv))
+	r.POST("/api/share/ai/link", _Ai_SetVideoLink0_HTTP_Handler(srv))
 }
 
 func _Ai_FindAITemplate0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
@@ -439,6 +443,60 @@ func _Ai_GetAIShareMessage0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context
 	}
 }
 
+func _Ai_GetShareQrcode0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
+	return func(ctx http.Context) error {
+		var in GetAIShareMessageRequest
+		if err := ctx.Bind(&in); err != nil {
+			return err
+		}
+		if err := ctx.BindQuery(&in); err != nil {
+			return err
+		}
+		http.SetOperation(ctx, "/api.ai.Ai/GetShareQrcode")
+		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
+			return srv.GetShareQrcode(ctx, req.(*GetAIShareMessageRequest))
+		})
+		out, err := h(ctx, &in)
+		if err != nil {
+			return err
+		}
+		success := &reply.SuccessReply{
+			Code: 0,
+		}
+		if out != nil {
+			success.Data = out
+		}
+		return ctx.Result(200, success)
+	}
+}
+
+func _Ai_SetVideoLink0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
+	return func(ctx http.Context) error {
+		var in SetVideoLinkRequest
+		if err := ctx.Bind(&in); err != nil {
+			return err
+		}
+		if err := ctx.BindQuery(&in); err != nil {
+			return err
+		}
+		http.SetOperation(ctx, "/api.ai.Ai/SetVideoLink")
+		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
+			return srv.SetVideoLink(ctx, req.(*SetVideoLinkRequest))
+		})
+		out, err := h(ctx, &in)
+		if err != nil {
+			return err
+		}
+		success := &reply.SuccessReply{
+			Code: 0,
+		}
+		if out != nil {
+			success.Data = out
+		}
+		return ctx.Result(200, success)
+	}
+}
+
 type AiHTTPClient interface {
 	CreateAIRobot(ctx context.Context, req *CreateAIRobotRequest, opts ...http.CallOption) (rsp *AIRobotIDReply, err error)
 	CreateAdditionalService(ctx context.Context, req *CreateAdditionalServiceRequest, opts ...http.CallOption) (rsp *CreateAdditionalServiceReply, err error)
@@ -451,7 +509,9 @@ type AiHTTPClient interface {
 	GetAIRobot(ctx context.Context, req *AIRobotIDRequest, opts ...http.CallOption) (rsp *AIRobotInfo, err error)
 	GetAIShareMessage(ctx context.Context, req *GetAIShareMessageRequest, opts ...http.CallOption) (rsp *GetAIShareMessageReply, err error)
 	GetAdditionalService(ctx context.Context, req *GetAdditionalServiceRequest, opts ...http.CallOption) (rsp *GetAdditionalServiceReply, err error)
+	GetShareQrcode(ctx context.Context, req *GetAIShareMessageRequest, opts ...http.CallOption) (rsp *GetShareQrcodeReply, err error)
 	SendAIChat(ctx context.Context, req *SendAIChatRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
+	SetVideoLink(ctx context.Context, req *SetVideoLinkRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
 	UpdateAIRobot(ctx context.Context, req *UpdateAIRobotRequest, opts ...http.CallOption) (rsp *AIRobotIDReply, err error)
 	UpdateAdditionalService(ctx context.Context, req *UpdateAdditionalServiceRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
 }
@@ -607,6 +667,19 @@ func (c *AiHTTPClientImpl) GetAdditionalService(ctx context.Context, in *GetAddi
 	return &out, err
 }
 
+func (c *AiHTTPClientImpl) GetShareQrcode(ctx context.Context, in *GetAIShareMessageRequest, opts ...http.CallOption) (*GetShareQrcodeReply, error) {
+	var out GetShareQrcodeReply
+	pattern := "/api/share/ai/qrcode"
+	path := binding.EncodeURL(pattern, in, false)
+	opts = append(opts, http.Operation("/api.ai.Ai/GetShareQrcode"))
+	opts = append(opts, http.PathTemplate(pattern))
+	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return &out, err
+}
+
 func (c *AiHTTPClientImpl) SendAIChat(ctx context.Context, in *SendAIChatRequest, opts ...http.CallOption) (*emptypb.Empty, error) {
 	var out emptypb.Empty
 	pattern := "/api/ai/send"
@@ -620,6 +693,19 @@ func (c *AiHTTPClientImpl) SendAIChat(ctx context.Context, in *SendAIChatRequest
 	return &out, err
 }
 
+func (c *AiHTTPClientImpl) SetVideoLink(ctx context.Context, in *SetVideoLinkRequest, opts ...http.CallOption) (*emptypb.Empty, error) {
+	var out emptypb.Empty
+	pattern := "/api/share/ai/link"
+	path := binding.EncodeURL(pattern, in, false)
+	opts = append(opts, http.Operation("/api.ai.Ai/SetVideoLink"))
+	opts = append(opts, http.PathTemplate(pattern))
+	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return &out, err
+}
+
 func (c *AiHTTPClientImpl) UpdateAIRobot(ctx context.Context, in *UpdateAIRobotRequest, opts ...http.CallOption) (*AIRobotIDReply, error) {
 	var out AIRobotIDReply
 	pattern := "/api/ai/update"

js/api/ai/ai_http_pb.ts

@@ -1,6 +1,6 @@
 // @ts-ignore
 import request from '@/libs/request';
-import {FindAITemplateRequest,FindAITemplateReply,CreateAIRobotRequest,AIRobotIDReply,AIRobotIDRequest,UpdateAIRobotRequest,FindAIRobotListRequest,AIRobotList,AIRobotInfo,FindAIChatRecordListRequest,AIRecordListReply,SendAIChatRequest,FindAdditionalServiceTemplateListReply,GetAdditionalServiceRequest,GetAdditionalServiceReply,CreateAdditionalServiceRequest,CreateAdditionalServiceReply,UpdateAdditionalServiceRequest,FindUserAIMessageReply,GetIsReadRequest,GetAIShareMessageRequest,GetAIShareMessageReply} from "./ai_pb";
+import {FindAITemplateRequest,FindAITemplateReply,CreateAIRobotRequest,AIRobotIDReply,AIRobotIDRequest,UpdateAIRobotRequest,FindAIRobotListRequest,AIRobotList,AIRobotInfo,FindAIChatRecordListRequest,AIRecordListReply,SendAIChatRequest,FindAdditionalServiceTemplateListReply,GetAdditionalServiceRequest,GetAdditionalServiceReply,CreateAdditionalServiceRequest,CreateAdditionalServiceReply,UpdateAdditionalServiceRequest,FindUserAIMessageReply,GetIsReadRequest,GetAIShareMessageRequest,GetAIShareMessageReply,GetShareQrcodeReply,SetVideoLinkRequest} from "./ai_pb";
 
 const AiService = {
   /**  查询AI模板 */
@@ -68,11 +68,21 @@ const AiService = {
 	const res = await request.post<{ data: FindUserAIMessageReply, code: string, message: string }>('/api/ai/message', req);
     return res.data.data;
   },
-  /**  获取AI信息 */
+  /**  获取AI升级信息 */
   GetAIShareMessage: async (req?: GetAIShareMessageRequest) => {
 	const res = await request.post<{ data: GetAIShareMessageReply, code: string, message: string }>('/api/share/ai/message', req);
     return res.data.data;
   },
+  /**  获取二维码 */
+  GetShareQrcode: async (req?: GetAIShareMessageRequest) => {
+	const res = await request.post<{ data: GetShareQrcodeReply, code: string, message: string }>('/api/share/ai/qrcode', req);
+    return res.data.data;
+  },
+  /**  保存视频链接 */
+  SetVideoLink: async (req?: SetVideoLinkRequest) => {
+	const res = await request.post('/api/share/ai/link', req);
+    return res.data.data;
+  },
 
 };
 

js/api/ai/ai_pb.ts

@@ -1,3 +1,10 @@
+export interface SetVideoLinkRequest{
+    videoUrl?:string;
+    pictureUrl?:string;
+}
+export interface GetShareQrcodeReply{
+    qrcodeUrl?:string;
+}
 export interface GetAIShareMessageRequest{
     /**  用户ID */
     userId?:string;