diff --git a/CodeSmith/CSharp/ApiGenerate.cst b/CodeSmith/CSharp/ApiGenerate.cst
new file mode 100644
index 0000000..cc7834e
--- /dev/null
+++ b/CodeSmith/CSharp/ApiGenerate.cst
@@ -0,0 +1,226 @@
+<%--
+Author: yubaolee
+Description: 用于生成OpenAuth.WebApi接口相关代码，包括controller/app/实体/dbcontext
+--%>
+<%@ Template Language="C#" TargetLanguage="Text" Debug="True" OutputType="Normal" %>
+
+<%@ Assembly Name="SchemaExplorer" %>
+<%@ Assembly Name="CodeSmith.CustomProperties" %>
+
+<%@ Assembly Name="Mono.Cecil" Path="..\Common" %>
+<%@ Assembly Name="ICSharpCode.NRefactory" Path="..\Common" %>
+<%@ Assembly Name="ICSharpCode.NRefactory.CSharp" Path="..\Common" %>
+
+<%@ Assembly Src="Internal\Model.cs" %>
+<%@ Assembly Src="Internal\Extensions.cs" %>
+<%@ Assembly Src="Internal\Generator.cs" %>
+<%@ Assembly Src="Internal\Parser.cs" %>
+
+<%@ Import Namespace="System.Collections.Generic" %>
+<%@ Import Namespace="System.IO" %>
+<%@ Import Namespace="System.Linq" %>
+<%@ Import Namespace="System.Text" %>
+<%@ Import Namespace="System.Text.RegularExpressions" %>
+<%@ Import Namespace="System.Diagnostics" %>
+
+<%@ Import Namespace="SchemaMapper" %>
+
+<%@ Property Name="WholeDb"
+Type="System.Boolean"
+Category="1.Database"
+Default="true"
+Description="是否直接生成选定数据库中的所有表" %>
+
+<%@ Property Name="HeaderModel"
+Type="System.Boolean"
+Category="1.Database"
+Default="true"
+Description="是否为启用头表模式，即类似‘入库订单’界面" %>
+
+<%@ Property Name="SourceDatabase"
+ Type="SchemaExplorer.DatabaseSchema"
+ Category="1.Database"
+ Description="The source database." %>
+
+<%@ Property Name="SourceTables"
+Type="SchemaExplorer.TableSchemaCollection"
+Category="1.Database" Description="可以选择一个或多个表（使用Ctrl键）" %>
+
+<%@ Property Name="directory"
+ Type="System.String"
+ Default=".\"
+ Optional="True"
+ Description="代码生成路径"
+ Editor="System.Windows.Forms.Design.FolderNameEditor, System.Design, Version=1.0.5000.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a" %>
+
+<%@ Property Name="ContextNamespace"
+ Type="System.String"
+ Category="2.Class"
+ Default="OpenAuth.Repository"
+ OnChanged="OnContextNamespaceChanged"
+ Description="DbContext默认命名空间，尽量不要更改"%>
+<%@ Property Name="EntityNamespace"
+ Type="System.String"
+ Default="OpenAuth.Repository.Domain"
+ Category="2.Class"
+ Description="实体默认命名空间，尽量不要更改"%>
+
+
+<%@ Register Name="EntityGeneratedClass"
+ Template="Internal\Entity.Generated.cst"
+ MergeProperties="False" %>
+
+<%@ Register Name="ContextGeneratedClass"
+ Template="Internal\Context.Generated.cst"
+ MergeProperties="True" %>
+
+<%@ Register Name="ApplicationGenerateClass"
+ Template="ApiGenerate\Application.cst"
+ MergeProperties="False" %>
+<%@ Register Name="RequestGenerateClass"
+ Template="ApiGenerate\Request.cst"
+ MergeProperties="False" %>
+<%@ Register Name="ModifyReqGenerateClass"
+ Template="ApiGenerate\ModifyReq.cst"
+ MergeProperties="False" %>
+<%@ Register Name="ControllerGenerateClass"
+ Template="ApiGenerate\Controller.cst"
+ MergeProperties="False" %>
+
+开始创建OpenAuth.Core WebApi相关代码 ...
+<% Generate(); %>
+
+
\ No newline at end of file
diff --git a/CodeSmith/CSharp/ApiGenerate/Application.cst b/CodeSmith/CSharp/ApiGenerate/Application.cst
new file mode 100644
index 0000000..9bcc9ed
--- /dev/null
+++ b/CodeSmith/CSharp/ApiGenerate/Application.cst
@@ -0,0 +1,157 @@
+<%--
+Name: Database Table Properties
+Author: yubaolee
+Description: Create a list of properties from a database table
+--%>
+<%@ CodeTemplate Language="C#" Encoding="utf-8" TargetLanguage="C#" Debug="True" Description="应用层" %>
+<%@ Map Name="CSharpAlias" Src="System-CSharpAlias" Description="System to C# Type Map" %>
+<%@ Assembly Name="SchemaExplorer" %>
+<%@ Import Namespace="SchemaExplorer" %>
+<%@ Property Name="Table"
+ Type="SchemaExplorer.TableSchema" %>
+<%@ Property Name="HeaderModel"
+Type="System.Boolean"
+Category="1.Database"
+Default="true"
+Description="是否为启用头表模式，即类似‘入库订单’界面" %>
+<%@ Assembly Src="../Web/Util.cs" %>
+<%@ Import Namespace="Util" %>
+using System;
+using System.Linq;
+using Infrastructure;
+using OpenAuth.App.Interface;
+using OpenAuth.App.Request;
+using OpenAuth.App.Response;
+using OpenAuth.Repository;
+using OpenAuth.Repository.Domain;
+using OpenAuth.Repository.Interface;
+namespace OpenAuth.App
+{
+ public class <%=Table.Name%>App : BaseStringApp<<%=Table.Name%>, OpenAuthDBContext>
+ {
+ private RevelanceManagerApp _revelanceApp;
+ ///
+ /// 加载列表
+ ///
+ public TableData Load(Query<%=Table.Name%>ListReq request)
+ {
+ var loginContext = _auth.GetCurrentUser();
+ if (loginContext == null)
+ {
+ throw new CommonException("登录已过期", Define.INVALID_TOKEN);
+ }
+ //如果是WebAPI,请务必改为loginContext.GetTableColumns("<%=Table.Name%>");
+ var columnFields = loginContext.GetTableColumnsFromDb("<%=Table.Name%>");
+ if (columnFields == null || columnFields.Count == 0)
+ {
+ throw new Exception("请在代码生成界面配置Category表的字段属性");
+ }
+ var result = new TableData();
+ var objs = UnitWork.Find<<%=Table.Name%>>(null);
+ if (!string.IsNullOrEmpty(request.key))
+ {
+ objs = objs.Where(u => u.Id.Contains(request.key));
+ }
+ var propertyStr = string.Join(',', columnFields.Select(u =>u.ColumnName));
+ result.columnFields = columnFields;
+ result.data = objs.OrderBy(u => u.Id)
+ .Skip((request.page - 1) * request.limit)
+ .Take(request.limit).Select($"new ({propertyStr})");
+ result.count = objs.Count();
+ return result;
+ }
+ <%
+ if(Table.Name.Contains("Tbl") && (!Table.Name.Contains("Dtbl")) && this.HeaderModel){
+ var dtblName = Table.Name.Replace("Tbl","Dtbl"); //明细表的表名
+ %>
+ public void Add(AddOrUpdate<%=Table.Name%>Req req)
+ {
+ var obj = req.MapTo<<%=Table.Name%>>();
+ //todo:根据自己的业务场景，补充或调整字段
+ obj.CreateTime = DateTime.Now;
+ var user = _auth.GetCurrentUser().User;
+ obj.CreateUserId = user.Id;
+ obj.CreateUserName = user.Name;
+ UnitWork.Add(obj);
+ if (req.<%=dtblName%>Reqs != null && req.<%=dtblName%>Reqs.Any())
+ {
+ foreach (var detail in req.<%=dtblName%>Reqs)
+ {
+ detail.ForeignKeyId = obj.Id; //todo:调整自己的明细表外键
+ _<%=dtblName%>App.AddNoSave(detail);
+ }
+ }
+ UnitWork.Save();
+ }
+ public void Update(AddOrUpdate<%=Table.Name%>Req obj)
+ {
+ var user = _auth.GetCurrentUser().User;
+ if (obj.<%=dtblName%>Reqs != null && obj.<%=dtblName%>Reqs.Any())
+ {
+ //id为空的添加
+ foreach (var detail in obj.<%=dtblName%>Reqs.Where(u =>string.IsNullOrEmpty(u.Id)))
+ {
+ detail.ForeignKeyId = obj.Id; //todo:调整自己的明细表外键
+ _<%=dtblName%>App.AddNoSave(detail);
+ }
+ //id比数据库少的，删除
+ var containids = obj.<%=dtblName%>Reqs.Select(u => u.Id)
+ .Where(u =>!string.IsNullOrEmpty(u)).ToList();
+ if (containids.Any())
+ {
+ UnitWork.Delete<<%=dtblName%>>(u =>(!containids.Contains(u.Id)) && u.ForeignKeyId == obj.Id); //todo:调整自己的明细表外键
+ }
+ //更新id相同的
+ foreach (var detail in obj.<%=dtblName%>Reqs.Where(u =>!string.IsNullOrEmpty(u.Id)))
+ {
+ _<%=dtblName%>App.Update(detail);
+ }
+ }
+ <%CreateUpdate();%>
+ UnitWork.Save();
+ }
+ <%
+ }else{ %>
+ public void Add(AddOrUpdate<%=Table.Name%>Req req)
+ {
+ var obj = req.MapTo<<%=Table.Name%>>();
+ //todo:根据自己的业务场景，补充或调整字段
+ //比如：obj.CreateTime = DateTime.Now;
+ // var user = _auth.GetCurrentUser().User;
+ // obj.CreateUserId = user.Id;
+ // obj.CreateUserName = user.Name;
+ Repository.Add(obj);
+ }
+ public void Update(AddOrUpdate<%=Table.Name%>Req obj)
+ {
+ <%CreateUpdate();%>
+ }
+ <%
+ }
+ %>
+ public <%=Table.Name%>App(IUnitWork unitWork, IRepository<<%=Table.Name%>, OpenAuthDBContext> repository,
+ RevelanceManagerApp app, IAuth auth) : base(unitWork, repository,auth)
+ {
+ _revelanceApp = app;
+ }
+ }
+}
+
\ No newline at end of file
diff --git a/CodeSmith/CSharp/ApiGenerate/Controller.cst b/CodeSmith/CSharp/ApiGenerate/Controller.cst
new file mode 100644
index 0000000..30119a0
--- /dev/null
+++ b/CodeSmith/CSharp/ApiGenerate/Controller.cst
@@ -0,0 +1,128 @@
+<%--
+Name: Database Table Properties
+Author: yubaolee
+Description: Create a list of properties from a database table
+--%>
+<%@ CodeTemplate Language="C#" Encoding="utf-8" TargetLanguage="C#" Debug="True" Description="控制器" %>
+<%@ Property Name="ModuleName" Type="String" Category="Context" Description="模块名称" %>
+<%@ Map Name="CSharpAlias" Src="System-CSharpAlias" Description="System to C# Type Map" %>
+<%@ Assembly Name="SchemaExplorer" %>
+<%@ Import Namespace="SchemaExplorer" %>
+
+using System;
+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
+{
+ ///
+ /// <%=ModuleName%>操作
+ ///
+ [Route("api/[controller]/[action]")]
+ [ApiController]
+ public class <%=ModuleName%>sController : ControllerBase
+ {
+ private readonly <%=ModuleName%>App _app;
+
+ ///
+ /// //获取详情
+ ///
+ [HttpGet]
+ public Response<<%=ModuleName%>> Get(string id)
+ {
+ var result = new Response<<%=ModuleName%>>();
+ 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(AddOrUpdate<%=ModuleName%>Req 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(AddOrUpdate<%=ModuleName%>Req 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 TableData Load([FromQuery]Query<%=ModuleName%>ListReq request)
+ {
+ return _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 <%=ModuleName%>sController(<%=ModuleName%>App app)
+ {
+ _app = app;
+ }
+ }
+}
diff --git a/CodeSmith/CSharp/ApiGenerate/ModifyReq.cst b/CodeSmith/CSharp/ApiGenerate/ModifyReq.cst
new file mode 100644
index 0000000..34bbb56
--- /dev/null
+++ b/CodeSmith/CSharp/ApiGenerate/ModifyReq.cst
@@ -0,0 +1,66 @@
+<%@ Template Language="C#" TargetLanguage="C#" Debug="True" Encoding="UTF-8" %>
+
+<%@ Assembly Src="../Internal/Model.cs" %>
+<%@ Assembly Src="../Internal/Extensions.cs" %>
+
+<%@ Import Namespace="System.Collections.Generic" %>
+<%@ Import Namespace="System.Linq" %>
+<%@ Import Namespace="System.Text" %>
+<%@ Import Namespace="System.Text.RegularExpressions" %>
+
+<%@ Import Namespace="SchemaMapper" %>
+
+<%@ Property Name="Table"
+ Type="SchemaExplorer.TableSchema" %>
+
+<%@ Property Name="HeaderModel"
+Type="System.Boolean"
+Category="1.Database"
+Default="true"
+Description="是否为启用头表模式，即类似‘入库订单’界面" %>
+
+<%@ Property Name="EntityNamespace"
+ Type="System.String" %>
+//------------------------------------------------------------------------------
+//
+// 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.Collections.Generic;
+using System.ComponentModel;
+using System.ComponentModel.DataAnnotations.Schema;
+using System.Text;
+using OpenAuth.Repository.Core;
+
+namespace OpenAuth.App.Request
+{
+ ///
+ /// <%= Table.Description %>
+ ///
+ [Table("<%= Table.Name%>")]
+ public partial class AddOrUpdate<%= Table.Name %>Req
+ {
+
+ <% foreach(ColumnSchema p in Table.Columns) {
+
+ %>
+ ///
+ /// <%=p.Description %>
+ ///
+ public <%= p.SystemType.ToNullableType(p.AllowDBNull == true) %> <%= p.Name%> { get; set; }
+ <% } %>
+
+ //todo:根据自己的业务场景添加需要的字段
+ <%
+ if(Table.Name.Contains("Tbl") && (!Table.Name.Contains("Dtbl")) && this.HeaderModel){
+ var dtblName = Table.Name.Replace("Tbl","Dtbl"); //明细表的表名
+ %>
+ public ListReq> <%=dtblName%>Reqs { get; set; }
+ <% } %>
+ }
+}
\ No newline at end of file
diff --git a/CodeSmith/CSharp/ApiGenerate/Request.cst b/CodeSmith/CSharp/ApiGenerate/Request.cst
new file mode 100644
index 0000000..6b9b70e
--- /dev/null
+++ b/CodeSmith/CSharp/ApiGenerate/Request.cst
@@ -0,0 +1,17 @@
+<%--
+Name: Database Table Properties
+Author: yubaolee
+Description: Create a list of properties from a database table
+--%>
+<%@ CodeTemplate Language="C#" Encoding="utf-8" TargetLanguage="C#" Debug="False" Description="应用层" %>
+<%@ Property Name="ModuleName" Type="String" Category="Context" Description="模块名称" %>
+<%@ Map Name="CSharpAlias" Src="System-CSharpAlias" Description="System to C# Type Map" %>
+<%@ Assembly Name="SchemaExplorer" %>
+<%@ Import Namespace="SchemaExplorer" %>
+namespace OpenAuth.App.Request
+{
+ public class Query<%=ModuleName%>ListReq : PageReq
+ {
+ //todo:根据自己的业务场景添加需要的字段
+ }
+}
\ No newline at end of file
diff --git a/CodeSmith/CSharp/Internal/Context.Generated.cst b/CodeSmith/CSharp/Internal/Context.Generated.cst
new file mode 100644
index 0000000..eddb09d
--- /dev/null
+++ b/CodeSmith/CSharp/Internal/Context.Generated.cst
@@ -0,0 +1,81 @@
+<%@ Template Language="C#" TargetLanguage="C#" Debug="True" Encoding="UTF-8" %>
+
+<%@ Assembly Src="../Internal/Model.cs" %>
+<%@ Assembly Src="../Internal/Extensions.cs" %>
+
+<%@ Import Namespace="System.Collections.Generic" %>
+<%@ Import Namespace="System.Linq" %>
+<%@ Import Namespace="System.Text" %>
+<%@ Import Namespace="System.Text.RegularExpressions" %>
+
+<%@ Import Namespace="SchemaMapper" %>
+
+<%@ Property Name="WholeDb"
+Type="System.Boolean"
+Category="1.Database"
+Default="true"
+Description="是否为整个数据库" %>
+
+<%@ Property Name="SourceDatabase"
+ Type="SchemaExplorer.DatabaseSchema"
+ Category="1.Database"
+ Description="The source database." %>
+
+<%@ Property Name="SourceTables"
+Type="SchemaExplorer.TableSchemaCollection"
+Category="1.Database" Description="选择部分表" %>
+
+<%@ Property Name="ContextNamespace" Type="System.String" %>
+<%@ Property Name="EntityNamespace" Type="System.String" %>
+
+
+using Microsoft.EntityFrameworkCore;
+using <%= EntityNamespace %>;
+
+namespace <%= ContextNamespace %>
+{
+ <%
+ string dbContextName;
+ if(WholeDb){
+ dbContextName = SourceDatabase.Name.ToSafeName();
+ }
+ else{
+ dbContextName = SourceTables.First().Database.Name.ToSafeName();
+ }
+ dbContextName = StringUtil.ToPascalCase(dbContextName);
+ Response.WriteLine(" public partial class "+ dbContextName +"Context: DbContext");
+
+ %>
+ {
+
+ protected override void OnModelCreating(ModelBuilder modelBuilder)
+ {
+ //当主键为联合主键时，需要把这里的内容拷贝到对应的位置
+ <%
+ TableSchemaCollection tables;
+ if(WholeDb){
+ tables = SourceDatabase.Tables;
+ }
+ else{
+ tables = SourceTables;
+ }
+
+ foreach(TableSchema table in tables)
+ {
+ if(table.PrimaryKeys.Count <=1) continue;
+ var keys = string.Join(",", table.Columns.Where(u=>u.IsPrimaryKeyMember==true)
+ .Select(u =>"c."+u.Name));
+ Response.WriteLine(" modelBuilder.Entity<"+table.Name+">()");
+ Response.WriteLine(" .HasKey(c => new { "+keys+" });");
+ }
+ %>
+ }
+
+ <%
+ foreach(TableSchema table in tables)
+ {
+ Response.WriteLine(" public virtual DbSet<"+table.Name+"> "+StringUtil.ToPascalCase(StringUtil.ToPlural(table.Name))+" { get; set; }");
+ }
+ %>
+ }
+}
\ No newline at end of file
diff --git a/CodeSmith/CSharp/Internal/Entity.Generated.cst b/CodeSmith/CSharp/Internal/Entity.Generated.cst
new file mode 100644
index 0000000..59ecd68
--- /dev/null
+++ b/CodeSmith/CSharp/Internal/Entity.Generated.cst
@@ -0,0 +1,75 @@
+<%@ Template Language="C#" TargetLanguage="C#" Debug="True" Encoding="UTF-8" %>
+
+<%@ Assembly Src="../Internal/Model.cs" %>
+<%@ Assembly Src="../Internal/Extensions.cs" %>
+
+<%@ Import Namespace="System.Collections.Generic" %>
+<%@ Import Namespace="System.Linq" %>
+<%@ Import Namespace="System.Text" %>
+<%@ Import Namespace="System.Text.RegularExpressions" %>
+
+<%@ Import Namespace="SchemaMapper" %>
+
+<%@ Property Name="Table"
+ Type="SchemaExplorer.TableSchema" %>
+
+<%@ Property Name="EntityNamespace"
+ Type="System.String" %>
+//------------------------------------------------------------------------------
+//
+// 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.Collections.Generic;
+using System.ComponentModel;
+using System.ComponentModel.DataAnnotations.Schema;
+using System.Text;
+using OpenAuth.Repository.Core;
+
+namespace <%= EntityNamespace %>
+{
+ ///
+ /// <%= Table.Description %>
+ ///
+ [Table("<%= Table.Name%>")]
+ public partial class <%= Table.Name %> : StringEntity
+ {
+ public <%= Table.Name %>()
+ {
+ <% foreach(ColumnSchema p in Table.Columns) {
+ if(p.IsPrimaryKeyMember) continue;
+ string type = p.SystemType.ToNullableType(p.AllowDBNull == true);
+ if(type =="int" || type=="decimal")
+ Response.WriteLine(" this."+p.Name+"= 0;");
+ else if(type =="string")
+ Response.WriteLine(" this."+p.Name+"= string.Empty;");
+ else if(type.ToLower().Contains("datetime"))
+ Response.WriteLine(" this."+p.Name+"= DateTime.Now;");
+ } // foreach %>
+ }
+
+
+ <%
+ foreach(ColumnSchema p in Table.Columns) {
+ if(p.IsPrimaryKeyMember) continue;
+ %>
+ ///
+ /// <%=p.Description %>
+ ///
+ [Description("<%=p.Description%>")]
+ <%if(p.Name.LastIndexOf("Id") != -1){%>
+ [Browsable(false)]
+ <%}%>
+ <%if(p.DataType == DbType.Byte){%>
+ public bool <%= p.Name%> { get; set; }
+ <%}else{%>
+ public <%= p.SystemType.ToNullableType(p.AllowDBNull == true) %> <%= p.Name%> { get; set; }
+ <%}%>
+ <% } // foreach %>
+ }
+}
\ No newline at end of file
diff --git a/CodeSmith/CSharp/Internal/Extensions.cs b/CodeSmith/CSharp/Internal/Extensions.cs
new file mode 100644
index 0000000..0e8dc28
--- /dev/null
+++ b/CodeSmith/CSharp/Internal/Extensions.cs
@@ -0,0 +1,187 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using CodeSmith.Engine;
+
+namespace SchemaMapper
+{
+ public enum CodeLanguage
+ {
+ CSharp,
+ VisualBasic
+ }
+
+ public static class Extensions
+ {
+ private static readonly HashSet _csharpKeywords;
+ private static readonly HashSet _visualBasicKeywords;
+ private static readonly Dictionary _csharpTypeAlias;
+
+ static Extensions()
+ {
+ _csharpKeywords = new HashSet(StringComparer.Ordinal)
+ {
+ "as", "do", "if", "in", "is",
+ "for", "int", "new", "out", "ref", "try",
+ "base", "bool", "byte", "case", "char", "else", "enum", "goto", "lock", "long", "null", "this", "true", "uint", "void",
+ "break", "catch", "class", "const", "event", "false", "fixed", "float", "sbyte", "short", "throw", "ulong", "using", "while",
+ "double", "extern", "object", "params", "public", "return", "sealed", "sizeof", "static", "string", "struct", "switch", "typeof", "unsafe", "ushort",
+ "checked", "decimal", "default", "finally", "foreach", "private", "virtual",
+ "abstract", "continue", "delegate", "explicit", "implicit", "internal", "operator", "override", "readonly", "volatile",
+ "__arglist", "__makeref", "__reftype", "interface", "namespace", "protected", "unchecked",
+ "__refvalue", "stackalloc"
+ };
+
+ _visualBasicKeywords = new HashSet(StringComparer.OrdinalIgnoreCase)
+ {
+ "as", "do", "if", "in", "is", "me", "of", "on", "or", "to",
+ "and", "dim", "end", "for", "get", "let", "lib", "mod", "new", "not", "rem", "set", "sub", "try", "xor",
+ "ansi", "auto", "byte", "call", "case", "cdbl", "cdec", "char", "cint", "clng", "cobj", "csng", "cstr", "date", "each", "else",
+ "enum", "exit", "goto", "like", "long", "loop", "next", "step", "stop", "then", "true", "wend", "when", "with",
+ "alias", "byref", "byval", "catch", "cbool", "cbyte", "cchar", "cdate", "class", "const", "ctype", "cuint", "culng", "endif", "erase", "error",
+ "event", "false", "gosub", "isnot", "redim", "sbyte", "short", "throw", "ulong", "until", "using", "while",
+ "csbyte", "cshort", "double", "elseif", "friend", "global", "module", "mybase", "object", "option", "orelse", "public", "resume", "return", "select", "shared",
+ "single", "static", "string", "typeof", "ushort",
+ "andalso", "boolean", "cushort", "decimal", "declare", "default", "finally", "gettype", "handles", "imports", "integer", "myclass", "nothing", "partial", "private", "shadows",
+ "trycast", "unicode", "variant",
+ "assembly", "continue", "delegate", "function", "inherits", "operator", "optional", "preserve", "property", "readonly", "synclock", "uinteger", "widening",
+ "addressof", "interface", "namespace", "narrowing", "overloads", "overrides", "protected", "structure", "writeonly",
+ "addhandler", "directcast", "implements", "paramarray", "raiseevent", "withevents",
+ "mustinherit", "overridable",
+ "mustoverride",
+ "removehandler",
+ "class_finalize", "notinheritable", "notoverridable",
+ "class_initialize"
+ };
+
+ _csharpTypeAlias = new Dictionary(16)
+ {
+ {"System.Int16", "short"},
+ {"System.Int32", "int"},
+ {"System.Int64", "long"},
+ {"System.String", "string"},
+ {"System.Object", "object"},
+ {"System.Boolean", "bool"},
+ {"System.Void", "void"},
+ {"System.Char", "char"},
+ {"System.Byte", "byte"},
+ {"System.UInt16", "ushort"},
+ {"System.UInt32", "uint"},
+ {"System.UInt64", "ulong"},
+ {"System.SByte", "sbyte"},
+ {"System.Single", "float"},
+ {"System.Double", "double"},
+ {"System.Decimal", "decimal"}
+ };
+ }
+
+ public static string ToCamelCase(this string name)
+ {
+ return StringUtil.ToCamelCase(name);
+ }
+
+ public static string ToPascalCase(this string name)
+ {
+ return StringUtil.ToPascalCase(name);
+ }
+
+
+ public static string ToFieldName(this string name)
+ {
+ return "_" + StringUtil.ToCamelCase(name);
+ }
+
+ public static string MakeUnique(this string name, Func exists)
+ {
+ string uniqueName = name;
+ int count = 1;
+
+ while (exists(uniqueName))
+ uniqueName = string.Concat(name, count++);
+
+ return uniqueName;
+ }
+
+ public static bool IsKeyword(this string text, CodeLanguage language = CodeLanguage.CSharp)
+ {
+ return language == CodeLanguage.VisualBasic
+ ? _visualBasicKeywords.Contains(text)
+ : _csharpKeywords.Contains(text);
+ }
+
+ public static string ToSafeName(this string name, CodeLanguage language = CodeLanguage.CSharp)
+ {
+ if (!name.IsKeyword(language))
+ return name;
+
+ return language == CodeLanguage.VisualBasic
+ ? string.Format("[{0}]", name)
+ : "@" + name;
+ }
+
+ public static string ToType(this Type type, CodeLanguage language = CodeLanguage.CSharp)
+ {
+ return ToType(type.FullName, language);
+ }
+
+ public static string ToType(this string type, CodeLanguage language = CodeLanguage.CSharp)
+ {
+ if (type == "System.Xml.XmlDocument")
+ type = "System.String";
+
+ string t;
+ if (language == CodeLanguage.CSharp && _csharpTypeAlias.TryGetValue(type, out t))
+ return t;
+
+
+ return type;
+ }
+
+ public static string ToNullableType(this Type type, bool isNullable = false, CodeLanguage language = CodeLanguage.CSharp)
+ {
+ return ToNullableType(type.FullName, isNullable, language);
+ }
+
+ public static string ToNullableType(this string type, bool isNullable = false, CodeLanguage language = CodeLanguage.CSharp)
+ {
+ bool isValueType = type.IsValueType();
+
+ type = type.ToType(language);
+
+ if (!isValueType || !isNullable)
+ return type;
+
+ return language == CodeLanguage.VisualBasic
+ ? string.Format("Nullable(Of {0})", type)
+ : type + "?";
+ }
+
+ public static bool IsValueType(this string type)
+ {
+ if (!type.StartsWith("System."))
+ return false;
+
+ var t = Type.GetType(type, false);
+ return t != null && t.IsValueType;
+ }
+
+ public static string ToDelimitedString(this IEnumerable values, string delimiter, string format = null)
+ {
+ var sb = new StringBuilder();
+ foreach (var i in values)
+ {
+ if (sb.Length > 0)
+ sb.Append(delimiter);
+
+ if (string.IsNullOrEmpty(format))
+ sb.Append(i);
+ else
+ sb.AppendFormat(format, i);
+ }
+
+ return sb.ToString();
+ }
+
+ }
+}
diff --git a/CodeSmith/CSharp/Internal/Generator.cs b/CodeSmith/CSharp/Internal/Generator.cs
new file mode 100644
index 0000000..751b669
--- /dev/null
+++ b/CodeSmith/CSharp/Internal/Generator.cs
@@ -0,0 +1,837 @@
+using System;
+using System.Collections;
+using System.Collections.Concurrent;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Linq;
+using System.Text.RegularExpressions;
+using CodeSmith.Engine;
+using SchemaExplorer;
+
+namespace SchemaMapper
+{
+ public enum TableNaming
+ {
+ Mixed = 0,
+ Plural = 1,
+ Singular = 2
+ }
+
+ public enum EntityNaming
+ {
+ Preserve = 0,
+ Plural = 1,
+ Singular = 2
+ }
+
+ public enum RelationshipNaming
+ {
+ None = 0,
+ Plural = 1,
+ ListSuffix = 2
+ }
+
+ public enum ContextNaming
+ {
+ Preserve = 0,
+ Plural = 1,
+ TableSuffix = 2
+ }
+
+ public class GeneratorSettings
+ {
+ public GeneratorSettings()
+ {
+ RelationshipNaming = RelationshipNaming.ListSuffix;
+ EntityNaming = EntityNaming.Singular;
+ TableNaming = TableNaming.Singular;
+ CleanExpressions = new List { @"^\d+" };
+ IgnoreExpressions = new List();
+ }
+
+ public TableNaming TableNaming { get; set; }
+
+ public EntityNaming EntityNaming { get; set; }
+
+ public RelationshipNaming RelationshipNaming { get; set; }
+
+ public ContextNaming ContextNaming { get; set; }
+
+ public List IgnoreExpressions { get; set; }
+
+ public List CleanExpressions { get; set; }
+
+ public bool InclusionMode { get; set; }
+
+ public bool IsIgnored(string name)
+ {
+ if (IgnoreExpressions.Count == 0)
+ return false;
+
+ bool isMatch = IgnoreExpressions.Any(regex => Regex.IsMatch(name, regex));
+
+ return InclusionMode ? !isMatch : isMatch;
+ }
+
+ public string CleanName(string name)
+ {
+ if (CleanExpressions.Count == 0)
+ return name;
+
+ foreach (var regex in CleanExpressions.Where(r => !string.IsNullOrEmpty(r)))
+ if (Regex.IsMatch(name, regex))
+ return Regex.Replace(name, regex, "");
+
+ return name;
+ }
+
+ public string RelationshipName(string name)
+ {
+ if (RelationshipNaming == RelationshipNaming.None)
+ return name;
+
+ if (RelationshipNaming == RelationshipNaming.ListSuffix)
+ return name + "List";
+
+ return StringUtil.ToPascalCase(StringUtil.ToPlural(name));
+ }
+
+ public string ContextName(string name)
+ {
+ if (ContextNaming == ContextNaming.Preserve)
+ return name;
+
+ if (ContextNaming == ContextNaming.TableSuffix)
+ return name + "Table";
+
+ return StringUtil.ToPascalCase(StringUtil.ToPlural(name));
+ }
+
+ public string EntityName(string name)
+ {
+ if (TableNaming != TableNaming.Plural && EntityNaming == EntityNaming.Plural)
+ name = StringUtil.ToPlural(name);
+ else if (TableNaming != TableNaming.Singular && EntityNaming == EntityNaming.Singular)
+ name = StringUtil.ToSingular(name);
+
+ return StringUtil.ToPascalCase(name);
+ }
+ }
+
+ public class SchemaItemProcessedEventArgs : EventArgs
+ {
+ public SchemaItemProcessedEventArgs(string name)
+ {
+ _name = name;
+ }
+
+ private readonly string _name;
+ public string Name
+ {
+ get { return _name; }
+ }
+ }
+
+ public class UniqueNamer
+ {
+ private readonly ConcurrentDictionary> _names;
+
+ public UniqueNamer()
+ {
+ _names = new ConcurrentDictionary>(StringComparer.OrdinalIgnoreCase);
+ Comparer = StringComparer.CurrentCulture;
+
+ // add existing
+ UniqueContextName("ChangeTracker");
+ UniqueContextName("Configuration");
+ UniqueContextName("Database");
+ UniqueContextName("InternalContext");
+ }
+
+ public IEqualityComparer Comparer { get; set; }
+
+ public string UniqueName(string bucketName, string name)
+ {
+ var hashSet = _names.GetOrAdd(bucketName, k => new HashSet(Comparer));
+ string result = name.MakeUnique(hashSet.Contains);
+ hashSet.Add(result);
+
+ return result;
+ }
+
+ public string UniqueClassName(string className)
+ {
+ const string globalClassName = "global::ClassName";
+ return UniqueName(globalClassName, className);
+ }
+
+ public string UniqueContextName(string name)
+ {
+ const string globalContextname = "global::ContextName";
+ return UniqueName(globalContextname, name);
+ }
+
+ public string UniqueRelationshipName(string name)
+ {
+ const string globalContextname = "global::RelationshipName";
+ return UniqueName(globalContextname, name);
+ }
+
+ }
+
+ public class Generator
+ {
+ private readonly UniqueNamer _namer;
+
+ public Generator()
+ {
+ _settings = new GeneratorSettings();
+ _namer = new UniqueNamer();
+ }
+
+ public event EventHandler SchemaItemProcessed;
+ protected void OnSchemaItemProcessed(string name)
+ {
+ var handler = SchemaItemProcessed;
+ if (handler == null)
+ return;
+
+ handler(this, new SchemaItemProcessedEventArgs(name));
+ }
+
+ private readonly GeneratorSettings _settings;
+ public GeneratorSettings Settings
+ {
+ get { return _settings; }
+ }
+
+ //按表信息创建DbContext
+ public EntityContext Generate(TableSchema tableSchema)
+ {
+ // only DeepLoad when in ignore mode
+ tableSchema.DeepLoad = !Settings.InclusionMode;
+
+ var entityContext = new EntityContext();
+ entityContext.DatabaseName = tableSchema.Database.Name;
+
+ string dataContextName = StringUtil.ToPascalCase(tableSchema.Database.Name) + "Context";
+ dataContextName = _namer.UniqueClassName(dataContextName);
+
+ entityContext.ClassName = dataContextName;
+
+ GetEntity(entityContext, tableSchema);
+
+
+ return entityContext;
+ }
+
+ //按数据库连接信息创建DbContext
+ public EntityContext Generate(DatabaseSchema databaseSchema)
+ {
+ // only DeepLoad when in ignore mode
+ databaseSchema.DeepLoad = !Settings.InclusionMode;
+
+ var entityContext = new EntityContext();
+ entityContext.DatabaseName = databaseSchema.Name;
+
+ string dataContextName = StringUtil.ToPascalCase(databaseSchema.Name) + "Context";
+ dataContextName = _namer.UniqueClassName(dataContextName);
+
+ entityContext.ClassName = dataContextName;
+
+ foreach (TableSchema t in databaseSchema.Tables)
+ {
+ if (Settings.IsIgnored(t.FullName))
+ {
+ Debug.WriteLine("Skipping Table: " + t.FullName);
+ }
+ else if (IsManyToMany(t))
+ {
+ CreateManyToMany(entityContext, t);
+ }
+ else
+ {
+ Debug.WriteLine("Getting Table Schema: " + t.FullName);
+ GetEntity(entityContext, t);
+ }
+
+ OnSchemaItemProcessed(t.FullName);
+ }
+
+ return entityContext;
+ }
+
+ //根据DbContext和tableSchema获取实体
+ public Entity GetEntity(EntityContext entityContext, TableSchema tableSchema, bool processRelationships = true, bool processMethods = true)
+ {
+ string key = tableSchema.FullName;
+
+ Entity entity = entityContext.Entities.ByTable(key)
+ ?? CreateEntity(entityContext, tableSchema);
+
+ if (!entity.Properties.IsProcessed)
+ CreateProperties(entity, tableSchema);
+
+ if (processRelationships && !entity.Relationships.IsProcessed)
+ CreateRelationships(entityContext, entity, tableSchema);
+
+ if (processMethods && !entity.Methods.IsProcessed)
+ CreateMethods(entity, tableSchema);
+
+ entity.IsProcessed = true;
+ return entity;
+ }
+
+ private Entity CreateEntity(EntityContext entityContext, TableSchema tableSchema)
+ {
+ var entity = new Entity
+ {
+ FullName = tableSchema.FullName,
+ TableName = tableSchema.Name,
+ TableSchema = tableSchema.Owner,
+ Description = tableSchema.Description
+ };
+
+ string className = ToClassName(tableSchema.Name);
+ className = _namer.UniqueClassName(className);
+
+ string mappingName = className + "Map";
+ mappingName = _namer.UniqueClassName(mappingName);
+
+ string contextName = Settings.ContextName(className);
+ contextName = ToPropertyName(entityContext.ClassName, contextName);
+ contextName = _namer.UniqueContextName(contextName);
+
+ entity.ClassName = className;
+ entity.ContextName = contextName;
+ entity.MappingName = mappingName;
+
+ entityContext.Entities.Add(entity);
+
+ return entity;
+ }
+
+ ///
+ /// 创建实体的属性
+ ///
+ private void CreateProperties(Entity entity, TableSchema tableSchema)
+ {
+ foreach (ColumnSchema columnSchema in tableSchema.Columns)
+ {
+ // skip unsupported type
+ if (columnSchema.NativeType.Equals("hierarchyid", StringComparison.OrdinalIgnoreCase)
+ || columnSchema.NativeType.Equals("sql_variant", StringComparison.OrdinalIgnoreCase))
+ {
+ Debug.WriteLine(string.Format("Skipping column '{0}' because it has an unsupported db type '{1}'.",
+ columnSchema.Name, columnSchema.NativeType));
+ continue;
+ }
+
+ Property property = entity.Properties.ByColumn(columnSchema.Name);
+
+ if (property == null)
+ {
+ property = new Property { ColumnName = columnSchema.Name };
+ entity.Properties.Add(property);
+ }
+
+ string propertyName = ToPropertyName(entity.ClassName, columnSchema.Name);
+ propertyName = _namer.UniqueName(entity.ClassName, propertyName);
+
+ property.PropertyName = propertyName;
+
+ property.DataType = columnSchema.DataType;
+ property.SystemType = columnSchema.SystemType;
+ property.NativeType = columnSchema.NativeType;
+ property.Description = columnSchema.Description;
+
+ property.IsPrimaryKey = columnSchema.IsPrimaryKeyMember;
+ property.IsForeignKey = columnSchema.IsForeignKeyMember;
+ property.IsNullable = columnSchema.AllowDBNull;
+
+ property.IsIdentity = IsIdentity(columnSchema);
+ property.IsRowVersion = IsRowVersion(columnSchema);
+ property.IsAutoGenerated = IsDbGenerated(columnSchema);
+
+ if (columnSchema.IsUnique)
+ property.IsUnique = columnSchema.IsUnique;
+
+ if (property.SystemType == typeof(string)
+ || property.SystemType == typeof(byte[]))
+ {
+ property.MaxLength = columnSchema.Size;
+ }
+
+ if (property.SystemType == typeof(float)
+ || property.SystemType == typeof(double)
+ || property.SystemType == typeof(decimal))
+ {
+ property.Precision = columnSchema.Precision;
+ property.Scale = columnSchema.Scale;
+ }
+
+ property.IsProcessed = true;
+ }
+
+ entity.Properties.IsProcessed = true;
+ }
+
+
+ private void CreateRelationships(EntityContext entityContext, Entity entity, TableSchema tableSchema)
+ {
+ foreach (TableKeySchema tableKey in tableSchema.ForeignKeys)
+ {
+ if (Settings.IsIgnored(tableKey.ForeignKeyTable.FullName)
+ || Settings.IsIgnored(tableKey.PrimaryKeyTable.FullName))
+ {
+ Debug.WriteLine("Skipping relationship '{0}' because table '{1}' or '{2}' is ignored.",
+ tableKey.FullName, tableKey.ForeignKeyTable.FullName, tableKey.PrimaryKeyTable.FullName);
+
+ continue;
+ }
+
+ CreateRelationship(entityContext, entity, tableKey);
+ }
+
+ entity.Relationships.IsProcessed = true;
+ }
+
+ private void CreateRelationship(EntityContext entityContext, Entity foreignEntity, TableKeySchema tableKeySchema)
+ {
+ Entity primaryEntity = GetEntity(entityContext, tableKeySchema.PrimaryKeyTable, false, false);
+
+ string primaryName = primaryEntity.ClassName;
+ string foreignName = foreignEntity.ClassName;
+
+ string relationshipName = tableKeySchema.Name;
+ relationshipName = _namer.UniqueRelationshipName(relationshipName);
+
+ bool isCascadeDelete = IsCascadeDelete(tableKeySchema);
+ bool foreignMembersRequired;
+ bool primaryMembersRequired;
+
+ var foreignMembers = GetKeyMembers(foreignEntity, tableKeySchema.ForeignKeyMemberColumns, tableKeySchema.Name, out foreignMembersRequired);
+ var primaryMembers = GetKeyMembers(primaryEntity, tableKeySchema.PrimaryKeyMemberColumns, tableKeySchema.Name, out primaryMembersRequired);
+
+ Relationship foreignRelationship = foreignEntity.Relationships
+ .FirstOrDefault(r => r.RelationshipName == relationshipName && r.IsForeignKey);
+
+ if (foreignRelationship == null)
+ {
+ foreignRelationship = new Relationship { RelationshipName = relationshipName };
+ foreignEntity.Relationships.Add(foreignRelationship);
+ }
+ foreignRelationship.IsMapped = true;
+ foreignRelationship.IsForeignKey = true;
+ foreignRelationship.ThisCardinality = foreignMembersRequired ? Cardinality.One : Cardinality.ZeroOrOne;
+ foreignRelationship.ThisEntity = foreignName;
+ foreignRelationship.ThisProperties = new List(foreignMembers);
+ foreignRelationship.OtherEntity = primaryName;
+ foreignRelationship.OtherProperties = new List(primaryMembers);
+ foreignRelationship.CascadeDelete = isCascadeDelete;
+
+ string prefix = GetMemberPrefix(foreignRelationship, primaryName, foreignName);
+
+ string foreignPropertyName = ToPropertyName(foreignEntity.ClassName, prefix + primaryName);
+ foreignPropertyName = _namer.UniqueName(foreignEntity.ClassName, foreignPropertyName);
+ foreignRelationship.ThisPropertyName = foreignPropertyName;
+
+ // add reverse
+ Relationship primaryRelationship = primaryEntity.Relationships
+ .FirstOrDefault(r => r.RelationshipName == relationshipName && r.IsForeignKey == false);
+
+ if (primaryRelationship == null)
+ {
+ primaryRelationship = new Relationship { RelationshipName = relationshipName };
+ primaryEntity.Relationships.Add(primaryRelationship);
+ }
+
+ primaryRelationship.IsMapped = false;
+ primaryRelationship.IsForeignKey = false;
+ primaryRelationship.ThisEntity = primaryName;
+ primaryRelationship.ThisProperties = new List(primaryMembers);
+ primaryRelationship.OtherEntity = foreignName;
+ primaryRelationship.OtherProperties = new List(foreignMembers);
+ primaryRelationship.CascadeDelete = isCascadeDelete;
+
+ bool isOneToOne = IsOneToOne(tableKeySchema, foreignRelationship);
+
+ if (isOneToOne)
+ primaryRelationship.ThisCardinality = primaryMembersRequired ? Cardinality.One : Cardinality.ZeroOrOne;
+ else
+ primaryRelationship.ThisCardinality = Cardinality.Many;
+
+ string primaryPropertyName = prefix + foreignName;
+ if (!isOneToOne)
+ primaryPropertyName = Settings.RelationshipName(primaryPropertyName);
+
+ primaryPropertyName = ToPropertyName(primaryEntity.ClassName, primaryPropertyName);
+ primaryPropertyName = _namer.UniqueName(primaryEntity.ClassName, primaryPropertyName);
+
+ primaryRelationship.ThisPropertyName = primaryPropertyName;
+
+ foreignRelationship.OtherPropertyName = primaryRelationship.ThisPropertyName;
+ foreignRelationship.OtherCardinality = primaryRelationship.ThisCardinality;
+
+ primaryRelationship.OtherPropertyName = foreignRelationship.ThisPropertyName;
+ primaryRelationship.OtherCardinality = foreignRelationship.ThisCardinality;
+
+ foreignRelationship.IsProcessed = true;
+ primaryRelationship.IsProcessed = true;
+ }
+
+ private void CreateManyToMany(EntityContext entityContext, TableSchema joinTable)
+ {
+ if (joinTable.ForeignKeys.Count != 2)
+ return;
+
+ var joinTableName = joinTable.Name;
+ var joinSchemaName = joinTable.Owner;
+
+ // first fkey is always left, second fkey is right
+ var leftForeignKey = joinTable.ForeignKeys[0];
+ var leftTable = leftForeignKey.PrimaryKeyTable;
+ var joinLeftColumn = leftForeignKey.ForeignKeyMemberColumns.Select(c => c.Name).ToList();
+ var leftEntity = GetEntity(entityContext, leftTable, false, false);
+
+ var rightForeignKey = joinTable.ForeignKeys[1];
+ var rightTable = rightForeignKey.PrimaryKeyTable;
+ var joinRightColumn = rightForeignKey.ForeignKeyMemberColumns.Select(c => c.Name).ToList();
+ var rightEntity = GetEntity(entityContext, rightTable, false, false);
+
+ string leftPropertyName = Settings.RelationshipName(rightEntity.ClassName);
+ leftPropertyName = _namer.UniqueName(leftEntity.ClassName, leftPropertyName);
+
+ string rightPropertyName = Settings.RelationshipName(leftEntity.ClassName);
+ rightPropertyName = _namer.UniqueName(rightEntity.ClassName, rightPropertyName);
+
+ string relationshipName = string.Format("{0}|{1}",
+ leftForeignKey.Name,
+ rightForeignKey.Name);
+
+ relationshipName = _namer.UniqueRelationshipName(relationshipName);
+
+ var left = new Relationship { RelationshipName = relationshipName };
+ left.IsForeignKey = false;
+ left.IsMapped = true;
+
+ left.ThisCardinality = Cardinality.Many;
+ left.ThisEntity = leftEntity.ClassName;
+ left.ThisPropertyName = leftPropertyName;
+
+ left.OtherCardinality = Cardinality.Many;
+ left.OtherEntity = rightEntity.ClassName;
+ left.OtherPropertyName = rightPropertyName;
+
+ left.JoinTable = joinTableName;
+ left.JoinSchema = joinSchemaName;
+ left.JoinThisColumn = new List(joinLeftColumn);
+ left.JoinOtherColumn = new List(joinRightColumn);
+
+ leftEntity.Relationships.Add(left);
+
+ var right = new Relationship { RelationshipName = relationshipName };
+ right.IsForeignKey = false;
+ right.IsMapped = false;
+
+ right.ThisCardinality = Cardinality.Many;
+ right.ThisEntity = rightEntity.ClassName;
+ right.ThisPropertyName = rightPropertyName;
+
+ right.OtherCardinality = Cardinality.Many;
+ right.OtherEntity = leftEntity.ClassName;
+ right.OtherPropertyName = leftPropertyName;
+
+ right.JoinTable = joinTableName;
+ right.JoinSchema = joinSchemaName;
+ right.JoinThisColumn = new List(joinRightColumn);
+ right.JoinOtherColumn = new List(joinLeftColumn);
+
+ rightEntity.Relationships.Add(right);
+ }
+
+
+ private void CreateMethods(Entity entity, TableSchema tableSchema)
+ {
+ if (tableSchema.HasPrimaryKey)
+ {
+ var method = GetMethodFromColumns(entity, tableSchema.PrimaryKey.MemberColumns);
+ if (method != null)
+ {
+ method.IsKey = true;
+ method.SourceName = tableSchema.PrimaryKey.FullName;
+
+ if (!entity.Methods.Any(m => m.NameSuffix == method.NameSuffix))
+ entity.Methods.Add(method);
+ }
+ }
+
+ GetIndexMethods(entity, tableSchema);
+ GetForeignKeyMethods(entity, tableSchema);
+
+ entity.Methods.IsProcessed = true;
+ }
+
+ private static void GetForeignKeyMethods(Entity entity, TableSchema table)
+ {
+ var columns = new List();
+
+ foreach (ColumnSchema column in table.ForeignKeyColumns)
+ {
+ columns.Add(column);
+
+ Method method = GetMethodFromColumns(entity, columns);
+ if (method != null && !entity.Methods.Any(m => m.NameSuffix == method.NameSuffix))
+ entity.Methods.Add(method);
+
+ columns.Clear();
+ }
+ }
+
+ private static void GetIndexMethods(Entity entity, TableSchema table)
+ {
+ foreach (IndexSchema index in table.Indexes)
+ {
+ Method method = GetMethodFromColumns(entity, index.MemberColumns);
+ if (method == null)
+ continue;
+
+ method.SourceName = index.FullName;
+ method.IsUnique = index.IsUnique;
+ method.IsIndex = true;
+
+ if (!entity.Methods.Any(m => m.NameSuffix == method.NameSuffix))
+ entity.Methods.Add(method);
+ }
+ }
+
+ private static Method GetMethodFromColumns(Entity entity, IEnumerable columns)
+ {
+ var method = new Method();
+ string methodName = string.Empty;
+
+ foreach (var column in columns)
+ {
+ var property = entity.Properties.ByColumn(column.Name);
+ if (property == null)
+ continue;
+
+ method.Properties.Add(property);
+ methodName += property.PropertyName;
+ }
+
+ if (method.Properties.Count == 0)
+ return null;
+
+ method.NameSuffix = methodName;
+ return method;
+ }
+
+
+ private static List GetKeyMembers(Entity entity, IEnumerable members, string name, out bool isRequired)
+ {
+ var keyMembers = new List();
+ isRequired = false;
+
+ foreach (var member in members)
+ {
+ var property = entity.Properties.ByColumn(member.Name);
+
+ if (property == null)
+ throw new InvalidOperationException(string.Format(
+ "Could not find column {0} for relationship {1}.",
+ member.Name,
+ name));
+
+ if (!isRequired)
+ isRequired = property.IsRequired;
+
+ keyMembers.Add(property.PropertyName);
+ }
+
+ return keyMembers;
+ }
+
+ private static string GetMemberPrefix(Relationship relationship, string primaryClass, string foreignClass)
+ {
+ string thisKey = relationship.ThisProperties.FirstOrDefault() ?? string.Empty;
+ string otherKey = relationship.OtherProperties.FirstOrDefault() ?? string.Empty;
+
+ bool isSameName = thisKey.Equals(otherKey, StringComparison.OrdinalIgnoreCase);
+ isSameName = (isSameName || thisKey.Equals(primaryClass + otherKey, StringComparison.OrdinalIgnoreCase));
+
+ string prefix = string.Empty;
+ if (isSameName)
+ return prefix;
+
+ prefix = thisKey.Replace(otherKey, "");
+ prefix = prefix.Replace(primaryClass, "");
+ prefix = prefix.Replace(foreignClass, "");
+ prefix = Regex.Replace(prefix, @"(_ID|_id|_Id|\.ID|\.id|\.Id|ID|Id)$", "");
+ prefix = Regex.Replace(prefix, @"^\d", "");
+
+ return prefix;
+ }
+
+ private static bool IsOneToOne(TableKeySchema tableKeySchema, Relationship foreignRelationship)
+ {
+ bool isFkeyPkey = tableKeySchema.ForeignKeyTable.HasPrimaryKey
+ && tableKeySchema.ForeignKeyTable.PrimaryKey != null
+ && tableKeySchema.ForeignKeyTable.PrimaryKey.MemberColumns.Count == 1
+ && tableKeySchema.ForeignKeyTable.PrimaryKey.MemberColumns.Contains(
+ foreignRelationship.ThisProperties.FirstOrDefault());
+
+ if (isFkeyPkey)
+ return true;
+
+ // if f.key is unique
+ return tableKeySchema.ForeignKeyMemberColumns.All(column => column.IsUnique);
+ }
+
+ private static bool IsManyToMany(TableSchema tableSchema)
+ {
+ // 1) Table must have Two ForeignKeys.
+ // 2) All columns must be either...
+ // a) Member of a Foreign Key.
+ // b) DbGenerated
+
+ if (tableSchema.Columns.Count < 2)
+ return false;
+
+ if (tableSchema.ForeignKeyColumns.Count != 2)
+ return false;
+
+ // all columns are fkeys
+ if (tableSchema.Columns.Count == 2 &&
+ tableSchema.ForeignKeyColumns.Count == 2)
+ return true;
+
+ // check all non fkey columns to make sure db gen'd
+ return tableSchema.NonForeignKeyColumns.All(c =>
+ IsDbGenerated(c) || HasDefaultValue(c));
+ }
+
+ #region Name Helpers
+ private string ToClassName(string name)
+ {
+ name = Settings.EntityName(name);
+ string legalName = ToLegalName(name);
+
+ return legalName;
+ }
+
+ private string ToPropertyName(string className, string name)
+ {
+ string propertyName = ToLegalName(name);
+ if (className.Equals(propertyName, StringComparison.OrdinalIgnoreCase))
+ propertyName += "Member";
+
+ return propertyName;
+ }
+
+ private string ToLegalName(string name)
+ {
+ string legalName = Settings.CleanName(name);
+ legalName = StringUtil.ToPascalCase(legalName);
+
+ return legalName;
+ }
+ #endregion
+
+ #region Column Flag Helpers
+ private static bool IsCascadeDelete(SchemaObjectBase column)
+ {
+ bool cascadeDelete = false;
+ string value;
+ try
+ {
+ if (column.ExtendedProperties.Contains(ExtendedPropertyNames.CascadeDelete))
+ {
+ value = column.ExtendedProperties[ExtendedPropertyNames.CascadeDelete].Value.ToString();
+ bool.TryParse(value, out cascadeDelete);
+ }
+ }
+ catch (Exception ex)
+ {
+ Debug.WriteLine("Error: " + ex.Message);
+ }
+
+ return cascadeDelete;
+ }
+
+ private static bool IsRowVersion(DataObjectBase column)
+ {
+ bool isTimeStamp = column.NativeType.Equals(
+ "timestamp", StringComparison.OrdinalIgnoreCase);
+ bool isRowVersion = column.NativeType.Equals(
+ "rowversion", StringComparison.OrdinalIgnoreCase);
+
+ return (isTimeStamp || isRowVersion);
+ }
+
+ private static bool IsDbGenerated(DataObjectBase column)
+ {
+ if (IsRowVersion(column))
+ return true;
+
+ if (IsIdentity(column))
+ return true;
+
+ bool isComputed = false;
+ string value;
+ try
+ {
+ if (column.ExtendedProperties.Contains(ExtendedPropertyNames.IsComputed))
+ {
+ value = column.ExtendedProperties[ExtendedPropertyNames.IsComputed].Value.ToString();
+ bool.TryParse(value, out isComputed);
+ }
+ }
+ catch (Exception ex)
+ {
+ Debug.WriteLine("Error: " + ex.Message);
+ }
+
+ return isComputed;
+ }
+
+ private static bool IsIdentity(DataObjectBase column)
+ {
+ string temp;
+ bool isIdentity = false;
+ try
+ {
+ if (column.ExtendedProperties.Contains(ExtendedPropertyNames.IsIdentity))
+ {
+ temp = column.ExtendedProperties[ExtendedPropertyNames.IsIdentity].Value.ToString();
+ bool.TryParse(temp, out isIdentity);
+ }
+ }
+ catch (Exception ex)
+ {
+ Debug.WriteLine("Error: " + ex.Message);
+ }
+
+ return isIdentity;
+ }
+
+ private static bool HasDefaultValue(DataObjectBase column)
+ {
+ try
+ {
+ if (!column.ExtendedProperties.Contains(ExtendedPropertyNames.DefaultValue))
+ return false;
+
+ string value = column.ExtendedProperties[ExtendedPropertyNames.DefaultValue].Value.ToString();
+ return !string.IsNullOrEmpty(value);
+ }
+ catch (Exception ex)
+ {
+ Debug.WriteLine("Error: " + ex.Message);
+ }
+
+ return false;
+ }
+ #endregion
+ }
+}
diff --git a/CodeSmith/CSharp/Internal/Model.cs b/CodeSmith/CSharp/Internal/Model.cs
new file mode 100644
index 0000000..b7b2a6f
--- /dev/null
+++ b/CodeSmith/CSharp/Internal/Model.cs
@@ -0,0 +1,370 @@
+using System;
+using System.Collections.Generic;
+using System.Collections.ObjectModel;
+using System.Data;
+using System.Diagnostics;
+using System.Linq;
+using System.Xml.Serialization;
+
+namespace SchemaMapper
+{
+ #region Base
+ public enum Cardinality
+ {
+ ZeroOrOne,
+ One,
+ Many
+ }
+
+ public class EntityBase
+ {
+ [XmlIgnore]
+ public bool IsProcessed { get; set; }
+ }
+ #endregion
+
+ #region Model
+ [DebuggerDisplay("Context: {ContextName}, Database: {DatabaseName}")]
+ public class EntityContext : EntityBase
+ {
+ public EntityContext()
+ {
+ Entities = new EntityCollection();
+ }
+
+ public string ClassName { get; set; }
+ public string DatabaseName { get; set; }
+
+ public EntityCollection Entities { get; set; }
+
+ public void RenameEntity(string originalName, string newName)
+ {
+ if (originalName == newName)
+ return;
+
+ Debug.WriteLine("Rename Entity '{0}' to '{1}'.", originalName, newName);
+ foreach (var entity in Entities)
+ {
+ if (entity.ClassName == originalName)
+ entity.ClassName = newName;
+
+ foreach (var relationship in entity.Relationships)
+ {
+ if (relationship.ThisEntity == originalName)
+ relationship.ThisEntity = newName;
+ if (relationship.OtherEntity == originalName)
+ relationship.OtherEntity = newName;
+ }
+ }
+ }
+
+ public void RenameProperty(string entityName, string originalName, string newName)
+ {
+ if (originalName == newName)
+ return;
+
+ Debug.WriteLine("Rename Property '{0}' to '{1}' in Entity '{2}'.", originalName, newName, entityName);
+ foreach (var entity in Entities)
+ {
+ if (entity.ClassName == entityName)
+ {
+ var property = entity.Properties.ByProperty(originalName);
+ if (property != null)
+ property.PropertyName = newName;
+ }
+
+ foreach (var relationship in entity.Relationships)
+ {
+ if (relationship.ThisEntity == entityName)
+ for (int i = 0; i < relationship.ThisProperties.Count; i++)
+ if (relationship.ThisProperties[i] == originalName)
+ relationship.ThisProperties[i] = newName;
+
+ if (relationship.OtherEntity == entityName)
+ for (int i = 0; i < relationship.OtherProperties.Count; i++)
+ if (relationship.OtherProperties[i] == originalName)
+ relationship.OtherProperties[i] = newName;
+ }
+ }
+
+ }
+ }
+
+ [DebuggerDisplay("Class: {ClassName}, Table: {FullName}, Context: {ContextName}")]
+ public class Entity : EntityBase
+ {
+ public Entity()
+ {
+ Properties = new PropertyCollection();
+ Relationships = new RelationshipCollection();
+ Methods = new MethodCollection();
+ }
+
+ public string ContextName { get; set; }
+ public string ClassName { get; set; }
+ public string MappingName { get; set; }
+ public string Description{ get;set;}
+
+ public string TableSchema { get; set; }
+ public string TableName { get; set; }
+ public string FullName { get; set; }
+
+ public PropertyCollection Properties { get; set; }
+ public RelationshipCollection Relationships { get; set; }
+ public MethodCollection Methods { get; set; }
+ }
+
+ [DebuggerDisplay("Property: {PropertyName}, Column: {ColumnName}, Type: {NativeType}")]
+ public class Property : EntityBase
+ {
+ public string PropertyName { get; set; }
+ public string ColumnName { get; set; }
+ public string Description { get; set; }
+
+ public DbType DataType { get; set; }
+ public string NativeType { get; set; }
+
+ [XmlIgnore]
+ public Type SystemType { get; set; }
+
+ public int? Order { get; set; }
+ public bool OrderSpecified
+ {
+ get { return Order.HasValue; }
+ }
+
+ public bool? IsNullable { get; set; }
+ public bool IsNullableSpecified
+ {
+ get { return IsNullable.HasValue; }
+ }
+
+ public bool IsRequired
+ {
+ get { return IsNullable == false; }
+ set { IsNullable = !value; }
+ }
+ public bool IsOptional
+ {
+ get { return IsNullable == true; }
+ set { IsNullable = value; }
+ }
+
+ public bool? IsPrimaryKey { get; set; }
+ public bool IsPrimaryKeySpecified
+ {
+ get { return IsPrimaryKey.HasValue; }
+ }
+ public bool? IsForeignKey { get; set; }
+ public bool IsForeignKeySpecified
+ {
+ get { return IsForeignKey.HasValue; }
+ }
+
+ public bool? IsAutoGenerated { get; set; }
+ public bool IsAutoGeneratedSpecified
+ {
+ get { return IsAutoGenerated.HasValue; }
+ }
+ public bool? IsReadOnly { get; set; }
+ public bool IsReadOnlySpecified
+ {
+ get { return IsReadOnly.HasValue; }
+ }
+ public bool? IsRowVersion { get; set; }
+ public bool IsRowVersionSpecified
+ {
+ get { return IsRowVersion.HasValue; }
+ }
+ public bool? IsIdentity { get; set; }
+ public bool IsIdentitySpecified
+ {
+ get { return IsIdentity.HasValue; }
+ }
+ public bool? IsUnique { get; set; }
+ public bool IsUniqueSpecified
+ {
+ get { return IsUnique.HasValue; }
+ }
+
+ public bool? IsUnicode { get; set; }
+ public bool IsUnicodeSpecified
+ {
+ get { return IsUnicode.HasValue; }
+ }
+ public bool? IsFixedLength { get; set; }
+ public bool IsFixedLengthSpecified
+ {
+ get { return IsFixedLength.HasValue; }
+ }
+
+ public int? MaxLength { get; set; }
+ public bool MaxLengthSpecified
+ {
+ get { return MaxLength.HasValue; }
+ }
+
+ public byte? Precision { get; set; }
+ public bool PrecisionSpecified
+ {
+ get { return Precision.HasValue; }
+ }
+ public int? Scale { get; set; }
+ public bool ScaleSpecified
+ {
+ get { return Scale.HasValue; }
+ }
+ }
+
+ [DebuggerDisplay("Other: {OtherEntity}, Property: {OtherPropertyName}, Relationship: {RelationshipName}")]
+ public class Relationship : EntityBase
+ {
+ public Relationship()
+ {
+ OtherProperties = new List();
+ ThisProperties = new List();
+ }
+
+ public string RelationshipName { get; set; }
+
+ public string ThisEntity { get; set; }
+ public string ThisPropertyName { get; set; }
+ public Cardinality ThisCardinality { get; set; }
+ public List ThisProperties { get; set; }
+
+ public string OtherEntity { get; set; }
+ public string OtherPropertyName { get; set; }
+ public Cardinality OtherCardinality { get; set; }
+ public List OtherProperties { get; set; }
+
+ public bool? CascadeDelete { get; set; }
+ public bool IsForeignKey { get; set; }
+ public bool IsMapped { get; set; }
+
+ public bool IsManyToMany
+ {
+ get
+ {
+ return ThisCardinality == Cardinality.Many
+ && OtherCardinality == Cardinality.Many;
+ }
+ }
+
+ public bool IsOneToOne
+ {
+ get
+ {
+ return ThisCardinality != Cardinality.Many
+ && OtherCardinality != Cardinality.Many;
+ }
+ }
+
+ public string JoinTable { get; set; }
+ public string JoinSchema { get; set; }
+ public List JoinThisColumn { get; set; }
+ public List JoinOtherColumn { get; set; }
+
+ }
+
+ [DebuggerDisplay("Suffix: {NameSuffix}, IsKey: {IsKey}, IsUnique: {IsUnique}")]
+ public class Method : EntityBase
+ {
+ public Method()
+ {
+ Properties = new List();
+ }
+
+ public string NameSuffix { get; set; }
+ public string SourceName { get; set; }
+
+ public bool IsKey { get; set; }
+ public bool IsUnique { get; set; }
+ public bool IsIndex { get; set; }
+
+ public List Properties { get; set; }
+ }
+ #endregion
+
+ #region Collections
+ public class EntityCollection
+ : ObservableCollection
+ {
+ public bool IsProcessed { get; set; }
+
+ public Entity ByTable(string fullName)
+ {
+ return this.FirstOrDefault(x => x.FullName == fullName);
+ }
+
+ public Entity ByTable(string tableName, string tableSchema)
+ {
+ return this.FirstOrDefault(x => x.TableName == tableName && x.TableSchema == tableSchema);
+ }
+
+ public Entity ByClass(string className)
+ {
+ return this.FirstOrDefault(x => x.ClassName == className);
+ }
+
+ public Entity ByContext(string contextName)
+ {
+ return this.FirstOrDefault(x => x.ContextName == contextName);
+ }
+ }
+
+ public class PropertyCollection
+ : ObservableCollection
+ {
+ public bool IsProcessed { get; set; }
+
+ public IEnumerable PrimaryKeys
+ {
+ get { return this.Where(p => p.IsPrimaryKey == true); }
+ }
+
+ public IEnumerable ForeignKeys
+ {
+ get { return this.Where(p => p.IsForeignKey == true); }
+ }
+
+ public Property ByColumn(string columnName)
+ {
+ return this.FirstOrDefault(x => x.ColumnName == columnName);
+ }
+
+ public Property ByProperty(string propertyName)
+ {
+ return this.FirstOrDefault(x => x.PropertyName == propertyName);
+ }
+ }
+
+ public class RelationshipCollection
+ : ObservableCollection
+ {
+ public bool IsProcessed { get; set; }
+
+ public Relationship ByName(string name)
+ {
+ return this.FirstOrDefault(x => x.RelationshipName == name);
+ }
+
+ public Relationship ByProperty(string propertyName)
+ {
+ return this.FirstOrDefault(x => x.ThisPropertyName == propertyName);
+ }
+
+ public Relationship ByOther(string name)
+ {
+ return this.FirstOrDefault(x => x.OtherEntity == name);
+ }
+ }
+
+ public class MethodCollection
+ : ObservableCollection
+ {
+ public bool IsProcessed { get; set; }
+ }
+
+ #endregion
+}
+
diff --git a/CodeSmith/CSharp/Internal/Parser.cs b/CodeSmith/CSharp/Internal/Parser.cs
new file mode 100644
index 0000000..95766be
--- /dev/null
+++ b/CodeSmith/CSharp/Internal/Parser.cs
@@ -0,0 +1,639 @@
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.IO;
+using System.Linq;
+using System.Text;
+using ICSharpCode.NRefactory.CSharp;
+
+namespace SchemaMapper
+{
+ #region Mapping Parser
+ [DebuggerDisplay("Table: {TableName}, Entity: {EntityClass}, Mapping: {MappingClass}")]
+ public class ParsedEntity
+ {
+ public ParsedEntity()
+ {
+ Properties = new List();
+ Relationships = new List();
+ }
+
+ public string EntityClass { get; set; }
+ public string MappingClass { get; set; }
+
+ public string TableName { get; set; }
+ public string TableSchema { get; set; }
+
+ public List Properties { get; private set; }
+ public List Relationships { get; private set; }
+ }
+
+ [DebuggerDisplay("Column: {ColumnName}, Property: {PropertyName}")]
+ public class ParsedProperty
+ {
+ public string ColumnName { get; set; }
+ public string PropertyName { get; set; }
+ }
+
+ [DebuggerDisplay("This: {ThisPropertyName}, Other: {OtherPropertyName}")]
+ public class ParsedRelationship
+ {
+ public ParsedRelationship()
+ {
+ ThisProperties = new List();
+ JoinThisColumn = new List();
+ JoinOtherColumn = new List();
+ }
+
+ public string ThisPropertyName { get; set; }
+ public List ThisProperties { get; private set; }
+
+ public string OtherPropertyName { get; set; }
+
+ public string JoinTable { get; set; }
+ public string JoinSchema { get; set; }
+ public List JoinThisColumn { get; private set; }
+ public List JoinOtherColumn { get; private set; }
+ }
+
+ public class MappingVisitor : DepthFirstAstVisitor
+ {
+ public MappingVisitor()
+ {
+ MappingBaseType = "EntityTypeConfiguration";
+ }
+
+ public string MappingBaseType { get; set; }
+ public ParsedEntity ParsedEntity { get; set; }
+
+ public override object VisitTypeDeclaration(TypeDeclaration typeDeclaration, object data)
+ {
+ var baseType = typeDeclaration.BaseTypes.OfType().FirstOrDefault();
+ if (baseType == null || baseType.MemberName != MappingBaseType)
+ return base.VisitTypeDeclaration(typeDeclaration, data);
+
+ var entity = baseType.TypeArguments.OfType().FirstOrDefault();
+ if (entity == null)
+ return base.VisitTypeDeclaration(typeDeclaration, data);
+
+ if (ParsedEntity == null)
+ ParsedEntity = new ParsedEntity();
+
+ ParsedEntity.EntityClass = entity.MemberName;
+ ParsedEntity.MappingClass = typeDeclaration.Name;
+
+ return base.VisitTypeDeclaration(typeDeclaration, ParsedEntity);
+ }
+
+ public override object VisitInvocationExpression(InvocationExpression invocationExpression, object data)
+ {
+ if (data == null)
+ return base.VisitInvocationExpression(invocationExpression, null);
+
+ // visit all the methods
+ var identifier = invocationExpression.Target.Children.OfType().FirstOrDefault();
+ string methodName = identifier == null ? string.Empty : identifier.Name;
+
+ // the different types of incoming data, helps us know what we're parsing
+ var parsedEntity = data as ParsedEntity;
+ var parsedProperty = data as ParsedProperty;
+ var parsedRelationship = data as ParsedRelationship;
+
+ switch (methodName)
+ {
+ case "ToTable":
+ var tableNameExpression = invocationExpression.Arguments
+ .OfType()
+ .ToArray();
+
+ string tableName = null;
+ string tableSchema = null;
+
+ if (tableNameExpression.Length >= 1)
+ tableName = tableNameExpression[0].Value.ToString();
+ if (tableNameExpression.Length >= 2)
+ tableSchema = tableNameExpression[1].Value.ToString();
+
+ // ToTable is either Entity -> Table map or Many to Many map
+ if (parsedEntity != null)
+ {
+ // when data is ParsedEntity, entity map
+ parsedEntity.TableName = tableName;
+ parsedEntity.TableSchema = tableSchema;
+ }
+ else if (parsedRelationship != null)
+ {
+ // when data is ParsedRelationship, many to many map
+ parsedRelationship.JoinTable = tableName;
+ parsedRelationship.JoinSchema = tableSchema;
+ }
+ break;
+ case "HasColumnName":
+ var columnNameExpression = invocationExpression.Arguments
+ .OfType()
+ .FirstOrDefault();
+
+ if (columnNameExpression == null)
+ break;
+
+ // property to column map start.
+ string columnName = columnNameExpression.Value.ToString();
+ var property = new ParsedProperty { ColumnName = columnName };
+ ParsedEntity.Properties.Add(property);
+
+ //only have column info at this point. pass data to get property name.
+ return base.VisitInvocationExpression(invocationExpression, property);
+ case "Property":
+ var propertyExpression = invocationExpression.Arguments
+ .OfType()
+ .FirstOrDefault();
+
+ if (parsedProperty == null || propertyExpression == null)
+ break;
+
+ // ParsedProperty is passed in as data from HasColumnName, add property name
+ var propertyBodyExpression = propertyExpression.Body as MemberReferenceExpression;
+ if (propertyBodyExpression != null)
+ parsedProperty.PropertyName = propertyBodyExpression.MemberName;
+
+ break;
+ case "Map":
+ // start a new Many to Many relationship
+ var mapRelation = new ParsedRelationship();
+ ParsedEntity.Relationships.Add(mapRelation);
+ // pass to child nodes to fill in data
+ return base.VisitInvocationExpression(invocationExpression, mapRelation);
+ case "HasForeignKey":
+ var foreignExpression = invocationExpression.Arguments
+ .OfType()
+ .FirstOrDefault();
+
+ if (foreignExpression == null)
+ break;
+
+ // when only 1 fkey, body will be member ref
+ if (foreignExpression.Body is MemberReferenceExpression)
+ {
+ var foreignBodyExpression = foreignExpression.Body as MemberReferenceExpression;
+ // start a new relationship
+ var foreignRelation = new ParsedRelationship();
+ ParsedEntity.Relationships.Add(foreignRelation);
+
+ foreignRelation.ThisProperties.Add(foreignBodyExpression.MemberName);
+ // pass as data for child nodes to fill in data
+ return base.VisitInvocationExpression(invocationExpression, foreignRelation);
+ }
+ // when more then 1 fkey, body will be an anonymous type
+ if (foreignExpression.Body is AnonymousTypeCreateExpression)
+ {
+ var foreignBodyExpression = foreignExpression.Body as AnonymousTypeCreateExpression;
+ var foreignRelation = new ParsedRelationship();
+ ParsedEntity.Relationships.Add(foreignRelation);
+
+ var properties = foreignBodyExpression.Children
+ .OfType()
+ .Select(m => m.MemberName);
+
+ foreignRelation.ThisProperties.AddRange(properties);
+
+ return base.VisitInvocationExpression(invocationExpression, foreignRelation);
+ }
+ break;
+ case "HasMany":
+ var hasManyExpression = invocationExpression.Arguments
+ .OfType()
+ .FirstOrDefault();
+
+ if (parsedRelationship == null || hasManyExpression == null)
+ break;
+
+ // filling existing relationship data
+ var hasManyBodyExpression = hasManyExpression.Body as MemberReferenceExpression;
+ if (hasManyBodyExpression != null)
+ parsedRelationship.ThisPropertyName = hasManyBodyExpression.MemberName;
+
+ break;
+ case "WithMany":
+ var withManyExpression = invocationExpression.Arguments
+ .OfType()
+ .FirstOrDefault();
+
+ if (parsedRelationship == null || withManyExpression == null)
+ break;
+
+ // filling existing relationship data
+ var withManyBodyExpression = withManyExpression.Body as MemberReferenceExpression;
+ if (withManyBodyExpression != null)
+ parsedRelationship.OtherPropertyName = withManyBodyExpression.MemberName;
+
+ break;
+ case "HasRequired":
+ case "HasOptional":
+ var hasExpression = invocationExpression.Arguments
+ .OfType()
+ .FirstOrDefault();
+
+ if (parsedRelationship == null || hasExpression == null)
+ break;
+
+ // filling existing relationship data
+ var hasBodyExpression = hasExpression.Body as MemberReferenceExpression;
+ if (hasBodyExpression != null)
+ parsedRelationship.ThisPropertyName = hasBodyExpression.MemberName;
+
+ break;
+ case "MapLeftKey":
+ if (parsedRelationship == null)
+ break;
+
+ var leftKeyExpression = invocationExpression.Arguments
+ .OfType()
+ .Select(e => e.Value.ToString());
+
+ parsedRelationship.JoinThisColumn.AddRange(leftKeyExpression);
+ break;
+ case "MapRightKey":
+ if (parsedRelationship == null)
+ break;
+
+ var rightKeyExpression = invocationExpression.Arguments
+ .OfType()
+ .Select(e => e.Value.ToString());
+
+ parsedRelationship.JoinOtherColumn.AddRange(rightKeyExpression);
+ break;
+ }
+
+ return base.VisitInvocationExpression(invocationExpression, data);
+ }
+ }
+
+ public static class MappingParser
+ {
+ public static ParsedEntity Parse(string mappingFile)
+ {
+ if (string.IsNullOrEmpty(mappingFile) || !File.Exists(mappingFile))
+ return null;
+
+ var parser = new CSharpParser();
+ CompilationUnit compilationUnit;
+
+ using (var stream = File.OpenText(mappingFile))
+ compilationUnit = parser.Parse(stream, mappingFile);
+
+ var visitor = new MappingVisitor();
+
+ visitor.VisitCompilationUnit(compilationUnit, null);
+ var parsedEntity = visitor.ParsedEntity;
+
+ if (parsedEntity != null)
+ Debug.WriteLine("Parsed Mapping File: '{0}'; Properties: {1}; Relationships: {2}",
+ Path.GetFileName(mappingFile),
+ parsedEntity.Properties.Count,
+ parsedEntity.Relationships.Count);
+
+ return parsedEntity;
+ }
+ }
+ #endregion
+
+ #region Context Parser
+ [DebuggerDisplay("Context: {ContextClass}")]
+ public class ParsedContext
+ {
+ public ParsedContext()
+ {
+ Properties = new List();
+ }
+
+ public string ContextClass { get; set; }
+
+ public List Properties { get; private set; }
+ }
+
+ [DebuggerDisplay("Entity: {EntityClass}, Property: {ContextProperty}")]
+ public class ParsedEntitySet
+ {
+ public string EntityClass { get; set; }
+ public string ContextProperty { get; set; }
+ }
+
+ public class ContextVisitor : DepthFirstAstVisitor
+ {
+ public ContextVisitor()
+ {
+ ContextBaseType = "DbContext";
+ DataSetType = "DbSet";
+ }
+
+ public string ContextBaseType { get; set; }
+ public string DataSetType { get; set; }
+
+ public ParsedContext ParsedContext { get; set; }
+
+ public override object VisitTypeDeclaration(TypeDeclaration typeDeclaration, object data)
+ {
+ var baseType = typeDeclaration.BaseTypes
+ .OfType()
+ .FirstOrDefault();
+
+ // warning: if inherited from custom base type, this will break
+ // anyway to improve this?
+ if (baseType == null || baseType.MemberName != ContextBaseType)
+ return base.VisitTypeDeclaration(typeDeclaration, data);
+
+ if (ParsedContext == null)
+ ParsedContext = new ParsedContext();
+
+ ParsedContext.ContextClass = typeDeclaration.Name;
+
+ return base.VisitTypeDeclaration(typeDeclaration, ParsedContext);
+ }
+
+ public override object VisitPropertyDeclaration(PropertyDeclaration propertyDeclaration, object data)
+ {
+ if (data == null)
+ return base.VisitPropertyDeclaration(propertyDeclaration, null);
+
+ // look for property to return generic DbSet type
+ var memberType = propertyDeclaration.ReturnType as MemberType;
+ if (memberType == null || memberType.MemberName != DataSetType)
+ return base.VisitPropertyDeclaration(propertyDeclaration, data);
+
+ // get the first generic type
+ var entityType = memberType.TypeArguments
+ .OfType()
+ .FirstOrDefault();
+
+ if (entityType == null)
+ return base.VisitPropertyDeclaration(propertyDeclaration, data);
+
+ var entitySet = new ParsedEntitySet
+ {
+ EntityClass = entityType.MemberName,
+ ContextProperty = propertyDeclaration.Name
+ };
+
+ ParsedContext.Properties.Add(entitySet);
+
+ return base.VisitPropertyDeclaration(propertyDeclaration, data);
+ }
+ }
+
+ public static class ContextParser
+ {
+ public static ParsedContext Parse(string contextFile)
+ {
+ if (string.IsNullOrEmpty(contextFile) || !File.Exists(contextFile))
+ return null;
+
+ var parser = new CSharpParser();
+ CompilationUnit compilationUnit;
+
+ using (var stream = File.OpenText(contextFile))
+ compilationUnit = parser.Parse(stream, contextFile);
+
+ var visitor = new ContextVisitor();
+
+ visitor.VisitCompilationUnit(compilationUnit, null);
+ var parsedContext = visitor.ParsedContext;
+
+ if (parsedContext != null)
+ Debug.WriteLine("Parsed Context File: '{0}'; Entities: {1}",
+ Path.GetFileName(contextFile),
+ parsedContext.Properties.Count);
+
+ return parsedContext;
+ }
+ }
+ #endregion
+
+ public static class Synchronizer
+ {
+ public static bool UpdateFromSource(EntityContext generatedContext, string contextDirectory, string mappingDirectory)
+ {
+ if (generatedContext == null)
+ return false;
+
+ // make sure to update the entities before the context
+ UpdateFromMapping(generatedContext, mappingDirectory);
+ UpdateFromContext(generatedContext, contextDirectory);
+ return true;
+ }
+
+ private static void UpdateFromContext(EntityContext generatedContext, string contextDirectory)
+ {
+ if (generatedContext == null
+ || contextDirectory == null
+ || !Directory.Exists(contextDirectory))
+ return;
+
+ // parse context
+ ParsedContext parsedContext = null;
+ var files = Directory.EnumerateFiles(contextDirectory, "*.Generated.cs").GetEnumerator();
+ while (files.MoveNext() && parsedContext == null)
+ parsedContext = ContextParser.Parse(files.Current);
+
+ if (parsedContext == null)
+ return;
+
+ if (generatedContext.ClassName != parsedContext.ContextClass)
+ {
+ Debug.WriteLine("Rename Context Class'{0}' to '{1}'.",
+ generatedContext.ClassName,
+ parsedContext.ContextClass);
+
+ generatedContext.ClassName = parsedContext.ContextClass;
+ }
+
+ foreach (var parsedProperty in parsedContext.Properties)
+ {
+ var entity = generatedContext.Entities.ByClass(parsedProperty.EntityClass);
+ if (entity == null)
+ continue;
+
+
+ if (entity.ContextName == parsedProperty.ContextProperty)
+ continue;
+
+ Debug.WriteLine("Rename Context Property'{0}' to '{1}'.",
+ entity.ContextName,
+ parsedProperty.ContextProperty);
+
+ entity.ContextName = parsedProperty.ContextProperty;
+ }
+ }
+
+ private static void UpdateFromMapping(EntityContext generatedContext, string mappingDirectory)
+ {
+ if (generatedContext == null
+ || mappingDirectory == null
+ || !Directory.Exists(mappingDirectory))
+ return;
+
+ // parse all mapping files
+ var mappingFiles = Directory.EnumerateFiles(mappingDirectory, "*.Generated.cs");
+ var parsedEntities = mappingFiles
+ .Select(MappingParser.Parse)
+ .Where(parsedEntity => parsedEntity != null)
+ .ToList();
+
+ var relationshipQueue = new List>();
+
+ // update all entity and property names first because relationships are linked by property names
+ foreach (var parsedEntity in parsedEntities)
+ {
+ // find entity by table name to support renaming entity
+ var entity = generatedContext.Entities
+ .ByTable(parsedEntity.TableName, parsedEntity.TableSchema);
+
+ if (entity == null)
+ continue;
+
+ // sync names
+ if (entity.MappingName != parsedEntity.MappingClass)
+ {
+ Debug.WriteLine("Rename Mapping Class'{0}' to '{1}'.",
+ entity.MappingName,
+ parsedEntity.MappingClass);
+
+ entity.MappingName = parsedEntity.MappingClass;
+ }
+
+ // use rename api to make sure all instances are renamed
+ generatedContext.RenameEntity(entity.ClassName, parsedEntity.EntityClass);
+
+ // sync properties
+ foreach (var parsedProperty in parsedEntity.Properties)
+ {
+ // find property by column name to support property name rename
+ var property = entity.Properties.ByColumn(parsedProperty.ColumnName);
+ if (property == null)
+ continue;
+
+ // use rename api to make sure all instances are renamed
+ generatedContext.RenameProperty(
+ entity.ClassName,
+ property.PropertyName,
+ parsedProperty.PropertyName);
+ }
+
+ // save relationship for later processing
+ var item = new Tuple(entity, parsedEntity);
+ relationshipQueue.Add(item);
+ }
+
+ // update relationships last
+ foreach (var tuple in relationshipQueue)
+ UpdateRelationships(generatedContext, tuple.Item1, tuple.Item2);
+ }
+
+ private static void UpdateRelationships(EntityContext generatedContext, Entity entity, ParsedEntity parsedEntity)
+ {
+ // sync relationships
+ foreach (var parsedRelationship in parsedEntity.Relationships.Where(r => r.JoinTable == null))
+ {
+ var parsedProperties = parsedRelationship.ThisProperties;
+ var relationship = entity.Relationships
+ .Where(r => !r.IsManyToMany)
+ .FirstOrDefault(r => r.ThisProperties.Except(parsedProperties).Count() == 0);
+
+ if (relationship == null)
+ continue;
+
+ bool isThisSame = relationship.ThisPropertyName == parsedRelationship.ThisPropertyName;
+ bool isOtherSame = relationship.OtherPropertyName == parsedRelationship.OtherPropertyName;
+
+ if (isThisSame && isOtherSame)
+ continue;
+
+ if (!isThisSame)
+ {
+ Debug.WriteLine("Rename Relationship Property '{0}.{1}' to '{0}.{2}'.",
+ relationship.ThisEntity,
+ relationship.ThisPropertyName,
+ parsedRelationship.ThisPropertyName);
+
+ relationship.ThisPropertyName = parsedRelationship.ThisPropertyName;
+ }
+ if (!isOtherSame)
+ {
+ Debug.WriteLine("Rename Relationship Property '{0}.{1}' to '{0}.{2}'.",
+ relationship.OtherEntity,
+ relationship.OtherPropertyName,
+ parsedRelationship.OtherPropertyName);
+
+ relationship.OtherPropertyName = parsedRelationship.OtherPropertyName;
+ }
+
+ // sync other relationship
+ var otherEntity = generatedContext.Entities.ByClass(relationship.OtherEntity);
+ if (otherEntity == null)
+ continue;
+
+ var otherRelationship = otherEntity.Relationships.ByName(relationship.RelationshipName);
+ if (otherRelationship == null)
+ continue;
+
+ otherRelationship.ThisPropertyName = relationship.OtherPropertyName;
+ otherRelationship.OtherPropertyName = relationship.ThisPropertyName;
+ }
+
+ // sync many to many
+ foreach (var parsedRelationship in parsedEntity.Relationships.Where(r => r.JoinTable != null))
+ {
+ var joinThisColumn = parsedRelationship.JoinThisColumn;
+ var joinOtherColumn = parsedRelationship.JoinOtherColumn;
+
+ var relationship = entity.Relationships
+ .Where(r => r.IsManyToMany)
+ .FirstOrDefault(r =>
+ r.JoinThisColumn.Except(joinThisColumn).Count() == 0 &&
+ r.JoinOtherColumn.Except(joinOtherColumn).Count() == 0 &&
+ r.JoinTable == parsedRelationship.JoinTable &&
+ r.JoinSchema == parsedRelationship.JoinSchema);
+
+ if (relationship == null)
+ continue;
+
+
+ bool isThisSame = relationship.ThisPropertyName == parsedRelationship.ThisPropertyName;
+ bool isOtherSame = relationship.OtherPropertyName == parsedRelationship.OtherPropertyName;
+
+ if (isThisSame && isOtherSame)
+ continue;
+
+ if (!isThisSame)
+ {
+ Debug.WriteLine("Rename Relationship Property '{0}.{1}' to '{0}.{2}'.",
+ relationship.ThisEntity,
+ relationship.ThisPropertyName,
+ parsedRelationship.ThisPropertyName);
+
+ relationship.ThisPropertyName = parsedRelationship.ThisPropertyName;
+ }
+ if (!isOtherSame)
+ {
+ Debug.WriteLine("Rename Relationship Property '{0}.{1}' to '{0}.{2}'.",
+ relationship.OtherEntity,
+ relationship.OtherPropertyName,
+ parsedRelationship.OtherPropertyName);
+
+ relationship.OtherPropertyName = parsedRelationship.OtherPropertyName;
+ }
+
+ // sync other relationship
+ var otherEntity = generatedContext.Entities.ByClass(relationship.OtherEntity);
+ if (otherEntity == null)
+ continue;
+
+ var otherRelationship = otherEntity.Relationships.ByName(relationship.RelationshipName);
+ if (otherRelationship == null)
+ continue;
+
+ otherRelationship.ThisPropertyName = relationship.OtherPropertyName;
+ otherRelationship.OtherPropertyName = relationship.ThisPropertyName;
+ }
+ }
+ }
+}
diff --git a/CodeSmith/CSharp/Web/Controller.cst b/CodeSmith/CSharp/Web/Controller.cst
new file mode 100644
index 0000000..9957a1c
--- /dev/null
+++ b/CodeSmith/CSharp/Web/Controller.cst
@@ -0,0 +1,105 @@
+<%--
+Name: Database Table Properties
+Author: yubaolee
+Description: Create a list of properties from a database table
+--%>
+<%@ CodeTemplate Language="C#" Encoding="utf-8" TargetLanguage="C#" Debug="False" Description="控制器" %>
+<%@ Property Name="ModuleName" Type="String" Category="Context" Description="模块名称" %>
+<%@ Map Name="CSharpAlias" Src="System-CSharpAlias" Description="System to C# Type Map" %>
+<%@ Assembly Name="SchemaExplorer" %>
+<%@ Import Namespace="SchemaExplorer" %>
+
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using Infrastructure;
+using Microsoft.AspNetCore.Mvc;
+using OpenAuth.App;
+using OpenAuth.App.Interface;
+using OpenAuth.App.Request;
+using OpenAuth.Repository.Domain;
+
+namespace OpenAuth.Mvc.Controllers
+{
+ public class <%=ModuleName%>sController : BaseController
+ {
+ private readonly <%=ModuleName%>App _app;
+
+ public <%=ModuleName%>sController(<%=ModuleName%>App app, IAuth auth) : base(auth)
+ {
+ _app = app;
+ }
+
+ //主页
+ public ActionResult Index()
+ {
+ return View();
+ }
+
+ ///
+ /// MVC界面添加
+ ///
+ ///
+ ///
+ [HttpPost]
+ public string Add(AddOrUpdate<%=ModuleName%>Req obj)
+ {
+ try
+ {
+ _app.Add(obj);
+
+ }
+ catch (Exception ex)
+ {
+ Result.Code = 500;
+ Result.Message = ex.Message;
+ }
+ return JsonHelper.Instance.Serialize(Result);
+ }
+
+ ///
+ /// MVC界面修改
+ ///
+ ///
+ ///
+ [HttpPost]
+ public string Update(AddOrUpdate<%=ModuleName%>Req obj)
+ {
+ try
+ {
+ _app.Update(obj);
+
+ }
+ catch (Exception ex)
+ {
+ Result.Code = 500;
+ Result.Message = ex.Message;
+ }
+ return JsonHelper.Instance.Serialize(Result);
+ }
+
+ ///
+ /// 加载列表
+ ///
+ public string Load([FromQuery]Query<%=ModuleName%>ListReq request)
+ {
+ return JsonHelper.Instance.Serialize(_app.Load(request));
+ }
+
+ [HttpPost]
+ public string Delete(string[] ids)
+ {
+ try
+ {
+ _app.Delete(ids);
+ }
+ catch (Exception e)
+ {
+ Result.Code = 500;
+ Result.Message = e.Message;
+ }
+
+ return JsonHelper.Instance.Serialize(Result);
+ }
+ }
+}
\ No newline at end of file
diff --git a/CodeSmith/CSharp/Web/Index.cshtml.cst b/CodeSmith/CSharp/Web/Index.cshtml.cst
new file mode 100644
index 0000000..7618888
--- /dev/null
+++ b/CodeSmith/CSharp/Web/Index.cshtml.cst
@@ -0,0 +1,98 @@
+<%--
+Name: 列表页面
+Author: yubaolee
+Description: 列表页面
+--%>
+<%@ CodeTemplate Language="C#" TargetLanguage="C#" Debug="False" Encoding="utf-8" Description="添加模块" %>
+<%@ Property Name="SourceTable" Type="SchemaExplorer.TableSchema" Category="Context"
+Description="连接的数据库" %>
+<%@ Property Name="ModuleName" Type="String" Category="Context" Description="模块名称" %>
+
+<%@ Map Name="CSharpAlias" Src="System-CSharpAlias" Description="System to C# Type Map" %>
+<%@ Assembly Name="SchemaExplorer" %>
+<%@ Import Namespace="SchemaExplorer" %>
+<%@ Assembly Src="Util.cs" %>
+<%@ Import Namespace="Util" %>
+
+@section header
+{
+
+}
+
+
+
+
+
+
+
+
+
+
+
diff --git a/CodeSmith/CSharp/Web/Util.cs b/CodeSmith/CSharp/Web/Util.cs
new file mode 100644
index 0000000..a6832e4
--- /dev/null
+++ b/CodeSmith/CSharp/Web/Util.cs
@@ -0,0 +1,39 @@
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.IO;
+using System.Linq;
+using System.Text;
+using CodeSmith.Engine;
+using SchemaExplorer;
+
+namespace Util{
+ public class Tools{
+ public static String GetDescription(ColumnSchema column) { //得到字段的描述
+ if(string.IsNullOrEmpty(column.Description))
+ return column.Name;
+ else
+ return column.Description;
+ }
+
+ public static bool NeedCascade(TableSchema SourceTable){ //判断表中是否需要下拉选择树
+ return SourceTable.Columns.Contains("ParentId")
+ || SourceTable.Columns.Contains("CascadeId") ;
+ }
+
+
+ public static string CreateBlank(int level){
+ if(level == 1){
+ return " ";
+ }
+ else{
+ var twoblanks = " ";
+ for (int i = level-1; i > 1; i--)
+ {
+ twoblanks +=twoblanks;
+ }
+ return CreateBlank(1) + twoblanks;
+ }
+ }
+ }
+}
\ No newline at end of file
diff --git a/CodeSmith/CSharp/Web/index.js.cst b/CodeSmith/CSharp/Web/index.js.cst
new file mode 100644
index 0000000..f76bdda
--- /dev/null
+++ b/CodeSmith/CSharp/Web/index.js.cst
@@ -0,0 +1,186 @@
+<%--
+Name: 主JS界面
+Author: yubaolee
+--%>
+<%@ CodeTemplate Language="C#" TargetLanguage="C#" Debug="False" Encoding="utf-8" Description="添加模块" %>
+<%@ Property Name="ModuleName" Type="String" Category="Context" Description="模块名称" %>
+
+<%@ Map Name="CSharpAlias" Src="System-CSharpAlias" Description="System to C# Type Map" %>
+<%@ Assembly Name="SchemaExplorer" %>
+<%@ Import Namespace="SchemaExplorer" %>
+<%@ Assembly Src="Util.cs" %>
+<%@ Import Namespace="Util" %>
+
+layui.config({
+ base: "/js/"
+}).use(['form', 'vue', 'ztree', 'layer', 'jquery', 'table', 'droptree', 'openauth', 'utils'], function () {
+ var form = layui.form,
+ layer = layui.layer,
+ $ = layui.jquery;
+ var table = layui.table;
+ var openauth = layui.openauth;
+ var toplayer = (top == undefined || top.layer === undefined) ? layer : top.layer; //顶层的LAYER
+
+ $("#menus").loadMenus("<%=ModuleName%>");
+
+
+ //加载表头
+ $.getJSON('/<%=ModuleName%>s/Load',
+ { page: 1, limit: 1 },
+ function (data) {
+ var columns = data.columnFields.filter(u => u.IsList ===true).map(function (e) {
+ return {
+ field: e.ColumnName,
+ title: e.Comment
+ };
+ });
+ columns.unshift({
+ type: 'checkbox',
+ fixed: 'left'
+ });
+ table.render({
+ elem: '#mainList',
+ page: true,
+ url: '/<%=ModuleName%>s/Load',
+ cols: [columns]
+ , response: {
+ statusCode: 200 //规定成功的状态码，默认：0
+ }
+ });
+ });
+
+
+ //主列表加载，可反复调用进行刷新
+ var config = {}; //table的参数，如搜索key，点击tree的id
+ var mainList = function(options) {
+ if (options != undefined) {
+ $.extend(config, options);
+ }
+ table.reload('mainList',
+ {
+ url: '/<%=ModuleName%>s/Load',
+ where: config
+ , response: {
+ statusCode: 200 //规定成功的状态码，默认：0
+ }
+ });
+ };
+ mainList();
+
+ //添加（编辑）对话框
+ var editDlg = function () {
+ var vm;
+ var update = false; //是否为更新
+ var show = function (data) {
+ var title = update ? "编辑信息" : "添加";
+ layer.open({
+ title: title,
+ area: ["500px", "400px"],
+ type: 1,
+ content: $('#divEdit'),
+ success: function () {
+ if(vm == undefined){
+ vm = new Vue({
+ el: "#formEdit",
+ data(){
+ return {
+ tmp:data //使用一个tmp封装一下，后面可以直接用vm.tmp赋值
+ }
+ },
+ watch:{
+ tmp(val){
+ this.$nextTick(function () {
+ form.render(); //刷新select等
+ layui.droptree("/Applications/GetList", "#AppName", "#AppId", false);
+
+ })
+ }
+ },
+ mounted(){
+ form.render();
+ layui.droptree("/Applications/GetList", "#AppName", "#AppId", false);
+
+ }
+ });
+ }else{
+ vm.tmp = Object.assign({}, vm.tmp,data)
+ }
+ },
+ end: mainList
+ });
+ var url = "/<%=ModuleName%>s/Add";
+ if (update) {
+ url = "/<%=ModuleName%>s/Update";
+ }
+ //提交数据
+ form.on('submit(formSubmit)',
+ function (data) {
+ $.post(url,
+ data.field,
+ function (data) {
+ layer.msg(data.Message);
+ },
+ "json");
+ return false;
+ });
+ }
+ return {
+ add: function () { //弹出添加
+ update = false;
+ show({
+ Id: ''
+ });
+ },
+ update: function (data) { //弹出编辑框
+ update = true;
+ show(data);
+ }
+ };
+ }();
+
+ //监听表格内部按钮
+ table.on('tool(list)', function (obj) {
+ var data = obj.data;
+ if (obj.event === 'detail') { //查看
+ layer.msg('ID：' + data.Id + ' 的查看操作');
+ }
+ });
+
+
+ //监听页面主按钮操作
+ var active = {
+ btnDel: function () { //批量删除
+ var checkStatus = table.checkStatus('mainList')
+ , data = checkStatus.data;
+ openauth.del("/<%=ModuleName%>s/Delete",
+ data.map(function (e) { return e.Id; }),
+ mainList);
+ }
+ , btnAdd: function () { //添加
+ editDlg.add();
+ }
+ , btnEdit: function () { //编辑
+ var checkStatus = table.checkStatus('mainList')
+ , data = checkStatus.data;
+ if (data.length != 1) {
+ layer.msg("请选择编辑的行，且同时只能编辑一行");
+ return;
+ }
+ editDlg.update(data[0]);
+ }
+
+ , search: function () { //搜索
+ mainList({ key: $('#key').val() });
+ }
+ , btnRefresh: function () {
+ mainList();
+ }
+ };
+
+ $('.toolList .layui-btn').on('click', function () {
+ var type = $(this).data('type');
+ active[type] ? active[type].call(this) : '';
+ });
+
+ //监听页面主按钮操作 end
+})
diff --git a/CodeSmith/CSharp/WebGenerate.cst b/CodeSmith/CSharp/WebGenerate.cst
new file mode 100644
index 0000000..c050980
--- /dev/null
+++ b/CodeSmith/CSharp/WebGenerate.cst
@@ -0,0 +1,130 @@
+<%--
+Author: yubaolee
+Description: 用于生成OpenAuth.Core开源版前端Web界面，包括mvc controller/csthml/js
+--%>
+<%@ Template Language="C#" TargetLanguage="Text" Debug="True" OutputType="None" %>
+
+<%@ Assembly Name="SchemaExplorer" %>
+<%@ Assembly Name="CodeSmith.CustomProperties" %>
+
+<%@ Assembly Name="Mono.Cecil" Path="..\Common" %>
+<%@ Assembly Name="ICSharpCode.NRefactory" Path="..\Common" %>
+<%@ Assembly Name="ICSharpCode.NRefactory.CSharp" Path="..\Common" %>
+
+<%@ Assembly Src="Internal\Model.cs" %>
+<%@ Assembly Src="Internal\Extensions.cs" %>
+<%@ Assembly Src="Internal\Generator.cs" %>
+<%@ Assembly Src="Internal\Parser.cs" %>
+
+<%@ Import Namespace="System.Collections.Generic" %>
+<%@ Import Namespace="System.IO" %>
+<%@ Import Namespace="System.Linq" %>
+<%@ Import Namespace="System.Text" %>
+<%@ Import Namespace="System.Text.RegularExpressions" %>
+
+<%@ Import Namespace="SchemaMapper" %>
+
+<%@ Property Name="SourceTable"
+Type="SchemaExplorer.TableSchema"
+Category="Context"
+Description="连接的数据库"
+OnChanged="OnSourceDatabaseChanged"%>
+
+<%@ Property Name="ModuleName"
+ Type="System.String"
+ Description="模块名称，如：User"%>
+<%@ Property Name="directory"
+ Type="System.String"
+ Default=".\"
+ Optional="True"
+ Description="代码生成路径"
+ Editor="System.Windows.Forms.Design.FolderNameEditor, System.Design, Version=1.0.5000.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a" %>
+
+<%@ Register Name="HtmlGenerateClass"
+ Template="Web\Index.cshtml.cst"
+ MergeProperties="False" %>
+<%@ Register Name="JSGenerateClass"
+ Template="Web\index.js.cst"
+ MergeProperties="False" %>
+<%@ Register Name="ControllerGenerateClass"
+ Template="Web\Controller.cst"
+ MergeProperties="False" %>
+Generating Entities ...
+<% Generate(); %>
+
+
\ No newline at end of file
diff --git a/CodeSmith/Common/ICSharpCode.NRefactory.CSharp.dll b/CodeSmith/Common/ICSharpCode.NRefactory.CSharp.dll
new file mode 100644
index 0000000..978ef71
Binary files /dev/null and b/CodeSmith/Common/ICSharpCode.NRefactory.CSharp.dll differ
diff --git a/CodeSmith/Common/ICSharpCode.NRefactory.dll b/CodeSmith/Common/ICSharpCode.NRefactory.dll
new file mode 100644
index 0000000..7a156bc
Binary files /dev/null and b/CodeSmith/Common/ICSharpCode.NRefactory.dll differ
diff --git a/CodeSmith/Common/Mono.Cecil.dll b/CodeSmith/Common/Mono.Cecil.dll
new file mode 100644
index 0000000..d22da17
Binary files /dev/null and b/CodeSmith/Common/Mono.Cecil.dll differ
diff --git a/Dockerfile b/Dockerfile
new file mode 100644
index 0000000..b7a9eed
--- /dev/null
+++ b/Dockerfile
@@ -0,0 +1,36 @@
+##See https://aka.ms/customizecontainer to learn how to customize your debug container and how Visual Studio uses this Dockerfile to build your images for faster debugging.
+#FROM mcr.microsoft.com/dotnet/aspnet:6.0 AS base
+#WORKDIR /app
+#EXPOSE 10010
+#
+#COPY . .
+#ENV ASPNETCORE_URLS=http://+:10010
+#ENTRYPOINT ["dotnet", "/app/OpenAuth.WebApi.dll"]
+
+
+#See https://aka.ms/customizecontainer to learn how to customize your debug container and how Visual Studio uses this Dockerfile to build your images for faster debugging.
+
+FROM mcr.microsoft.com/dotnet/aspnet:6.0 AS base
+WORKDIR /app
+EXPOSE 10010
+
+FROM mcr.microsoft.com/dotnet/sdk:6.0 AS build
+WORKDIR /src
+COPY ["OpenAuth.WebApi/OpenAuth.WebApi.csproj", "OpenAuth.WebApi/"]
+COPY ["Infrastructure/Infrastructure.csproj", "Infrastructure/"]
+COPY ["OpenAuth.App/OpenAuth.App.csproj", "OpenAuth.App/"]
+COPY ["OpenAuth.Repository/OpenAuth.Repository.csproj", "OpenAuth.Repository/"]
+RUN dotnet restore "OpenAuth.WebApi/OpenAuth.WebApi.csproj"
+COPY . .
+WORKDIR "/src/OpenAuth.WebApi"
+RUN dotnet build "OpenAuth.WebApi.csproj" -c Release -o /app/build
+
+FROM build AS publish
+RUN dotnet publish "OpenAuth.WebApi.csproj" -c Release -o /app/publish /p:UseAppHost=false
+
+FROM base AS final
+WORKDIR /app
+COPY --from=publish /app/publish .
+ENV ASPNETCORE_URLS=http://+:10010
+ENTRYPOINT ["dotnet", "OpenAuth.WebApi.dll"]
+
diff --git a/Infrastructure/AppSetting.cs b/Infrastructure/AppSetting.cs
new file mode 100644
index 0000000..861f385
--- /dev/null
+++ b/Infrastructure/AppSetting.cs
@@ -0,0 +1,55 @@
+using System.Collections.Generic;
+
+namespace Infrastructure
+{
+ ///
+ /// 配置项
+ ///
+ public class AppSetting
+ {
+
+ public AppSetting()
+ {
+ SSOPassport = "http://localhost:52789";
+ Version = "";
+ UploadPath = "";
+ IdentityServerUrl = "";
+ }
+ ///
+ /// SSO地址
+ ///
+ public string SSOPassport { get; set; }
+
+ ///
+ /// 版本信息
+ /// 如果为demo,则屏蔽Post请求
+ ///
+ public string Version { get; set; }
+
+ ///
+ /// 数据库类型 SqlServer、MySql
+ ///
+ public Dictionary DbTypes { get; set; }
+
+ /// 附件上传路径
+ public string UploadPath { get; set; }
+
+ //identity授权的地址
+ public string IdentityServerUrl { get; set; }
+
+ ///
+ /// Redis服务器配置
+ ///
+ //public string RedisConf { get; set; }
+ public RedisConf RedisConf { get; set; }
+
+ //是否是Identity授权方式
+ public bool IsIdentityAuth => !string.IsNullOrEmpty(IdentityServerUrl);
+ }
+
+ public class RedisConf
+ {
+ public string Conn { get; set; }
+ public int Database { get; set; }
+ }
+}
diff --git a/Infrastructure/AutoMapperExt.cs b/Infrastructure/AutoMapperExt.cs
new file mode 100644
index 0000000..7dc7c53
--- /dev/null
+++ b/Infrastructure/AutoMapperExt.cs
@@ -0,0 +1,74 @@
+// ***********************************************************************
+// Assembly : FairUtility
+// Author : Yubao Li
+// Created : 08-27-2015
+//
+// Last Modified By : Yubao Li
+// Last Modified On : 08-27-2015
+// ***********************************************************************
+//
+// Copyright (c) . All rights reserved.
+//
+//
+// ***********************************************************************
+
+using System;
+using AutoMapper;
+using System.Collections;
+using System.Collections.Generic;
+
+namespace Infrastructure
+{
+ public static class AutoMapperExt
+ {
+ ///
+ /// 类型映射
+ ///
+ public static T MapTo(this object obj)
+ {
+ if (obj == null) return default(T);
+
+ var config = new MapperConfiguration(cfg=>cfg.CreateMap(obj.GetType(),typeof(T)));
+ var mapper = config.CreateMapper();
+ return mapper.Map(obj);
+ }
+
+ ///
+ /// 集合列表类型映射
+ ///
+ public static List MapToList(this IEnumerable source)
+ {
+ Type sourceType = source.GetType().GetGenericArguments()[0]; //获取枚举的成员类型
+ var config = new MapperConfiguration(cfg => cfg.CreateMap(sourceType, typeof(TDestination)));
+ var mapper = config.CreateMapper();
+
+ return mapper.Map>(source);
+ }
+
+ ///
+ /// 集合列表类型映射
+ ///
+ public static List MapToList(this IEnumerable source)
+ {
+ var config = new MapperConfiguration(cfg => cfg.CreateMap(typeof(TSource), typeof(TDestination)));
+ var mapper = config.CreateMapper();
+
+ return mapper.Map>(source);
+ }
+
+ ///
+ /// 类型映射
+ ///
+ public static TDestination MapTo(this TSource source, TDestination destination)
+ where TSource : class
+ where TDestination : class
+ {
+ if (source == null) return destination;
+
+ var config = new MapperConfiguration(cfg => cfg.CreateMap(typeof(TSource), typeof(TDestination)));
+ var mapper = config.CreateMapper();
+ return mapper.Map(source);
+ }
+
+ }
+}
\ No newline at end of file
diff --git a/Infrastructure/Cache/CacheContext.cs b/Infrastructure/Cache/CacheContext.cs
new file mode 100644
index 0000000..a11f0a0
--- /dev/null
+++ b/Infrastructure/Cache/CacheContext.cs
@@ -0,0 +1,88 @@
+// ***********************************************************************
+// Assembly : Helper
+// Author : yubaolee
+// Created : 12-16-2016
+//
+// Last Modified By : yubaolee
+// Last Modified On : 12-21-2016
+// 使用微软默认带超时的Cache
+// File: CacheContext.cs
+// ***********************************************************************
+
+using System;
+using System.Collections.Concurrent;
+using Microsoft.Extensions.Caching.Memory;
+
+namespace Infrastructure.Cache
+{
+ public class CacheContext : ICacheContext
+ {
+ private IMemoryCache _objCache;
+ private static readonly ConcurrentDictionary> queueDic = new ConcurrentDictionary>();
+ public CacheContext(IMemoryCache objCache)
+ {
+ _objCache = objCache;
+ }
+
+ public override T Get(string key)
+ {
+ return _objCache.Get(key);
+ }
+
+ public override bool Set(string key, T t, DateTime expire)
+ {
+ var obj = Get(key);
+ if (obj != null)
+ {
+ Remove(key);
+ }
+
+ _objCache.Set(key, t, new MemoryCacheEntryOptions()
+ .SetAbsoluteExpiration(expire)); //绝对过期时间
+
+ return true;
+ }
+
+ public override bool Remove(string key)
+ {
+ _objCache.Remove(key);
+ return true;
+ }
+ ///
+ /// 添加并发锁
+ ///
+ /// 值
+ /// 执行方法
+ /// 键
+ ///
+ public override async Task Lock(string id, Func> func, string key = "hc")
+ {
+ var queue = queueDic.GetOrAdd(id, new ConcurrentQueue());
+ var token = Guid.NewGuid().ToString();
+ queue.Enqueue(token);
+ queue.TryPeek(out string newToken);
+ if (token != newToken)
+ {
+ while (true)
+ {
+ Thread.Sleep(10);
+ queue.TryPeek(out newToken);
+ if (token == newToken)
+ {
+ break;
+ }
+ }
+ }
+
+ try
+ {
+ return await func(id);
+ }
+ finally
+ {
+ queue.TryDequeue(out string _);
+ }
+
+ }
+ }
+}
diff --git a/Infrastructure/Cache/EnyimMemcachedContext.cs b/Infrastructure/Cache/EnyimMemcachedContext.cs
new file mode 100644
index 0000000..c2fc64c
--- /dev/null
+++ b/Infrastructure/Cache/EnyimMemcachedContext.cs
@@ -0,0 +1,55 @@
+// ***********************************************************************
+// Assembly : Infrastructure
+// Author : yubaolee
+// Created : 06-21-2016
+//
+// Last Modified By : yubaolee
+// Last Modified On : 06-21-2016
+// Contact : Add services.AddEnyimMemcached(...)
+// and app.UseEnyimMemcached() in Startup.
+// File: EnyimMemcachedContext.cs
+// ***********************************************************************
+
+
+
+using System;
+using Enyim.Caching;
+using Enyim.Caching.Memcached;
+
+namespace Infrastructure.Cache
+{
+ public sealed class EnyimMemcachedContext : ICacheContext
+ {
+ private IMemcachedClient _memcachedClient;
+
+ public EnyimMemcachedContext(IMemcachedClient client)
+ {
+ _memcachedClient = client;
+ }
+
+ ///
+ ///
+ ///
+ ///
+ ///
+ ///
+ public override T Get(string key)
+ {
+ return _memcachedClient.Get(key);
+ }
+
+ public override bool Set(string key, T t, DateTime expire)
+ {
+ return _memcachedClient.Store(StoreMode.Set, key, t, expire);
+ }
+
+ public override bool Remove(string key)
+ {
+ return _memcachedClient.Remove(key);
+ }
+ public override Task Lock(string id, Func> func, string key = "hc")
+ {
+ return func(id);
+ }
+ }
+}
\ No newline at end of file
diff --git a/Infrastructure/Cache/ICacheContext.cs b/Infrastructure/Cache/ICacheContext.cs
new file mode 100644
index 0000000..89580b7
--- /dev/null
+++ b/Infrastructure/Cache/ICacheContext.cs
@@ -0,0 +1,36 @@
+using System;
+
+namespace Infrastructure.Cache
+{
+ ///
+ /// 缓存接口
+ ///
+ public abstract class ICacheContext
+ {
+ ///
+ /// 获取缓存项
+ ///
+ /// 缓存对象类型
+ /// 键
+ /// 缓存对象
+ public abstract T Get(string key);
+
+ ///
+ /// 设置缓存项
+ ///
+ /// 缓存对象类型
+ /// 键
+ /// 缓存对象
+ /// true成功,false失败
+ public abstract bool Set(string key, T t, DateTime expire);
+
+ ///
+ /// 移除一个缓存项
+ ///
+ /// 缓存项key
+ /// true成功,false失败
+ public abstract bool Remove(string key);
+ public abstract Task Lock(string id, Func> func, string key = "hc");
+
+ }
+}
\ No newline at end of file
diff --git a/Infrastructure/Cache/RedisCacheContext.cs b/Infrastructure/Cache/RedisCacheContext.cs
new file mode 100644
index 0000000..ceedd6d
--- /dev/null
+++ b/Infrastructure/Cache/RedisCacheContext.cs
@@ -0,0 +1,63 @@
+using System;
+using Enyim.Caching;
+using Enyim.Caching.Memcached;
+using Microsoft.Extensions.Options;
+using StackExchange.Redis;
+
+namespace Infrastructure.Cache
+{
+ ///
+ /// 缓存redis实现
+ ///
+ public sealed class RedisCacheContext : ICacheContext
+ {
+ private ConnectionMultiplexer _conn { get; set; }
+ private IDatabase iDatabase { get; set; }
+
+ public RedisCacheContext(IOptions options)
+ {
+ _conn = ConnectionMultiplexer.Connect(options.Value.RedisConf.Conn);
+ iDatabase = _conn.GetDatabase(options.Value.RedisConf.Database);
+ }
+
+ public override T Get(string key)
+ {
+ RedisValue value = iDatabase.StringGet(key);
+ if (!value.HasValue)
+ {
+ return default(T);
+ }
+
+ if (typeof(T) == typeof(string))
+ {
+ return (T)Convert.ChangeType(value, typeof(T));
+ }
+ else
+ {
+ return JsonHelper.Instance.Deserialize(value);
+ }
+ }
+
+ public override bool Set(string key, T t, DateTime expire)
+ {
+ if (typeof(T) == typeof(string))
+ {
+ return iDatabase.StringSet(key, t.ToString(), expire - DateTime.Now);
+ }
+ else
+ {
+ return iDatabase.StringSet(key, JsonHelper.Instance.Serialize(t), expire - DateTime.Now);
+ }
+ }
+
+ public override bool Remove(string key)
+ {
+ return iDatabase.KeyDelete(key);
+ }
+
+ public override Task Lock(string id, Func> func, string key = "hc")
+ {
+ return func(id);
+ }
+ }
+}
\ No newline at end of file
diff --git a/Infrastructure/CommonException.cs b/Infrastructure/CommonException.cs
new file mode 100644
index 0000000..32e0cc2
--- /dev/null
+++ b/Infrastructure/CommonException.cs
@@ -0,0 +1,22 @@
+
+using System;
+
+namespace Infrastructure
+{
+ public class CommonException : Exception
+ {
+ private int _code;
+
+ public CommonException(string message, int code)
+ : base(message)
+ {
+ this._code = code;
+ }
+
+ public int Code
+ {
+ get { return _code; }
+ }
+
+ }
+}
diff --git a/Infrastructure/Const/FlowInstanceStatus.cs b/Infrastructure/Const/FlowInstanceStatus.cs
new file mode 100644
index 0000000..3e3c86a
--- /dev/null
+++ b/Infrastructure/Const/FlowInstanceStatus.cs
@@ -0,0 +1,30 @@
+namespace Infrastructure.Const
+{
+ ///
+ /// 流程状态
+ ///
+ public struct FlowInstanceStatus
+ {
+ ///
+ /// 撤销、召回
+ ///
+ public const int Draft = -1;
+ ///
+ /// 正在运行
+ ///
+ public const int Running = 0;
+ ///
+ /// 完成
+ ///
+ public const int Finished = 1;
+ ///
+ /// 不同意
+ ///
+ public const int Disagree = 3;
+ ///
+ /// 驳回
+ ///
+ public const int Rejected = 4;
+
+ }
+}
\ No newline at end of file
diff --git a/Infrastructure/Const/HtmlElementType.cs b/Infrastructure/Const/HtmlElementType.cs
new file mode 100644
index 0000000..0389706
--- /dev/null
+++ b/Infrastructure/Const/HtmlElementType.cs
@@ -0,0 +1,26 @@
+namespace Infrastructure.Const
+{
+ public struct HtmlElementType
+ {
+ public const string drop = "drop";
+ public const string droplist = "droplist";
+ public const string select = "select";
+ public const string selectlist = "selectlist";
+ public const string checkbox = "checkbox";
+ public const string textarea = "textarea";
+ public const string thanorequal = "thanorequal";
+ public const string lessorequal = "lessorequal";
+
+
+ public const string gt = "gt";
+ public const string lt = "lt";
+ public const string GT = ">";
+ public const string LT = "<";
+ public const string like = "like";
+
+ public const string ThanOrEqual = ">=";
+ public const string LessOrequal = "<=";
+ public const string Contains = "in";
+ public const string Equal = "=";
+ }
+}
\ No newline at end of file
diff --git a/Infrastructure/Const/JobStatus.cs b/Infrastructure/Const/JobStatus.cs
new file mode 100644
index 0000000..7616d75
--- /dev/null
+++ b/Infrastructure/Const/JobStatus.cs
@@ -0,0 +1,17 @@
+namespace Infrastructure.Const
+{
+ ///
+ /// 定时任务状态
+ ///
+ public enum JobStatus
+ {
+ ///
+ /// 未启动
+ ///
+ NotRun,
+ ///
+ /// 正在运行
+ ///
+ Running
+ }
+}
\ No newline at end of file
diff --git a/Infrastructure/Const/LinqExpressionType.cs b/Infrastructure/Const/LinqExpressionType.cs
new file mode 100644
index 0000000..ecc32e2
--- /dev/null
+++ b/Infrastructure/Const/LinqExpressionType.cs
@@ -0,0 +1,15 @@
+namespace Infrastructure.Const
+{
+ public enum LinqExpressionType
+ {
+ Equal=0,//=
+ NotEqual=1,//!=
+ GreaterThan,//>
+ LessThan,//<
+ ThanOrEqual,//>=
+ LessThanOrEqual,//<=
+ In,
+ Contains,//Contains
+ NotContains//NotContains
+ }
+}
diff --git a/Infrastructure/Const/QueryOrderBy.cs b/Infrastructure/Const/QueryOrderBy.cs
new file mode 100644
index 0000000..f409707
--- /dev/null
+++ b/Infrastructure/Const/QueryOrderBy.cs
@@ -0,0 +1,8 @@
+namespace Infrastructure.Const
+{
+ public enum QueryOrderBy
+ {
+ Desc=1,
+ Asc=2
+ }
+}
diff --git a/Infrastructure/Const/ResponseType.cs b/Infrastructure/Const/ResponseType.cs
new file mode 100644
index 0000000..1552f90
--- /dev/null
+++ b/Infrastructure/Const/ResponseType.cs
@@ -0,0 +1,27 @@
+namespace Infrastructure.Const
+{
+ public enum ResponseType
+ {
+ ServerError = 1,
+ LoginExpiration = 302,
+ ParametersLack = 303,
+ TokenExpiration,
+ PINError,
+ NoPermissions,
+ NoRolePermissions,
+ LoginError,
+ AccountLocked,
+ LoginSuccess,
+ SaveSuccess,
+ AuditSuccess,
+ OperSuccess,
+ RegisterSuccess,
+ ModifyPwdSuccess,
+ EidtSuccess,
+ DelSuccess,
+ NoKey,
+ NoKeyDel,
+ KeyError,
+ Other
+ }
+}
diff --git a/Infrastructure/Const/SqlDbTypeName.cs b/Infrastructure/Const/SqlDbTypeName.cs
new file mode 100644
index 0000000..2bc9bc7
--- /dev/null
+++ b/Infrastructure/Const/SqlDbTypeName.cs
@@ -0,0 +1,24 @@
+namespace Infrastructure.Const
+{
+ public struct SqlDbTypeName
+ {
+ public const string NVarChar = "nvarchar";
+ public const string VarChar = "varchar";
+ public const string NChar = "nchar";
+ public const string Char = "char";
+ public const string Text = "text";
+ public const string Int = "int";
+ public const string BigInt = "bigint";
+ public const string DateTime = "datetime";
+ public const string Date = "date";
+ public const string SmallDateTime = "smalldatetime";
+ public const string SmallDate = "smalldate";
+ public const string Float = "float";
+ public const string Decimal = "decimal";
+ public const string Double = "double";
+ public const string Bit = "bit";
+ public const string Bool = "bool";
+ public const string UniqueIdentifier = "uniqueidentifier";
+
+ }
+}
diff --git a/Infrastructure/Database/DbDataConvertExtensions.cs b/Infrastructure/Database/DbDataConvertExtensions.cs
new file mode 100644
index 0000000..517f7ad
--- /dev/null
+++ b/Infrastructure/Database/DbDataConvertExtensions.cs
@@ -0,0 +1,412 @@
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations.Schema;
+using System.Data;
+using System.Linq;
+using System.Reflection;
+using System.Threading.Tasks;
+using Infrastructure.Extensions;
+
+namespace Infrastructure.Database
+{
+ ///
+ /// 数据库数据转换拓展
+ ///
+ public static class DbDataConvertExtensions
+ {
+ ///
+ /// 将 DataTable 转 List 集合
+ ///
+ /// 返回值类型
+ /// DataTable
+ /// List{T}
+ public static List ToList(this DataTable dataTable)
+ {
+ return dataTable.ToList(typeof(List)) as List;
+ }
+
+ ///
+ /// 将 DataTable 转 List 集合
+ ///
+ /// 返回值类型
+ /// DataTable
+ /// List{T}
+ public static async Task> ToListAsync(this DataTable dataTable)
+ {
+ var list = await dataTable.ToListAsync(typeof(List));
+ return list as List;
+ }
+
+ ///
+ /// 将 DataSet 转 元组
+ ///
+ /// 元组元素类型
+ /// DataSet
+ /// 元组类型
+ public static List ToList(this DataSet dataSet)
+ {
+ var tuple = dataSet.ToList(typeof(List));
+ return tuple[0] as List;
+ }
+
+ ///
+ /// 将 DataSet 转 元组
+ ///
+ /// 元组元素类型
+ /// 元组元素类型
+ /// DataSet
+ /// 元组类型
+ public static (List list1, List list2) ToList(this DataSet dataSet)
+ {
+ var tuple = dataSet.ToList(typeof(List), typeof(List));
+ return (tuple[0] as List, tuple[1] as List);
+ }
+
+ ///
+ /// 将 DataSet 转 元组
+ ///
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// DataSet
+ /// 元组类型
+ public static (List list1, List list2, List list3) ToList(this DataSet dataSet)
+ {
+ var tuple = dataSet.ToList(typeof(List), typeof(List), typeof(List));
+ return (tuple[0] as List, tuple[1] as List, tuple[2] as List);
+ }
+
+ ///
+ /// 将 DataSet 转 元组
+ ///
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// DataSet
+ /// 元组类型
+ public static (List list1, List list2, List list3, List list4) ToList(this DataSet dataSet)
+ {
+ var tuple = dataSet.ToList(typeof(List), typeof(List), typeof(List), typeof(List));
+ return (tuple[0] as List, tuple[1] as List, tuple[2] as List, tuple[3] as List);
+ }
+
+ ///
+ /// 将 DataSet 转 元组
+ ///
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// DataSet
+ /// 元组类型
+ public static (List list1, List list2, List list3, List list4, List list5) ToList(this DataSet dataSet)
+ {
+ var tuple = dataSet.ToList(typeof(List), typeof(List), typeof(List), typeof(List), typeof(List));
+ return (tuple[0] as List, tuple[1] as List, tuple[2] as List, tuple[3] as List, tuple[4] as List);
+ }
+
+ ///
+ /// 将 DataSet 转 元组
+ ///
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// DataSet
+ /// 元组类型
+ public static (List list1, List list2, List list3, List list4, List list5, List list6) ToList(this DataSet dataSet)
+ {
+ var tuple = dataSet.ToList(typeof(List), typeof(List), typeof(List), typeof(List), typeof(List), typeof(List));
+ return (tuple[0] as List, tuple[1] as List, tuple[2] as List, tuple[3] as List, tuple[4] as List, tuple[5] as List);
+ }
+
+ ///
+ /// 将 DataSet 转 元组
+ ///
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// DataSet
+ /// 元组类型
+ public static (List list1, List list2, List list3, List list4, List list5, List list6, List list7) ToList(this DataSet dataSet)
+ {
+ var tuple = dataSet.ToList(typeof(List), typeof(List), typeof(List), typeof(List), typeof(List), typeof(List), typeof(List));
+ return (tuple[0] as List, tuple[1] as List, tuple[2] as List, tuple[3] as List, tuple[4] as List, tuple[5] as List, tuple[6] as List);
+ }
+
+ ///
+ /// 将 DataSet 转 元组
+ ///
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// 元组元素类型
+ /// DataSet
+ /// 元组类型
+ public static (List list1, List list2, List list3, List list4, List list5, List list6, List list7, List list8) ToList(this DataSet dataSet)
+ {
+ var tuple = dataSet.ToList(typeof(List), typeof(List), typeof(List), typeof(List), typeof(List), typeof(List), typeof(List), typeof(List));
+ return (tuple[0] as List, tuple[1] as List, tuple[2] as List, tuple[3] as List, tuple[4] as List, tuple[5] as List, tuple[6] as List, tuple[7] as List);
+ }
+
+ ///
+ /// 将 DataSet 转 特定类型
+ ///
+ /// DataSet
+ /// 特定类型集合
+ /// List{object}
+ public static List