Merge branch 'main' of https://github.com/xuzeyu91/AntSK

fix 删除openai配置文件

.gitignore

@@ -330,13 +330,13 @@ ASALocalRun/
 *.pdb
 # MFractors (Xamarin productivity tool) working folder 
 .mfractor/
-/.semantic-kernel/results/src/ISS.IPSA.AiAgent.Api/plugins/BasePlugin/YesNo
 **/bin/
 **/obj/
 **/.vs/
-
-/Xzy.KnowledgeBase/appsettings.Development.json
-/Xzy.KnowledgeBase/XzyAgent.db
-/Xzy.KnowledgeBase/AntSK.db
 /AntSK/AntSK.db
 /AntSK/appsettings.Development.json
+/AntSK.db
+**/tmp-memory-files/*
+/src/AntSK/AntSK.db
+/src/AntSK/appsettings.Development.json
+/src/AntSK.db

AntSK.Domain/Domain/Interface/IKMService.cs

@@ -1,14 +0,0 @@
-using AntSK.Domain.Domain.Dto;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace AntSK.Domain.Domain.Interface
-{
-    public interface IKMService
-    {
-        Task<List<KMFile>> GetDocumentByFileID(string fileid);
-    }
-}

AntSK.Domain/Domain/Service/KMService.cs

@@ -1,41 +0,0 @@
-using AntSK.Domain.Common.DependencyInjection;
-using AntSK.Domain.Domain.Interface;
-using Microsoft.KernelMemory;
-using AntSK.Domain.Utils;
-using AntSK.Domain.Domain.Dto;
-
-namespace AntSK.Domain.Domain.Service
-{
-    [ServiceDescription(typeof(IKMService), ServiceLifetime.Scoped)]
-    public class KMService(MemoryServerless _memory) : IKMService
-    {
-        public async Task<List<KMFile>> GetDocumentByFileID(string fileid)
-        {
-            var memories = await _memory.ListIndexesAsync();
-            var memoryDbs = _memory.Orchestrator.GetMemoryDbs();
-            List<KMFile> docTextList = new List<KMFile>();
-
-            foreach (var memoryIndex in memories)
-            {
-                foreach (var memoryDb in memoryDbs)
-                {
-
-                    var items = await memoryDb.GetListAsync(memoryIndex.Name, new List<MemoryFilter>() { new MemoryFilter().ByDocument(fileid) }, 100, true).ToListAsync();
-                    foreach (var item in items)
-                    {
-                        KMFile file = new KMFile()
-                        {
-                            Text = item.Payload.FirstOrDefault(p => p.Key == "text").Value.ConvertToString(),
-                            Url = item.Payload.FirstOrDefault(p => p.Key == "url").Value.ConvertToString(),
-                            LastUpdate = item.Payload.FirstOrDefault(p => p.Key == "last_update").Value.ConvertToString(),
-                            Schema = item.Payload.FirstOrDefault(p => p.Key == "schema").Value.ConvertToString(),
-                            File = item.Payload.FirstOrDefault(p => p.Key == "file").Value.ConvertToString(),
-                        };
-                        docTextList.Add(file);
-                    }
-                }
-            }
-            return docTextList;
-        }
-    }
-}

AntSK.Domain/Options/ConnectionOption.cs

@@ -1,20 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace AntSK.Domain.Options
-{
-    public class ConnectionOption
-    {
-        /// <summary>
-        /// sqlite连接字符串
-        /// </summary>
-        public static string Sqlite { get; set; }
-        /// <summary>
-        /// pg链接字符串
-        /// </summary>
-        public static string Postgres { get; set; }
-    }
-}

AntSK.Domain/Options/LoginOption.cs

@@ -1,15 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace AntSK.Domain.Options
-{
-    public class LoginOption
-    {
-        public static string User { get; set; }
-
-        public static string Password { get; set; }
-    }
-}

AntSK.Domain/Options/OpenAIOption.cs

@@ -1,17 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace AntSK.Domain.Options
-{
-    public class OpenAIOption
-    {
-        public static string EndPoint { get; set; }
-        public static string Key { get; set; }
-        public static string Model { get; set; }
-
-        public static string EmbeddingModel { get; set; }
-    }
-}

AntSK.Domain/Repositories/AI/Kms/Kmss.cs

@@ -1,32 +0,0 @@
-using SqlSugar;
-using System;
-using System.Collections.Generic;
-using System.ComponentModel.DataAnnotations;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace AntSK.Domain.Repositories
-{
-    [SugarTable("Kms")]
-    public partial class Kmss
-    {
-        [SugarColumn(IsPrimaryKey = true)]
-        public string Id { get; set; }
-        /// <summary>
-        /// 图标
-        /// </summary>
-        [Required]
-        public string Icon { get; set; }
-        /// <summary>
-        /// 名称
-        /// </summary>
-        [Required]
-        public string Name { get; set; }
-        /// <summary>
-        /// 会话模型
-        /// </summary>
-        [Required]
-        public string Describe { get; set; }
-    }
-}

AntSK.Domain/Repositories/Base/SqlSugarHelper.cs

@@ -1,51 +0,0 @@
-using SqlSugar;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-using AntSK.Domain.Options;
-using AntSK.Domain.Utils;
-using System.Reflection;
-
-namespace AntSK.Domain.Repositories.Base
-{
-    public class SqlSugarHelper
-    {
-        /// <summary>
-        /// sqlserver连接
-        /// </summary>
-        public static SqlSugarScope Sqlite = new SqlSugarScope(new ConnectionConfig()
-        {
-            ConnectionString = ConnectionOption.Postgres,
-            DbType = DbType.PostgreSQL,
-            InitKeyType = InitKeyType.Attribute,//从特性读取主键和自增列信息
-            IsAutoCloseConnection = true,
-            ConfigureExternalServices = new ConfigureExternalServices
-            {
-                //注意:  这儿AOP设置不能少
-                EntityService = (c, p) =>
-                {
-                    /***高版C#写法***/
-                    //支持string?和string  
-                    if (p.IsPrimarykey == false && new NullabilityInfoContext()
-                     .Create(c).WriteState is NullabilityState.Nullable)
-                    {
-                        p.IsNullable = true;
-                    }
-                }
-            }
-        }, Db =>
-        {
-            Db.Aop.OnLogExecuting = (sql, pars) =>
-            {
-                if (Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT").ConvertToString() == "Development")
-                {
-                    Console.WriteLine(sql + "\r\n" +
-                        Sqlite.Utilities.SerializeObject(pars.ToDictionary(it => it.ParameterName, it => it.Value)));
-                    Console.WriteLine();
-                }
-            };
-        });
-    }
-}

AntSK.Domain/Xzy.KnowledgeBase.Domain.xml

@@ -1,473 +0,0 @@
-<?xml version="1.0"?>
-<doc>
-    <assembly>
-        <name>AntSK.Domain</name>
-    </assembly>
-    <members>
-        <member name="T:AntSK.Domain.Common.DependencyInjection.ServiceCollectionExtensions">
-            <summary>
-            容器扩展
-            </summary>
-        </member>
-        <member name="M:AntSK.Domain.Common.DependencyInjection.ServiceCollectionExtensions.AddServicesFromAssemblies(Microsoft.Extensions.DependencyInjection.IServiceCollection,System.String[])">
-            <summary>
-            从程序集中加载类型并添加到容器中
-            </summary>
-            <param name="services">容器</param>
-            <param name="assemblies">程序集集合</param>
-            <returns></returns>
-        </member>
-        <member name="F:AntSK.Domain.Common.DependencyInjection.ServiceLifetime.Scoped">
-            <summary>
-            作用域
-            </summary>
-        </member>
-        <member name="F:AntSK.Domain.Common.DependencyInjection.ServiceLifetime.Singleton">
-            <summary>
-            单例
-            </summary>
-        </member>
-        <member name="F:AntSK.Domain.Common.DependencyInjection.ServiceLifetime.Transient">
-            <summary>
-            瞬时
-            </summary>
-        </member>
-        <member name="M:AntSK.Domain.Map.MapperExtend.ToDTOList``1(System.Object)">
-            <summary>
-            Entity集合转DTO集合
-            </summary>
-            <typeparam name="T"></typeparam>
-            <param name="value"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Map.MapperExtend.ToDTO``1(System.Object)">
-            <summary>
-            Entity转DTO
-            </summary>
-            <typeparam name="T"></typeparam>
-            <param name="value"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Map.MapperExtend.MapTo``1(System.Object,``0)">
-            <summary>
-            给已有对象map,适合update场景，如需过滤空值需要在AutoMapProfile 设置
-            </summary>
-            <typeparam name="T"></typeparam>
-            <param name="self"></param>
-            <param name="result"></param>
-            <returns></returns>
-        </member>
-        <member name="P:AntSK.Domain.Model.PageList`1.PageIndex">
-            <summary>
-            当前页，从1开始
-            </summary>
-        </member>
-        <member name="P:AntSK.Domain.Model.PageList`1.PageSize">
-            <summary>
-            每页数量
-            </summary>
-        </member>
-        <member name="P:AntSK.Domain.Model.PageList`1.TotalCount">
-            <summary>
-            总数
-            </summary>
-        </member>
-        <member name="P:AntSK.Domain.Options.ConnectionOption.Sqlite">
-            <summary>
-            sqlite连接字符串
-            </summary>
-        </member>
-        <member name="P:AntSK.Domain.Repositories.Apps.Name">
-            <summary>
-            名称
-            </summary>
-        </member>
-        <member name="P:AntSK.Domain.Repositories.Apps.Describe">
-            <summary>
-            描述
-            </summary>
-        </member>
-        <member name="P:AntSK.Domain.Repositories.KmsDetails.FileName">
-            <summary>
-            文件名称
-            </summary>
-        </member>
-        <member name="P:AntSK.Domain.Repositories.KmsDetails.DataCount">
-            <summary>
-            数据数量
-            </summary>
-        </member>
-        <member name="P:AntSK.Domain.Repositories.KmsDetails.Status">
-            <summary>
-            状态
-            </summary>
-        </member>
-        <member name="P:AntSK.Domain.Repositories.KmsDetails.CreateTime">
-            <summary>
-            创建时间
-            </summary>
-        </member>
-        <member name="P:AntSK.Domain.Repositories.Kmss.Name">
-            <summary>
-            名称
-            </summary>
-        </member>
-        <member name="P:AntSK.Domain.Repositories.Kmss.ChatModel">
-            <summary>
-            会话模型
-            </summary>
-        </member>
-        <member name="P:AntSK.Domain.Repositories.Kmss.EmbeddingModel">
-            <summary>
-            向量模型
-            </summary>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.GetList">
-            <summary>
-            获取所有list
-            </summary>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.GetListAsync">
-            <summary>
-            获取所有list-异步
-            </summary>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.GetList(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}})">
-            <summary>
-            根据lambda查询
-            </summary>
-            <param name="whereExpression"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.GetListAsync(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}})">
-            <summary>
-            根据lambda查询-异步
-            </summary>
-            <param name="whereExpression"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.Count(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}})">
-            <summary>
-            根据lambda表达式获取数量
-            </summary>
-            <param name="whereExpression"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.CountAsync(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}})">
-            <summary>
-            根据lambda表达式获取数量-异步
-            </summary>
-            <param name="whereExpression"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.GetPageList(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}},SqlSugar.PageModel)">
-            <summary>
-            获取分页
-            </summary>
-            <param name="whereExpression"></param>
-            <param name="page"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.GetPageListAsync(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}},SqlSugar.PageModel)">
-            <summary>
-            获取分页-异步
-            </summary>
-            <param name="whereExpression"></param>
-            <param name="page"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.GetById(System.Object)">
-            <summary>
-            根据id获取实体
-            </summary>
-            <param name="id"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.GetByIdAsync(System.Object)">
-            <summary>
-            根据id获取实体-异步
-            </summary>
-            <param name="id"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.GetSingle(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}})">
-            <summary>
-            根据lambda获取单个对象 （注意，需要确保唯一，如果获取到2个会报错，这种场景需要使用GetFirst）
-            </summary>
-            <param name="whereExpression"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.GetSingleAsync(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}})">
-            <summary>
-            根据lambda获取单个对象-异步  （注意，需要确保唯一，如果获取到2个会报错，这种场景需要使用GetFirst）
-            </summary>
-            <param name="whereExpression"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.GetFirst(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}})">
-            <summary>
-            根据lambda获取单个对象
-            </summary>
-            <param name="whereExpression"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.GetFirstAsync(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}})">
-            <summary>
-            根据lambda获取单个对象 --异步
-            </summary>
-            <param name="whereExpression"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.Insert(`0)">
-            <summary>
-            实体插入
-            </summary>
-            <param name="obj"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.InsertAsync(`0)">
-            <summary>
-            实体插入-异步
-            </summary>
-            <param name="obj"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.InsertRange(System.Collections.Generic.List{`0})">
-            <summary>
-            批量插入
-            </summary>
-            <param name="objs"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.InsertRangeAsync(System.Collections.Generic.List{`0})">
-            <summary>
-            批量插入-异步
-            </summary>
-            <param name="objs"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.InsertReturnIdentity(`0)">
-            <summary>
-            插入返回自增列
-            </summary>
-            <param name="obj"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.InsertReturnIdentityAsync(`0)">
-            <summary>
-            插入返回自增列-异步
-            </summary>
-            <param name="obj"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.InsertReturnBigIdentity(`0)">
-            <summary>
-            插入返回longid
-            </summary>
-            <param name="obj"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.InsertReturnBigIdentityAsync(`0)">
-            <summary>
-            插入返回longid-异步
-            </summary>
-            <param name="obj"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.DeleteByIds(System.Object[])">
-            <summary>
-            批量删除
-            </summary>
-            <param name="ids"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.DeleteByIdsAsync(System.Object[])">
-            <summary>
-            批量删除-异步
-            </summary>
-            <param name="ids"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.Delete(System.Object)">
-            <summary>
-            根据主键删除
-            </summary>
-            <param name="id"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.DeleteAsync(System.Object)">
-            <summary>
-            根据主键删除-异步
-            </summary>
-            <param name="id"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.Delete(`0)">
-            <summary>
-            根据实体删除
-            </summary>
-            <param name="obj"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.DeleteAsync(`0)">
-            <summary>
-            根据实体删除-异步
-            </summary>
-            <param name="obj"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.Delete(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}})">
-            <summary>
-            根据表达式删除
-            </summary>
-            <param name="whereExpression"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.DeleteAsync(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}})">
-            <summary>
-            根据表达式删除-异步
-            </summary>
-            <param name="whereExpression"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.Update(`0)">
-            <summary>
-            更新
-            </summary>
-            <param name="obj"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.UpdateAsync(`0)">
-            <summary>
-            更新-异步
-            </summary>
-            <param name="obj"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.UpdateRange(System.Collections.Generic.List{`0})">
-            <summary>
-            批量更新
-            </summary>
-            <param name="objs"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.UpdateRangeAsync(System.Collections.Generic.List{`0})">
-            <summary>
-            批量更新-异步
-            </summary>
-            <param name="objs"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.IsAny(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}})">
-            <summary>
-            是否包含元素
-            </summary>
-            <param name="whereExpression"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Repositories.Base.Repository`1.IsAnyAsync(System.Linq.Expressions.Expression{System.Func{`0,System.Boolean}})">
-            <summary>
-            是否包含元素-异步
-            </summary>
-            <param name="whereExpression"></param>
-            <returns></returns>
-        </member>
-        <member name="F:AntSK.Domain.Repositories.Base.SqlSugarHelper.Sqlite">
-            <summary>
-            sqlserver连接
-            </summary>
-        </member>
-        <member name="M:AntSK.Domain.Utils.ConvertUtils.IsNull(System.Object)">
-            <summary>
-            判断是否为空，为空返回true
-            </summary>
-            <param name="data"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Utils.ConvertUtils.IsNotNull(System.Object)">
-            <summary>
-            判断是否为空，为空返回true
-            </summary>
-            <param name="data"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Utils.ConvertUtils.IsNull(System.String)">
-            <summary>
-            判断是否为空，为空返回true
-            </summary>
-            <param name="data"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Utils.ConvertUtils.ConvertToString(System.Object)">
-            <summary>
-            将obj类型转换为string
-            </summary>
-            <param name="s"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Utils.ConvertUtils.ConvertToInt32(System.Object)">
-            <summary>
-            object 转int32
-            </summary>
-            <param name="s"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Utils.ConvertUtils.ConvertToInt64(System.Object)">
-            <summary>
-            object 转int32
-            </summary>
-            <param name="s"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Utils.ConvertUtils.ConvertToDouble(System.Object)">
-            <summary>
-            将字符串转double
-            </summary>
-            <param name="s"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Utils.ConvertUtils.ConvertToDateTime(System.String)">
-            <summary>
-            转换为datetime类型
-            </summary>
-            <param name="s"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Utils.ConvertUtils.ConvertToDateTime(System.String,System.String)">
-            <summary>
-            转换为datetime类型的格式字符串
-            </summary>
-            <param name="s">要转换的对象</param>
-            <param name="y">格式化字符串</param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Utils.ConvertUtils.ConvertToDecimal(System.Object)">
-            <summary>
-            将字符串转换成decimal
-            </summary>
-            <param name="s"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Utils.ConvertUtils.DecimalFraction(System.Decimal)">
-            <summary>
-            decimal保留2位小数
-            </summary>
-        </member>
-        <member name="M:AntSK.Domain.Utils.ConvertUtils.ReplaceHtml(System.String)">
-            <summary>
-            替换html种的特殊字符
-            </summary>
-            <param name="s"></param>
-            <returns></returns>
-        </member>
-        <member name="M:AntSK.Domain.Utils.ConvertUtils.StreamToByte(System.IO.Stream)">
-            <summary>
-            流转byte
-            </summary>
-            <param name="stream"></param>
-            <returns></returns>
-        </member>
-    </members>
-</doc>

AntSK/Pages/ChatPage/Chat.razor.cs

@@ -1,268 +0,0 @@
-using AntDesign;
-using AntSK.Domain.Model;
-using AntSK.Domain.Repositories;
-using AntSK.Domain.Utils;
-using Azure.AI.OpenAI;
-using Azure.Core;
-using DocumentFormat.OpenXml.EMMA;
-using MarkdownSharp;
-using Microsoft.AspNetCore.Components;
-using Microsoft.KernelMemory;
-using Microsoft.OpenApi.Models;
-using Microsoft.SemanticKernel;
-using Microsoft.SemanticKernel.ChatCompletion;
-using Microsoft.SemanticKernel.Connectors.OpenAI;
-using Newtonsoft.Json;
-using SqlSugar;
-using System;
-using System.Text;
-
-namespace AntSK.Pages.ChatPage
-{
-    public partial class Chat
-    {
-        [Parameter]
-        public string AppId { get; set; }
-        [Inject] 
-        protected MessageService? Message { get; set; }
-        [Inject]
-        protected IApps_Repositories _apps_Repositories { get; set; }
-        [Inject]
-        protected IKmss_Repositories _kmss_Repositories { get; set; }
-        [Inject]
-        protected IKmsDetails_Repositories _kmsDetails_Repositories { get; set; }
-        [Inject]
-        protected MemoryServerless _memory { get; set; }
-        [Inject]
-        protected Kernel _kernel { get; set; }
-
-        protected bool _loading = false;
-        protected List<MessageInfo> MessageList = [];
-        protected string? _messageInput;
-        protected string _json = "";
-        protected bool Sendding = false;
-
-        List<RelevantSource> RelevantSources = new List<RelevantSource>();
-
-        protected List<Apps> _list = new List<Apps>();
-        protected override async Task OnInitializedAsync()
-        {
-            await base.OnInitializedAsync();
-            _list= _apps_Repositories.GetList();
-        }
-        protected async Task OnSendAsync()
-        {
-            if (string.IsNullOrWhiteSpace(_messageInput))
-            {
-                _ = Message.Info("请输入消息", 2);
-                return;
-            }
-
-            if (string.IsNullOrWhiteSpace(AppId))
-            {
-                _ = Message.Info("请选择应用进行测试", 2);
-                return;
-            }
-
-            MessageList.Add(new MessageInfo()
-            {
-                ID = Guid.NewGuid().ToString(),
-                Context = _messageInput,
-                CreateTime = DateTime.Now,
-                IsSend = true
-            });
-
-
-            Sendding = true;
-            await SendAsync(_messageInput);
-            _messageInput = "";
-            Sendding = false;
-
-        }
-        protected async Task OnCopyAsync(MessageInfo item)
-        {
-            await Task.Run(() =>
-            {
-                _messageInput = item.Context;
-            });
-        }
-
-        protected async Task OnClearAsync(string id)
-        {
-            await Task.Run(() =>
-            {
-                MessageList = MessageList.Where(w => w.ID != id).ToList();
-            });
-        }
-
-        protected async Task<bool> SendAsync(string questions)
-        {
-            string msg = questions;
-            //处理多轮会话
-            if (MessageList.Count > 0)
-            {
-                msg = await HistorySummarize(questions);
-            }
-
-            Apps app=_apps_Repositories.GetFirst(p => p.Id == AppId);
-            switch (app.Type)
-            {
-                case "chat":
-                    //普通会话
-                    await SendChat(questions, msg, app);
-                    break;
-                case "kms":
-                    //知识库问答
-                    await SendKms(questions, msg, app);
-                    break;
-            }
-
-            return await Task.FromResult(true);
-        }
-
-        /// <summary>
-        /// 发送知识库问答
-        /// </summary>
-        /// <param name="questions"></param>
-        /// <param name="msg"></param>
-        /// <param name="app"></param>
-        /// <returns></returns>
-        private async Task SendKms(string questions, string msg, Apps app)
-        {
-            //知识库问答
-            var filters = new List<MemoryFilter>();
-
-            var kmsidList = app.KmsIdList.Split(",");
-            foreach (var kmsid in kmsidList)
-            {
-                filters.Add(new MemoryFilter().ByTag("kmsid", kmsid));
-            }
-
-            var kmsResult = await _memory.AskAsync(msg, index: "kms", filters: filters);
-            if (kmsResult != null)
-            {
-                if (!string.IsNullOrEmpty(kmsResult.Result))
-                {
-                    string answers = kmsResult.Result;
-                    var markdown = new Markdown();
-                    string htmlAnswers = markdown.Transform(answers);
-                    var info1 = new MessageInfo()
-                    {
-                        ID = Guid.NewGuid().ToString(),
-                        Context = answers,
-                        HtmlAnswers = htmlAnswers,
-                        CreateTime = DateTime.Now,
-                    };
-                    MessageList.Add(info1);
-                }
-
-                foreach (var x in kmsResult.RelevantSources)
-                {
-                    foreach (var xsd in x.Partitions)
-                    {
-                        var markdown = new Markdown();
-                        string sourceName = x.SourceName;
-                        var fileDetail = _kmsDetails_Repositories.GetFirst(p => p.FileGuidName == x.SourceName);
-                        if (fileDetail.IsNotNull())
-                        {
-                            sourceName = fileDetail.FileName;
-                        }
-                        RelevantSources.Add(new RelevantSource() { SourceName = sourceName, Text = markdown.Transform(xsd.Text), Relevance = xsd.Relevance });
-                    }
-                }
-            }
-        }
-
-        /// <summary>
-        /// 发送普通对话
-        /// </summary>
-        /// <param name="questions"></param>
-        /// <param name="msg"></param>
-        /// <param name="app"></param>
-        /// <returns></returns>
-        private async Task SendChat(string questions, string msg, Apps app)
-        {
-            if (string.IsNullOrEmpty(app.Prompt))
-            {
-                //如果模板为空，给默认提示词
-                app.Prompt = "{{$input}}";
-            }
-            var promptTemplateFactory = new KernelPromptTemplateFactory();
-            var promptTemplate = promptTemplateFactory.Create(new PromptTemplateConfig(app.Prompt));
-            var renderedPrompt = await promptTemplate.RenderAsync(_kernel);
-
-            var func = _kernel.CreateFunctionFromPrompt(app.Prompt, new OpenAIPromptExecutionSettings());
-            var chatResult = _kernel.InvokeStreamingAsync<StreamingChatMessageContent>(function: func, arguments: new KernelArguments() { ["input"] = msg });
-            MessageInfo info = null;
-            var markdown = new Markdown();
-            await foreach (var content in chatResult)
-            {
-                if (info == null)
-                {
-                    info = new MessageInfo();
-                    info.ID = Guid.NewGuid().ToString();
-                    info.Context = content?.Content?.ConvertToString();
-                    info.HtmlAnswers = content?.Content?.ConvertToString();
-                    info.CreateTime = DateTime.Now;
-
-                    MessageList.Add(info);
-                }
-                else
-                {
-                    info.HtmlAnswers += content.Content;
-                    await Task.Delay(50); 
-                }
-                await InvokeAsync(StateHasChanged);
-            }
-            //全部处理完后再处理一次Markdown
-            if (info.IsNotNull())
-            {
-                info!.HtmlAnswers = markdown.Transform(info.HtmlAnswers);
-            }
-     
-            await InvokeAsync(StateHasChanged);
-        }
-
-        /// <summary>
-        /// 历史会话的会话总结
-        /// </summary>
-        /// <param name="questions"></param>
-        /// <returns></returns>
-        private async Task<string> HistorySummarize(string questions)
-        {
-            if (MessageList.Count > 1)
-            {
-                StringBuilder history = new StringBuilder();
-                foreach (var item in MessageList)
-                {
-                    if (item.IsSend)
-                    {
-                        history.Append($"user:{item.Context}{Environment.NewLine}");
-                    }
-                    else
-                    {
-                        history.Append($"assistant:{item.Context}{Environment.NewLine}");
-                    }
-                }
-
-                KernelFunction sunFun = _kernel.Plugins.GetFunction("ConversationSummaryPlugin", "SummarizeConversation");
-                var summary = await _kernel.InvokeAsync(sunFun, new() { ["input"] = $"内容是：{history.ToString()} {Environment.NewLine} 请注意用中文总结" });
-                string his = summary.GetValue<string>();
-                var msg = $"历史对话：{his}{Environment.NewLine} 用户问题：{Environment.NewLine}{questions}"; ;
-                return msg;
-            }
-            else 
-            {
-                return questions;
-            }
-        }
-    }
-
-    public class RelevantSource
-    {
-        public string SourceName { get; set; }
-
-        public string Text { get; set; }
-        public float Relevance { get; set; }
-    }
-}

AntSK/Pages/KmsPage/AddKms.razor

@@ -1,42 +0,0 @@
-@namespace AntSK.Pages.KmsPage
-@using AntSK.Domain.Repositories
-@using AntSK.Models
-@page "/Kms/Add"
-@inject IMessageService _message
-@using AntSK.Services.Auth
-@inherits AuthComponentBase
-
-<PageContainer Title="新增知识库">
-    <ChildContent>
-        <Card>
-            <Form 
-                  Model="@_kmsModel"
-                  Style="margin-top: 8px;"
-                  OnFinish="HandleSubmit">
-                <FormItem Label="知识库名称" LabelCol="LayoutModel._formItemLayout.LabelCol" WrapperCol="LayoutModel._formItemLayout.WrapperCol">
-                    <Input Placeholder="请输入知识库名称" @bind-Value="@context.Name" />
-                </FormItem>
-                <FormItem Label="图标" LabelCol="LayoutModel._formItemLayout.LabelCol" WrapperCol="LayoutModel._formItemLayout.WrapperCol">
-                    <Input Placeholder="请输入图标" @bind-Value="@context.Icon" />
-                    <a href="https://antblazor.com/zh-CN/components/icon" target="_blank">图标库</a>
-                </FormItem>
-                <FormItem Label="描述" LabelCol="LayoutModel._formItemLayout.LabelCol" WrapperCol="LayoutModel._formItemLayout.WrapperCol">
-                    <Input Placeholder="请输入描述" @bind-Value="@context.Describe" />
-                </FormItem>
-                <FormItem Label=" " Style="margin-top:32px" WrapperCol="LayoutModel._submitFormLayout.WrapperCol">
-                    <Button Type="primary" HtmlType="submit">
-                        保存
-                    </Button>
-                </FormItem>
-            </Form>
-        </Card>
-    </ChildContent>
-</PageContainer>
-
-
-<style>
-    .avatar-uploader > .ant-upload {
-        width: 128px;
-        height: 128px;
-    }
-</style>

AntSK/Pages/KmsPage/AddKms.razor.cs

@@ -1,36 +0,0 @@
-using AntDesign;
-using Microsoft.AspNetCore.Components;
-using AntSK.Domain.Repositories;
-using AntSK.Models;
-using System.IO;
-
-namespace AntSK.Pages.KmsPage
-{
-
-    public partial class AddKms
-    {
-        [Inject]
-        protected IKmss_Repositories _kmss_Repositories { get; set; }
-        [Inject]
-        protected NavigationManager NavigationManager { get; set; }
-        [Inject]
-        protected MessageService? Message { get; set; }
-
-        private readonly Kmss _kmsModel = new Kmss() ;
-
-        private void HandleSubmit()
-        {
-            _kmsModel.Id = Guid.NewGuid().ToString();
-            if (_kmss_Repositories.IsAny(p => p.Name == _kmsModel.Name))
-            {
-                _ = Message.Error("名称已存在！", 2);
-                return;
-            }
-
-            _kmss_Repositories.Insert(_kmsModel);
-
-            NavigationManager.NavigateTo("/kmslist");
-
-        }
-    }    
-}

AntSK/Pages/Setting/User/UserList.razor.cs

@@ -1,44 +0,0 @@
-using AntDesign;
-using AntSK.Domain.Repositories;
-using AntSK.Models;
-using AntSK.Services;
-using Microsoft.AspNetCore.Components;
-
-namespace AntSK.Pages.Setting.User
-{
-    public partial class UserList
-    {
-        private readonly BasicListFormModel _model = new BasicListFormModel();
-
-        private readonly IDictionary<string, ProgressStatus> _pStatus = new Dictionary<string, ProgressStatus>
-        {
-            {"active", ProgressStatus.Active},
-            {"exception", ProgressStatus.Exception},
-            {"normal", ProgressStatus.Normal},
-            {"success", ProgressStatus.Success}
-        };
-
-        private List<Users> _data;
-
-        private string _searchKeyword;
-
-        [Inject] 
-        protected IUsers_Repositories _users_Repositories { get; set; }
-
-
-        protected override async Task OnInitializedAsync()
-        {
-            await base.OnInitializedAsync();
-            _data = _users_Repositories.GetList();
-        }
-
-        public void AddUser() {
-            NavigationManager.NavigateTo("/setting/user/add");
-        }
-
-        public void Edit(string userid)
-        {
-            NavigationManager.NavigateTo("/setting/user/add/"+userid);
-        }
-    }
-}

AntSK/Services/OpenApi/OpenApiService.cs

@@ -1,210 +0,0 @@
-using AntSK.Domain.Common.DependencyInjection;
-using AntSK.Domain.Model;
-using AntSK.Domain.Repositories;
-using AntSK.Domain.Utils;
-using AntSK.Models;
-using AntSK.Models.OpenAPI;
-using AntSK.Pages.ChatPage;
-using MarkdownSharp;
-using Microsoft.KernelMemory;
-using Microsoft.SemanticKernel.Connectors.OpenAI;
-using Microsoft.SemanticKernel;
-using System.Text;
-using System;
-using ServiceLifetime = AntSK.Domain.Common.DependencyInjection.ServiceLifetime;
-using AntDesign.Core.Extensions;
-using Azure.AI.OpenAI;
-using Azure;
-using Azure.Core;
-using Microsoft.AspNetCore.Http.HttpResults;
-using AntDesign;
-using Newtonsoft.Json;
-using System.Text.Json;
-
-namespace AntSK.Services.OpenApi
-{
-    public interface IOpenApiService
-    {
-        Task Chat(OpenAIModel model, string sk, HttpContext HttpContext);
-    }
-
-    [ServiceDescription(typeof(IOpenApiService), ServiceLifetime.Scoped)]
-    public class OpenApiService(
-        IApps_Repositories _apps_Repositories,
-        IKmss_Repositories _kmss_Repositories,
-        IKmsDetails_Repositories _kmsDetails_Repositories,
-        Kernel _kernel,
-        MemoryServerless _memory
-        ) : IOpenApiService
-    {
-        public async Task Chat(OpenAIModel model,string sk, HttpContext HttpContext)
-        {
-
-
-            Apps app = _apps_Repositories.GetFirst(p => p.SecretKey == sk);
-
-            if (app.IsNotNull())
-            {
-                string msg= await HistorySummarize(model);
-                switch (app.Type)
-                {
-                    case "chat":
-                        //普通会话
-                        if (model.stream)
-                        {
-                            OpenAIStreamResult result1 = new OpenAIStreamResult();
-                            result1.created = DateTimeOffset.UtcNow.ToUnixTimeSeconds();
-                            result1.choices = new List<StreamChoicesModel>() { new StreamChoicesModel() { delta = new OpenAIMessage() { role = "assistant" } } };
-                            await SendChatStream( HttpContext, result1, app, msg);
-                            HttpContext.Response.ContentType = "application/json";
-                            await HttpContext.Response.WriteAsync(JsonConvert.SerializeObject(result1));
-                            await HttpContext.Response.CompleteAsync();
-                            return;
-                        }
-                        else 
-                        {
-                            OpenAIResult result2 = new OpenAIResult();
-                            result2.created = DateTimeOffset.UtcNow.ToUnixTimeSeconds();
-                            result2.choices = new List<ChoicesModel>() { new ChoicesModel() { message = new OpenAIMessage() { role = "assistant" } } };
-                            result2.choices[0].message.content = await SendChat(msg, app);
-                            HttpContext.Response.ContentType = "application/json";
-                            await HttpContext.Response.WriteAsync(JsonConvert.SerializeObject(result2));
-                            await HttpContext.Response.CompleteAsync();
-                        }
-                        break;
-                    case "kms":
-                        //知识库问答
-                        OpenAIResult result3 = new OpenAIResult();
-                        result3.created = DateTimeOffset.UtcNow.ToUnixTimeSeconds();
-                        result3.choices = new List<ChoicesModel>() { new ChoicesModel() { message = new OpenAIMessage() { role = "assistant" } } };
-                        result3.choices[0].message.content = await SendKms( msg, app);
-                        HttpContext.Response.ContentType = "application/json";
-                        await HttpContext.Response.WriteAsync(JsonConvert.SerializeObject(result3));
-                        await HttpContext.Response.CompleteAsync();
-                        break;
-                }
-            }
-    
-        }
-
-        private async Task SendChatStream( HttpContext HttpContext, OpenAIStreamResult result, Apps app, string msg)
-        {
-            HttpContext.Response.Headers.Add("Content-Type", "text/event-stream");
-
-            if (string.IsNullOrEmpty(app.Prompt))
-            {
-                //如果模板为空，给默认提示词
-                app.Prompt = "{{$input}}";
-            }
-            var promptTemplateFactory = new KernelPromptTemplateFactory();
-            var promptTemplate = promptTemplateFactory.Create(new PromptTemplateConfig(app.Prompt));
-            var renderedPrompt = await promptTemplate.RenderAsync(_kernel);
-
-            var func = _kernel.CreateFunctionFromPrompt(app.Prompt, new OpenAIPromptExecutionSettings());
-            var chatResult = _kernel.InvokeStreamingAsync<StreamingChatMessageContent>(function: func, arguments: new KernelArguments() { ["input"] = msg });
-            int i = 0;
-
-            await foreach (var content in chatResult)
-            {
-                result.choices[0].delta.content = content.Content.ConvertToString();
-                string message = $"data: {JsonConvert.SerializeObject(result)}\n\n";
-                await HttpContext.Response.WriteAsync(message, Encoding.UTF8);
-                await HttpContext.Response.Body.FlushAsync();
-                //模拟延迟。
-                await Task.Delay(TimeSpan.FromMilliseconds(50));
-            }
-
-            await HttpContext.Response.WriteAsync("data: [DONE]");
-            await HttpContext.Response.Body.FlushAsync();
-
-            await HttpContext.Response.CompleteAsync();
-        }
-
-
-        /// <summary>
-        /// 发送知识库问答
-        /// </summary>
-        /// <param name="questions"></param>
-        /// <param name="msg"></param>
-        /// <param name="app"></param>
-        /// <returns></returns>
-        private async Task<string> SendKms( string msg, Apps app)
-        {
-            string result = "";
-            //知识库问答
-            var filters = new List<MemoryFilter>();
-
-            var kmsidList = app.KmsIdList.Split(",");
-            foreach (var kmsid in kmsidList)
-            {
-                filters.Add(new MemoryFilter().ByTag("kmsid", kmsid));
-            }
-
-            var kmsResult = await _memory.AskAsync(msg, index: "kms", filters: filters);
-            if (kmsResult != null)
-            {
-                if (!string.IsNullOrEmpty(kmsResult.Result))
-                {
-                    string answers = kmsResult.Result;
-                    result = answers;     
-                }
-            }
-            return result;
-        }
-
-
-
-        /// <summary>
-        /// 发送普通对话
-        /// </summary>
-        /// <param name="questions"></param>
-        /// <param name="msg"></param>
-        /// <param name="app"></param>
-        /// <returns></returns>
-        private async Task<string> SendChat( string msg, Apps app)
-        {
-            string result = "";
-            if (string.IsNullOrEmpty(app.Prompt))
-            {
-                //如果模板为空，给默认提示词
-                app.Prompt = "{{$input}}";
-            }
-            var promptTemplateFactory = new KernelPromptTemplateFactory();
-            var promptTemplate = promptTemplateFactory.Create(new PromptTemplateConfig(app.Prompt));
-            var renderedPrompt = await promptTemplate.RenderAsync(_kernel);
-
-            var func = _kernel.CreateFunctionFromPrompt(app.Prompt, new OpenAIPromptExecutionSettings());
-            var chatResult = await _kernel.InvokeAsync(function: func, arguments: new KernelArguments() { ["input"] = msg });
-            if (chatResult.IsNotNull())
-            {
-                string answers = chatResult.GetValue<string>();
-                result = answers;
-            }
-            return result;
-        }
-
-        /// <summary>
-        /// 历史会话的会话总结
-        /// </summary>
-        /// <param name="questions"></param>
-        /// <param name="msg"></param>
-        /// <returns></returns>
-        private async Task<string> HistorySummarize(OpenAIModel model)
-        {
-
-            StringBuilder history = new StringBuilder();
-            string questions = model.messages[model.messages.Count-1].content;
-            for(int i=0;i<model.messages.Count()-1;i++)
-            {
-                var item = model.messages[i];
-                history.Append($"{item.role}:{item.content}{Environment.NewLine}");
-            }
-
-            KernelFunction sunFun = _kernel.Plugins.GetFunction("ConversationSummaryPlugin", "SummarizeConversation");
-            var summary = await _kernel.InvokeAsync(sunFun, new() { ["input"] = $"内容是：{history.ToString()} {Environment.NewLine} 请注意用中文总结" });
-            string his = summary.GetValue<string>();
-            var msg = $"历史对话:{his}{Environment.NewLine}用户问题：{Environment.NewLine}{questions}"; ;
-            return msg;
-        }
-    }
-}

AntSK/Xzy.KnowledgeBase.xml

@@ -1,14 +0,0 @@
-<?xml version="1.0"?>
-<doc>
-    <assembly>
-        <name>AntSK</name>
-    </assembly>
-    <members>
-        <member name="M:AntSK.Controllers.InitController.InitTable">
-            <summary>
-            初始化DB 和表
-            </summary>
-            <returns></returns>
-        </member>
-    </members>
-</doc>

Dockerfile

@@ -1,13 +1,25 @@
-FROM mcr.microsoft.com/dotnet/aspnet:8.0  AS base
+# Build stage
+FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build
+WORKDIR /src
+
+# Copy csproj and restore as distinct layers
+COPY ["src/AntSK/AntSK.csproj", "AntSK/"]
+RUN dotnet restore "AntSK/AntSK.csproj"
+
+# Copy everything else and build
+COPY src/ .
+WORKDIR "/src/AntSK"
+RUN dotnet build "AntSK.csproj" -c Release -o /app/build
+RUN dotnet publish "AntSK.csproj" -c Release -o /app/publish
+
+# Runtime stage
+FROM mcr.microsoft.com/dotnet/aspnet:8.0 AS base
 WORKDIR /service
 EXPOSE 5000
 
-WORKDIR /app
-COPY ["AntSK/bin/Release/net8.0/publish", "publish"]
-
-WORKDIR /app/publish
-
 FROM base AS final
+WORKDIR /app
+COPY --from=build /app/publish .
 RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
 RUN echo 'Asia/Shanghai' >/etc/timezone
-ENTRYPOINT ["dotnet", "AntSK.dll"]
+ENTRYPOINT ["dotnet", "AntSK.dll"]

README.en.md

@@ -35,6 +35,8 @@
 
 - **API interface publishing**: internal functions are provided externally in the form of API, so that developers can easily translate Xzy AntSK KnowledgeBase is integrated into other applications to enhance application intelligence.
 
+- **Model management**: Adapt and manage different models from different vendors.
+
 
 
 ## Application scenarios
@@ -121,43 +123,77 @@ The model supports openai by default. If you need to use azure openai and need t
 
 The following configuration files need to be configured
 
+## Using Docker Compose
+Provided pg version appsettings. json and simplified version (Sqlite+disk) Docker Compose. simple. yml
+Download Docker Compose.yml from the project root directory, and then place the configuration file appsettings.json and it in a unified directory,
+The image of PG has been prepared here. You can modify the default account password in Docker Compose.yml, and your appsettings. json database connection needs to be consistent.
+Then you can enter the directory and execute it
+```
+docker compose up - d
+```
+To start AntSK
+
+Some meanings of configuration files
+
 ```
 
-"ConnectionStrings":{
-
-"Postgres": "Host=; Port=; Database=antsk; Username=; Password="
-
-},
-
-"OpenAIOption":{
-
-"EndPoint": "",
-
-"Key": "",
-
-"Model": "",
-
-"Embedding Model": """""
-
-},
-
-Postgres:{
-
-"ConnectionString": "Host=; Port=; Database=antsk; Username=; Password=",
-
-"TableNamePrefix": "km -"
-
-},
-"Login": {
-  "User": "admin",
-  "Password": "xuzeyu"
+{
+  "DBConnection": {
+    "DbType": "Sqlite", 
+    "ConnectionStrings": "Data Source=AntSK.db;"
+  },
+  "OpenAIOption": {
+    "EndPoint": "http://localhost:5000/llama/",
+    "Key": "NotNull",
+    "Model": "gpt4-turbo",
+    "EmbeddingModel": "text-embedding-ada-002"
+  },
+  "KernelMemory": {
+    "VectorDb": "Disk", 
+    "ConnectionString": "Host=;Port=;Database=antsk;Username=;Password=",
+    "TableNamePrefix": "km-"
+  },
+  "LLamaSharp": {
+    "RunType": "GPU", 
+    "Chat": "D:\\Code\\AI\\AntBlazor\\model\\qwen1_5-1_8b-chat-q8_0.gguf",
+    "Embedding": "D:\\Code\\AI\\AntBlazor\\model\\qwen1_5-1_8b-chat-q8_0.gguf"
+  },
+  "Login": {
+    "User": "admin",
+    "Password": "xuzeyu"
+  },
+  "BackgroundTaskBroker": {
+    "ImportKMSTask": {
+      "WorkerCount": 1 
+    }
+  }
 }
 
 ```
 
-I use CodeFirst mode. As long as the database link is configured, the table structure is automatically created
-
+```
+//Supports multiple databases, including SqlSugar, MySql, SqlServer, Sqlite, Oracle, PostgreSQL, Dm, Kdbndp, Oscar, MySqlConnector, Access, OpenGaussian, QuestDB, HG, ClickHouse, GBase, Odbc, OceanBaseForOracle, TDengine, GaussDB, OceanBase, Tidb, Vastbase, PolarDB, Custom
+DBConnection DbType
+//Connection string, corresponding strings need to be used according to different DB types
+DBConnection ConnectionStrings
+//You can use an online API that conforms to the OpenAI format (domestic models use one API adapter), or you can use AntSK's built-in llama API, with the IP and port being the AntSK startup address
+OpenAIOption EndPoint
+//Model key, if using a local model, it can default to Notnull. Chinese cannot be used here
+OpenAIOption Key
+//The type of vector storage supports Postgres Disk Memory, where Postgres requires the configuration of ConnectionString
+KernelMemory VectorDb
+//The running mode used by the local model is GUP CPU. If using an online API, you can freely use one
+LLamaSharp RunType
+//The model path of the local session model should pay attention to distinguishing between Linux and Windows drive letters
+LLamaSharp Chat
+//The model path of the local vector model should pay attention to distinguishing between Linux and Windows drive letters
+LLamaSharp Embedding
+//Default administrator account password
+Login
+//The number of threads for importing asynchronous processing can be higher when using online APIs. Local models suggest 1, otherwise memory overflow and crash may occur
+BackgroundTaskBroker ImportKMSTask WorkerCount
 
+```
 
 
 To learn more or start using**AntSK**, you can follow my public account and join the exchange group.

README.md

@@ -18,6 +18,8 @@
 
 - **API接口发布**：将内部功能以API的形式对外提供，便于开发者将AntSK 集成进其他应用，增强应用智慧。
 
+- **模型管理**：适配和管理集成不同厂商的不同模型。
+
 ## 应用场景
 
 AntSK 适用于多种业务场景，例如：
@@ -60,49 +62,121 @@ AntSK 适用于多种业务场景，例如：
 ## 如何开始？
 
 在这里我使用的是Postgres 作为数据存储和向量存储，因为Semantic Kernel和Kernel Memory都支持他，当然你也可以换成其他的。
-模型默认支持openai,如果需要使用azure openai需要调整SK的依赖注入，也可以使用one-api进行集成。
-Login是默认的登陆账号和密码
-需要配置如下的配置文件
-### 需要注意的是PostgreSQL需要安装扩展vector 
 
+模型默认支持openai,如果需要使用azure openai需要调整SK的依赖注入，也可以使用one-api进行集成。
+
+Login是默认的登陆账号和密码
+
+需要配置如下的配置文件
+
+## 使用docker-compose 
+
+提供了pg版本 **appsettings.json** 和 简化版本（Sqlite+disk） **docker-compose.simple.yml**
+
+从项目根目录下载**docker-compose.yml**,然后把配置文件**appsettings.json**和它放在统一目录，
+
+这里已经把pg的镜像做好了。在docker-compose.yml中可以修改默认账号密码，然后你的**appsettings.json**的数据库连接需要保持一致。
+
+然后你可以进入到目录后执行
 ```
-  "ConnectionStrings": {
-    "Postgres": "Host=;Port=;Database=antsk;Username=;Password="
+docker-compose up -d
+```
+来启动AntSK
+
+## 如何在docker中挂载本地模型
+```
+# 非 host 版本, 不使用本机代理
+version: '3.8'
+services:
+  antsk:
+    container_name: antsk
+    image: registry.cn-hangzhou.aliyuncs.com/xuzeyu91/antsk:v0.1.5
+    ports:
+      - 5000:5000
+    networks:
+      - antsk
+    depends_on:
+      - antskpg
+    restart: always
+    environment:
+      - ASPNETCORE_URLS=http://*:5000
+    volumes:
+      - ./appsettings.json:/app/appsettings.json # 本地配置文件 需要放在同级目录
+      - D://model:/app/model
+networks:
+  antsk:
+```
+以这个为示例，意思是把windows本地D://model的文件夹挂载进 容器内/app/model 如果是这样你的appsettings.json中的模型地址应该配置为  
+```
+model/xxx.gguf
+```
+
+## 配置文件的一些含义
+```
+{
+  "DBConnection": {
+    "DbType": "Sqlite", 
+    "ConnectionStrings": "Data Source=AntSK.db;"
   },
-  "OpenAIOption": {
-    "EndPoint": "",
-    "Key": "",
-    "Model": "",
-    "EmbeddingModel": ""
-  },
-  "Postgres": {
+  "KernelMemory": {
+    "VectorDb": "Disk", 
     "ConnectionString": "Host=;Port=;Database=antsk;Username=;Password=",
     "TableNamePrefix": "km-"
   },
+  "LLamaSharp": {
+    "RunType": "GPU", 
+    "Chat": "D:\\Code\\AI\\AntBlazor\\model\\qwen1_5-1_8b-chat-q8_0.gguf",
+    "Embedding": "D:\\Code\\AI\\AntBlazor\\model\\qwen1_5-1_8b-chat-q8_0.gguf"
+  },
   "Login": {
     "User": "admin",
     "Password": "xuzeyu"
+  },
+  "BackgroundTaskBroker": {
+    "ImportKMSTask": {
+      "WorkerCount": 1 
+    }
   }
+}
 ```
-我使用的是CodeFirst模式，只要配置好数据库链接，表结构是自动创建的
-
-如果想使用LLamaSharp运行本地模型还需要设置如下配置：
 ```
-  "LLamaSharp": {
-    "Chat": "D:\\Code\\AI\\AntBlazor\\model\\tinyllama-1.1b-chat.gguf",
-    "Embedding": "D:\\Code\\AI\\AntBlazor\\model\\tinyllama-1.1b-chat.gguf"
-  },
+//支持多种数据库，具体可以查看SqlSugar，MySql，SqlServer，Sqlite，Oracle，PostgreSQL，Dm，Kdbndp，Oscar，MySqlConnector，Access，OpenGauss，QuestDB，HG，ClickHouse，GBase，Odbc，OceanBaseForOracle，TDengine，GaussDB，OceanBase，Tidb，Vastbase，PolarDB，Custom
+DBConnection.DbType
+//连接字符串，需要根据不同DB类型，用对应的字符串
+DBConnection.ConnectionStrings
+//可以使用符合openai格式的在线API（国产模型使用one-api转接） ，也可以使用AntSK自带的llama api，ip和端口是AntSK启动地址
+OpenAIOption.EndPoint
+//模型秘钥，如果使用本地模型可以默认NotNull 这里不能用中文
+OpenAIOption.Key
+//向量存储的类型，支持  Postgres  Disk  Memory ，其中Postgres需要配置 ConnectionString
+KernelMemory.VectorDb
+//本地模型使用的运行方式  GUP  CPU ,如果用在线API 这个随意使用一个即可
+LLamaSharp.RunType
+//本地会话模型的模型路径 注意区分linux和windows盘符不同
+LLamaSharp.Chat
+//本地向量模型的模型路径 注意区分linux和windows盘符不同
+LLamaSharp.Embedding
+//默认管理员账号密码
+Login
+//导入异步处理的线程数，使用在线API可以高一点，本地模型建议1 否则容易内存溢出崩掉
+BackgroundTaskBroker.ImportKMSTask.WorkerCount
 ```
 
-需要配置Chat和Embedding模型的地址，然后修改EndPoint为本地：
+## 找不到样式问题解决：
+AntSK/src/AntSK下执行:
 ```
- "OpenAIOption": {
-    "EndPoint": "https://ip:port/llama/",
-    "Key": "",
-    "Model": "",
-    "EmbeddingModel": ""
-  },
+dotnet clean
+dotnet build
+dotnet publish "AntSK.csproj"
 ```
+再去AntSK/src/AntSK/bin/Release/net8.0/publish下
+```
+dotnet AntSK.dll
+```
+然后启动就有样式了
+
+DB我使用的是CodeFirst模式，只要配置好数据库链接，表结构是自动创建的
+
 
 
 想了解更多信息或开始使用 **AntSK**，可以关注我的公众号以及加入交流群。
@@ -114,3 +188,4 @@ Login是默认的登陆账号和密码
 ---
 
 我们对您在**AntSK**的兴趣表示感谢，并期待与您携手共创智能化的未来！
+

docker-compose.simple.yml

@@ -0,0 +1,17 @@
+# 非 host 版本, 不使用本机代理
+version: '3.8'
+services:
+  antsk:
+    container_name: antsk
+    image: registry.cn-hangzhou.aliyuncs.com/xuzeyu91/antsk:v0.1.6.2
+    ports:
+      - 5000:5000
+    networks:
+      - antsk
+    restart: always
+    environment:
+      - ASPNETCORE_URLS=http://*:5000
+    volumes:
+      - ./appsettings.json:/app/appsettings.json # 本地配置文件 需要放在同级目录
+networks:
+  antsk:

docker-compose.yml

@@ -0,0 +1,34 @@
+# 非 host 版本, 不使用本机代理
+version: '3.8'
+services:
+  antskpg:
+    image: registry.cn-hangzhou.aliyuncs.com/xuzeyu91/pg:v0.5.0 
+    container_name: antskpg
+    restart: always
+    ports: # 生产环境建议不要暴露
+      - 5432:5432
+    networks:
+      - antsk
+    environment:
+      # 这里的配置只有首次运行生效。修改后，重启镜像是不会生效的。需要把持久化数据删除再重启，才有效果
+      - POSTGRES_USER=username
+      - POSTGRES_PASSWORD=password
+      - POSTGRES_DB=antsk
+    volumes:
+      - ./pg/data:/var/lib/postgresql/data
+  antsk:
+    container_name: antsk
+    image: registry.cn-hangzhou.aliyuncs.com/xuzeyu91/antsk:v0.1.6.2
+    ports:
+      - 5000:5000
+    networks:
+      - antsk
+    depends_on:
+      - antskpg
+    restart: always
+    environment:
+      - ASPNETCORE_URLS=http://*:5000
+    volumes:
+      - ./appsettings.json:/app/appsettings.json # 本地配置文件 需要放在同级目录
+networks:
+  antsk:

src/AntSK.Domain/AntSK.Domain.csproj

@@ -5,17 +5,20 @@
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
     <DocumentationFile>AntSK.Domain.xml</DocumentationFile>
+    <NoWarn>CA1050,CA1707,CA2007,VSTHRD111,CS1591,RCS1110,CA5394,SKEXP0001,SKEXP0002,SKEXP0003,SKEXP0004,SKEXP0010,SKEXP0011,,SKEXP0012,SKEXP0020,SKEXP0021,SKEXP0022,SKEXP0023,SKEXP0024,SKEXP0025,SKEXP0026,SKEXP0027,SKEXP0028,SKEXP0029,SKEXP0030,SKEXP0031,SKEXP0032,SKEXP0040,SKEXP0041,SKEXP0042,SKEXP0050,SKEXP0051,SKEXP0052,SKEXP0053,SKEXP0054,SKEXP0055,SKEXP0060,SKEXP0061,SKEXP0101,SKEXP0102</NoWarn>
   </PropertyGroup>
   <ItemGroup>
+    <PackageReference Include="AntDesign.Charts" Version="0.5.1" />
+    <PackageReference Include="AntDesign.ProLayout" Version="0.17.3" />
+    
     <PackageReference Include="AutoMapper" Version="8.1.0" />
     <PackageReference Include="BCrypt.Net-Next" Version="4.0.3" />
-    <PackageReference Include="LLamaSharp.kernel-memory" Version="0.10.0" />
-    <PackageReference Include="LLamaSharp.semantic-kernel" Version="0.10.0" />
     <PackageReference Include="MarkdownSharp" Version="2.0.5" />
     <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
     <PackageReference Include="SqlSugarCore" Version="5.1.4.143" />
     <PackageReference Include="System.Data.SQLite.Core" Version="1.0.118" />
-
+    <PackageReference Include="RestSharp" Version="110.2.0" />
+    
     <PackageReference Include="Microsoft.SemanticKernel" Version="1.4.0" />
     <PackageReference Include="Microsoft.SemanticKernel.Core" Version="1.4.0" />
     <PackageReference Include="Microsoft.SemanticKernel.Plugins.Core" Version="1.4.0-alpha" />
@@ -24,6 +27,14 @@
 
     <PackageReference Include="LLamaSharp" Version="0.10.0" />
     <PackageReference Include="LLamaSharp.Backend.Cpu" Version="0.10.0" />
+    <PackageReference Include="LLamaSharp.Backend.Cuda12" Version="0.10.0" />
+    <PackageReference Include="LLamaSharp.kernel-memory" Version="0.10.0" />
+    <PackageReference Include="LLamaSharp.semantic-kernel" Version="0.10.0" />
+    
+    
+  </ItemGroup>
+  <ItemGroup>
+    <ProjectReference Include="..\MiddleWare\AntSK.BackgroundTask\AntSK.BackgroundTask.csproj" />
   </ItemGroup>
 
 </Project>

src/AntSK.Domain/AntSK.Domain.xml

@@ -32,6 +32,66 @@
             瞬时
             </summary>
         </member>
+        <member name="M:AntSK.Domain.Common.Map.MapperExtend.ToDTOList``1(System.Object)">
+            <summary>
+            Entity集合转DTO集合
+            </summary>
+            <typeparam name="T"></typeparam>
+            <param name="value"></param>
+            <returns></returns>
+        </member>
+        <member name="M:AntSK.Domain.Common.Map.MapperExtend.ToDTO``1(System.Object)">
+            <summary>
+            Entity转DTO
+            </summary>
+            <typeparam name="T"></typeparam>
+            <param name="value"></param>
+            <returns></returns>
+        </member>
+        <member name="F:AntSK.Domain.Domain.Other.LLamaConfig.dicLLamaWeights">
+            <summary>
+            避免模型重复加载，本地缓存
+            </summary>
+        </member>
+        <member name="M:AntSK.Domain.Domain.Service.ChatService.SendChatByAppAsync(AntSK.Domain.Repositories.Apps,System.String,System.String)">
+            <summary>
+            发送消息
+            </summary>
+            <param name="app"></param>
+            <param name="questions"></param>
+            <param name="history"></param>
+            <returns></returns>
+        </member>
+        <member name="M:AntSK.Domain.Domain.Service.KernelService.GetKernelByApp(AntSK.Domain.Repositories.Apps)">
+            <summary>
+            获取kernel实例，依赖注入不好按每个用户去Import不同的插件，所以每次new一个新的kernel
+            </summary>
+            <param name="modelId"></param>
+            <param name="apiKey"></param>
+            <returns></returns>
+        </member>
+        <member name="M:AntSK.Domain.Domain.Service.KernelService.ImportFunctionsByApp(AntSK.Domain.Repositories.Apps,Microsoft.SemanticKernel.Kernel)">
+            <summary>
+            根据app配置的插件，导入插件
+            </summary>
+            <param name="app"></param>
+            <param name="_kernel"></param>
+        </member>
+        <member name="M:AntSK.Domain.Domain.Service.KernelService.RegisterPluginsWithKernel(Microsoft.SemanticKernel.Kernel)">
+            <summary>
+            注册默认插件
+            </summary>
+            <param name="kernel"></param>
+        </member>
+        <member name="M:AntSK.Domain.Domain.Service.KernelService.HistorySummarize(Microsoft.SemanticKernel.Kernel,System.String,System.String)">
+            <summary>
+            会话总结
+            </summary>
+            <param name="_kernel"></param>
+            <param name="questions"></param>
+            <param name="history"></param>
+            <returns></returns>
+        </member>
         <member name="M:AntSK.Domain.Map.MapperExtend.ToDTOList``1(System.Object)">
             <summary>
             Entity集合转DTO集合
@@ -57,6 +117,16 @@
             <param name="result"></param>
             <returns></returns>
         </member>
+        <member name="T:AntSK.Domain.Model.Enum.AIType">
+            <summary>
+            AI类型
+            </summary>
+        </member>
+        <member name="T:AntSK.Domain.Model.Enum.AIModelType">
+            <summary>
+            模型类型
+            </summary>
+        </member>
         <member name="P:AntSK.Domain.Model.MessageInfo.IsSend">
             <summary>
             发送是true  接收是false
@@ -77,16 +147,71 @@
             总数
             </summary>
         </member>
-        <member name="P:AntSK.Domain.Options.ConnectionOption.Sqlite">
+        <member name="P:AntSK.Domain.Options.DBConnectionOption.DbType">
             <summary>
             sqlite连接字符串
             </summary>
         </member>
-        <member name="P:AntSK.Domain.Options.ConnectionOption.Postgres">
+        <member name="P:AntSK.Domain.Options.DBConnectionOption.ConnectionStrings">
             <summary>
             pg链接字符串
             </summary>
         </member>
+        <member name="P:AntSK.Domain.Options.KernelMemoryOption.VectorDb">
+            <summary>
+            向量库
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Options.KernelMemoryOption.ConnectionString">
+            <summary>
+            连接字符串
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Options.KernelMemoryOption.TableNamePrefix">
+            <summary>
+            表前缀
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Apis.Name">
+            <summary>
+            接口名称
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Apis.Describe">
+            <summary>
+            接口描述
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Apis.Url">
+            <summary>
+            接口地址
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Apis.Method">
+            <summary>
+            请求方法
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Apis.Query">
+            <summary>
+            QueryString参数
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Apis.JsonBody">
+            <summary>
+            jsonBody 实体
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Apis.InputPrompt">
+            <summary>
+            入参提示词
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Apis.OutputPrompt">
+            <summary>
+            返回提示词
+            </summary>
+        </member>
         <member name="P:AntSK.Domain.Repositories.Apps.Name">
             <summary>
             名称
@@ -97,11 +222,36 @@
             描述
             </summary>
         </member>
+        <member name="P:AntSK.Domain.Repositories.Apps.Icon">
+            <summary>
+            图标
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Apps.Type">
+            <summary>
+            类型
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Apps.ChatModelID">
+            <summary>
+            会话模型ID
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Apps.Temperature">
+            <summary>
+            温度
+            </summary>
+        </member>
         <member name="P:AntSK.Domain.Repositories.Apps.Prompt">
             <summary>
             提示词
             </summary>
         </member>
+        <member name="P:AntSK.Domain.Repositories.Apps.ApiFunctionList">
+            <summary>
+            插件列表
+            </summary>
+        </member>
         <member name="P:AntSK.Domain.Repositories.Apps.KmsIdList">
             <summary>
             知识库ID列表
@@ -137,6 +287,11 @@
             创建时间
             </summary>
         </member>
+        <member name="P:AntSK.Domain.Repositories.KmsDetails.Status">
+            <summary>
+            状态
+            </summary>
+        </member>
         <member name="P:AntSK.Domain.Repositories.Kmss.Icon">
             <summary>
             图标
@@ -152,6 +307,31 @@
             会话模型
             </summary>
         </member>
+        <member name="P:AntSK.Domain.Repositories.Kmss.ChatModelID">
+            <summary>
+            会话模型ID
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Kmss.EmbeddingModelID">
+            <summary>
+            向量模型ID
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Kmss.MaxTokensPerParagraph">
+            <summary>
+            每个段落的最大标记数。
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Kmss.MaxTokensPerLine">
+            <summary>
+            每行，也就是每句话的最大标记数
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.Kmss.OverlappingTokens">
+            <summary>
+            段落之间重叠标记的数量。
+            </summary>
+        </member>
         <member name="M:AntSK.Domain.Repositories.Base.Repository`1.GetList">
             <summary>
             获取所有list
@@ -404,11 +584,41 @@
             <param name="whereExpression"></param>
             <returns></returns>
         </member>
-        <member name="F:AntSK.Domain.Repositories.Base.SqlSugarHelper.Sqlite">
+        <member name="M:AntSK.Domain.Repositories.Base.SqlSugarHelper.SqlScope">
             <summary>
             sqlserver连接
             </summary>
         </member>
+        <member name="P:AntSK.Domain.Repositories.AIModels.AIType">
+            <summary>
+            AI类型
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.AIModels.AIModelType">
+            <summary>
+            模型类型
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.AIModels.EndPoint">
+            <summary>
+            模型地址
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.AIModels.ModelName">
+            <summary>
+            模型名称
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.AIModels.ModelKey">
+            <summary>
+            模型秘钥
+            </summary>
+        </member>
+        <member name="P:AntSK.Domain.Repositories.AIModels.ModelDescription">
+            <summary>
+            部署名，azure需要使用
+            </summary>
+        </member>
         <member name="P:AntSK.Domain.Repositories.Users.No">
             <summary>
             工号，用于登陆
@@ -524,5 +734,11 @@
             <param name="stream"></param>
             <returns></returns>
         </member>
+        <member name="M:AntSK.Domain.Utils.RepoFiles.SamplePluginsPath">
+            <summary>
+            Scan the local folders from the repo, looking for "samples/plugins" folder.
+            </summary>
+            <returns>The full path to samples/plugins</returns>
+        </member>
     </members>
 </doc>

src/AntSK.Domain/Common/DependencyInjection/DependencyInjection.cs

@@ -1,10 +1,5 @@
 using Microsoft.Extensions.DependencyInjection;
-using System;
-using System.Collections.Generic;
-using System.Linq;
 using System.Reflection;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace AntSK.Domain.Common.DependencyInjection
 {

src/AntSK.Domain/Common/DependencyInjection/ServiceDescriptionAttribute.cs

@@ -1,10 +1,4 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace AntSK.Domain.Common.DependencyInjection
+namespace AntSK.Domain.Common.DependencyInjection
 {
     public class ServiceDescriptionAttribute : Attribute
     {

src/AntSK.Domain/Common/Map/AutoMapProfile.cs

@@ -0,0 +1,12 @@
+using AutoMapper;
+
+namespace AntSK.Domain.Common.Map
+{
+    public class AutoMapProfile : Profile
+    {
+        public AutoMapProfile()
+        {
+            //CreateMap<PMP_BizCase_Main_Max, BizcaseQueryDTO>();
+        }
+    }
+}

src/AntSK.Domain/Common/Map/MapperExtend.cs

@@ -0,0 +1,32 @@
+namespace AntSK.Domain.Common.Map
+{
+    public static class MapperExtend
+    {
+        /// <summary>
+        /// Entity集合转DTO集合
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public static List<T> ToDTOList<T>(this object value)
+        {
+            if (value == null)
+                return new List<T>();
+
+            return AutoMapper.Mapper.Map<List<T>>(value);
+        }
+        /// <summary>
+        /// Entity转DTO
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public static T ToDTO<T>(this object value)
+        {
+            if (value == null)
+                return default(T);
+
+            return AutoMapper.Mapper.Map<T>(value);
+        }
+    }
+}

src/AntSK.Domain/Common/Map/MapperRegister.cs

@@ -0,0 +1,28 @@
+using AutoMapper;
+using Microsoft.Extensions.DependencyInjection;
+
+namespace AntSK.Domain.Common.Map
+{
+    public static class MapperRegister
+    {
+        public static void AddMapper(this IServiceCollection services)
+        {
+            var config = new MapperConfiguration(cfg =>
+            {
+                cfg.CreateMissingTypeMaps = true;
+                cfg.ValidateInlineMaps = false;
+                cfg.AddProfile<AutoMapProfile>();
+            });
+
+            IMapper mapper = config.CreateMapper();
+
+            //启动实体映射
+            Mapper.Initialize(cfg =>
+            {
+                cfg.CreateMissingTypeMaps = true;
+                cfg.ValidateInlineMaps = false;
+                cfg.AddProfile<AutoMapProfile>();
+            });
+        }
+    }
+}

src/AntSK.Domain/Domain/Dto/KMFile.cs

@@ -1,10 +1,4 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace AntSK.Domain.Domain.Dto
+namespace AntSK.Domain.Domain.Dto
 {
     public class KMFile
     {

src/AntSK.Domain/Domain/Dto/OpenAPI/OpenAIModel.cs

@@ -1,11 +1,4 @@
-using Microsoft.AspNetCore.Identity;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace AntSK.Models
+namespace AntSK.Domain.Domain.Dto
 {
     public class OpenAIModel
     {

src/AntSK.Domain/Domain/Dto/OpenAPI/OpenAIResult.cs

@@ -1,7 +1,6 @@
 using Newtonsoft.Json;
-using System.Text.Json.Serialization;
 
-namespace AntSK.Models.OpenAPI
+namespace AntSK.Domain.Domain.Dto
 {
     public class OpenAIResult
     {
@@ -21,7 +20,7 @@ namespace AntSK.Models.OpenAPI
         public OpenAIMessage message { get; set; }
     }
 
-    public class OpenAIEmbeddingResult 
+    public class OpenAIEmbeddingResult
     {
         [JsonProperty("object")]
         public string obj { get; set; } = "list";
@@ -29,17 +28,17 @@ namespace AntSK.Models.OpenAPI
 
         public UsageModel usage { get; set; } = new UsageModel();
 
-        public  List<DataModel> data { get; set; } = new List<DataModel>() { new DataModel() };
+        public List<DataModel> data { get; set; } = new List<DataModel>() { new DataModel() };
     }
 
-    public class UsageModel 
+    public class UsageModel
     {
         public long prompt_tokens { get; set; } = 0;
 
         public long total_tokens { get; set; } = 0;
     }
 
-    public class DataModel 
+    public class DataModel
     {
         [JsonProperty("object")]
         public string obj { get; set; } = "embedding";

src/AntSK.Domain/Domain/Dto/RelevantSource.cs

@@ -0,0 +1,16 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace AntSK.Domain.Domain.Dto
+{
+    public class RelevantSource
+    {
+        public string SourceName { get; set; }
+
+        public string Text { get; set; }
+        public float Relevance { get; set; }
+    }
+}

src/AntSK.Domain/Domain/Interface/IChatService.cs

@@ -0,0 +1,18 @@
+using AntSK.Domain.Domain.Dto;
+using AntSK.Domain.Repositories;
+using Microsoft.SemanticKernel;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace AntSK.Domain.Domain.Interface
+{
+    public interface IChatService
+    {
+        IAsyncEnumerable<StreamingKernelContent> SendChatByAppAsync(Apps app, string questions, string history);
+
+        IAsyncEnumerable<StreamingKernelContent> SendKmsByAppAsync(Apps app, string questions, string history, List<RelevantSource> relevantSources = null);
+    }
+}

src/AntSK.Domain/Domain/Interface/IHttpService.cs

@@ -0,0 +1,9 @@
+using RestSharp;
+
+namespace AntSK.Domain.Domain.Interface
+{
+    public interface IHttpService
+    {
+        Task<RestResponse> PostAsync(string url, Object jsonBody);
+    }
+}

src/AntSK.Domain/Domain/Interface/IImportKMSService.cs

@@ -0,0 +1,9 @@
+using AntSK.Domain.Model;
+
+namespace AntSK.Domain.Domain.Interface
+{
+    public interface IImportKMSService
+    {
+        void ImportKMSTask(ImportKMSTaskReq req);
+    }
+}

src/AntSK.Domain/Domain/Interface/IKMService.cs

@@ -0,0 +1,11 @@
+using AntSK.Domain.Domain.Dto;
+using Microsoft.KernelMemory;
+
+namespace AntSK.Domain.Domain.Interface
+{
+    public interface IKMService
+    {
+        MemoryServerless GetMemoryByKMS(string kmsID, SearchClientConfig searchClientConfig = null);
+        Task<List<KMFile>> GetDocumentByFileID(string kmsid, string fileid);
+    }
+}

src/AntSK.Domain/Domain/Interface/IKernelService.cs

@@ -0,0 +1,12 @@
+using AntSK.Domain.Repositories;
+using Microsoft.SemanticKernel;
+
+namespace AntSK.Domain.Domain.Interface
+{
+    public interface IKernelService
+    {
+        Kernel GetKernelByApp(Apps app);
+        void ImportFunctionsByApp(Apps app, Kernel _kernel);
+        Task<string> HistorySummarize(Kernel _kernel, string questions, string history);
+    }
+}

src/AntSK.Domain/Domain/Other/BackGroundTaskHandler.cs

@@ -0,0 +1,41 @@
+using AntSK.BackgroundTask;
+using AntSK.Domain.Domain.Interface;
+using AntSK.Domain.Model;
+using Microsoft.Extensions.DependencyInjection;
+
+namespace AntSK.Domain.Domain.Other
+{
+    public class BackGroundTaskHandler : IBackgroundTaskHandler<ImportKMSTaskReq>
+    {
+        private readonly IServiceScopeFactory _scopeFactory;
+
+        public BackGroundTaskHandler(IServiceScopeFactory scopeFactory)
+        {
+            _scopeFactory = scopeFactory;
+        }
+        public async Task ExecuteAsync(ImportKMSTaskReq item)
+        {
+            using (var scope = _scopeFactory.CreateScope())
+            {
+                Console.WriteLine("ExecuteAsync.开始执行后台任务");
+                var importKMSService = scope.ServiceProvider.GetRequiredService<IImportKMSService>();
+                //不能使用异步
+                importKMSService.ImportKMSTask(item);
+                Console.WriteLine("ExecuteAsync.后台任务执行完成");
+            }
+
+        }
+
+        public Task OnFailed()
+        {
+            return Task.CompletedTask;
+
+        }
+
+        public Task OnSuccess()
+        {
+            return Task.CompletedTask;
+        }
+
+    }
+}

src/AntSK.Domain/Domain/Other/LLamaConfig.cs

@@ -0,0 +1,44 @@
+using LLama;
+using LLama.Common;
+using LLamaSharp.KernelMemory;
+
+namespace AntSK.Domain.Domain.Other
+{
+    public static class LLamaConfig
+    {
+        static object lockobj = new object();
+        /// <summary>
+        /// 避免模型重复加载，本地缓存
+        /// </summary>
+        static Dictionary<string, (LLamaWeights, ModelParams)> dicLLamaWeights = new Dictionary<string, (LLamaWeights, ModelParams)>();
+        public static (LLamaWeights, ModelParams) GetLLamaConfig(string modelPath, LLamaSharpConfig config = null)
+        {
+            lock (lockobj)
+            {
+                if (dicLLamaWeights.ContainsKey(modelPath))
+                {
+                    return dicLLamaWeights.GetValueOrDefault(modelPath);
+                }
+                else
+                {
+                    InferenceParams infParams = new() { AntiPrompts = ["\n\n"] };
+                    LLamaSharpConfig lsConfig = new(modelPath) { DefaultInferenceParams = infParams };
+                    if (config != null)
+                    {
+                        lsConfig = config;
+                    }
+                    var parameters = new ModelParams(lsConfig.ModelPath)
+                    {
+                        ContextSize = lsConfig?.ContextSize ?? 2048,
+                        Seed = lsConfig?.Seed ?? 0,
+                        GpuLayerCount = lsConfig?.GpuLayerCount ?? 20,
+                        EmbeddingMode = true
+                    };
+                    var weights = LLamaWeights.LoadFromFile(parameters);
+                    dicLLamaWeights.Add(modelPath, (weights, parameters));
+                    return (weights, parameters);
+                }
+            }
+        }
+    }
+}

src/AntSK.Domain/Domain/Service/ChatService.cs

@@ -0,0 +1,105 @@
+using AntSK.Domain.Common.DependencyInjection;
+using AntSK.Domain.Domain.Interface;
+using AntSK.Domain.Repositories;
+using Microsoft.SemanticKernel.Connectors.OpenAI;
+using Microsoft.SemanticKernel;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using AntSK.Domain.Utils;
+using Microsoft.KernelMemory;
+using AntSK.Domain.Model;
+using MarkdownSharp;
+using AntSK.Domain.Domain.Dto;
+
+namespace AntSK.Domain.Domain.Service
+{
+    [ServiceDescription(typeof(IChatService), ServiceLifetime.Scoped)]
+    public class ChatService(
+        IKernelService _kernelService,
+        IKMService _kMService ,
+        IKmsDetails_Repositories _kmsDetails_Repositories
+        ) : IChatService
+    {
+        /// <summary>
+        /// 发送消息
+        /// </summary>
+        /// <param name="app"></param>
+        /// <param name="questions"></param>
+        /// <param name="history"></param>
+        /// <returns></returns>
+        public async IAsyncEnumerable<StreamingKernelContent> SendChatByAppAsync(Apps app, string questions, string history)
+        {
+            if (string.IsNullOrEmpty(app.Prompt) || !app.Prompt.Contains("{{$input}}"))
+            {
+                //如果模板为空，给默认提示词
+                app.Prompt = app.Prompt.ConvertToString() + "{{$input}}";
+            }
+            var _kernel = _kernelService.GetKernelByApp(app);
+            var temperature = app.Temperature / 100;//存的是0~100需要缩小
+            OpenAIPromptExecutionSettings settings = new() { Temperature = temperature };
+            if (!string.IsNullOrEmpty(app.ApiFunctionList))
+            {
+                _kernelService.ImportFunctionsByApp(app, _kernel);
+                settings.ToolCallBehavior = ToolCallBehavior.AutoInvokeKernelFunctions;
+            }
+
+            var func = _kernel.CreateFunctionFromPrompt(app.Prompt, settings);
+            var chatResult = _kernel.InvokeStreamingAsync(function: func, arguments: new KernelArguments() { ["input"] = $"{history}{Environment.NewLine} user:{questions}" });
+            await foreach (var content in chatResult)
+            {
+                yield return content;
+            }
+        }
+
+        public async IAsyncEnumerable<StreamingKernelContent> SendKmsByAppAsync(Apps app, string questions, string history, List<RelevantSource> relevantSources=null)
+        {
+            var _kernel = _kernelService.GetKernelByApp(app);
+            //知识库问答
+            var filters = new List<MemoryFilter>();
+            var kmsidList = app.KmsIdList.Split(",");
+            //只取第一个知识库的配置
+            var _memory = _kMService.GetMemoryByKMS(kmsidList.FirstOrDefault());
+            foreach (var kmsid in kmsidList)
+            {
+                filters.Add(new MemoryFilter().ByTag("kmsid", kmsid));
+            }
+            var xlresult = await _memory.SearchAsync(questions, index: "kms", filters: filters);
+            string dataMsg = "";
+            if (xlresult != null)
+            {
+                foreach (var item in xlresult.Results)
+                {
+                    foreach (var part in item.Partitions)
+                    {
+                        dataMsg += $"[file:{item.SourceName};Relevance:{(part.Relevance * 100).ToString("F2")}%]:{part.Text}{Environment.NewLine}";
+
+                        if (relevantSources.IsNotNull())
+                        {
+                            var markdown = new Markdown();
+                            string sourceName = item.SourceName;
+                            var fileDetail = _kmsDetails_Repositories.GetFirst(p => p.FileGuidName == item.SourceName);
+                            if (fileDetail.IsNotNull())
+                            {
+                                sourceName = fileDetail.FileName;
+                            }
+                            relevantSources.Add(new RelevantSource() { SourceName = sourceName, Text = markdown.Transform(part.Text), Relevance = part.Relevance });
+                        }
+                    }
+                }
+                KernelFunction jsonFun = _kernel.Plugins.GetFunction("KMSPlugin", "Ask");
+                var chatResult = _kernel.InvokeStreamingAsync(function: jsonFun,
+                    arguments: new KernelArguments() { ["doc"] = dataMsg, ["history"] = history, ["questions"] = questions });
+
+                MessageInfo info = null;
+                var markdown1 = new Markdown();
+                await foreach (var content in chatResult)
+                {
+                    yield return content;
+                }             
+            }
+        }
+    }
+}

src/AntSK.Domain/Domain/Service/HttpService.cs

@@ -0,0 +1,21 @@
+using AntSK.Domain.Common.DependencyInjection;
+using AntSK.Domain.Domain.Interface;
+using Newtonsoft.Json;
+using RestSharp;
+
+namespace AntSK.Domain.Domain.Service
+{
+    [ServiceDescription(typeof(IHttpService), ServiceLifetime.Scoped)]
+    public class HttpService : IHttpService
+    {
+        public async Task<RestResponse> PostAsync(string url, Object jsonBody)
+        {
+            RestClient client = new RestClient();
+            RestRequest request = new RestRequest(url, Method.Post);
+            string josn = JsonConvert.SerializeObject(jsonBody);
+            request.AddJsonBody(jsonBody);
+            var result = await client.ExecuteAsync(request);
+            return result;
+        }
+    }
+}

src/AntSK.Domain/Domain/Service/ImportKMSService.cs

@@ -0,0 +1,80 @@
+using AntSK.Domain.Common.DependencyInjection;
+using AntSK.Domain.Domain.Interface;
+using AntSK.Domain.Model;
+using AntSK.Domain.Repositories;
+using Microsoft.KernelMemory;
+
+namespace AntSK.Domain.Domain.Service
+{
+    [ServiceDescription(typeof(IImportKMSService), ServiceLifetime.Scoped)]
+    public class ImportKMSService(
+        IKMService _kMService,
+        IKmsDetails_Repositories _kmsDetails_Repositories,
+        IKmss_Repositories _kmss_Repositories
+        ) : IImportKMSService
+    {
+
+        public void ImportKMSTask(ImportKMSTaskReq req)
+        {
+            try
+            {
+                var km = _kmss_Repositories.GetFirst(p => p.Id == req.KmsId);
+
+                var _memory = _kMService.GetMemoryByKMS(km.Id);
+                string fileid = req.KmsDetail.Id;
+                switch (req.ImportType)
+                {
+                    case ImportType.File:
+                        //导入文件
+                        {
+                            var importResult = _memory.ImportDocumentAsync(new Document(fileid)
+                          .AddFile(req.FilePath)
+                          .AddTag("kmsid", req.KmsId)
+                          , index: "kms").Result;
+                            //查询文档数量
+                            var docTextList = _kMService.GetDocumentByFileID(km.Id, fileid).Result;
+                            string fileGuidName = Path.GetFileName(req.FilePath);
+                            req.KmsDetail.FileName = req.FileName;
+                            req.KmsDetail.FileGuidName = fileGuidName;
+                            req.KmsDetail.DataCount = docTextList.Count;
+
+                        }
+                        break;
+                    case ImportType.Url:
+                        {
+                            //导入url                  
+                            var importResult = _memory.ImportWebPageAsync(req.Url, fileid, new TagCollection() { { "kmsid", req.KmsId } }
+                                 , index: "kms").Result;
+                            //查询文档数量
+                            var docTextList = _kMService.GetDocumentByFileID(km.Id, fileid).Result;
+                            req.KmsDetail.Url = req.Url;
+                            req.KmsDetail.DataCount = docTextList.Count;
+                        }
+                        break;
+                    case ImportType.Text:
+                        //导入文本
+                        {
+                            var importResult = _memory.ImportTextAsync(req.Text, fileid, new TagCollection() { { "kmsid", req.KmsId } }
+                       , index: "kms").Result;
+                            //查询文档数量
+                            var docTextList = _kMService.GetDocumentByFileID(km.Id, fileid).Result;
+                            req.KmsDetail.Url = req.Url;
+                            req.KmsDetail.DataCount = docTextList.Count;
+
+                        }
+                        break;
+                }
+                req.KmsDetail.Status = Model.Enum.ImportKmsStatus.Success;
+                _kmsDetails_Repositories.Update(req.KmsDetail);
+                //_kmsDetails_Repositories.GetList(p => p.KmsId == req.KmsId);
+                Console.WriteLine("后台导入任务成功:" + req.KmsDetail.DataCount);
+            }
+            catch (Exception ex)
+            {
+                req.KmsDetail.Status = Model.Enum.ImportKmsStatus.Fail;
+                _kmsDetails_Repositories.Update(req.KmsDetail);
+                Console.WriteLine("后台导入任务异常:" + ex.Message);
+            }
+        }
+    }
+}

src/AntSK.Domain/Domain/Service/KMService.cs

@@ -0,0 +1,188 @@
+using AntSK.Domain.Common.DependencyInjection;
+using AntSK.Domain.Domain.Dto;
+using AntSK.Domain.Domain.Interface;
+using AntSK.Domain.Domain.Other;
+using AntSK.Domain.Repositories;
+using AntSK.Domain.Utils;
+using LLama;
+using LLamaSharp.KernelMemory;
+using Microsoft.Extensions.Configuration;
+using Microsoft.KernelMemory;
+using Microsoft.KernelMemory.Configuration;
+using Microsoft.KernelMemory.ContentStorage.DevTools;
+using Microsoft.KernelMemory.FileSystem.DevTools;
+using Microsoft.KernelMemory.Postgres;
+
+namespace AntSK.Domain.Domain.Service
+{
+    [ServiceDescription(typeof(IKMService), ServiceLifetime.Scoped)]
+    public class KMService(
+           IConfiguration _config,
+           IKmss_Repositories _kmss_Repositories,
+           IAIModels_Repositories _aIModels_Repositories
+        ) : IKMService
+    {
+        public MemoryServerless GetMemoryByKMS(string kmsID, SearchClientConfig searchClientConfig = null)
+        {
+            //获取KMS配置
+            var kms = _kmss_Repositories.GetFirst(p => p.Id == kmsID);
+            var chatModel = _aIModels_Repositories.GetFirst(p => p.Id == kms.ChatModelID);
+            var embedModel = _aIModels_Repositories.GetFirst(p => p.Id == kms.EmbeddingModelID);
+
+            //http代理
+            var chatHttpClient = OpenAIHttpClientHandlerUtil.GetHttpClient(chatModel.EndPoint);
+            var embeddingHttpClient = OpenAIHttpClientHandlerUtil.GetHttpClient(embedModel.EndPoint);
+
+            //搜索配置
+            if (searchClientConfig.IsNull())
+            {
+                searchClientConfig = new SearchClientConfig
+                {
+                    MaxAskPromptSize = 2048,
+                    MaxMatchesCount = 3,
+                    AnswerTokens = 1000,
+                    EmptyAnswer = "知识库未搜索到相关内容"
+                };
+            }
+
+            var memory = new KernelMemoryBuilder()
+            .WithSearchClientConfig(searchClientConfig)
+            .WithCustomTextPartitioningOptions(new TextPartitioningOptions
+            {
+                MaxTokensPerLine = kms.MaxTokensPerLine,
+                MaxTokensPerParagraph = kms.MaxTokensPerParagraph,
+                OverlappingTokens = kms.OverlappingTokens
+            });
+            //加载huihu 模型
+            WithTextGenerationByAIType(memory, chatModel, chatHttpClient);
+            //加载向量模型
+            WithTextEmbeddingGenerationByAIType(memory, embedModel, embeddingHttpClient);
+            //加载向量库
+            WithMemoryDbByVectorDB(memory, _config);
+
+            var result = memory.Build<MemoryServerless>();
+            return result;
+
+        }
+
+        private void WithTextEmbeddingGenerationByAIType(IKernelMemoryBuilder memory, AIModels embedModel, HttpClient embeddingHttpClient)
+        {
+            switch (embedModel.AIType)
+            {
+                case Model.Enum.AIType.OpenAI:
+                    memory.WithOpenAITextEmbeddingGeneration(new OpenAIConfig()
+                    {
+                        APIKey = embedModel.ModelKey,
+                        EmbeddingModel = embedModel.ModelName
+                    }, null, false, embeddingHttpClient);
+                    break;
+                case Model.Enum.AIType.AzureOpenAI:
+                    memory.WithAzureOpenAITextEmbeddingGeneration(new AzureOpenAIConfig()
+                    {
+                        APIKey = embedModel.ModelKey,
+                        Deployment = embedModel.ModelName.ConvertToString(),
+                        Endpoint = embedModel.EndPoint.ConvertToString(),
+                        Auth = AzureOpenAIConfig.AuthTypes.APIKey,
+                        APIType = AzureOpenAIConfig.APITypes.EmbeddingGeneration,
+                    });
+                    break;
+                case Model.Enum.AIType.LLamaSharp:
+                    var (weights, parameters) = LLamaConfig.GetLLamaConfig(embedModel.ModelName);
+                    var embedder = new LLamaEmbedder(weights, parameters);
+                    memory.WithLLamaSharpTextEmbeddingGeneration(new LLamaSharpTextEmbeddingGenerator(embedder));
+                    break;
+            }
+        }
+
+        private void WithTextGenerationByAIType(IKernelMemoryBuilder memory, AIModels chatModel, HttpClient chatHttpClient)
+        {
+            switch (chatModel.AIType)
+            {
+                case Model.Enum.AIType.OpenAI:
+                    memory.WithOpenAITextGeneration(new OpenAIConfig()
+                    {
+                        APIKey = chatModel.ModelKey,
+                        TextModel = chatModel.ModelName
+                    }, null, chatHttpClient);
+                    break;
+                case Model.Enum.AIType.AzureOpenAI:
+                    memory.WithAzureOpenAITextGeneration(new AzureOpenAIConfig()
+                    {
+                        APIKey = chatModel.ModelKey,
+                        Deployment = chatModel.ModelName.ConvertToString(),
+                        Endpoint = chatModel.EndPoint.ConvertToString(),
+                        Auth = AzureOpenAIConfig.AuthTypes.APIKey,
+                        APIType = AzureOpenAIConfig.APITypes.TextCompletion,
+                    });
+                    break;
+                case Model.Enum.AIType.LLamaSharp:
+                    var (weights, parameters) = LLamaConfig.GetLLamaConfig(chatModel.ModelName);
+                    var context = weights.CreateContext(parameters);
+                    var executor = new StatelessExecutor(weights, parameters);
+                    memory.WithLLamaSharpTextGeneration(new LlamaSharpTextGenerator(weights, context, executor));
+                    break;
+            }
+        }
+
+        private void WithMemoryDbByVectorDB(IKernelMemoryBuilder memory, IConfiguration _config)
+        {
+            string VectorDb = _config["KernelMemory:VectorDb"].ConvertToString();
+            string ConnectionString = _config["KernelMemory:ConnectionString"].ConvertToString();
+            string TableNamePrefix = _config["KernelMemory:TableNamePrefix"].ConvertToString();
+            switch (VectorDb)
+            {
+                case "Postgres":
+                    memory.WithPostgresMemoryDb(new PostgresConfig()
+                    {
+                        ConnectionString = ConnectionString,
+                        TableNamePrefix = TableNamePrefix
+                    });
+                    break;
+                case "Disk":
+                    memory.WithSimpleFileStorage(new SimpleFileStorageConfig()
+                    {
+                        StorageType = FileSystemTypes.Disk
+                    });
+                    break;
+                case "Memory":
+                    memory.WithSimpleFileStorage(new SimpleFileStorageConfig()
+                    {
+                        StorageType = FileSystemTypes.Volatile
+                    });
+                    break;
+            }
+        }
+
+        public async Task<List<KMFile>> GetDocumentByFileID(string kmsid, string fileid)
+        {
+            var _memory = GetMemoryByKMS(kmsid);
+            var memories = await _memory.ListIndexesAsync();
+            var memoryDbs = _memory.Orchestrator.GetMemoryDbs();
+            List<KMFile> docTextList = new List<KMFile>();
+
+            foreach (var memoryIndex in memories)
+            {
+                foreach (var memoryDb in memoryDbs)
+                {
+
+                    var items = await memoryDb.GetListAsync(memoryIndex.Name, new List<MemoryFilter>() { new MemoryFilter().ByDocument(fileid) }, 100, true).ToListAsync();
+                    foreach (var item in items)
+                    {
+                        KMFile file = new KMFile()
+                        {
+                            Text = item.Payload.FirstOrDefault(p => p.Key == "text").Value.ConvertToString(),
+                            Url = item.Payload.FirstOrDefault(p => p.Key == "url").Value.ConvertToString(),
+                            LastUpdate = item.Payload.FirstOrDefault(p => p.Key == "last_update").Value.ConvertToString(),
+                            Schema = item.Payload.FirstOrDefault(p => p.Key == "schema").Value.ConvertToString(),
+                            File = item.Payload.FirstOrDefault(p => p.Key == "file").Value.ConvertToString(),
+                        };
+                        docTextList.Add(file);
+                    }
+                }
+            }
+            return docTextList;
+        }
+
+
+    }
+}

src/AntSK.Domain/Domain/Service/KernelService.cs

@@ -0,0 +1,190 @@
+using AntSK.Domain.Common.DependencyInjection;
+using AntSK.Domain.Domain.Interface;
+using AntSK.Domain.Domain.Other;
+using AntSK.Domain.Model;
+using AntSK.Domain.Repositories;
+using AntSK.Domain.Utils;
+using LLama;
+using LLamaSharp.SemanticKernel.TextCompletion;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.SemanticKernel;
+using Microsoft.SemanticKernel.Plugins.Core;
+using Microsoft.SemanticKernel.TextGeneration;
+using RestSharp;
+using ServiceLifetime = AntSK.Domain.Common.DependencyInjection.ServiceLifetime;
+
+namespace AntSK.Domain.Domain.Service
+{
+    [ServiceDescription(typeof(IKernelService), ServiceLifetime.Scoped)]
+    public class KernelService : IKernelService
+    {
+        private readonly IApis_Repositories _apis_Repositories;
+        private readonly IAIModels_Repositories _aIModels_Repositories;
+        public KernelService(
+              IApis_Repositories apis_Repositories,
+        IAIModels_Repositories aIModels_Repositories
+            )
+        {
+            _apis_Repositories = apis_Repositories;
+            _aIModels_Repositories = aIModels_Repositories;
+
+        }
+        /// <summary>
+        /// 获取kernel实例，依赖注入不好按每个用户去Import不同的插件，所以每次new一个新的kernel
+        /// </summary>
+        /// <param name="modelId"></param>
+        /// <param name="apiKey"></param>
+        /// <returns></returns>
+        public Kernel GetKernelByApp(Apps app)
+        {
+            var chatModel = _aIModels_Repositories.GetFirst(p => p.Id == app.ChatModelID);
+
+            var chatHttpClient = OpenAIHttpClientHandlerUtil.GetHttpClient(chatModel.EndPoint);
+
+            var builder = Kernel.CreateBuilder();
+            WithTextGenerationByAIType(builder, chatModel, chatHttpClient);
+
+
+            var kernel = builder.Build();
+            RegisterPluginsWithKernel(kernel);
+            return kernel;
+        }
+
+        private void WithTextGenerationByAIType(IKernelBuilder builder, AIModels chatModel, HttpClient chatHttpClient)
+        {
+            switch (chatModel.AIType)
+            {
+                case Model.Enum.AIType.OpenAI:
+                    builder.AddOpenAIChatCompletion(
+                       modelId: chatModel.ModelName,
+                       apiKey: chatModel.ModelKey,
+                       httpClient: chatHttpClient);
+                    break;
+                case Model.Enum.AIType.AzureOpenAI:
+                    builder.AddAzureOpenAIChatCompletion(
+                        deploymentName: chatModel.ModelName,
+                        apiKey: chatModel.ModelKey,
+                        endpoint: chatModel.EndPoint
+                        );
+                    break;
+                case Model.Enum.AIType.LLamaSharp:
+                    var (weights, parameters) = LLamaConfig.GetLLamaConfig(chatModel.ModelName);
+                    var ex = new StatelessExecutor(weights, parameters);
+                    builder.Services.AddKeyedSingleton<ITextGenerationService>("local-llama", new LLamaSharpTextCompletion(ex));
+                    break;
+            }
+        }
+
+        /// <summary>
+        /// 根据app配置的插件，导入插件
+        /// </summary>
+        /// <param name="app"></param>
+        /// <param name="_kernel"></param>
+        public void ImportFunctionsByApp(Apps app, Kernel _kernel)
+        {
+            //开启自动插件调用
+            var apiIdList = app.ApiFunctionList.Split(",");
+            var apiList = _apis_Repositories.GetList(p => apiIdList.Contains(p.Id));
+            List<KernelFunction> functions = new List<KernelFunction>();
+            var plugin = _kernel.Plugins.FirstOrDefault(p => p.Name == "ApiFunctions");
+            {
+                foreach (var api in apiList)
+                {
+                    switch (api.Method)
+                    {
+                        case HttpMethodType.Get:
+                            functions.Add(_kernel.CreateFunctionFromMethod((string msg) =>
+                            {
+                                try
+                                {
+                                    Console.WriteLine(msg);
+                                    RestClient client = new RestClient();
+                                    RestRequest request = new RestRequest(api.Url, Method.Get);
+                                    foreach (var header in api.Header.Split("\n"))
+                                    {
+                                        var headerArray = header.Split(":");
+                                        if (headerArray.Length == 2)
+                                        {
+                                            request.AddHeader(headerArray[0], headerArray[1]);
+                                        }
+                                    }
+                                    //这里应该还要处理一次参数提取，等后面再迭代
+                                    foreach (var query in api.Query.Split("\n"))
+                                    {
+                                        var queryArray = query.Split("=");
+                                        if (queryArray.Length == 2)
+                                        {
+                                            request.AddQueryParameter(queryArray[0], queryArray[1]);
+                                        }
+                                    }
+                                    var result = client.Execute(request);
+                                    return result.Content;
+                                }
+                                catch (System.Exception ex)
+                                {
+                                    return "调用失败：" + ex.Message;
+                                }
+                            }, api.Name, $"{api.Describe}"));
+                            break;
+                        case HttpMethodType.Post:
+                            functions.Add(_kernel.CreateFunctionFromMethod((string msg) =>
+                            {
+                                try
+                                {
+                                    Console.WriteLine(msg);
+                                    RestClient client = new RestClient();
+                                    RestRequest request = new RestRequest(api.Url, Method.Post);
+                                    foreach (var header in api.Header.Split("\n"))
+                                    {
+                                        var headerArray = header.Split(":");
+                                        if (headerArray.Length == 2)
+                                        {
+                                            request.AddHeader(headerArray[0], headerArray[1]);
+                                        }
+                                    }
+                                    //这里应该还要处理一次参数提取，等后面再迭代
+                                    request.AddJsonBody(api.JsonBody);
+                                    var result = client.Execute(request);
+                                    return result.Content;
+                                }
+                                catch (System.Exception ex)
+                                {
+                                    return "调用失败：" + ex.Message;
+                                }
+                            }, api.Name, $"{api.Describe}"));
+                            break;
+                    }
+                }
+                _kernel.ImportPluginFromFunctions("ApiFunctions", functions);
+            }
+
+        }
+
+        /// <summary>
+        /// 注册默认插件
+        /// </summary>
+        /// <param name="kernel"></param>
+        void RegisterPluginsWithKernel(Kernel kernel)
+        {
+            kernel.ImportPluginFromObject(new ConversationSummaryPlugin(), "ConversationSummaryPlugin");
+            kernel.ImportPluginFromObject(new TimePlugin(), "TimePlugin");
+            kernel.ImportPluginFromPromptDirectory(Path.Combine(RepoFiles.SamplePluginsPath(), "KMSPlugin"));
+        }
+
+        /// <summary>
+        /// 会话总结
+        /// </summary>
+        /// <param name="_kernel"></param>
+        /// <param name="questions"></param>
+        /// <param name="history"></param>
+        /// <returns></returns>
+        public async Task<string> HistorySummarize(Kernel _kernel, string questions, string history)
+        {
+            KernelFunction sunFun = _kernel.Plugins.GetFunction("ConversationSummaryPlugin", "SummarizeConversation");
+            var summary = await _kernel.InvokeAsync(sunFun, new() { ["input"] = $"内容是：{history.ToString()} {Environment.NewLine} 请注意用中文总结" });
+            string his = summary.GetValue<string>();
+            var msg = $"history：{history.ToString()}{Environment.NewLine} user：{questions}"; ;
+            return msg;
+        }
+    }
+}

src/AntSK.Domain/Map/AutoMapProfile.cs

@@ -1,9 +1,4 @@
 using AutoMapper;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace AntSK.Domain.Map
 {

src/AntSK.Domain/Map/MapperExtend.cs

@@ -1,9 +1,4 @@
 using AutoMapper;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace AntSK.Domain.Map
 {

src/AntSK.Domain/Map/MapperRegister.cs

@@ -1,10 +1,5 @@
 using AutoMapper;
 using Microsoft.Extensions.DependencyInjection;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace AntSK.Domain.Map
 {

src/AntSK.Domain/Model/Enum/AIModelType.cs

@@ -0,0 +1,21 @@
+namespace AntSK.Domain.Model.Enum
+{
+    /// <summary>
+    /// AI类型
+    /// </summary>
+    public enum AIType
+    {
+        OpenAI = 1,
+        AzureOpenAI = 2,
+        LLamaSharp = 3
+    }
+
+    /// <summary>
+    /// 模型类型
+    /// </summary>
+    public enum AIModelType
+    {
+        Chat = 1,
+        Embedding = 2,
+    }
+}

src/AntSK.Domain/Model/Enum/HttpMethodType.cs

@@ -0,0 +1,9 @@
+namespace AntSK.Domain.Model
+{
+    public enum HttpMethodType
+    {
+        Get = 1,
+        Post = 2,
+
+    }
+}

src/AntSK.Domain/Model/Enum/ImportKmsStatus.cs

@@ -0,0 +1,9 @@
+namespace AntSK.Domain.Model.Enum
+{
+    public enum ImportKmsStatus
+    {
+        Loadding = 0,
+        Success = 1,
+        Fail = 2
+    }
+}

src/AntSK.Domain/Model/ImportKMSTaskReq.cs

@@ -0,0 +1,34 @@
+using AntSK.Domain.Repositories;
+
+namespace AntSK.Domain.Model
+{
+    public class ImportKMSTaskDTO
+    {
+
+        public ImportType ImportType { get; set; }
+
+        public string KmsId { get; set; }
+
+        public string Url { get; set; } = "";
+
+
+        public string Text { get; set; } = "";
+
+        public string FilePath { get; set; } = "";
+
+        public string FileName { get; set; } = "";
+    }
+
+
+    public class ImportKMSTaskReq : ImportKMSTaskDTO
+    {
+        public KmsDetails KmsDetail { get; set; } = new KmsDetails();
+    }
+
+    public enum ImportType
+    {
+        File = 1,
+        Url = 2,
+        Text = 3
+    }
+}

src/AntSK.Domain/Model/MessageInfo.cs

@@ -1,10 +1,4 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace AntSK.Domain.Model
+namespace AntSK.Domain.Model
 {
     public class MessageInfo
     {

src/AntSK.Domain/Model/PageList.cs

@@ -1,10 +1,4 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace AntSK.Domain.Model
+namespace AntSK.Domain.Model
 {
     public class PageList<T>
     {

src/AntSK.Domain/Options/DBConnectionOption.cs

@@ -0,0 +1,14 @@
+namespace AntSK.Domain.Options
+{
+    public class DBConnectionOption
+    {
+        /// <summary>
+        /// sqlite连接字符串
+        /// </summary>
+        public static string DbType { get; set; }
+        /// <summary>
+        /// pg链接字符串
+        /// </summary>
+        public static string ConnectionStrings { get; set; }
+    }
+}

src/AntSK.Domain/Options/KernelMemoryOption.cs

@@ -0,0 +1,18 @@
+namespace AntSK.Domain.Options
+{
+    public class KernelMemoryOption
+    {
+        /// <summary>
+        /// 向量库
+        /// </summary>
+        public static string VectorDb { get; set; }
+        /// <summary>
+        /// 连接字符串
+        /// </summary>
+        public static string ConnectionString { get; set; }
+        /// <summary>
+        /// 表前缀
+        /// </summary>
+        public static string TableNamePrefix { get; set; }
+    }
+}

src/AntSK.Domain/Options/LLamaSharpOption.cs

@@ -1,13 +1,8 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace AntSK.Domain.Options
+namespace AntSK.Domain.Options
 {
     public class LLamaSharpOption
     {
+        public static string RunType { get; set; }
         public static string Chat { get; set; }
 
         public static string Embedding { get; set; }

src/AntSK.Domain/Options/LoginOption.cs

@@ -0,0 +1,9 @@
+namespace AntSK.Domain.Options
+{
+    public class LoginOption
+    {
+        public static string User { get; set; }
+
+        public static string Password { get; set; }
+    }
+}

src/AntSK.Domain/Repositories/AI/Api/Apis.cs

@@ -0,0 +1,62 @@
+using AntSK.Domain.Model;
+using SqlSugar;
+using System.ComponentModel.DataAnnotations;
+
+namespace AntSK.Domain.Repositories
+{
+    [SugarTable("Apis")]
+    public partial class Apis
+    {
+        [SugarColumn(IsPrimaryKey = true)]
+        public string Id { get; set; }
+
+        /// <summary>
+        /// 接口名称
+        /// </summary>
+        [Required]
+        public string Name { get; set; }
+
+        /// <summary>
+        /// 接口描述
+        /// </summary>
+        [Required]
+        public string Describe { get; set; }
+        /// <summary>
+        /// 接口地址
+        /// </summary>
+        [Required]
+        public string Url { get; set; }
+        /// <summary>
+        /// 请求方法
+        /// </summary>
+        [Required]
+        public HttpMethodType Method { get; set; }
+
+        [SugarColumn(ColumnDataType = "varchar(1000)")]
+        public string? Header { get; set; }
+        /// <summary>
+        /// QueryString参数
+        /// </summary>
+        [SugarColumn(ColumnDataType = "varchar(1000)")]
+        public string? Query { get; set; }
+        /// <summary>
+        /// jsonBody 实体
+        /// </summary>
+        [SugarColumn(ColumnDataType = "varchar(7000)")]
+        public string? JsonBody { get; set; }
+
+        /// <summary>
+        /// 入参提示词
+        /// </summary>
+        [Required]
+        [SugarColumn(ColumnDataType = "varchar(1500)")]
+        public string InputPrompt { get; set; }
+
+        /// <summary>
+        /// 返回提示词
+        /// </summary>
+        [Required]
+        [SugarColumn(ColumnDataType = "varchar(1500)")]
+        public string OutputPrompt { get; set; }
+    }
+}

src/AntSK.Domain/Repositories/AI/Api/Apis_Repositories.cs

@@ -0,0 +1,11 @@
+
+using AntSK.Domain.Common.DependencyInjection;
+using AntSK.Domain.Repositories.Base;
+
+namespace AntSK.Domain.Repositories
+{
+    [ServiceDescription(typeof(IApis_Repositories), ServiceLifetime.Scoped)]
+    public class Apis_Repositories : Repository<Apis>, IApis_Repositories
+    {
+    }
+}

src/AntSK.Domain/Repositories/AI/Api/IApis_Repositories.cs

@@ -0,0 +1,8 @@
+using AntSK.Domain.Repositories.Base;
+
+namespace AntSK.Domain.Repositories
+{
+    public interface IApis_Repositories : IRepository<Apis>
+    {
+    }
+}

src/AntSK.Domain/Repositories/AI/App/Apps.cs

@@ -1,10 +1,5 @@
 using SqlSugar;
-using System;
-using System.Collections.Generic;
 using System.ComponentModel.DataAnnotations;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace AntSK.Domain.Repositories
 {
@@ -25,16 +20,41 @@ namespace AntSK.Domain.Repositories
         /// </summary>
         [Required]
         public string Describe { get; set; }
+        /// <summary>
+        /// 图标
+        /// </summary>
         [Required]
         public string Icon { get; set; }
 
+        /// <summary>
+        /// 类型
+        /// </summary>
         [Required]
         public string Type { get; set; }
 
+        /// <summary>
+        /// 会话模型ID
+        /// </summary>
+        [Required]
+        public string? ChatModelID { get; set; }
+
+        /// <summary>
+        /// 温度
+        /// </summary>
+        [SugarColumn(DefaultValue = "70")]
+        public double Temperature { get; set; } = 70f;
+
         /// <summary>
         /// 提示词
         /// </summary>
         public string? Prompt { get; set; }
+
+        /// <summary>
+        /// 插件列表
+        /// </summary>
+        public string? ApiFunctionList { get; set; }
+
+
         /// <summary>
         /// 知识库ID列表
         /// </summary>

src/AntSK.Domain/Repositories/AI/App/Apps_Repositories.cs

@@ -1,11 +1,6 @@
 
-using AntSK.Domain.Repositories.Base;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 using AntSK.Domain.Common.DependencyInjection;
+using AntSK.Domain.Repositories.Base;
 
 namespace AntSK.Domain.Repositories
 {

src/AntSK.Domain/Repositories/AI/App/IApps_Repositories.cs

@@ -1,9 +1,4 @@
 using AntSK.Domain.Repositories.Base;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace AntSK.Domain.Repositories
 {

src/AntSK.Domain/Repositories/AI/Kms/IKmss_Repositories.cs

@@ -1,9 +1,4 @@
 using AntSK.Domain.Repositories.Base;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace AntSK.Domain.Repositories
 {

src/AntSK.Domain/Repositories/AI/Kms/Kmss.cs

@@ -0,0 +1,60 @@
+using SqlSugar;
+using System.ComponentModel.DataAnnotations;
+
+namespace AntSK.Domain.Repositories
+{
+    [SugarTable("Kms")]
+    public partial class Kmss
+    {
+        [SugarColumn(IsPrimaryKey = true)]
+        public string Id { get; set; }
+        /// <summary>
+        /// 图标
+        /// </summary>
+        [Required]
+        public string Icon { get; set; }
+        /// <summary>
+        /// 名称
+        /// </summary>
+        [Required]
+        public string Name { get; set; }
+        /// <summary>
+        /// 会话模型
+        /// </summary>
+        [Required]
+        public string Describe { get; set; }
+        /// <summary>
+        /// 会话模型ID
+        /// </summary>
+        [Required]
+
+        public string? ChatModelID { get; set; }
+        /// <summary>
+        /// 向量模型ID
+        /// </summary>
+        [Required]
+        public string? EmbeddingModelID { get; set; }
+
+        /// <summary>
+        /// 每个段落的最大标记数。
+        /// </summary>
+        [SugarColumn(DefaultValue = "299")]
+        public int MaxTokensPerParagraph { get; set; } = 299;
+
+
+        /// <summary>
+        /// 每行，也就是每句话的最大标记数
+        /// </summary>
+        [SugarColumn(DefaultValue = "99")]
+        public int MaxTokensPerLine { get; set; } = 99;
+
+
+        /// <summary>
+        /// 段落之间重叠标记的数量。
+        /// </summary>
+        [SugarColumn(DefaultValue = "49")]
+        public int OverlappingTokens { get; set; } = 49;
+
+
+    }
+}

src/AntSK.Domain/Repositories/AI/Kms/Kmss_Repositories.cs

@@ -1,11 +1,6 @@
 
-using AntSK.Domain.Repositories.Base;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 using AntSK.Domain.Common.DependencyInjection;
+using AntSK.Domain.Repositories.Base;
 
 namespace AntSK.Domain.Repositories
 {

src/AntSK.Domain/Repositories/AI/KmsDetail/IKmsDetails_Repositories.cs

@@ -1,9 +1,4 @@
 using AntSK.Domain.Repositories.Base;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace AntSK.Domain.Repositories
 {

src/AntSK.Domain/Repositories/AI/KmsDetail/KmsDetails.cs

@@ -1,9 +1,5 @@
-using SqlSugar;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
+using AntSK.Domain.Model.Enum;
+using SqlSugar;
 
 namespace AntSK.Domain.Repositories
 {
@@ -32,9 +28,14 @@ namespace AntSK.Domain.Repositories
         /// </summary>
         public int? DataCount { get; set; }
 
+
         /// <summary>
         /// 创建时间
         /// </summary>
         public DateTime CreateTime { get; set; }
+        /// <summary>
+        /// 状态
+        /// </summary>
+        public ImportKmsStatus? Status { get; set; } = ImportKmsStatus.Loadding;
     }
 }

src/AntSK.Domain/Repositories/AI/KmsDetail/KmsDetails_Repositories.cs

@@ -1,11 +1,6 @@
 
-using AntSK.Domain.Repositories.Base;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 using AntSK.Domain.Common.DependencyInjection;
+using AntSK.Domain.Repositories.Base;
 
 namespace AntSK.Domain.Repositories
 {

src/AntSK.Domain/Repositories/Base/IRepository.cs

@@ -1,11 +1,6 @@
-using SqlSugar;
-using System;
-using System.Collections.Generic;
-using System.Linq;
+using AntSK.Domain.Model;
+using SqlSugar;
 using System.Linq.Expressions;
-using System.Text;
-using System.Threading.Tasks;
-using AntSK.Domain.Model;
 
 namespace AntSK.Domain.Repositories.Base
 {

src/AntSK.Domain/Repositories/Base/Repository.cs

@@ -1,37 +1,34 @@
-using SqlSugar;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Linq.Expressions;
-using System.Text;
-using System.Threading.Tasks;
-using AntSK.Domain.Map;
+using AntSK.Domain.Map;
 using AntSK.Domain.Model;
+using SqlSugar;
+using System.Linq.Expressions;
+
 
 namespace AntSK.Domain.Repositories.Base
 {
     public class Repository<T> : SimpleClient<T> where T : class, new()
     {
+
         public Repository(ISqlSugarClient context = null) : base(context)//注意这里要有默认值等于null
         {
+
             if (context == null)
             {
             }
-            //Sqlite.DbMaintenance.CreateDatabase();
-            //Sqlite.CodeFirst.InitTables(typeof(CodeFirstTable1));
+
         }
 
         //注意：如果使用Client不能写成静态的，Scope并发更高
-        public static SqlSugarScope Sqlite = SqlSugarHelper.Sqlite;
 
+        public static SqlSugarScope SqlScope = SqlSugarHelper.SqlScope();
         public SimpleClient<T> CurrentDb
-        { get { return new SimpleClient<T>(Sqlite); } }//用来处理T表的常用操作
+        { get { return new SimpleClient<T>(SqlScope); } }//用来处理T表的常用操作
 
         #region 通用方法
 
         public virtual SqlSugarScope GetDB()
         {
-            return Sqlite;
+            return SqlScope;
         }
 
         /// <summary>

src/AntSK.Domain/Repositories/Base/SqlSugarHelper.cs

@@ -0,0 +1,48 @@
+using AntSK.Domain.Options;
+using SqlSugar;
+using System.Reflection;
+
+namespace AntSK.Domain.Repositories.Base
+{
+    public class SqlSugarHelper()
+    {
+
+        /// <summary>
+        /// sqlserver连接
+        /// </summary>
+        public static SqlSugarScope SqlScope()
+        {
+
+            string DBType = DBConnectionOption.DbType;
+            string ConnectionString = DBConnectionOption.ConnectionStrings;
+
+            var config = new ConnectionConfig()
+            {
+                ConnectionString = ConnectionString,
+                InitKeyType = InitKeyType.Attribute,//从特性读取主键和自增列信息
+                IsAutoCloseConnection = true,
+                ConfigureExternalServices = new ConfigureExternalServices
+                {
+                    //注意:  这儿AOP设置不能少
+                    EntityService = (c, p) =>
+                    {
+                        /***高版C#写法***/
+                        //支持string?和string  
+                        if (p.IsPrimarykey == false && new NullabilityInfoContext()
+                         .Create(c).WriteState is NullabilityState.Nullable)
+                        {
+                            p.IsNullable = true;
+                        }
+                    }
+                }
+            };
+            DbType dbType = (DbType)Enum.Parse(typeof(DbType), DBType);
+            config.DbType = dbType;
+            var scope = new SqlSugarScope(config, Db =>
+            {
+
+            });
+            return scope;
+        }
+    }
+}

src/AntSK.Domain/Repositories/Setting/AIModel/AIModels.cs

@@ -0,0 +1,46 @@
+using AntSK.Domain.Model.Enum;
+using SqlSugar;
+using System.ComponentModel.DataAnnotations;
+
+namespace AntSK.Domain.Repositories
+{
+    [SugarTable("AIModels")]
+    public partial class AIModels
+    {
+        [SugarColumn(IsPrimaryKey = true)]
+        public string Id { get; set; }
+        /// <summary>
+        /// AI类型
+        /// </summary>
+
+        [Required]
+        [SugarColumn(DefaultValue = "1")]
+        public AIType AIType { get; set; } = AIType.OpenAI;
+        /// <summary>
+        /// 模型类型
+        /// </summary>
+        [Required]
+        public AIModelType AIModelType { get; set; } = AIModelType.Chat;
+        /// <summary>
+        /// 模型地址
+        /// </summary>
+        [Required]
+        public string EndPoint { get; set; } = "";
+        /// <summary>
+        /// 模型名称
+        /// </summary>
+        [Required]
+        public string ModelName { get; set; } = "";
+        /// <summary>
+        /// 模型秘钥
+        /// </summary>
+        [Required]
+        public string ModelKey { get; set; } = "";
+        /// <summary>
+        /// 部署名，azure需要使用
+        /// </summary>
+
+        [Required]
+        public string ModelDescription { get; set; }
+    }
+}

src/AntSK.Domain/Repositories/Setting/AIModel/AIModels_Repositories.cs

@@ -0,0 +1,11 @@
+
+using AntSK.Domain.Common.DependencyInjection;
+using AntSK.Domain.Repositories.Base;
+
+namespace AntSK.Domain.Repositories
+{
+    [ServiceDescription(typeof(IAIModels_Repositories), ServiceLifetime.Scoped)]
+    public class AIModels_Repositories : Repository<AIModels>, IAIModels_Repositories
+    {
+    }
+}

src/AntSK.Domain/Repositories/Setting/AIModel/IAIModels_Repositories.cs

@@ -0,0 +1,8 @@
+using AntSK.Domain.Repositories.Base;
+
+namespace AntSK.Domain.Repositories
+{
+    public interface IAIModels_Repositories : IRepository<AIModels>
+    {
+    }
+}

src/AntSK.Domain/Repositories/Setting/User/IUsers_Repositories.cs

@@ -1,9 +1,4 @@
 using AntSK.Domain.Repositories.Base;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace AntSK.Domain.Repositories
 {

src/AntSK.Domain/Repositories/Setting/User/Users.cs

@@ -1,10 +1,5 @@
 using SqlSugar;
-using System;
-using System.Collections.Generic;
 using System.ComponentModel.DataAnnotations;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace AntSK.Domain.Repositories
 {

src/AntSK.Domain/Repositories/Setting/User/Users_Repositories.cs

@@ -1,11 +1,6 @@
 
-using AntSK.Domain.Repositories.Base;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 using AntSK.Domain.Common.DependencyInjection;
+using AntSK.Domain.Repositories.Base;
 
 namespace AntSK.Domain.Repositories
 {

src/AntSK.Domain/Utils/ConvertUtils.cs

@@ -1,10 +1,4 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace AntSK.Domain.Utils
+namespace AntSK.Domain.Utils
 {
     public static class ConvertUtils
     {

src/AntSK.Domain/Utils/DateTimeConverter.cs

@@ -1,10 +1,5 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Text.Json;
+using System.Text.Json;
 using System.Text.Json.Serialization;
-using System.Threading.Tasks;
 
 namespace AntSK.Domain.Utils
 {

src/AntSK.Domain/Utils/JSUtils.cs

@@ -0,0 +1,17 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.JSInterop;
+
+namespace AntSK.Domain.Utils
+{
+    public static class JSUtils
+    {
+        public static async Task ScrollToBottomAsync(this IJSRuntime _JSRuntime, string elementId)
+        {
+            await _JSRuntime.InvokeVoidAsync("scrollToBottom", elementId);
+        }
+    }
+}

src/AntSK.Domain/Utils/LongToDateTimeConverter.cs

@@ -1,5 +1,4 @@
-using System;
-using System.Buffers.Text;
+using System.Buffers.Text;
 using System.Text.Json;
 using System.Text.Json.Serialization;
 

src/AntSK.Domain/Utils/OpenAIHttpClientHandler.cs

@@ -1,21 +1,26 @@
-using AntSK.Domain.Options;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Text.RegularExpressions;
-using System.Threading.Tasks;
+using System.Text.RegularExpressions;
 
 namespace AntSK.Domain.Utils
 {
     public class OpenAIHttpClientHandler : HttpClientHandler
     {
+        private string _endPoint { get; set; }
+        public OpenAIHttpClientHandler(string endPoint)
+        {
+            this._endPoint = endPoint;
+        }
+
         protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
         {
             UriBuilder uriBuilder;
             Regex regex = new Regex(@"(https?)://([^/:]+)(:\d+)?/(.*)");
-            Match match = regex.Match(OpenAIOption.EndPoint);
-
+            Match match = regex.Match(_endPoint);
+            if (Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT") == "Development" && request.Content != null)
+            {
+                string requestBody = await request.Content.ReadAsStringAsync();
+                //便于调试查看请求prompt
+                Console.WriteLine(requestBody);
+            }
             if (match.Success)
             {
                 string xieyi = match.Groups[1].Value;
@@ -35,14 +40,14 @@ namespace AntSK.Domain.Utils
                         {
                             // 这里是你要修改的 URL
                             Scheme = $"{xieyi}://{hostnew}/",
-                            Host = host,                         
+                            Host = host,
                             Path = route + "v1/chat/completions",
                         };
                         if (port.ConvertToInt32() != 0)
                         {
                             uriBuilder.Port = port.ConvertToInt32();
                         }
-                      
+
                         request.RequestUri = uriBuilder.Uri;
 
                         break;
@@ -69,4 +74,16 @@ namespace AntSK.Domain.Utils
             return response;
         }
     }
+
+
+    public class OpenAIHttpClientHandlerUtil
+    {
+        public static HttpClient GetHttpClient(string endPoint)
+        {
+            var handler = new OpenAIHttpClientHandler(endPoint.ConvertToString());
+            var httpClient = new HttpClient(handler);
+            httpClient.Timeout = TimeSpan.FromMinutes(5);
+            return httpClient;
+        }
+    }
 }

src/AntSK.Domain/Utils/PasswordUtil.cs

@@ -1,6 +1,4 @@
-using BCrypt.Net;
-
-namespace AntSK.Domain.Utils
+namespace AntSK.Domain.Utils
 {
     public class PasswordUtil
     {

src/AntSK.Domain/Utils/RepoFiles.cs

@@ -0,0 +1,54 @@
+using System.Reflection;
+
+namespace AntSK.Domain.Utils
+{
+    public static class RepoFiles
+    {
+        /// <summary>
+        /// Scan the local folders from the repo, looking for "samples/plugins" folder.
+        /// </summary>
+        /// <returns>The full path to samples/plugins</returns>
+        public static string SamplePluginsPath()
+        {
+            string Parent = AppDomain.CurrentDomain.BaseDirectory;
+            string Folder = "plugins";
+
+            bool SearchPath(string pathToFind, out string result, int maxAttempts = 10)
+            {
+                var currDir = Path.GetFullPath(Assembly.GetExecutingAssembly().Location);
+                bool found;
+                do
+                {
+                    result = Path.Join(currDir, pathToFind);
+                    found = Directory.Exists(result);
+                    currDir = Path.GetFullPath(Path.Combine(currDir, ".."));
+                } while (maxAttempts-- > 0 && !found);
+
+                return found;
+            }
+
+            if (!SearchPath(Parent + Path.DirectorySeparatorChar + Folder, out string path)
+                && !SearchPath(Folder, out path))
+            {
+                throw new YourAppException("Plugins directory not found. The app needs the plugins from the repo to work.");
+            }
+
+            return path;
+        }
+    }
+
+    public class YourAppException : Exception
+    {
+        public YourAppException() : base()
+        {
+        }
+
+        public YourAppException(string message) : base(message)
+        {
+        }
+
+        public YourAppException(string message, Exception innerException) : base(message, innerException)
+        {
+        }
+    }
+}

src/AntSK.sln

@@ -9,9 +9,15 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "AntSK.Domain", "AntSK.Domai
 EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Docker", "Docker", "{9F2E193A-5F9D-4C82-B591-CB133EEB59F0}"
 	ProjectSection(SolutionItems) = preProject
-		Dockerfile = Dockerfile
+		..\docker-compose.simple.yml = ..\docker-compose.simple.yml
+		..\docker-compose.yml = ..\docker-compose.yml
+		..\Dockerfile = ..\Dockerfile
 	EndProjectSection
 EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "MiddleWare", "MiddleWare", "{40DDB1DC-571B-4A95-9F34-47F52981C511}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "AntSK.BackgroundTask", "MiddleWare\AntSK.BackgroundTask\AntSK.BackgroundTask.csproj", "{DF87E829-99C5-44A7-9718-B3E67DC801F6}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -26,10 +32,17 @@ Global
 		{64F17C9A-97C2-46FA-9345-86C5289288AD}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{64F17C9A-97C2-46FA-9345-86C5289288AD}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{64F17C9A-97C2-46FA-9345-86C5289288AD}.Release|Any CPU.Build.0 = Release|Any CPU
+		{DF87E829-99C5-44A7-9718-B3E67DC801F6}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{DF87E829-99C5-44A7-9718-B3E67DC801F6}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{DF87E829-99C5-44A7-9718-B3E67DC801F6}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{DF87E829-99C5-44A7-9718-B3E67DC801F6}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
 	EndGlobalSection
+	GlobalSection(NestedProjects) = preSolution
+		{DF87E829-99C5-44A7-9718-B3E67DC801F6} = {40DDB1DC-571B-4A95-9F34-47F52981C511}
+	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {2076B7C9-2E5B-4580-9712-03F0D56BC1AF}
 	EndGlobalSection

src/AntSK/AntSK.csproj

@@ -8,8 +8,8 @@
     <NoWarn>CA1050,CA1707,CA2007,VSTHRD111,CS1591,RCS1110,CA5394,SKEXP0001,SKEXP0002,SKEXP0003,SKEXP0004,SKEXP0010,SKEXP0011,,SKEXP0012,SKEXP0020,SKEXP0021,SKEXP0022,SKEXP0023,SKEXP0024,SKEXP0025,SKEXP0026,SKEXP0027,SKEXP0028,SKEXP0029,SKEXP0030,SKEXP0031,SKEXP0032,SKEXP0040,SKEXP0041,SKEXP0042,SKEXP0050,SKEXP0051,SKEXP0052,SKEXP0053,SKEXP0054,SKEXP0055,SKEXP0060,SKEXP0061,SKEXP0101,SKEXP0102</NoWarn>
   </PropertyGroup>
   <ItemGroup>
-    <PackageReference Include="AntDesign.Charts" Version="0.5.1" />
-    <PackageReference Include="AntDesign.ProLayout" Version="0.17.3" />
+
+    
     <PackageReference Include="Microsoft.AspNetCore.Authorization" Version="8.0.2" />
     <PackageReference Include="Microsoft.AspNetCore.Components.Authorization" Version="8.0.2" />
     <PackageReference Include="Microsoft.AspNetCore.Components.WebAssembly.Authentication" Version="8.0.2" />
@@ -20,5 +20,11 @@
   <ItemGroup>
     <ProjectReference Include="..\AntSK.Domain\AntSK.Domain.csproj" />
   </ItemGroup>
+
+  <ItemGroup>
+    <None Update="plugins\KMSPlugin\Ask\skprompt.txt">
+      <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+    </None>
+  </ItemGroup>
   
 </Project>

src/AntSK/AntSK.xml

@@ -16,13 +16,19 @@
             </summary>
             <returns></returns>
         </member>
-        <member name="M:AntSK.Controllers.LLamaSharpController.chat(AntSK.Models.OpenAIModel)">
+        <member name="T:AntSK.Controllers.KMSController">
+            <summary>
+            
+            </summary>
+            <param name="_taskBroker"></param>
+        </member>
+        <member name="M:AntSK.Controllers.LLamaSharpController.chat(AntSK.Domain.Domain.Dto.OpenAIModel)">
             <summary>
             本地会话接口
             </summary>
             <returns></returns>
         </member>
-        <member name="M:AntSK.Controllers.LLamaSharpController.embedding(AntSK.Models.OpenAIEmbeddingModel)">
+        <member name="M:AntSK.Controllers.LLamaSharpController.embedding(AntSK.Domain.Domain.Dto.OpenAIEmbeddingModel)">
             <summary>
             本地嵌入接口
             </summary>
@@ -39,7 +45,7 @@
             对外接口
             </summary>
         </member>
-        <member name="M:AntSK.Controllers.OpenController.chat(AntSK.Models.OpenAIModel)">
+        <member name="M:AntSK.Controllers.OpenController.chat(AntSK.Domain.Domain.Dto.OpenAIModel)">
             <summary>
             对话接口
             </summary>
@@ -59,11 +65,11 @@
             发送普通对话
             </summary>
             <param name="questions"></param>
-            <param name="msg"></param>
+            <param name="history"></param>
             <param name="app"></param>
             <returns></returns>
         </member>
-        <member name="M:AntSK.Pages.ChatPage.Chat.HistorySummarize(System.String)">
+        <member name="M:AntSK.Pages.ChatPage.Chat.HistorySummarize(AntSK.Domain.Repositories.Apps,System.String)">
             <summary>
             历史会话的会话总结
             </summary>
@@ -84,11 +90,11 @@
             发送普通对话
             </summary>
             <param name="questions"></param>
-            <param name="msg"></param>
+            <param name="history"></param>
             <param name="app"></param>
             <returns></returns>
         </member>
-        <member name="M:AntSK.Pages.ChatPage.OpenChat.HistorySummarize(System.String)">
+        <member name="M:AntSK.Pages.ChatPage.OpenChat.HistorySummarize(AntSK.Domain.Repositories.Apps,System.String)">
             <summary>
             历史会话的会话总结
             </summary>
@@ -112,15 +118,6 @@
             本地Embedding
             </summary>
         </member>
-        <member name="M:AntSK.Services.OpenApi.OpenApiService.SendKms(System.String,AntSK.Domain.Repositories.Apps)">
-            <summary>
-            发送知识库问答
-            </summary>
-            <param name="questions"></param>
-            <param name="msg"></param>
-            <param name="app"></param>
-            <returns></returns>
-        </member>
         <member name="M:AntSK.Services.OpenApi.OpenApiService.SendChat(System.String,AntSK.Domain.Repositories.Apps)">
             <summary>
             发送普通对话
@@ -130,7 +127,16 @@
             <param name="app"></param>
             <returns></returns>
         </member>
-        <member name="M:AntSK.Services.OpenApi.OpenApiService.HistorySummarize(AntSK.Models.OpenAIModel)">
+        <member name="M:AntSK.Services.OpenApi.OpenApiService.SendKms(System.String,AntSK.Domain.Repositories.Apps)">
+            <summary>
+            发送知识库问答
+            </summary>
+            <param name="questions"></param>
+            <param name="msg"></param>
+            <param name="app"></param>
+            <returns></returns>
+        </member>
+        <member name="M:AntSK.Services.OpenApi.OpenApiService.HistorySummarize(AntSK.Domain.Repositories.Apps,AntSK.Domain.Domain.Dto.OpenAIModel)">
             <summary>
             历史会话的会话总结
             </summary>

src/AntSK/Components/GlobalHeader/RightContent.razor.cs

@@ -1,15 +1,12 @@
 using AntDesign;
 using AntDesign.ProLayout;
-using Microsoft.AspNetCore.Components;
-using System.Collections.Generic;
-using System.Linq;
-using System.Threading.Tasks;
+using AntSK.Domain.Options;
 using AntSK.Models;
 using AntSK.Services;
+using AntSK.Services.Auth;
+using Microsoft.AspNetCore.Components;
 using Microsoft.AspNetCore.Components.Authorization;
 using System.Security.Claims;
-using AntSK.Services.Auth;
-using AntSK.Domain.Options;
 
 namespace AntSK.Components
 {
@@ -56,7 +53,7 @@ namespace AntSK.Components
         [Inject] public AuthenticationStateProvider AuthenticationStateProvider { get; set; }
         [Inject] protected MessageService? Message { get; set; }
 
-        private ClaimsPrincipal context  => ((AntSKAuthProvider)AuthenticationStateProvider).GetCurrentUser();
+        private ClaimsPrincipal context => ((AntSKAuthProvider)AuthenticationStateProvider).GetCurrentUser();
 
         protected override async Task OnInitializedAsync()
         {
@@ -86,7 +83,7 @@ namespace AntSK.Components
                     {
                         NavigationManager.NavigateTo("/setting/user/info/" + context.Identity.Name);
                     }
-                    else 
+                    else
                     {
                         _ = Message.Info("管理员无需设置", 2);
                     }

src/AntSK/Controllers/FileController.cs

@@ -1,7 +1,4 @@
-using AntDesign;
-using Microsoft.AspNetCore.Http;
-using Microsoft.AspNetCore.Mvc;
-using System.Net.NetworkInformation;
+using Microsoft.AspNetCore.Mvc;
 
 namespace AntSK.Controllers
 {
@@ -32,10 +29,10 @@ namespace AntSK.Controllers
             }
 
             string extension = Path.GetExtension(file.FileName);
-            string fileid=Guid.NewGuid().ToString();
+            string fileid = Guid.NewGuid().ToString();
             // 组合目标路径
-            var uploads = Path.Combine(uploadsFolderPath, fileid+extension);
-       
+            var uploads = Path.Combine(uploadsFolderPath, fileid + extension);
+
             // 保存文件至目标路径
             using var fileStream = System.IO.File.Create(uploads);
             using var uploadStream = file.OpenReadStream();

src/AntSK/Controllers/InitController.cs

@@ -1,6 +1,5 @@
-using Microsoft.AspNetCore.Http;
+using AntSK.Domain.Repositories;
 using Microsoft.AspNetCore.Mvc;
-using AntSK.Domain.Repositories;
 
 namespace AntSK.Controllers
 {
@@ -25,6 +24,11 @@ namespace AntSK.Controllers
             _repository.GetDB().CodeFirst.InitTables(typeof(Apps));
             _repository.GetDB().CodeFirst.InitTables(typeof(Kmss));
             _repository.GetDB().CodeFirst.InitTables(typeof(KmsDetails));
+            _repository.GetDB().CodeFirst.InitTables(typeof(Users));
+            _repository.GetDB().CodeFirst.InitTables(typeof(Apis));
+            _repository.GetDB().CodeFirst.InitTables(typeof(AIModels));
+            //创建vector插件如果数据库没有则需要提供支持向量的数据库
+            _repository.GetDB().Ado.ExecuteCommandAsync($"CREATE EXTENSION IF NOT EXISTS vector;");
             return Ok();
         }
     }

src/AntSK/Controllers/KMSController.cs

@@ -0,0 +1,53 @@
+using AntSK.BackgroundTask;
+using AntSK.Domain.Domain.Interface;
+using AntSK.Domain.Map;
+using AntSK.Domain.Model;
+using AntSK.Domain.Model.Enum;
+using AntSK.Domain.Repositories;
+using Microsoft.AspNetCore.Mvc;
+
+namespace AntSK.Controllers
+{
+    /// <summary>
+    /// 
+    /// </summary>
+    /// <param name="_taskBroker"></param>
+    [Route("api/[controller]/[action]")]
+    [ApiController]
+    public class KMSController : ControllerBase
+    {
+        private readonly IKmsDetails_Repositories _kmsDetails_Repositories;
+        private readonly IKMService _iKMService;
+        private readonly BackgroundTaskBroker<ImportKMSTaskReq> _taskBroker;
+        public KMSController(
+            IKmsDetails_Repositories kmsDetails_Repositories,
+            IKMService iKMService,
+            BackgroundTaskBroker<ImportKMSTaskReq> taskBroker
+            )
+        {
+            _kmsDetails_Repositories = kmsDetails_Repositories;
+            _iKMService = iKMService;
+            _taskBroker = taskBroker;
+        }
+        [HttpPost]
+        public async Task<IActionResult> ImportKMSTask(ImportKMSTaskDTO model)
+        {
+            Console.WriteLine("api/kms/ImportKMSTask  开始");
+            ImportKMSTaskReq req = model.ToDTO<ImportKMSTaskReq>();
+            KmsDetails detail = new KmsDetails()
+            {
+                Id = Guid.NewGuid().ToString(),
+                KmsId = req.KmsId,
+                CreateTime = DateTime.Now,
+                Status = ImportKmsStatus.Loadding,
+                Type = model.ImportType.ToString().ToLower()
+            };
+
+            _kmsDetails_Repositories.Insert(detail);
+            req.KmsDetail = detail;
+            _taskBroker.QueueWorkItem(req);
+            Console.WriteLine("api/kms/ImportKMSTask  结束");
+            return Ok();
+        }
+    }
+}

src/AntSK/Controllers/LLamaSharpController.cs

@@ -1,8 +1,6 @@
-using AntSK.Models;
-using Microsoft.AspNetCore.Http;
-using Microsoft.AspNetCore.Mvc;
-using AntSK.Domain.Utils;
+using AntSK.Domain.Domain.Dto;
 using AntSK.Services.LLamaSharp;
+using Microsoft.AspNetCore.Mvc;
 
 namespace AntSK.Controllers
 {
@@ -17,6 +15,7 @@ namespace AntSK.Controllers
         [Route("llama/v1/chat/completions")]
         public async Task chat(OpenAIModel model)
         {
+            Console.WriteLine("开始：llama/v1/chat/completions");
             if (model.stream)
             {
                 await _lLamaSharpService.ChatStream(model, HttpContext);
@@ -25,6 +24,7 @@ namespace AntSK.Controllers
             {
                 await _lLamaSharpService.Chat(model, HttpContext);
             }
+            Console.WriteLine("结束：llama/v1/chat/completions");
         }
 
         /// <summary>
@@ -36,8 +36,9 @@ namespace AntSK.Controllers
         [Route("llama/v1/embeddings")]
         public async Task embedding(OpenAIEmbeddingModel model)
         {
-
-            await _lLamaSharpService.Embedding(model,HttpContext);
+            Console.WriteLine("开始：llama/v1/embeddings");
+            await _lLamaSharpService.Embedding(model, HttpContext);
+            Console.WriteLine("结束：llama/v1/embeddings");
 
         }
     }