AIShareInfo

api/ai/ai.proto

@@ -106,6 +106,38 @@ service Ai {
   rpc CronAdditionalService (google.protobuf.Empty) returns (google.protobuf.Empty){};
   // 用户已读
   rpc GetIsRead (GetIsReadRequest) returns (google.protobuf.Empty){};
+  
+  // 获取AI信息
+  rpc GetAIShareMessage (GetAIShareMessageRequest) returns (GetAIShareMessageReply){
+    option (google.api.http) = {
+      post: "/api/share/ai/message",
+      body:"*"
+    };
+  };
+}
+message GetAIShareMessageRequest{
+  string userId = 1;// 用户ID
+  int64 robotId = 2;// 机器人ID
+}
+
+message GetAIShareMessageReply{
+  int64 expirationTime = 1;// 过期时间
+  repeated AIShareInfo list = 2;
+
+}
+
+message AIShareInfo{
+  string title = 1;// 标题
+  int64 price = 2;// 价格
+  int64 originPrice = 3;// 原价
+  string description = 4;// 描述
+  string topLabel = 5;// 上面的标签 （例：限时免费）
+  string underShowLabel = 6;// 下面的标签 （例：发短视频）
+  string underHideLabel = 7;// 下面的标签 （例：点赞两次）
+  bool isVip = 8;// 是否是vip
+  int64 num = 9; // 分享数、点赞数
+  string numDescription = 10;// num的描述
+  bool isFinish = 11;// 是否完成
 }
 
 message FindUserAIMessageReply{
@@ -190,7 +222,7 @@ message Message{
 
 message SendAIChatRequest{
   int64 id = 1;
-  string message = 2;// 消息
+  Message message = 2; // 消息
   string messageType = 3;// 消息类型
   string websocketTag = 4;
 }

api/ai/ai_grpc.pb.go

@@ -49,6 +49,8 @@ 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信息
+	GetAIShareMessage(ctx context.Context, in *GetAIShareMessageRequest, opts ...grpc.CallOption) (*GetAIShareMessageReply, error)
 }
 
 type aiClient struct {
@@ -194,6 +196,15 @@ func (c *aiClient) GetIsRead(ctx context.Context, in *GetIsReadRequest, opts ...
 	return out, nil
 }
 
+func (c *aiClient) GetAIShareMessage(ctx context.Context, in *GetAIShareMessageRequest, opts ...grpc.CallOption) (*GetAIShareMessageReply, error) {
+	out := new(GetAIShareMessageReply)
+	err := c.cc.Invoke(ctx, "/api.ai.Ai/GetAIShareMessage", 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
@@ -228,6 +239,8 @@ type AiServer interface {
 	CronAdditionalService(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
 	// 用户已读
 	GetIsRead(context.Context, *GetIsReadRequest) (*emptypb.Empty, error)
+	// 获取AI信息
+	GetAIShareMessage(context.Context, *GetAIShareMessageRequest) (*GetAIShareMessageReply, error)
 	mustEmbedUnimplementedAiServer()
 }
 
@@ -280,6 +293,9 @@ func (UnimplementedAiServer) CronAdditionalService(context.Context, *emptypb.Emp
 func (UnimplementedAiServer) GetIsRead(context.Context, *GetIsReadRequest) (*emptypb.Empty, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method GetIsRead not implemented")
 }
+func (UnimplementedAiServer) GetAIShareMessage(context.Context, *GetAIShareMessageRequest) (*GetAIShareMessageReply, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetAIShareMessage not implemented")
+}
 func (UnimplementedAiServer) mustEmbedUnimplementedAiServer() {}
 
 // UnsafeAiServer may be embedded to opt out of forward compatibility for this service.
@@ -563,6 +579,24 @@ func _Ai_GetIsRead_Handler(srv interface{}, ctx context.Context, dec func(interf
 	return interceptor(ctx, in, info, handler)
 }
 
+func _Ai_GetAIShareMessage_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).GetAIShareMessage(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/api.ai.Ai/GetAIShareMessage",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(AiServer).GetAIShareMessage(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)
@@ -630,6 +664,10 @@ var Ai_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "GetIsRead",
 			Handler:    _Ai_GetIsRead_Handler,
 		},
+		{
+			MethodName: "GetAIShareMessage",
+			Handler:    _Ai_GetAIShareMessage_Handler,
+		},
 	},
 	Streams:  []grpc.StreamDesc{},
 	Metadata: "ai.proto",

api/ai/ai_http.pb.go

@@ -36,6 +36,7 @@ type AiHTTPServer interface {
 	FindAdditionalServiceTemplateList(context.Context, *emptypb.Empty) (*FindAdditionalServiceTemplateListReply, error)
 	FindUserAIMessage(context.Context, *emptypb.Empty) (*FindUserAIMessageReply, error)
 	GetAIRobot(context.Context, *AIRobotIDRequest) (*AIRobotInfo, error)
+	GetAIShareMessage(context.Context, *GetAIShareMessageRequest) (*GetAIShareMessageReply, error)
 	GetAdditionalService(context.Context, *GetAdditionalServiceRequest) (*GetAdditionalServiceReply, error)
 	SendAIChat(context.Context, *SendAIChatRequest) (*emptypb.Empty, error)
 	UpdateAIRobot(context.Context, *UpdateAIRobotRequest) (*AIRobotIDReply, error)
@@ -57,6 +58,7 @@ func RegisterAiHTTPServer(s *http.Server, srv AiHTTPServer) {
 	r.POST("/api/ai/service/create", _Ai_CreateAdditionalService0_HTTP_Handler(srv))
 	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))
 }
 
 func _Ai_FindAITemplate0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
@@ -410,6 +412,33 @@ func _Ai_FindUserAIMessage0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context
 	}
 }
 
+func _Ai_GetAIShareMessage0_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/GetAIShareMessage")
+		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
+			return srv.GetAIShareMessage(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)
+	}
+}
+
 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)
@@ -420,6 +449,7 @@ type AiHTTPClient interface {
 	FindAdditionalServiceTemplateList(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *FindAdditionalServiceTemplateListReply, err error)
 	FindUserAIMessage(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *FindUserAIMessageReply, err error)
 	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)
 	SendAIChat(ctx context.Context, req *SendAIChatRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
 	UpdateAIRobot(ctx context.Context, req *UpdateAIRobotRequest, opts ...http.CallOption) (rsp *AIRobotIDReply, err error)
@@ -551,6 +581,19 @@ func (c *AiHTTPClientImpl) GetAIRobot(ctx context.Context, in *AIRobotIDRequest,
 	return &out, err
 }
 
+func (c *AiHTTPClientImpl) GetAIShareMessage(ctx context.Context, in *GetAIShareMessageRequest, opts ...http.CallOption) (*GetAIShareMessageReply, error) {
+	var out GetAIShareMessageReply
+	pattern := "/api/share/ai/message"
+	path := binding.EncodeURL(pattern, in, false)
+	opts = append(opts, http.Operation("/api.ai.Ai/GetAIShareMessage"))
+	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) GetAdditionalService(ctx context.Context, in *GetAdditionalServiceRequest, opts ...http.CallOption) (*GetAdditionalServiceReply, error) {
 	var out GetAdditionalServiceReply
 	pattern := "/api/ai/service/get"

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} 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} from "./ai_pb";
 
 const AiService = {
   /**  查询AI模板 */
@@ -68,6 +68,11 @@ const AiService = {
 	const res = await request.post<{ data: FindUserAIMessageReply, code: string, message: string }>('/api/ai/message', req);
     return res.data.data;
   },
+  /**  获取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;
+  },
 
 };
 

js/api/ai/ai_pb.ts

@@ -1,3 +1,38 @@
+export interface GetAIShareMessageRequest{
+    /**  用户ID */
+    userId?:string;
+    /**  机器人ID */
+    robotId?:number;
+}
+export interface GetAIShareMessageReply{
+    /**  过期时间 */
+    expirationTime?:number;
+    list?:Array<AIShareInfo>;
+}
+export interface AIShareInfo{
+    /**  标题 */
+    title?:string;
+    /**  价格 */
+    price?:number;
+    /**  原价 */
+    originPrice?:number;
+    /**  描述 */
+    description?:string;
+    /**  上面的标签 （例：限时免费） */
+    topLabel?:string;
+    /**  下面的标签 （例：发短视频） */
+    underShowLabel?:string;
+    /**  下面的标签 （例：点赞两次） */
+    underHideLabel?:string;
+    /**  是否是vip */
+    isVip?:boolean;
+    /**  分享数、点赞数 */
+    num?:number;
+    /**  num的描述 */
+    numDescription?:string;
+    /**  是否完成 */
+    isFinish?:boolean;
+}
 export interface FindUserAIMessageReply{
     /**  创建是否免费 */
     isFree?:boolean;
@@ -98,7 +133,7 @@ export interface Message{
 export interface SendAIChatRequest{
     id?:number;
     /**  消息 */
-    message?:string;
+    message?:Message;
     /**  消息类型 */
     messageType?:string;
     websocketTag?:string;