xwl2023/Yi.Framework
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 完成AzureOpenAI改造

Browse Source
This commit is contained in:
ccnetcore
2025-06-17 23:25:55 +08:00
parent 0cd795f57a
commit 58fcc92e4d
13 changed files with 119 additions and 95 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
Yi.Abp.Net8/module/chat-hub/Yi.Framework.ChatHub.Domain/Managers/AiManager.cs
View File

@@ -1,26 +1,19 @@
using System.Collections.Generic;
using System.Net;
using Microsoft.Extensions.Options;
using Microsoft.SemanticKernel;
using Microsoft.SemanticKernel;
using Microsoft.SemanticKernel.ChatCompletion;
using Microsoft.SemanticKernel.Connectors.OpenAI;
// using OpenAI;
// using OpenAI.Managers;
// using OpenAI.ObjectModels;
// using OpenAI.ObjectModels.RequestModels;
// using OpenAI.ObjectModels.ResponseModels;
using Volo.Abp.DependencyInjection;
using Volo.Abp.Domain.Services;
using Yi.Framework.ChatHub.Domain.Shared.Dtos;
using Yi.Framework.ChatHub.Domain.Shared.Options;
using Yi.Framework.SemanticKernel;
namespace Yi.Framework.ChatHub.Domain.Managers
{
public class AiManager : ISingletonDependency
{
private readonly Kernel _kernel;
public AiManager(Kernel kernel)
private readonly SemanticKernelClient _client;
public AiManager(SemanticKernelClient client)
{
_kernel = kernel;
_client = client;
}
public async IAsyncEnumerable<string?> ChatAsStreamAsync(string model, List<AiChatContextDto> aiChatContextDtos)
@@ -29,38 +22,41 @@ namespace Yi.Framework.ChatHub.Domain.Managers
{
yield return null;
}
var openSettings = new OpenAIPromptExecutionSettings()
{
MaxTokens =1000
//MaxTokens = 1000
};
var chatCompletionService = this._kernel.GetRequiredService<IChatCompletionService>(model);
var chatCompletionService = this._client.Kernel.GetRequiredService<IChatCompletionService>(model);
var history =new ChatHistory();
var history = new ChatHistory();
foreach (var aiChatContextDto in aiChatContextDtos)
{
if (aiChatContextDto.AnswererType==AnswererTypeEnum.Ai)
if (aiChatContextDto.AnswererType == AnswererTypeEnum.Ai)
{
history.AddSystemMessage(aiChatContextDto.Message);
history.AddAssistantMessage(aiChatContextDto.Message);
}
else if(aiChatContextDto.AnswererType==AnswererTypeEnum.User)
else if (aiChatContextDto.AnswererType == AnswererTypeEnum.User)
{
history.AddUserMessage(aiChatContextDto.Message);
}
}
var results = chatCompletionService.GetStreamingChatMessageContentsAsync(
chatHistory: history,
executionSettings: openSettings,
kernel: _kernel);
kernel: _client.Kernel);
if (results is null)
{
yield return null;
yield return null;
}
await foreach (var result in results)
{
yield return result.Content;
}
await foreach (var result in results)
{
yield return result.Content;
}
}
}
}
}

2
Yi.Abp.Net8/module/chat-hub/Yi.Framework.ChatHub.Domain/Yi.Framework.ChatHub.Domain.csproj
View File

@@ -2,13 +2,13 @@
<Import Project="..\..\..\common.props" />
<ItemGroup>
<ProjectReference Include="..\..\..\framework\Yi.Framework.SemanticKernel\Yi.Framework.SemanticKernel.csproj" />
<ProjectReference Include="..\..\..\framework\Yi.Framework.SqlSugarCore.Abstractions\Yi.Framework.SqlSugarCore.Abstractions.csproj" />
<ProjectReference Include="..\Yi.Framework.ChatHub.Domain.Shared\Yi.Framework.ChatHub.Domain.Shared.csproj" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Volo.Abp.AspNetCore.SignalR" Version="$(AbpVersion)" />
<PackageReference Include="Microsoft.SemanticKernel" Version="1.40.0" />
<PackageReference Include="Volo.Abp.Ddd.Domain" Version="$(AbpVersion)" />
<PackageReference Include="Volo.Abp.Caching" Version="$(AbpVersion)" />
<ProjectReference Include="..\..\..\framework\Yi.Framework.Caching.FreeRedis\Yi.Framework.Caching.FreeRedis.csproj" />

28
Yi.Abp.Net8/module/chat-hub/Yi.Framework.ChatHub.Domain/YiFrameworkChatHubDomainModule.cs
View File

@@ -1,43 +1,23 @@
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.SemanticKernel;
using Microsoft.Extensions.DependencyInjection;
using Volo.Abp.Domain;
using Yi.Framework.Caching.FreeRedis;
using Yi.Framework.ChatHub.Domain.Shared;
using Yi.Framework.Core.Options;
using Yi.Framework.SemanticKernel;
namespace Yi.Framework.ChatHub.Domain
{
[DependsOn(
typeof(YiFrameworkChatHubDomainSharedModule),
typeof(YiFrameworkCachingFreeRedisModule),
typeof(YiFrameworkSemanticKernelModule),
typeof(AbpDddDomainModule)
)]
)]
public class YiFrameworkChatHubDomainModule : AbpModule
{
public override void ConfigureServices(ServiceConfigurationContext context)
{
var configuration = context.Services.GetConfiguration();
var services = context.Services;
// 配置绑定
var semanticKernelSection = configuration.GetSection("SemanticKernel");
services.Configure<SemanticKernelOptions>(configuration.GetSection("SemanticKernel"));
#pragma warning disable SKEXP0010
// 从配置中获取值
var options = semanticKernelSection.Get<SemanticKernelOptions>();
foreach (var optionsModelId in options.ModelIds)
{
services.AddKernel()
.AddOpenAIChatCompletion(
serviceId: optionsModelId,
modelId: optionsModelId,
endpoint: new Uri(options.Endpoint),
apiKey: options.ApiKey);
}
#pragma warning restore SKEXP0010
}
}
}