feat:完成ai网关搭建

Yi.Abp.Net8/module/ai-hub/Yi.Framework.AiHub.Application.Contracts/Options/AiGateWayOptions.cs

@@ -0,0 +1,17 @@
+namespace Yi.Framework.AiHub.Application.Contracts.Options;
+
+public class AiGateWayOptions
+{
+    public AiChatOptionDic Chats { get; set; }
+}
+
+public class AiChatOptionDic : Dictionary<string, AiChatModelOptions>
+{
+}
+
+public class AiChatModelOptions
+{
+    public List<string> ModelIds { get; set; }
+    public string Endpoint { get; set; }
+    public string ApiKey { get; set; }
+}

Yi.Abp.Net8/module/ai-hub/Yi.Framework.AiHub.Application.Contracts/YiFrameworkAiHubApplicationContractsModule.cs

@@ -1,3 +1,5 @@
+using Microsoft.Extensions.DependencyInjection;
+using Yi.Framework.AiHub.Application.Contracts.Options;
 using Yi.Framework.AiHub.Domain.Shared;
 using Yi.Framework.Ddd.Application.Contracts;
 
@@ -5,11 +7,12 @@ namespace Yi.Framework.AiHub.Application.Contracts
 {
     [DependsOn(
         typeof(YiFrameworkAiHubDomainSharedModule),
-        
-
         typeof(YiFrameworkDddApplicationContractsModule))]
     public class YiFrameworkAiHubApplicationContractsModule : AbpModule
     {
-
+        public override void ConfigureServices(ServiceConfigurationContext context)
+        {
+            var build = context.Services.GetConfiguration();
+        }
     }
 }

Yi.Abp.Net8/module/ai-hub/Yi.Framework.AiHub.Application/Services/AiService.cs

@@ -1,19 +1,28 @@
-using Microsoft.AspNetCore.Http;
+using System.Text;
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Options;
+using Newtonsoft.Json;
+using Newtonsoft.Json.Serialization;
+using OpenAI.Chat;
 using Volo.Abp.Application.Services;
 using Yi.Framework.AiHub.Application.Contracts.Dtos;
+using Yi.Framework.AiHub.Application.Contracts.Options;
+using Yi.Framework.AiHub.Domain.Managers;
 
 namespace Yi.Framework.AiHub.Application.Services;
 
 public class AiService : ApplicationService
 {
-    // private readonly SemanticKernelClient _skClient;
+    private readonly AiGateWayOptions _options;
-    private IHttpContextAccessor httpContextAccessor;
+    private readonly IHttpContextAccessor _httpContextAccessor;
+
+    public AiService(IOptions<AiGateWayOptions> options, IHttpContextAccessor httpContextAccessor)
+    {
+        _options = options.Value;
+        this._httpContextAccessor = httpContextAccessor;
+    }
 
-    // public AiService(SemanticKernelClient skClient, IHttpContextAccessor httpContextAccessor)
-    // {
-    //     _skClient = skClient;
-    //     this.httpContextAccessor = httpContextAccessor;
-    // }
 
     /// <summary>
     /// 获取模型列表
@@ -21,96 +30,68 @@ public class AiService : ApplicationService
     /// <returns></returns>
     public async Task<List<ModelGetListOutput>> GetModelAsync()
     {
-        return new List<ModelGetListOutput>()
+        var output = _options.Chats.SelectMany(x => x.Value.ModelIds)
-        {
+            .Select(x => new ModelGetListOutput()
-            new ModelGetListOutput
             {
                 Id = 001,
                 Category = "chat",
-                ModelName = "gpt-4.1-mini",
+                ModelName = x,
-                ModelDescribe = "gpt下的ai",
+                ModelDescribe = "这是一个直连模型",
                 ModelPrice = 4,
                 ModelType = "1",
                 ModelShow = "0",
-                SystemPrompt = "",
+                Remark = "直连模型"
-                ApiHost = "",
+            }).ToList();
-                ApiKey = "",
+        return output;
-                Remark = "牛逼"
+    }
-            },
+
-            new ModelGetListOutput
+
+    /// <summary>
+    /// 发送消息
+    /// </summary>
+    /// <param name="input"></param>
+    /// <param name="cancelToken"></param>
+    public async Task PostSendAsync(SendMessageInput input, CancellationToken cancelToken)
     {
-                Id = 002,
+        var httpContext = this._httpContextAccessor.HttpContext;
-                Category = "chat",
+        var response = httpContext.Response;
-                ModelName = "grok-3-mini",
+        // 设置响应头，声明是 SSE 流
-                ModelDescribe = "马斯克的ai",
+        response.ContentType = "text/event-stream";
-                ModelPrice = 5,
+        response.Headers.Append("Cache-Control", "no-cache");
-                ModelType = "1",
+        response.Headers.Append("Connection", "keep-alive");
-                ModelShow = "0",
+
-                SystemPrompt = "",
+
-                ApiHost = "",
+        var history = new List<ChatMessage>();
-                ApiKey = "",
+        foreach (var aiChatContextDto in input.Messages)
-                Remark = "牛逼啊"
+        {
+            if (aiChatContextDto.Role == "ai")
+            {
+                history.Add(ChatMessage.CreateAssistantMessage(aiChatContextDto.Content));
+            }
+            else if (aiChatContextDto.Role == "user")
+            {
+                history.Add(ChatMessage.CreateUserMessage(aiChatContextDto.Content));
+            }
+        }
+
+        var gateWay = LazyServiceProvider.GetRequiredService<AiGateWayManager>();
+        var completeChatResponse = gateWay.CompleteChatAsync(input.Model, history);
+        await using var writer = new StreamWriter(response.Body, Encoding.UTF8, leaveOpen: true);
+        await foreach (var data in completeChatResponse)
+        {
+            var model = MapToMessage(input.Model, data);
+            var message = JsonConvert.SerializeObject(model, new JsonSerializerSettings
+            {
+                ContractResolver = new CamelCasePropertyNamesContractResolver()
+            });
+
+            await writer.WriteLineAsync($"data: {message}\n");
+            await writer.FlushAsync(cancelToken); // 确保立即推送数据
         }
-        };
     }
 
 
-    // /// <summary>
+    private SendMessageOutputDto MapToMessage(string modelId, string content)
-    // /// 发送消息
-    // /// </summary>
-    // /// <param name="input"></param>
-    // /// <param name="cancelToken"></param>
-    // public async Task PostSendAsync(SendMessageInput input,CancellationToken cancelToken)
-    // {
-    //     var httpContext = this.httpContextAccessor.HttpContext;
-    //     var response = httpContext.Response;
-    //     // 设置响应头，声明是 SSE 流
-    //     response.ContentType = "text/event-stream";
-    //     response.Headers.Append("Cache-Control", "no-cache");
-    //     response.Headers.Append("Connection", "keep-alive");
-    //
-    //
-    //     var chatCompletionService = this._skClient.Kernel.GetRequiredService<IChatCompletionService>(input.Model);
-    //     var history = new ChatHistory();
-    //     var openSettings = new AzureOpenAIPromptExecutionSettings()
-    //     {
-    //         MaxTokens = 3000
-    //     };
-    //     foreach (var aiChatContextDto in input.Messages)
-    //     {
-    //         if (aiChatContextDto.Role == "ai")
-    //         {
-    //             history.AddAssistantMessage(aiChatContextDto.Content);
-    //         }
-    //         else if (aiChatContextDto.Role == "user")
-    //         {
-    //             history.AddUserMessage(aiChatContextDto.Content);
-    //         }
-    //     }
-    //
-    //     var results = chatCompletionService.GetStreamingChatMessageContentsAsync(
-    //         chatHistory: history,
-    //         executionSettings: openSettings,
-    //         kernel: _skClient.Kernel,
-    //         cancelToken);
-    //
-    //
-    //     await using var writer = new StreamWriter(response.Body, Encoding.UTF8, leaveOpen: true);
-    //     await foreach (var result in results)
-    //     {
-    //         var modle = GetMessage(input.Model, result.Content);
-    //         var message = JsonConvert.SerializeObject(modle, new JsonSerializerSettings
-    //         {
-    //             ContractResolver = new CamelCasePropertyNamesContractResolver()
-    //         });
-    //
-    //         await writer.WriteLineAsync($"data: {message}\n");
-    //         await writer.FlushAsync(cancelToken); // 确保立即推送数据
-    //     }
-    // }
-
-
-    private SendMessageOutputDto GetMessage(string modelId, string content)
     {
         var output = new SendMessageOutputDto
         {

Yi.Abp.Net8/module/ai-hub/Yi.Framework.AiHub.Domain/AiChat/IChatService.cs

@@ -0,0 +1,8 @@
+using OpenAI.Chat;
+
+namespace Yi.Framework.AiHub.Domain.AiChat;
+
+public interface IChatService
+{
+    public IAsyncEnumerable<string> CompleteChatAsync(string modelId, List<ChatMessage> messages);
+}

Yi.Abp.Net8/module/ai-hub/Yi.Framework.AiHub.Domain/AiChat/Impl/AzureChatService.cs

@@ -0,0 +1,40 @@
+using Azure;
+using Azure.AI.OpenAI;
+using Microsoft.Extensions.Options;
+using OpenAI.Chat;
+using Yi.Framework.AiHub.Application.Contracts.Options;
+
+namespace Yi.Framework.AiHub.Domain.AiChat.Impl;
+
+public class AzureChatService : IChatService
+{
+    private readonly AiChatModelOptions _options;
+
+    public AzureChatService(IOptions<AiGateWayOptions> options)
+    {
+        this._options = options.Value.Chats[nameof(AzureChatService)];
+    }
+
+    public async IAsyncEnumerable<string> CompleteChatAsync(string modelId, List<ChatMessage> messages)
+    {
+        var endpoint = new Uri(_options.Endpoint);
+
+        var deploymentName = modelId;
+        var apiKey = _options.ApiKey;
+
+        AzureOpenAIClient azureClient = new(
+            endpoint,
+            new AzureKeyCredential(apiKey));
+        ChatClient chatClient = azureClient.GetChatClient(deploymentName);
+
+        var response = chatClient.CompleteChatStreamingAsync(messages);
+
+        await foreach (StreamingChatCompletionUpdate update in response)
+        {
+            foreach (ChatMessageContentPart updatePart in update.ContentUpdate)
+            {
+                yield return updatePart.Text;
+            }
+        }
+    }
+}

Yi.Abp.Net8/module/ai-hub/Yi.Framework.AiHub.Domain/Managers/AiGateWayManager.cs

@@ -0,0 +1,33 @@
+using Azure;
+using Azure.AI.OpenAI;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Options;
+using OpenAI.Chat;
+using Volo.Abp.Domain.Services;
+using Yi.Framework.AiHub.Application.Contracts.Options;
+using Yi.Framework.AiHub.Domain.AiChat;
+
+namespace Yi.Framework.AiHub.Domain.Managers;
+
+public class AiGateWayManager : DomainService
+{
+    private readonly AiGateWayOptions _options;
+
+    public AiGateWayManager(IOptions<AiGateWayOptions> options)
+    {
+        this._options = options.Value;
+    }
+
+    public IAsyncEnumerable<string> CompleteChatAsync(string modelId, List<ChatMessage> messages)
+    {
+        foreach (var chat in _options.Chats)
+        {
+            if (chat.Value.ModelIds.Contains(modelId))
+            {
+                var chatService = LazyServiceProvider.GetRequiredKeyedService<IChatService>(chat.Key);
+                return chatService.CompleteChatAsync(modelId, messages);
+            }
+        }
+        throw new UserFriendlyException($"当前暂不支持该模型-【{modelId}】");
+    }
+}

Yi.Abp.Net8/module/ai-hub/Yi.Framework.AiHub.Domain/Managers/OpenAiManager.cs

@@ -1,39 +0,0 @@
-using Azure;
-using Azure.AI.OpenAI;
-using OpenAI.Chat;
-using Volo.Abp.Domain.Services;
-
-namespace Yi.Framework.AiHub.Domain.Managers;
-
-public class OpenAiManager : DomainService
-{
-    public static async Task TestAsync()
-    {
-        var endpoint = new Uri("https://japan-ccnetcore-resource.cognitiveservices.azure.com/");
-     //   var deploymentName = "gpt-4.1-mini";
-       var deploymentName = "o4-mini";
-        var apiKey = "FaccnRh7Zvz25OCGH07kHPe2z1aCXMliLdr3esgWHgXQ2aivwFgDJQQJ99BFACi0881XJ3w3AAAAACOGAJ2G";
-
-        AzureOpenAIClient azureClient = new(
-            endpoint,
-            new AzureKeyCredential(apiKey));
-        ChatClient chatClient = azureClient.GetChatClient(deploymentName);
-
-        List<ChatMessage> messages = new List<ChatMessage>()
-        {
-            new UserChatMessage("使用c#写一个贪吃蛇代码"),
-        };
-
-        var response = chatClient.CompleteChatStreamingAsync(messages);
-
-        await foreach (StreamingChatCompletionUpdate update in response)
-        {
-            foreach (ChatMessageContentPart updatePart in update.ContentUpdate)
-            {
-                System.Console.Write(updatePart.Text);
-            }
-        }
-
-        System.Console.WriteLine("结束");
-    }
-}

Yi.Abp.Net8/module/ai-hub/Yi.Framework.AiHub.Domain/Yi.Framework.AiHub.Domain.csproj

@@ -9,6 +9,7 @@
   <ItemGroup>
     <ProjectReference Include="..\..\..\framework\Yi.Framework.Mapster\Yi.Framework.Mapster.csproj" />
     <ProjectReference Include="..\..\..\framework\Yi.Framework.SqlSugarCore.Abstractions\Yi.Framework.SqlSugarCore.Abstractions.csproj" />
+    <ProjectReference Include="..\Yi.Framework.AiHub.Application.Contracts\Yi.Framework.AiHub.Application.Contracts.csproj" />
     <ProjectReference Include="..\Yi.Framework.AiHub.Domain.Shared\Yi.Framework.AiHub.Domain.Shared.csproj" />
   </ItemGroup>
 

Yi.Abp.Net8/module/ai-hub/Yi.Framework.AiHub.Domain/YiFrameworkAiHubDomainModule.cs

@@ -1,6 +1,11 @@
 using Microsoft.Extensions.DependencyInjection;
+using OpenAI.Chat;
 using Volo.Abp.Caching;
 using Volo.Abp.Domain;
+using Yi.Framework.AiHub.Application.Contracts.Options;
+using Yi.Framework.AiHub.Domain.AiChat;
+using Yi.Framework.AiHub.Domain.AiChat.Impl;
+using Yi.Framework.AiHub.Domain.Managers;
 using Yi.Framework.AiHub.Domain.Shared;
 using Yi.Framework.Mapster;
 
@@ -17,11 +22,17 @@ namespace Yi.Framework.AiHub.Domain
         {
             var configuration = context.Services.GetConfiguration();
             var services = context.Services;
+            
+            Configure<AiGateWayOptions>(configuration.GetSection("AiGateWay"));
+            
+            
+            services.AddKeyedTransient<IChatService, AzureChatService>(nameof(AzureChatService));
         }
 
         public override async Task OnApplicationInitializationAsync(ApplicationInitializationContext context)
         {
-            await Yi.Framework.AiHub.Domain.Managers.OpenAiManager.Test2Async();
+            var service = context.ServiceProvider;
+         
         }
     }
 }

Yi.Abp.Net8/src/Yi.Abp.Web/appsettings.json

@@ -27,10 +27,14 @@
   "Settings": {
     "Test": "hello"
   },
-
   //数据库类型列表
-    "DbList": [ "Sqlite", "Mysql", "Sqlserver", "Oracle", "PostgreSQL" ],
+  "DbList": [
-
+    "Sqlite",
+    "Mysql",
+    "Sqlserver",
+    "Oracle",
+    "PostgreSQL"
+  ],
   "DbConnOptions": {
     "Url": "DataSource=yi-abp-dev.db",
     "DbType": "Sqlite",
@@ -38,7 +42,8 @@
     "EnabledCodeFirst": true,
     "EnabledSqlLog": true,
     "EnabledDbSeed": true,
-        "EnableUnderLine": false, // 启用驼峰转下划线
+    "EnableUnderLine": false,
+    // 启用驼峰转下划线
     //SAAS多租户
     "EnabledSaasMultiTenancy": true
     //读写分离地址
@@ -49,14 +54,12 @@
     //  "HOST=[xxxx];PORT=5432;DATABASE=[xxxx];USERID=[xxxx];PASSWORD=[xxxx]" //PostgreSQL
     //]
   },
-
   //redis使用freeesql参数在“FreeSqlOptions的ConnectionStringBuilder中”
   "Redis": {
     "IsEnabled": false,
     "Configuration": "127.0.0.1:6379,password=123,defaultDatabase=13",
     "JobDb": 13
   },
-
   //鉴权
   "JwtOptions": {
     "Issuer": "https://ccnetcore.com",
@@ -71,8 +74,6 @@
     "SecurityKey": "67ij4o6jo4i5j6io45j6i4j74p5k6i54ojoi5t9g8ergoj34ofgkrtbmreog894jbioemgropihj48rj4io5juopjgior",
     "ExpiresMinuteTime": 172800
   },
-
-
   //第三方登录
   "OAuth": {
     //QQ
@@ -88,26 +89,33 @@
       "RedirectUri": ""
     }
   },
-
   //Rbac模块
   "RbacOptions": {
     //超级管理员种子数据默认密码
     "AdminPassword": "123456",
-
     //是否开启验证码验证
     "EnableCaptcha": true,
-
     //是否开启注册功能
     "EnableRegister": false,
-
     //开启定时数据库备份
     "EnableDataBaseBackup": false
   },
-  
   //语义内核
   "SemanticKernel": {
+    "ModelIds": [
+      "gpt-4o"
+    ],
+    "Endpoint": "https://xxx.com/v1",
+    "ApiKey": "sk-xxxxxx"
+  },
+  //AI网关
+  "AiGateWay": {
+    "Chats": {
+      "AzureChatService": {
         "ModelIds": ["gpt-4o"],
         "Endpoint": "https://xxx.com/v1",
         "ApiKey": "sk-xxxxxx"
       }
     }
+  }
+}