查询用户的ai信息

api/ai/ai.proto

@@ -95,12 +95,24 @@ service Ai {
       body:"*"
     };
   };
+  // 查询用户的ai信息
+  rpc FindUserAIMessage (google.protobuf.Empty) returns (FindUserAIMessageReply){
+    option (google.api.http) = {
+      post: "/api/ai/message",
+      body:"*"
+    };
+  };
   // 定时执行服务
   rpc CronAdditionalService (google.protobuf.Empty) returns (google.protobuf.Empty){};
   // 用户已读
   rpc GetIsRead (GetIsReadRequest) returns (google.protobuf.Empty){};
 }
 
+message FindUserAIMessageReply{
+  bool isFree = 1;// 创建是否免费
+  int64 unreadNum = 2;// 未读数
+}
+
 message GetIsReadRequest{
   string userId = 1;
   int64 robotId = 2;

api/ai/ai_grpc.pb.go

@@ -43,6 +43,8 @@ type AiClient interface {
 	CreateAdditionalService(ctx context.Context, in *CreateAdditionalServiceRequest, opts ...grpc.CallOption) (*CreateAdditionalServiceReply, error)
 	// 更新额外服务
 	UpdateAdditionalService(ctx context.Context, in *UpdateAdditionalServiceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
+	// 查询用户的ai信息
+	FindUserAIMessage(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FindUserAIMessageReply, error)
 	// 定时执行服务
 	CronAdditionalService(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
 	// 用户已读
@@ -165,6 +167,15 @@ func (c *aiClient) UpdateAdditionalService(ctx context.Context, in *UpdateAdditi
 	return out, nil
 }
 
+func (c *aiClient) FindUserAIMessage(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FindUserAIMessageReply, error) {
+	out := new(FindUserAIMessageReply)
+	err := c.cc.Invoke(ctx, "/api.ai.Ai/FindUserAIMessage", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
 func (c *aiClient) CronAdditionalService(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) {
 	out := new(emptypb.Empty)
 	err := c.cc.Invoke(ctx, "/api.ai.Ai/CronAdditionalService", in, out, opts...)
@@ -211,6 +222,8 @@ type AiServer interface {
 	CreateAdditionalService(context.Context, *CreateAdditionalServiceRequest) (*CreateAdditionalServiceReply, error)
 	// 更新额外服务
 	UpdateAdditionalService(context.Context, *UpdateAdditionalServiceRequest) (*emptypb.Empty, error)
+	// 查询用户的ai信息
+	FindUserAIMessage(context.Context, *emptypb.Empty) (*FindUserAIMessageReply, error)
 	// 定时执行服务
 	CronAdditionalService(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
 	// 用户已读
@@ -258,6 +271,9 @@ func (UnimplementedAiServer) CreateAdditionalService(context.Context, *CreateAdd
 func (UnimplementedAiServer) UpdateAdditionalService(context.Context, *UpdateAdditionalServiceRequest) (*emptypb.Empty, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method UpdateAdditionalService not implemented")
 }
+func (UnimplementedAiServer) FindUserAIMessage(context.Context, *emptypb.Empty) (*FindUserAIMessageReply, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method FindUserAIMessage not implemented")
+}
 func (UnimplementedAiServer) CronAdditionalService(context.Context, *emptypb.Empty) (*emptypb.Empty, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method CronAdditionalService not implemented")
 }
@@ -493,6 +509,24 @@ func _Ai_UpdateAdditionalService_Handler(srv interface{}, ctx context.Context, d
 	return interceptor(ctx, in, info, handler)
 }
 
+func _Ai_FindUserAIMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(emptypb.Empty)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(AiServer).FindUserAIMessage(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/api.ai.Ai/FindUserAIMessage",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(AiServer).FindUserAIMessage(ctx, req.(*emptypb.Empty))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
 func _Ai_CronAdditionalService_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
 	in := new(emptypb.Empty)
 	if err := dec(in); err != nil {
@@ -584,6 +618,10 @@ var Ai_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "UpdateAdditionalService",
 			Handler:    _Ai_UpdateAdditionalService_Handler,
 		},
+		{
+			MethodName: "FindUserAIMessage",
+			Handler:    _Ai_FindUserAIMessage_Handler,
+		},
 		{
 			MethodName: "CronAdditionalService",
 			Handler:    _Ai_CronAdditionalService_Handler,

api/ai/ai_http.pb.go

@@ -34,6 +34,7 @@ type AiHTTPServer interface {
 	FindAIRobotList(context.Context, *FindAIRobotListRequest) (*AIRobotList, error)
 	FindAITemplate(context.Context, *FindAITemplateRequest) (*FindAITemplateReply, error)
 	FindAdditionalServiceTemplateList(context.Context, *emptypb.Empty) (*FindAdditionalServiceTemplateListReply, error)
+	FindUserAIMessage(context.Context, *emptypb.Empty) (*FindUserAIMessageReply, error)
 	GetAIRobot(context.Context, *AIRobotIDRequest) (*AIRobotInfo, error)
 	GetAdditionalService(context.Context, *GetAdditionalServiceRequest) (*GetAdditionalServiceReply, error)
 	SendAIChat(context.Context, *SendAIChatRequest) (*emptypb.Empty, error)
@@ -55,6 +56,7 @@ func RegisterAiHTTPServer(s *http.Server, srv AiHTTPServer) {
 	r.POST("/api/ai/service/get", _Ai_GetAdditionalService0_HTTP_Handler(srv))
 	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))
 }
 
 func _Ai_FindAITemplate0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
@@ -381,6 +383,33 @@ func _Ai_UpdateAdditionalService0_HTTP_Handler(srv AiHTTPServer) func(ctx http.C
 	}
 }
 
+func _Ai_FindUserAIMessage0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
+	return func(ctx http.Context) error {
+		var in emptypb.Empty
+		if err := ctx.Bind(&in); err != nil {
+			return err
+		}
+		if err := ctx.BindQuery(&in); err != nil {
+			return err
+		}
+		http.SetOperation(ctx, "/api.ai.Ai/FindUserAIMessage")
+		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
+			return srv.FindUserAIMessage(ctx, req.(*emptypb.Empty))
+		})
+		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)
@@ -389,6 +418,7 @@ type AiHTTPClient interface {
 	FindAIRobotList(ctx context.Context, req *FindAIRobotListRequest, opts ...http.CallOption) (rsp *AIRobotList, err error)
 	FindAITemplate(ctx context.Context, req *FindAITemplateRequest, opts ...http.CallOption) (rsp *FindAITemplateReply, err error)
 	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)
 	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)
@@ -495,6 +525,19 @@ func (c *AiHTTPClientImpl) FindAdditionalServiceTemplateList(ctx context.Context
 	return &out, err
 }
 
+func (c *AiHTTPClientImpl) FindUserAIMessage(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*FindUserAIMessageReply, error) {
+	var out FindUserAIMessageReply
+	pattern := "/api/ai/message"
+	path := binding.EncodeURL(pattern, in, false)
+	opts = append(opts, http.Operation("/api.ai.Ai/FindUserAIMessage"))
+	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) GetAIRobot(ctx context.Context, in *AIRobotIDRequest, opts ...http.CallOption) (*AIRobotInfo, error) {
 	var out AIRobotInfo
 	pattern := "/api/ai/find/info"

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,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} from "./ai_pb";
 
 const AiService = {
   /**  查询AI模板 */
@@ -63,6 +63,11 @@ const AiService = {
 	const res = await request.post('/api/ai/service/update', req);
     return res.data.data;
   },
+  /**  查询用户的ai信息 */
+  FindUserAIMessage: async (req?: undefined) => {
+	const res = await request.post<{ data: FindUserAIMessageReply, code: string, message: string }>('/api/ai/message', req);
+    return res.data.data;
+  },
 
 };
 

js/api/ai/ai_pb.ts

@@ -1,3 +1,9 @@
+export interface FindUserAIMessageReply{
+    /**  创建是否免费 */
+    isFree?:boolean;
+    /**  未读数 */
+    unreadNum?:number;
+}
 export interface GetIsReadRequest{
     userId?:string;
     robotId?:number;