317 lines
8.7 KiB
C#
317 lines
8.7 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.ComponentModel.DataAnnotations;
|
|
using System.Linq;
|
|
using System.Net.Mime;
|
|
using System.Reflection.Metadata;
|
|
using BITKit;
|
|
using Cysharp.Threading.Tasks;
|
|
using Godot;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using Constant = BITKit.Constant;
|
|
|
|
namespace BITFactory;
|
|
// ReSharper disable once IdentifierTypo
|
|
[Serializable]
|
|
public abstract class IDIS_Base
|
|
{
|
|
/// <summary>
|
|
/// 创建时间
|
|
/// </summary>
|
|
public DateTime CreateTime { get; set; }=DateTime.Now;
|
|
/// <summary>
|
|
/// 更新时间
|
|
/// </summary>
|
|
public DateTime UpdateTime { get; set; }=DateTime.Now;
|
|
}
|
|
// ReSharper disable once IdentifierTypo
|
|
/// <summary>
|
|
/// 标识的值
|
|
/// </summary>
|
|
[Serializable]
|
|
public class IDIS_Value:IDIS_Base
|
|
{
|
|
/// <summary>
|
|
/// 标识码
|
|
/// </summary>
|
|
[Key]
|
|
public string Handle { get; set; }
|
|
/// <summary>
|
|
/// 创建用户,例如:模板名称,用户名称
|
|
/// </summary>
|
|
public string CreateUser { get; set; }
|
|
}
|
|
// ReSharper disable once IdentifierTypo
|
|
public class IDIS_Query : IDIS_Value
|
|
{
|
|
|
|
// ReSharper disable once IdentifierTypo
|
|
/// <summary>
|
|
/// 关联的数据
|
|
/// </summary>
|
|
public IDIS_Data[] Datas { get; internal set; }
|
|
// ReSharper disable once IdentifierTypo
|
|
/// <summary>
|
|
/// 关联的标识引用
|
|
/// </summary>
|
|
public IDIS_Reference[] References { get; internal set; }
|
|
}
|
|
|
|
/// <summary>
|
|
/// 标识的格式
|
|
/// </summary>
|
|
[Serializable]
|
|
// ReSharper disable once IdentifierTypo
|
|
public class IDIS_Data:IDIS_Base
|
|
{
|
|
/// <summary>
|
|
/// 不需要处理这个
|
|
/// </summary>
|
|
[Key]
|
|
public int Index { get; set; }
|
|
/// <summary>
|
|
/// 标识码
|
|
/// </summary>
|
|
public string Handle { get; set; }
|
|
/// <summary>
|
|
/// 记录的名称,通常为中文
|
|
/// </summary>
|
|
public string Name { get; set; }
|
|
/// <summary>
|
|
/// 值类型,例如string,url,site
|
|
/// </summary>
|
|
public string Format { get; set; }
|
|
/// <summary>
|
|
/// 值
|
|
/// </summary>
|
|
public string Value { get; set; }
|
|
/// <summary>
|
|
/// 类型,用于解析时对数据条目进行分类
|
|
/// </summary>
|
|
public string Category { get; set; }
|
|
}
|
|
/// <summary>
|
|
/// 标识的引用或关联
|
|
/// </summary>
|
|
[Serializable]
|
|
// ReSharper disable once IdentifierTypo
|
|
public class IDIS_Reference:IDIS_Base
|
|
{
|
|
/// <summary>
|
|
/// 不需要处理这个
|
|
/// </summary>
|
|
[Key]
|
|
public int Index{ get; set; }
|
|
/// <summary>
|
|
/// 标识码
|
|
/// </summary>
|
|
public string Handle { get; set; }
|
|
/// <summary>
|
|
/// 相关联的标识
|
|
/// </summary>
|
|
public string RelatedHandle { get; set; }
|
|
}
|
|
// ReSharper disable once IdentifierTypo
|
|
public class IDIS_DBContext:DbContext
|
|
{
|
|
/// <summary>
|
|
/// 标识表
|
|
/// </summary>
|
|
private DbSet<IDIS_Value> Values { get; set; }
|
|
/// <summary>
|
|
/// 标识数据表
|
|
/// </summary>
|
|
private DbSet<IDIS_Data> Datas{ get; set; }
|
|
/// <summary>
|
|
/// 标识引用表
|
|
/// </summary>
|
|
private DbSet<IDIS_Reference> References{ get; set; }
|
|
/// <summary>
|
|
/// 确保创建数据库
|
|
/// </summary>
|
|
/// <param name="optionsBuilder"></param>
|
|
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
|
|
{
|
|
// ReSharper disable once StringLiteralTypo
|
|
//var sql = SQLiteContextHelper.GetConnectionString("IDIS");
|
|
SQLiteContextHelper.GetConnectionSqlAndPath("IDIS",out var sql,out var path);
|
|
optionsBuilder.UseSqlite(sql);
|
|
optionsBuilder.UseQueryTrackingBehavior(QueryTrackingBehavior.TrackAll);
|
|
BIT4Log.Log<IDIS_DBContext>($"已创建标识数据库:{path}");
|
|
}
|
|
|
|
/// <summary>
|
|
/// 查询多个标识
|
|
/// </summary>
|
|
/// <param name="key">模糊标识码</param>
|
|
/// <param name="queries">查询列表</param>
|
|
/// <returns>是否查询到了内容</returns>
|
|
public bool Query(string key, out IDIS_Query[] queries)
|
|
{
|
|
ChangeTracker.DetectChanges();
|
|
ChangeTracker.Clear();
|
|
// queries = Values
|
|
// .Where(x => x.Handle.Contains(key) || x.CreateUser.Contains(key))
|
|
// .Select(x => new IDIS_Query()
|
|
// {
|
|
// Handle = x.Handle,
|
|
// CreateTime = x.CreateTime,
|
|
// UpdateTime = x.UpdateTime,
|
|
// CreateUser = x.CreateUser,
|
|
// Datas = Datas.Where(data => data.Handle == x.Handle).ToArray(),
|
|
// References = References.Where(reference => reference.Handle == x.Handle).ToArray()
|
|
// }).ToArray();
|
|
// return queries.Any();
|
|
var _data = Datas.ToList();
|
|
var _values = Values.ToList();
|
|
var handleKey = key.Split('?').First();
|
|
|
|
var _queries=_values.Where(x => x.Handle.Contains(handleKey) || (string.IsNullOrEmpty(x.CreateUser) is false && x.CreateUser.Contains(handleKey))).ToArray();
|
|
var searchEnties =new List<KeyValuePair<string, string>>();
|
|
if (_queries.Any() is false)
|
|
{
|
|
queries = Array.Empty<IDIS_Query>();
|
|
return false;
|
|
}
|
|
if (key.Contains('?'))
|
|
{
|
|
var expression = key.Split("?", 2).Last();
|
|
foreach (var cmd in expression.Split("&").Where(x=>x.Contains('=')).Where(x=>x.Split('=').Length is 2)) {
|
|
var split = cmd.Split('=',2);
|
|
var name = split[0];
|
|
var value = split[1];
|
|
searchEnties.Add(new KeyValuePair<string, string>(name,value));
|
|
var validData = _data.Where(x => x.Name == name && x.Value == value);
|
|
if (_queries.Any())
|
|
{
|
|
validData = validData.Where(x=>_queries.Any(y=>y.Handle==x.Handle));
|
|
}
|
|
_queries=_values
|
|
.Select(x=>validData.Any(y=>x.Handle == y.Handle)?x:null)
|
|
.Where(x=>x!=null)
|
|
.ToArray();
|
|
}
|
|
}
|
|
queries = _queries.Select(x => new IDIS_Query()
|
|
{
|
|
Handle = x.Handle,
|
|
CreateTime = x.CreateTime,
|
|
UpdateTime = x.UpdateTime,
|
|
CreateUser = x.CreateUser,
|
|
Datas = Datas.Where(data => data.Handle == x.Handle).ToArray(),
|
|
References = References.Where(reference => reference.Handle == x.Handle).ToArray()
|
|
}).ToArray();
|
|
if (searchEnties.Any())
|
|
{
|
|
var newQueries = new List<IDIS_Query>();
|
|
foreach (var query in queries)
|
|
{
|
|
query.Datas = query.Datas.Where(x=>searchEnties.Any(y=>y.Key==x.Name&&y.Value==x.Value)).ToArray();
|
|
newQueries.Add(query);
|
|
}
|
|
queries=newQueries.ToArray();
|
|
}
|
|
return queries.Any();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 查询单个标识
|
|
/// </summary>
|
|
/// <param name="key">模糊标识</param>
|
|
/// <param name="query">标识查询结果</param>
|
|
/// <returns>是否查询到了标识</returns>
|
|
public bool Query(string key, out IDIS_Query query)
|
|
{
|
|
Query(key, out IDIS_Query[] queries);
|
|
query = queries.FirstOrDefault();
|
|
return queries.Any();
|
|
}
|
|
public bool Register(string handle,string createUser = Constant.System.Internal)
|
|
{
|
|
var handleExists = Values.Any(x => x.Handle == handle);
|
|
if (handleExists)
|
|
{
|
|
return false;
|
|
}
|
|
var value = new IDIS_Value()
|
|
{
|
|
Handle = handle,
|
|
CreateUser = createUser,
|
|
};
|
|
Values.Add(value);
|
|
SaveChangesAsync();
|
|
return true;
|
|
}
|
|
public void Register(string handle,string name,string format, string value,string category)
|
|
{
|
|
var handleExists = Values.Any(x => x.Handle == handle);
|
|
if (!handleExists)
|
|
{
|
|
Register(handle);
|
|
}
|
|
var data = new IDIS_Data()
|
|
{
|
|
Name = name,
|
|
Handle = handle,
|
|
Format = format,
|
|
Value = value,
|
|
Category = category,
|
|
};
|
|
Datas.Add(data);
|
|
SaveChangesAsync();
|
|
}
|
|
|
|
public void RegisterReference(string handle, string refenceHandle)
|
|
{
|
|
References.Add(new IDIS_Reference()
|
|
{
|
|
Handle = handle,
|
|
RelatedHandle = refenceHandle,
|
|
});
|
|
SaveChangesAsync();
|
|
}
|
|
|
|
public bool Update(string handle, string format, string value)
|
|
{
|
|
var result = Datas.FirstOrDefault(x => x.Handle == handle && x.Format == format);
|
|
if (result is null) return false;
|
|
result.UpdateTime=DateTime.Now;
|
|
result.Value = value;
|
|
SaveChangesAsync();
|
|
return true;
|
|
}
|
|
}
|
|
// ReSharper disable once IdentifierTypo
|
|
/// <summary>
|
|
/// 标识码注册与查询服务
|
|
/// </summary>
|
|
public partial class IDIS_Service:Node
|
|
{
|
|
public static IDIS_Service Singleton { get; private set; }
|
|
private static IDIS_DBContext Context;
|
|
public override void _Ready()
|
|
{
|
|
Context = new IDIS_DBContext();
|
|
BIT4Log.Log<IDIS_Service>("已创建标识数据库");
|
|
UniTask.Run(()=>Context.Database.EnsureCreatedAsync());
|
|
}
|
|
|
|
public override void _EnterTree()
|
|
{
|
|
Singleton = this;
|
|
}
|
|
|
|
public override void _ExitTree()
|
|
{
|
|
Context.Dispose();
|
|
Context = null;
|
|
}
|
|
|
|
public bool Query(string word,out IDIS_Query[] queries) => Context.Query(word, out queries);
|
|
public bool Register(string handle,string createUser=Constant.System.Internal) => Context.Register(handle,createUser);
|
|
public void Register(string handle,string name, string format, string value,string category) => Context.Register(handle,name, format, value,category);
|
|
public void RegisterReference(string handle,string refenceHandle) => Context.RegisterReference(handle,refenceHandle);
|
|
public static string GenerateHandle() => $"88.123.99/{Mathf.Abs(Guid.NewGuid().GetHashCode())}";
|
|
public bool Query(string key, out IDIS_Query query) => Context.Query(key, out query);
|
|
public bool Update(string handle, string format, string value) => Context.Update(handle, format, value);
|
|
} |