From 4dd882cf905cb48b2454eabb130b54e9e472e222 Mon Sep 17 00:00:00 2001 From: wintel Date: Thu, 13 Mar 2025 00:31:22 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=A4=96=E9=83=A8=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E6=BA=90=E7=AE=A1=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ExtDataSourceApp/ExtDataSourceApp.cs | 77 ++++++++++ .../AddOrUpdateExternalDataSourceReq.cs | 113 ++++++++++++++ .../Request/QueryExternalDataSourceListReq.cs | 7 + .../Domain/ExternalDataSource.cs | 139 ++++++++++++++++++ .../ExternalDataSourcesController.cs | 113 ++++++++++++++ 5 files changed, 449 insertions(+) create mode 100644 OpenAuth.App/ExtDataSourceApp/ExtDataSourceApp.cs create mode 100644 OpenAuth.App/ExtDataSourceApp/Request/AddOrUpdateExternalDataSourceReq.cs create mode 100644 OpenAuth.App/ExtDataSourceApp/Request/QueryExternalDataSourceListReq.cs create mode 100644 OpenAuth.Repository/Domain/ExternalDataSource.cs create mode 100644 OpenAuth.WebApi/Controllers/ExternalDataSourcesController.cs diff --git a/OpenAuth.App/ExtDataSourceApp/ExtDataSourceApp.cs b/OpenAuth.App/ExtDataSourceApp/ExtDataSourceApp.cs new file mode 100644 index 00000000..340f2ee3 --- /dev/null +++ b/OpenAuth.App/ExtDataSourceApp/ExtDataSourceApp.cs @@ -0,0 +1,77 @@ +using System; +using System.Threading.Tasks; +using Infrastructure; +using OpenAuth.App.Interface; +using OpenAuth.App.Request; +using OpenAuth.App.Response; +using OpenAuth.Repository.Domain; +using SqlSugar; + + +namespace OpenAuth.App +{ + public class ExtDataSourceApp : SqlSugarBaseApp + { + + /// + /// 加载列表 + /// + public async Task Load(QueryExternalDataSourceListReq request) + { + var loginContext = _auth.GetCurrentUser(); + if (loginContext == null) + { + throw new CommonException("登录已过期", Define.INVALID_TOKEN); + } + + var result = new TableData(); + var objs = GetDataPrivilege("u"); + if (!string.IsNullOrEmpty(request.key)) + { + objs = objs.Where(u => u.Name.Contains(request.key)); + } + + result.data = objs.OrderBy(u => u.Name) + .Skip((request.page - 1) * request.limit) + .Take(request.limit).ToList(); + result.count = await objs.CountAsync(); + return result; + } + + public void Add(AddOrUpdateExternalDataSourceReq req) + { + var obj = req.MapTo(); + obj.Createtime = DateTime.Now; + var user = _auth.GetCurrentUser().User; + obj.Createuserid = user.Id; + obj.Createusername = user.Name; + Repository.Insert(obj); + } + + public void Update(AddOrUpdateExternalDataSourceReq obj) + { + var user = _auth.GetCurrentUser().User; + Repository.Update(u => new ExternalDataSource + { + Dbtype = obj.Dbtype, + Databasename = obj.Databasename, + Server = obj.Server, + Port = obj.Port, + Username = obj.Username, + Password = obj.Password, + Description = obj.Description, + Enabled = obj.Enabled, + Testsuccess = obj.Testsuccess, + Connectionstring = obj.Connectionstring, + Updatetime = DateTime.Now, + Updateuserid = user.Id, + Updateusername = user.Name + },u => u.Id == obj.Id); + + } + + public ExtDataSourceApp(ISqlSugarClient client, IAuth auth) : base(client, auth) + { + } + } +} \ No newline at end of file diff --git a/OpenAuth.App/ExtDataSourceApp/Request/AddOrUpdateExternalDataSourceReq.cs b/OpenAuth.App/ExtDataSourceApp/Request/AddOrUpdateExternalDataSourceReq.cs new file mode 100644 index 00000000..4f126190 --- /dev/null +++ b/OpenAuth.App/ExtDataSourceApp/Request/AddOrUpdateExternalDataSourceReq.cs @@ -0,0 +1,113 @@ +//------------------------------------------------------------------------------ +// This code was generated by a CodeSmith Template. +// +// DO NOT MODIFY contents of this file. Changes to this +// file will be lost if the code is regenerated. +// Author:Yubao Li +//------------------------------------------------------------------------------ +using System; +using System.ComponentModel; +using System.ComponentModel.DataAnnotations.Schema; +using OpenAuth.Repository.Core; + +namespace OpenAuth.App.Request +{ + /// + /// + /// + + public class AddOrUpdateExternalDataSourceReq + { + /// + ///创建时间 + /// + public DateTime Createtime { get; set; } + + /// + ///创建用户名 + /// + public string Createusername { get; set; } + + /// + ///创建用户ID + /// + public string Createuserid { get; set; } + + /// + ///更新用户ID + /// + public string Updateuserid { get; set; } + + /// + ///更新用户名 + /// + public string Updateusername { get; set; } + + /// + ///是否测试成功 + /// + public bool? Testsuccess { get; set; } + + /// + ///最后测试时间 + /// + public DateTime? Updatetime { get; set; } + + /// + ///主键 + /// + public string Id { get; set; } + + /// + ///是否启用 + /// + public bool Enabled { get; set; } + + /// + ///连接字符串 + /// + public string Connectionstring { get; set; } + + /// + ///描述 + /// + public string Description { get; set; } + + /// + ///密码 + /// + public string Password { get; set; } + + /// + ///用户名 + /// + public string Username { get; set; } + + /// + ///端口 + /// + public int? Port { get; set; } + + /// + ///服务器地址 + /// + public string Server { get; set; } + + /// + ///数据库名称 + /// + public string Databasename { get; set; } + + /// + ///数据库类型 + /// + public string Dbtype { get; set; } + + /// + ///数据源名称 + /// + public string Name { get; set; } + + + } +} \ No newline at end of file diff --git a/OpenAuth.App/ExtDataSourceApp/Request/QueryExternalDataSourceListReq.cs b/OpenAuth.App/ExtDataSourceApp/Request/QueryExternalDataSourceListReq.cs new file mode 100644 index 00000000..6f933dbe --- /dev/null +++ b/OpenAuth.App/ExtDataSourceApp/Request/QueryExternalDataSourceListReq.cs @@ -0,0 +1,7 @@ +namespace OpenAuth.App.Request +{ + public class QueryExternalDataSourceListReq : PageReq + { + + } +} diff --git a/OpenAuth.Repository/Domain/ExternalDataSource.cs b/OpenAuth.Repository/Domain/ExternalDataSource.cs new file mode 100644 index 00000000..8b6302fb --- /dev/null +++ b/OpenAuth.Repository/Domain/ExternalDataSource.cs @@ -0,0 +1,139 @@ +using System; +using System.ComponentModel; +using System.ComponentModel.DataAnnotations.Schema; +using OpenAuth.Repository.Core; + +namespace OpenAuth.Repository.Domain +{ + /// + ///外部数据源 + /// + [Table("ExternalDataSource")] + public class ExternalDataSource : StringEntity + { + public ExternalDataSource() + { + this.Createtime = DateTime.Now; + this.Createusername = ""; + this.Createuserid = ""; + this.Updateuserid = ""; + this.Updateusername = ""; + this.Testsuccess = false; + this.Updatetime = DateTime.Now; + this.Enabled = false; + this.Connectionstring = ""; + this.Description = ""; + this.Password = ""; + this.Username = ""; + this.Port = 0; + this.Server = ""; + this.Databasename = ""; + this.Dbtype = ""; + this.Name = ""; + + } + /// + ///创建时间 + /// + [Description("创建时间")] + public DateTime Createtime { get; set; } + + /// + ///创建用户名 + /// + [Description("创建用户名")] + public string Createusername { get; set; } + + /// + ///创建用户ID + /// + [Description("创建用户ID")] + public string Createuserid { get; set; } + + /// + ///更新用户ID + /// + [Description("更新用户ID")] + public string Updateuserid { get; set; } + + /// + ///更新用户名 + /// + [Description("更新用户名")] + public string Updateusername { get; set; } + + /// + ///是否测试成功 + /// + [Description("是否测试成功")] + public bool? Testsuccess { get; set; } + + /// + ///最后测试时间 + /// + [Description("最后测试时间")] + public DateTime? Updatetime { get; set; } + + /// + ///是否启用 + /// + [Description("是否启用")] + public bool Enabled { get; set; } + + /// + ///连接字符串 + /// + [Description("连接字符串")] + public string Connectionstring { get; set; } + + /// + ///描述 + /// + [Description("描述")] + public string Description { get; set; } + + /// + ///密码 + /// + [Description("密码")] + public string Password { get; set; } + + /// + ///用户名 + /// + [Description("用户名")] + public string Username { get; set; } + + /// + ///端口 + /// + [Description("端口")] + public int? Port { get; set; } + + /// + ///服务器地址 + /// + [Description("服务器地址")] + public string Server { get; set; } + + /// + ///数据库名称 + /// + [Description("数据库名称")] + public string Databasename { get; set; } + + /// + ///数据库类型 + /// + [Description("数据库类型")] + public string Dbtype { get; set; } + + /// + ///数据源名称 + /// + [Description("数据源名称")] + public string Name { get; set; } + + + } +} \ No newline at end of file diff --git a/OpenAuth.WebApi/Controllers/ExternalDataSourcesController.cs b/OpenAuth.WebApi/Controllers/ExternalDataSourcesController.cs new file mode 100644 index 00000000..d0bc8e13 --- /dev/null +++ b/OpenAuth.WebApi/Controllers/ExternalDataSourcesController.cs @@ -0,0 +1,113 @@ +using System; +using System.Threading.Tasks; +using Infrastructure; +using Microsoft.AspNetCore.Mvc; +using OpenAuth.App; +using OpenAuth.App.Request; +using OpenAuth.App.Response; +using OpenAuth.Repository.Domain; + +namespace OpenAuth.WebApi.Controllers +{ + /// + /// 外部数据源管理接口 + /// + [Route("api/[controller]/[action]")] + [ApiController] + [ApiExplorerSettings(GroupName = "外部数据源管理接口_ExternalDataSources")] + public class ExternalDataSourcesController : ControllerBase + { + private readonly ExtDataSourceApp _app; + + //获取详情 + [HttpGet] + public Response Get(string id) + { + var result = new Response(); + try + { + result.Result = _app.Get(id); + } + catch (Exception ex) + { + result.Code = 500; + result.Message = ex.InnerException?.Message ?? ex.Message; + } + + return result; + } + + //添加 + [HttpPost] + public Response Add([FromBody]AddOrUpdateExternalDataSourceReq obj) + { + var result = new Response(); + try + { + _app.Add(obj); + + } + catch (Exception ex) + { + result.Code = 500; + result.Message = ex.InnerException?.Message ?? ex.Message; + } + + return result; + } + + //修改 + [HttpPost] + public Response Update([FromBody]AddOrUpdateExternalDataSourceReq obj) + { + var result = new Response(); + try + { + _app.Update(obj); + + } + catch (Exception ex) + { + result.Code = 500; + result.Message = ex.InnerException?.Message ?? ex.Message; + } + + return result; + } + + /// + /// 加载列表 + /// + [HttpGet] + public async Task Load([FromQuery]QueryExternalDataSourceListReq request) + { + return await _app.Load(request); + } + + /// + /// 批量删除 + /// + [HttpPost] + public Response Delete([FromBody]string[] ids) + { + var result = new Response(); + try + { + _app.Delete(ids); + + } + catch (Exception ex) + { + result.Code = 500; + result.Message = ex.InnerException?.Message ?? ex.Message; + } + + return result; + } + + public ExternalDataSourcesController(ExtDataSourceApp app) + { + _app = app; + } + } +}