Learning/AntSK
1
0
Fork 0
mirror of https://github.com/AIDotNet/AntSK.git synced 2026-02-25 03:30:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

Compare commits

base: Learning:0.1.4
Branches Tags
Learning:main Learning:feature_role Learning:copilot/add-role-based-access-control
Learning:0.6.6 Learning:0.6.5 Learning:0.6.4 Learning:0.6.3 Learning:0.6.2 Learning:0.6.1 Learning:0.6.0 Learning:0.5.6 Learning:0.5.5 Learning:0.5.4 Learning:0.5.3 Learning:0.5.2 Learning:0.5.1 Learning:0.5.0 Learning:0.4.5 Learning:0.4.4 Learning:0.4.3.1 Learning:0.4.3 Learning:0.4.2 Learning:0.4.1 Learning:0.4.0 Learning:0.3.9 Learning:0.3.8 Learning:0.3.6 Learning:0.3.5 Learning:0.3.4 Learning:0.3.3 Learning:0.3.2 Learning:0.3.1 Learning:0.3.0 Learning:0.2.9 Learning:0.2.8 Learning:0.2.7.1 Learning:0.2.7 Learning:0.2.6 Learning:0.2.5 Learning:0.2.4 Learning:0.2.3 Learning:0.2.2.1 Learning:0.2.2 Learning:0.2.1.1 Learning:0.2.1 Learning:0.2.0 Learning:0.1.9 Learning:0.1.8 Learning:0.1.7 Learning:0.1.6.1 Learning:0.1.6 Learning:0.1.5 Learning:0.1.4.1 Learning:0.1.4 Learning:0.1.3 Learning:0.1.2 Learning:0.1.1 Learning:0.1.0
..
compare: Learning:0.1.5
Branches Tags
Learning:main Learning:feature_role Learning:copilot/add-role-based-access-control
Learning:0.6.6 Learning:0.6.5 Learning:0.6.4 Learning:0.6.3 Learning:0.6.2 Learning:0.6.1 Learning:0.6.0 Learning:0.5.6 Learning:0.5.5 Learning:0.5.4 Learning:0.5.3 Learning:0.5.2 Learning:0.5.1 Learning:0.5.0 Learning:0.4.5 Learning:0.4.4 Learning:0.4.3.1 Learning:0.4.3 Learning:0.4.2 Learning:0.4.1 Learning:0.4.0 Learning:0.3.9 Learning:0.3.8 Learning:0.3.6 Learning:0.3.5 Learning:0.3.4 Learning:0.3.3 Learning:0.3.2 Learning:0.3.1 Learning:0.3.0 Learning:0.2.9 Learning:0.2.8 Learning:0.2.7.1 Learning:0.2.7 Learning:0.2.6 Learning:0.2.5 Learning:0.2.4 Learning:0.2.3 Learning:0.2.2.1 Learning:0.2.2 Learning:0.2.1.1 Learning:0.2.1 Learning:0.2.0 Learning:0.1.9 Learning:0.1.8 Learning:0.1.7 Learning:0.1.6.1 Learning:0.1.6 Learning:0.1.5 Learning:0.1.4.1 Learning:0.1.4 Learning:0.1.3 Learning:0.1.2 Learning:0.1.1 Learning:0.1.0

30 Commits
0.1.4 ... 0.1.5

Author SHA1 Message Date
zyxucp
a97cc538f6 fix 修改dockerfile路径 2024-03-07 16:37:19 +08:00
zyxucp
45471c9bf4 add 增加精简版docker-compose 2024-03-07 16:29:33 +08:00
zyxucp
7145192988 Merge branch 'feature_appsetting' 2024-03-07 16:24:51 +08:00
zyxucp
0935becf70 fix 增加注释 2024-03-07 16:21:33 +08:00
zyxucp
a155c906b3 fix 修改为异步请求 2024-03-07 16:04:23 +08:00
zyxucp
fa8e82224a fix 导入问题修复 2024-03-07 13:08:26 +08:00
zyxucp
7088e26e09 add 调整项目结构 2024-03-07 12:39:12 +08:00
zyxucp
f471bdb607 fix 变量错误bug修复 2024-03-07 11:59:07 +08:00
zyxucp
0a0bd67834 fix 1 2024-03-07 11:57:36 +08:00
zyxucp
e91f8331de fix 修改忽略本地目录 2024-03-07 11:52:53 +08:00
zyxucp
2e90a7fe90 fix 修改目录增加src 2024-03-07 11:52:09 +08:00
zyxucp
3fb3c5bad5 fix 调整 2024-03-06 23:53:46 +08:00
zyxucp
a6753ee888 add 增加导入后台队列模式 2024-03-06 23:18:41 +08:00
zyxucp
9b04d3a758 add 增加CPU和GPU的选择 2024-03-06 22:21:10 +08:00
zyxucp
68e2b2ff9b fix 修改默认切片数和保存校验 2024-03-06 21:54:52 +08:00
zyxucp
464baa6125 add 修改仓储多库兼容，和注释 2024-03-06 19:22:23 +08:00
zyxucp
78083a0b68 fix 更新配置文件 2024-03-06 19:14:24 +08:00
zyxucp
681e248bdf del 删除不要的历史文件 2024-03-06 19:12:40 +08:00
zyxucp
1ca9493ce9 忽略本地内存配置 2024-03-06 19:09:38 +08:00
zyxucp
5537a8796f 忽略本地内存配置 2024-03-06 19:09:25 +08:00
zyxucp
e2a1ab80b0 删除本地文件 2024-03-06 19:06:48 +08:00
zyxucp
74db9e425f add 支持不同的业务数据库和向量数据库 2024-03-06 19:05:12 +08:00
zyxucp
3e2152a979 fix httpheader 中文异常 2024-03-06 16:09:05 +08:00
zyxucp
930c6c88ae Merge branch 'main' of https://github.com/xuzeyu91/AntSK 2024-03-06 14:44:46 +08:00
zyxucp
24bc276732 fix 处理mysql api实体长度问题 2024-03-06 14:42:02 +08:00
zyxucp
17cab5c51b Update docker-compose.yml 2024-03-06 14:29:40 +08:00
zyxucp
96dbc8e9e6 增加新增字段默认值 2024-03-06 14:20:50 +08:00
zyxucp
56a0d51794 忽略本地db 2024-03-06 14:19:15 +08:00
zyxucp
1cdbd969ba add 增加init api新增表的初始化 2024-03-06 13:36:41 +08:00
zyxucp
d77ece2aa6 Update docker-compose.yml 2024-03-06 12:55:19 +08:00
219 changed files with 1262 additions and 731 deletions
Expand all files Collapse all files

10
.gitignore vendored
View File

@@ -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

51
AntSK.Domain/Repositories/Base/SqlSugarHelper.cs
View File

@@ -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();
}
};
});
}
}

473
AntSK.Domain/Xzy.KnowledgeBase.Domain.xml
View File

@@ -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>

14
AntSK/Xzy.KnowledgeBase.xml
View File

@@ -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>

2
Dockerfile
View File

@@ -3,7 +3,7 @@ FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build
WORKDIR /src
# Copy csproj and restore as distinct layers
COPY ["AntSK/AntSK.csproj", "AntSK/"]
COPY ["src/AntSK/AntSK.csproj", "AntSK/"]
RUN dotnet restore "AntSK/AntSK.csproj"
# Copy everything else and build

17
docker-compose.simple.yml Normal file
View File

@@ -0,0 +1,17 @@
# 非 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
restart: always
environment:
- ASPNETCORE_URLS=http://*:5000
volumes:
- ./appsettings.json:/app/appsettings.json # 本地配置文件 需要放在同级目录
networks:
antsk:

4
docker-compose.yml
View File

@@ -18,7 +18,7 @@ services:
- ./pg/data:/var/lib/postgresql/data
antsk:
container_name: antsk
image: registry.cn-hangzhou.aliyuncs.com/xuzeyu91/antsk:v0.1.3
image: registry.cn-hangzhou.aliyuncs.com/xuzeyu91/antsk:v0.1.5
ports:
- 5000:5000
networks:
@@ -31,4 +31,4 @@ services:
volumes:
- ./appsettings.json:/app/appsettings.json # 本地配置文件 需要放在同级目录
networks:
antsk:
antsk:

8
AntSK.Domain/AntSK.Domain.csproj → src/AntSK.Domain/AntSK.Domain.csproj
View File

@@ -10,8 +10,6 @@
<ItemGroup>
<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" />
@@ -26,8 +24,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>

42
AntSK.Domain/AntSK.Domain.xml → src/AntSK.Domain/AntSK.Domain.xml
View File

@@ -32,6 +32,22 @@
瞬时
</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="M:AntSK.Domain.Domain.Service.KernelService.GetKernel(System.String,System.String)">
<summary>
获取kernel实例，依赖注入不好按每个用户去Import不同的插件，所以每次new一个新的kernel
@@ -107,16 +123,31 @@
总数
</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>
接口名称
@@ -227,6 +258,11 @@
创建时间
</summary>
</member>
<member name="P:AntSK.Domain.Repositories.KmsDetails.Status">
<summary>
状态
</summary>
</member>
<member name="P:AntSK.Domain.Repositories.Kmss.Icon">
<summary>
图标
@@ -509,7 +545,7 @@
<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>

0
AntSK.Domain/Common/DependencyInjection/DependencyInjection.cs → src/AntSK.Domain/Common/DependencyInjection/DependencyInjection.cs
View File

0
AntSK.Domain/Common/DependencyInjection/ServiceDescriptionAttribute.cs → src/AntSK.Domain/Common/DependencyInjection/ServiceDescriptionAttribute.cs
View File

15
src/AntSK.Domain/Common/Map/AutoMapProfile.cs Normal file
View File

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

36
src/AntSK.Domain/Common/Map/MapperExtend.cs Normal file
View File

@@ -0,0 +1,36 @@
using System;
using System.Collections.Generic;
using System.Text;
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);
}
}
}

31
src/AntSK.Domain/Common/Map/MapperRegister.cs Normal file
View File

@@ -0,0 +1,31 @@
using AutoMapper;
using Microsoft.Extensions.DependencyInjection;
using System;
using System.Collections.Generic;
using System.Text;
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>();
});
}
}
}

0
AntSK.Domain/Domain/Dto/KMFile.cs → src/AntSK.Domain/Domain/Dto/KMFile.cs
View File

14
src/AntSK.Domain/Domain/Interface/IHttpService.cs Normal file
View File

@@ -0,0 +1,14 @@
using RestSharp;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace AntSK.Domain.Domain.Interface
{
public interface IHttpService
{
Task<RestResponse> PostAsync(string url, Object jsonBody);
}
}

14
src/AntSK.Domain/Domain/Interface/IImportKMSService.cs Normal file
View File

@@ -0,0 +1,14 @@
using AntSK.Domain.Model;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace AntSK.Domain.Domain.Interface
{
public interface IImportKMSService
{
void ImportKMSTask(ImportKMSTaskReq req);
}
}

0
AntSK.Domain/Domain/Interface/IKMService.cs → src/AntSK.Domain/Domain/Interface/IKMService.cs
View File

0
AntSK.Domain/Domain/Interface/IKernelService.cs → src/AntSK.Domain/Domain/Interface/IKernelService.cs
View File

46
src/AntSK.Domain/Domain/Service/BackGroundTaskHandler.cs Normal file
View File

@@ -0,0 +1,46 @@
using AntSK.BackgroundTask;
using AntSK.Domain.Domain.Interface;
using AntSK.Domain.Model;
using Microsoft.Extensions.DependencyInjection;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace AntSK.Domain.Domain.Service
{
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;
}
}
}

30
src/AntSK.Domain/Domain/Service/HttpService.cs Normal file
View File

@@ -0,0 +1,30 @@
using AntSK.Domain.Common.DependencyInjection;
using AntSK.Domain.Domain.Interface;
using AntSK.Domain.Model;
using AntSK.Domain.Utils;
using Microsoft.KernelMemory;
using Newtonsoft.Json;
using RestSharp;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;
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;
}
}
}

91
src/AntSK.Domain/Domain/Service/ImportKMSService.cs Normal file
View File

@@ -0,0 +1,91 @@
using AntSK.Domain.Common.DependencyInjection;
using AntSK.Domain.Domain.Interface;
using AntSK.Domain.Model;
using AntSK.Domain.Repositories;
using Microsoft.KernelMemory;
using Microsoft.KernelMemory.Configuration;
using Microsoft.SemanticKernel.Services;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
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.GetMemory(textPartitioningOptions: new TextPartitioningOptions()
{
MaxTokensPerLine = km.MaxTokensPerLine,
MaxTokensPerParagraph = km.MaxTokensPerParagraph,
OverlappingTokens = km.OverlappingTokens
});
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(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(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(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);
}
}
}
}

68
AntSK.Domain/Domain/Service/KMService.cs → src/AntSK.Domain/Domain/Service/KMService.cs
View File

@@ -10,21 +10,22 @@ using Microsoft.KernelMemory.Postgres;
using System.Net.Http;
using Microsoft.Extensions.Options;
using Microsoft.KernelMemory.Configuration;
using Microsoft.Extensions.Configuration;
namespace AntSK.Domain.Domain.Service
{
[ServiceDescription(typeof(IKMService), ServiceLifetime.Scoped)]
public class KMService(
IOptions<PostgresConfig> postgresOptions
IConfiguration _config
) : IKMService
{
public MemoryServerless GetMemory(SearchClientConfig searchClientConfig=null, TextPartitioningOptions textPartitioningOptions=null)
public MemoryServerless GetMemory(SearchClientConfig searchClientConfig = null, TextPartitioningOptions textPartitioningOptions = null)
{
var handler = new OpenAIHttpClientHandler();
var httpClient = new HttpClient(handler);
if (searchClientConfig.IsNull())
{
searchClientConfig = new SearchClientConfig
searchClientConfig = new SearchClientConfig
{
MaxAskPromptSize = 2048,
MaxMatchesCount = 3,
@@ -43,26 +44,51 @@ namespace AntSK.Domain.Domain.Service
};
}
var memory = new KernelMemoryBuilder()
.WithPostgresMemoryDb(postgresOptions.Value)
.WithSimpleFileStorage(new SimpleFileStorageConfig { StorageType = FileSystemTypes.Volatile, Directory = "_files" })
.WithSearchClientConfig(searchClientConfig)
//如果用本地模型需要设置token小一点。
.WithCustomTextPartitioningOptions(textPartitioningOptions)
.WithOpenAITextGeneration(new OpenAIConfig()
{
APIKey = OpenAIOption.Key,
TextModel = OpenAIOption.Model
}, null, httpClient)
.WithOpenAITextEmbeddingGeneration(new OpenAIConfig()
{
APIKey = OpenAIOption.Key,
EmbeddingModel = OpenAIOption.EmbeddingModel
var memory = new KernelMemoryBuilder()
.WithSimpleFileStorage(new SimpleFileStorageConfig { StorageType = FileSystemTypes.Volatile, Directory = "_files" })
.WithSearchClientConfig(searchClientConfig)
.WithCustomTextPartitioningOptions(textPartitioningOptions)
.WithOpenAITextGeneration(new OpenAIConfig()
{
APIKey = OpenAIOption.Key,
TextModel = OpenAIOption.Model
}, null, false, httpClient)
.Build<MemoryServerless>();
return memory;
}, null, httpClient)
.WithOpenAITextEmbeddingGeneration(new OpenAIConfig()
{
APIKey = OpenAIOption.Key,
EmbeddingModel = OpenAIOption.EmbeddingModel
}, null, false, httpClient);
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;
}
var result = memory.Build<MemoryServerless>();
return result;
}
public async Task<List<KMFile>> GetDocumentByFileID(string fileid)

0
AntSK.Domain/Domain/Service/KernelService.cs → src/AntSK.Domain/Domain/Service/KernelService.cs
View File

0
AntSK.Domain/Map/AutoMapProfile.cs → src/AntSK.Domain/Map/AutoMapProfile.cs
View File

0
AntSK.Domain/Map/MapperExtend.cs → src/AntSK.Domain/Map/MapperExtend.cs
View File

0
AntSK.Domain/Map/MapperRegister.cs → src/AntSK.Domain/Map/MapperRegister.cs
View File

0
AntSK.Domain/Model/Enum/AIModelType.cs → src/AntSK.Domain/Model/Enum/AIModelType.cs
View File

0
AntSK.Domain/Model/Enum/HttpMethodType.cs → src/AntSK.Domain/Model/Enum/HttpMethodType.cs
View File

15
src/AntSK.Domain/Model/Enum/ImportKmsStatus.cs Normal file
View File

@@ -0,0 +1,15 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace AntSK.Domain.Model.Enum
{
public enum ImportKmsStatus
{
Loadding=0,
Success=1,
Fail=2
}
}

39
src/AntSK.Domain/Model/ImportKMSTaskReq.cs Normal file
View File

@@ -0,0 +1,39 @@
using AntSK.Domain.Repositories;
using Microsoft.KernelMemory;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
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
}
}

0
AntSK.Domain/Model/MessageInfo.cs → src/AntSK.Domain/Model/MessageInfo.cs
View File

0
AntSK.Domain/Model/PageList.cs → src/AntSK.Domain/Model/PageList.cs
View File

6
AntSK.Domain/Options/ConnectionOption.cs → src/AntSK.Domain/Options/DBConnectionOption.cs
View File

@@ -6,15 +6,15 @@ using System.Threading.Tasks;
namespace AntSK.Domain.Options
{
public class ConnectionOption
public class DBConnectionOption
{
/// <summary>
/// sqlite连接字符串
/// </summary>
public static string Sqlite { get; set; }
public static string DbType { get; set; }
/// <summary>
/// pg链接字符串
/// </summary>
public static string Postgres { get; set; }
public static string ConnectionStrings { get; set; }
}
}

24
src/AntSK.Domain/Options/KernelMemoryOption.cs Normal file
View File

@@ -0,0 +1,24 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
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; }
}
}

1
AntSK.Domain/Options/LLamaSharpOption.cs → src/AntSK.Domain/Options/LLamaSharpOption.cs
View File

@@ -8,6 +8,7 @@ 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; }

0
AntSK.Domain/Options/LoginOption.cs → src/AntSK.Domain/Options/LoginOption.cs
View File

0
AntSK.Domain/Options/OpenAIOption.cs → src/AntSK.Domain/Options/OpenAIOption.cs
View File

10
AntSK.Domain/Repositories/AI/Api/Apis.cs → src/AntSK.Domain/Repositories/AI/Api/Apis.cs
View File

@@ -37,31 +37,31 @@ namespace AntSK.Domain.Repositories
[Required]
public HttpMethodType Method { get; set; }
[SugarColumn(ColumnDataType = "varchar(2000)")]
[SugarColumn(ColumnDataType = "varchar(1000)")]
public string? Header { get; set; }
/// <summary>
/// QueryString参数
/// </summary>
[SugarColumn(ColumnDataType = "varchar(2000)")]
[SugarColumn(ColumnDataType = "varchar(1000)")]
public string? Query { get; set; }
/// <summary>
/// jsonBody 实体
/// </summary>
[SugarColumn(ColumnDataType = "varchar(8000)")]
[SugarColumn(ColumnDataType = "varchar(7000)")]
public string? JsonBody { get; set; }
/// <summary>
/// 入参提示词
/// </summary>
[Required]
[SugarColumn(ColumnDataType = "varchar(2000)")]
[SugarColumn(ColumnDataType = "varchar(1500)")]
public string InputPrompt { get; set; }
/// <summary>
/// 返回提示词
/// </summary>
[Required]
[SugarColumn(ColumnDataType = "varchar(2000)")]
[SugarColumn(ColumnDataType = "varchar(1500)")]
public string OutputPrompt { get; set; }
}
}

0
AntSK.Domain/Repositories/AI/Api/Apis_Repositories.cs → src/AntSK.Domain/Repositories/AI/Api/Apis_Repositories.cs
View File

0
AntSK.Domain/Repositories/AI/Api/IApis_Repositories.cs → src/AntSK.Domain/Repositories/AI/Api/IApis_Repositories.cs
View File

1
AntSK.Domain/Repositories/AI/App/Apps.cs → src/AntSK.Domain/Repositories/AI/App/Apps.cs
View File

@@ -40,6 +40,7 @@ namespace AntSK.Domain.Repositories
/// <summary>
/// 温度
/// </summary>
[SugarColumn(DefaultValue = "70")]
public double Temperature { get; set; }=70f;
/// <summary>

0
AntSK.Domain/Repositories/AI/App/Apps_Repositories.cs → src/AntSK.Domain/Repositories/AI/App/Apps_Repositories.cs
View File

0
AntSK.Domain/Repositories/AI/App/IApps_Repositories.cs → src/AntSK.Domain/Repositories/AI/App/IApps_Repositories.cs
View File

0
AntSK.Domain/Repositories/AI/Kms/IKmss_Repositories.cs → src/AntSK.Domain/Repositories/AI/Kms/IKmss_Repositories.cs
View File

9
AntSK.Domain/Repositories/AI/Kms/Kmss.cs → src/AntSK.Domain/Repositories/AI/Kms/Kmss.cs
View File

@@ -32,18 +32,21 @@ namespace AntSK.Domain.Repositories
/// <summary>
/// 每个段落的最大标记数。
/// </summary>
public int MaxTokensPerParagraph { get; set; } = 1000;
[SugarColumn(DefaultValue = "299")]
public int MaxTokensPerParagraph { get; set; } = 299;
/// <summary>
/// 每行，也就是每句话的最大标记数
/// </summary>
public int MaxTokensPerLine { get; set; } = 300;
[SugarColumn(DefaultValue = "99")]
public int MaxTokensPerLine { get; set; } = 99;
/// <summary>
/// 段落之间重叠标记的数量。
/// </summary>
public int OverlappingTokens { get; set; } = 100;
[SugarColumn(DefaultValue = "49")]
public int OverlappingTokens { get; set; } = 49;
}
}

0
AntSK.Domain/Repositories/AI/Kms/Kmss_Repositories.cs → src/AntSK.Domain/Repositories/AI/Kms/Kmss_Repositories.cs
View File

0
AntSK.Domain/Repositories/AI/KmsDetail/IKmsDetails_Repositories.cs → src/AntSK.Domain/Repositories/AI/KmsDetail/IKmsDetails_Repositories.cs
View File

8
AntSK.Domain/Repositories/AI/KmsDetail/KmsDetails.cs → src/AntSK.Domain/Repositories/AI/KmsDetail/KmsDetails.cs
View File

@@ -1,4 +1,5 @@
using SqlSugar;
using AntSK.Domain.Model.Enum;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
@@ -32,9 +33,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;
}
}

0
AntSK.Domain/Repositories/AI/KmsDetail/KmsDetails_Repositories.cs → src/AntSK.Domain/Repositories/AI/KmsDetail/KmsDetails_Repositories.cs
View File

0
AntSK.Domain/Repositories/Base/IRepository.cs → src/AntSK.Domain/Repositories/Base/IRepository.cs
View File

15
AntSK.Domain/Repositories/Base/Repository.cs → src/AntSK.Domain/Repositories/Base/Repository.cs
View File

@@ -7,31 +7,34 @@ using System.Text;
using System.Threading.Tasks;
using AntSK.Domain.Map;
using AntSK.Domain.Model;
using Microsoft.Extensions.Configuration;
namespace AntSK.Domain.Repositories.Base
{
public class Repository<T> : SimpleClient<T> where T : class, new()
{
public Repository(ISqlSugarClient context = null) : base(context)//注意这里要有默认值等于null
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>

54
src/AntSK.Domain/Repositories/Base/SqlSugarHelper.cs Normal file
View File

@@ -0,0 +1,54 @@
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;
using Microsoft.Extensions.Configuration;
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;
}
}
}

0
AntSK.Domain/Repositories/Setting/AIModel/AIModels.cs → src/AntSK.Domain/Repositories/Setting/AIModel/AIModels.cs
View File

0
AntSK.Domain/Repositories/Setting/AIModel/AIModels_Repositories.cs → src/AntSK.Domain/Repositories/Setting/AIModel/AIModels_Repositories.cs
View File

0
AntSK.Domain/Repositories/Setting/AIModel/IAIModels_Repositories.cs → src/AntSK.Domain/Repositories/Setting/AIModel/IAIModels_Repositories.cs
View File

0
AntSK.Domain/Repositories/Setting/User/IUsers_Repositories.cs → src/AntSK.Domain/Repositories/Setting/User/IUsers_Repositories.cs
View File

0
AntSK.Domain/Repositories/Setting/User/Users.cs → src/AntSK.Domain/Repositories/Setting/User/Users.cs
View File

0
AntSK.Domain/Repositories/Setting/User/Users_Repositories.cs → src/AntSK.Domain/Repositories/Setting/User/Users_Repositories.cs
View File

0
AntSK.Domain/Utils/ConvertUtils.cs → src/AntSK.Domain/Utils/ConvertUtils.cs
View File

0
AntSK.Domain/Utils/DateTimeConverter.cs → src/AntSK.Domain/Utils/DateTimeConverter.cs
View File

0
AntSK.Domain/Utils/LongToDateTimeConverter.cs → src/AntSK.Domain/Utils/LongToDateTimeConverter.cs
View File

0
AntSK.Domain/Utils/OpenAIHttpClientHandler.cs → src/AntSK.Domain/Utils/OpenAIHttpClientHandler.cs
View File

0
AntSK.Domain/Utils/PasswordUtil.cs → src/AntSK.Domain/Utils/PasswordUtil.cs
View File

0
AntSK.Domain/Utils/RepoFiles.cs → src/AntSK.Domain/Utils/RepoFiles.cs
View File

16
AntSK.sln → src/AntSK.sln
View File

@@ -9,10 +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
docker-compose.yml = docker-compose.yml
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
@@ -27,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

0
AntSK/AntSK.csproj → src/AntSK/AntSK.csproj
View File

6
AntSK/AntSK.xml → src/AntSK/AntSK.xml
View File

@@ -16,6 +16,12 @@
</summary>
<returns></returns>
</member>
<member name="T:AntSK.Controllers.KMSController">
<summary>
</summary>
<param name="_taskBroker"></param>
</member>
<member name="M:AntSK.Controllers.LLamaSharpController.chat(AntSK.Models.OpenAIModel)">
<summary>
本地会话接口

0
AntSK/App.razor → src/AntSK/App.razor
View File

0
AntSK/Components/GlobalHeader/RightContent.razor → src/AntSK/Components/GlobalHeader/RightContent.razor
View File

0
AntSK/Components/GlobalHeader/RightContent.razor.cs → src/AntSK/Components/GlobalHeader/RightContent.razor.cs
View File

0
AntSK/Controllers/FileController.cs → src/AntSK/Controllers/FileController.cs
View File

5
AntSK/Controllers/InitController.cs → src/AntSK/Controllers/InitController.cs
View File

@@ -25,6 +25,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();
}
}

57
src/AntSK/Controllers/KMSController.cs Normal file
View File

@@ -0,0 +1,57 @@
using AntSK.Domain.Model;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using static AntSK.Pages.KmsPage.KmsDetail;
using System;
using AntSK.Domain.Repositories;
using AntSK.Domain.Domain.Interface;
using Microsoft.KernelMemory.Configuration;
using AntSK.Domain.Model.Enum;
using AntSK.Domain.Map;
using AntSK.BackgroundTask;
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();
}
}
}

0
AntSK/Controllers/LLamaSharpController.cs → src/AntSK/Controllers/LLamaSharpController.cs
View File

0
AntSK/Controllers/OpenController.cs → src/AntSK/Controllers/OpenController.cs
View File

0
AntSK/Extensions/DateTimeExtension.cs → src/AntSK/Extensions/DateTimeExtension.cs
View File

0
AntSK/Layouts/BasicLayout.razor → src/AntSK/Layouts/BasicLayout.razor
View File

0
AntSK/Layouts/OpenLayout.razor → src/AntSK/Layouts/OpenLayout.razor
View File

0
AntSK/Layouts/UserLayout.razor → src/AntSK/Layouts/UserLayout.razor
View File

0
AntSK/Layouts/UserLayout.razor.css → src/AntSK/Layouts/UserLayout.razor.css
View File

0
AntSK/Models/OpenAPI/OpenAIModel.cs → src/AntSK/Models/OpenAPI/OpenAIModel.cs
View File

0
AntSK/Models/OpenAPI/OpenAIResult.cs → src/AntSK/Models/OpenAPI/OpenAIResult.cs
View File

0
AntSK/Models/Template/ActivitiesType.cs → src/AntSK/Models/Template/ActivitiesType.cs
View File

0
AntSK/Models/Template/ActivityGroup.cs → src/AntSK/Models/Template/ActivityGroup.cs
View File

0
AntSK/Models/Template/ActivityProject.cs → src/AntSK/Models/Template/ActivityProject.cs
View File

0
AntSK/Models/Template/ActivityUser.cs → src/AntSK/Models/Template/ActivityUser.cs
View File

0
AntSK/Models/Template/AdvancedOperation.cs → src/AntSK/Models/Template/AdvancedOperation.cs
View File

0
AntSK/Models/Template/AdvancedProfileData.cs → src/AntSK/Models/Template/AdvancedProfileData.cs
View File

0
AntSK/Models/Template/BasicGood.cs → src/AntSK/Models/Template/BasicGood.cs
View File

0
AntSK/Models/Template/BasicProfileDataType.cs → src/AntSK/Models/Template/BasicProfileDataType.cs
View File

0
AntSK/Models/Template/BasicProgress.cs → src/AntSK/Models/Template/BasicProgress.cs
View File

0
AntSK/Models/Template/ChartData.cs → src/AntSK/Models/Template/ChartData.cs
View File

0
AntSK/Models/Template/ChartDataItem.cs → src/AntSK/Models/Template/ChartDataItem.cs
View File

0
AntSK/Models/Template/CurrentUser.cs → src/AntSK/Models/Template/CurrentUser.cs
View File

0
AntSK/Models/Template/FormItemLayout.cs → src/AntSK/Models/Template/FormItemLayout.cs
View File

0
AntSK/Models/Template/FormModel.cs → src/AntSK/Models/Template/FormModel.cs
View File

0
AntSK/Models/Template/LayoutModel.cs → src/AntSK/Models/Template/LayoutModel.cs
View File

0
AntSK/Models/Template/ListFormModel.cs → src/AntSK/Models/Template/ListFormModel.cs
View File

0
AntSK/Models/Template/ListItemDataType.cs → src/AntSK/Models/Template/ListItemDataType.cs
View File

Some files were not shown because too many files have changed in this diff Show More