Slickflow.NET 開源工做流引擎基礎介紹(九) -- .NET Core2.0 版本實現介紹

時間  2020-05-10
標籤 slickflow.net slickflow 開源 引擎 基礎 介紹 core2.0 core 版本 實現 简体版
原文   原文鏈接

前言：.NET Core 是.NET Framework的新一代版本，是微軟開發的第一個跨平臺 (Windows、Mac OSX、Linux) 的應用程序開發框架（Application Framework），將來也將會支持 FreeBSD 與 Alpine 平臺。.Net Core也是微軟在一開始發展時就開源的軟件平臺，其開發目標是跨平臺的 .NET 平臺。前端

.NET Core 平臺的開發優點 ：sql

  1. 支持或能夠移轉 (port) 到更多的操做系統平臺與芯片架構 (也就是將來項目會跨出 x86 平臺)。
  2. 具備引人注目的性能與高可靠度。
  3. 開發人員能快速與直覺的獲取 .NET Core 開發環境。
  4. 在直覺與具生產力的狀況下建造應用程序，使用文件，示例與 NuGet 組件。

以上文字引用來源：https://zh.wikipedia.org/wiki/.NET_Core數據庫

1. .NET Core 2.0 遷移指南json

    因爲.NET Core跨平臺開發和性能方面的優點，再加上.NET Core2.0版本的推出，愈來愈多的客戶逐漸遷移到.NET Core框架進行軟件系統的開發。Slickflow引擎組件的.NET Core版本的推出，也是爲了解決跨平臺引擎產品的實現。本文大體描述了建立.NET Core2.0 爲目標版本類庫，數據訪問項目和Asp.NET Mvc Core等類型項目的搭建過程，方便用戶快速上手。後端

1.1 數據訪問項目api

1) IRepository模式實現session

    Repository模式實現通用數據訪問接口，其好處是首先定義出標準的增刪改查接口，其次能夠知足對接後端不一樣的數據處理框架，如Dapper，EF和NHibernate等框架。架構

/// <summary>
    /// 數據操做類接口
    /// </summary>
    /// <typeparam name="T">數據實體類型</typeparam>
    public interface IRepository<T> where T : class
    {
        DbSet<T> GetDbSet();

        T GetByID(dynamic id);
        T Get(Expression<Func<T, bool>> predicate);
        IQueryable<T> GetAll();

        IQueryable<T> Query(string sql, params object[] parameters);
        IEnumerable<T> Query(Expression<Func<T, bool>> predicate);
        int Count(Expression<Func<T, bool>> predicate = null);


        //insert, update, delete
        T Insert(T entity);
        void Insert(params T[] entities);
        void Insert(IEnumerable<T> entities);
        void Update(T entity);
        void Update(params T[] entities);
        void Update(IEnumerable<T> entities);
        void Delete(dynamic id);
        void Delete(params T[] entities);
        void Delete(IEnumerable<T> entities);
    }

2) UnitOfWork 解決事務app

    引擎內部邏輯處理一般是多表的插入編輯操做，爲保持數據事務完整性，須要實現會話事務的參數傳遞，提供提交和回滾的處理方式。Slickflow.Data.IDbSession用來實現UnitOfWork模式。框架

/// <summary>
    /// 數據會話接口
    /// </summary>
    public interface IDbSession : IDisposable
    {
        DbContext DbContext { get; }
        IRepository<T> GetRepository<T>() where T : class;
        int SaveChanges();
        int ExecuteSqlCommand(string sql, params object[] paramters);
    }

    代碼示例：Session做爲參數，傳入具體接口方法，最終實現事務的一致提交或回滾。

/// <summary>
        ///  運行流程測試
        /// </summary>
        /// <param name="runner">運行者</param>
        /// <returns>執行結果</returns>
        [HttpPost]
        public ResponseResult RunProcessApp([FromBody] WfAppRunner runner)
        {
            using (var session = DbFactory.CreateSession())
            {
                var transaction = session.DbContext.Database.BeginTransaction();
                var wfService = new WorkflowService();
                var result = wfService.RunProcessApp(runner, session);

                if (result.Status == WfExecutedStatus.Success)
                {
                    transaction.Commit();
                    return ResponseResult.Success();
                }
                else
                {
                    transaction.Rollback();
                    return ResponseResult.Error(result.Message);
                }
            }
        }

1.2 Asp.NET Mvc Core項目

1) Mvc和WebAPI路由統一配置

    一般在.NET項目開發中，Mvc項目用於前端頁面展示，WebAPI用於後端接口實現。在項目實踐過程當中，能夠將兩個項目整合爲一，便於環境配置。

app.UseMvc(route => {
                route.MapRoute(
                    name: "default",
                    template: "{controller=Home}/{action=Index}/{id?}");

                route.MapRoute(
                    name:"defaultApi", 
                    template: "api/{controller}/{action}/{id?}");
            });

2) 數據庫鏈接串配置

    數據庫連接串在appsettings.json文件中進行定義，讀取方法以下：

var dbType = ConfigurationExtensions.GetConnectionString(Configuration, "WfDBConnectionType");
            var sqlConnectionString = ConfigurationExtensions.GetConnectionString(Configuration, "WfDBConnectionString");

            Slickflow.Data.ConnectionString.DbType = dbType;
            Slickflow.Data.ConnectionString.Value = sqlConnectionString;

3) DbContext 數據庫類型匹配

    因爲不一樣類型數據庫的數據訪問組件不一樣，因此特地作了接口對應匹配，傳入數據庫鏈接串值。

protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
        {
            if (ConnectionString.DbType == DatabaseTypeEnum.SQLSERVER.ToString())
                optionsBuilder.UseSqlServer(ConnectionString.Value);
            else if (ConnectionString.DbType == DatabaseTypeEnum.MYSQL.ToString())
                optionsBuilder.UseMySql(ConnectionString.Value);
            else if (ConnectionString.DbType == DatabaseTypeEnum.ORACLE.ToString())
                optionsBuilder.UseOracle(ConnectionString.Value);
        }

　　

2. EF Core對多數據庫生成的支持

    EF Code First是由實體來生成數據庫模型，簡要過程描述爲：首先定義好實體對象，對應數據庫字段類型，而後執行EF Migrations的操做命令來生成數據庫對象。其中常常用到的命令有：

   1) dotnet ef migrations add MyFirstMigraton

   2) dotnet ef migrations update database

   下面就以WfProcess表的建立來講明大體的建立過程。

2.1 MS SQLSERVER數據庫

    採用的數據訪問組件默認爲：Microsoft.EntityFrameworkCore。

 1) 實體屬性標識

/// <summary>
    /// 流程實體類
    /// </summary>
    [Table("WfProcess")]
    public class ProcessEntity
    {
        [Key]
        [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
        [Column(Order = 0)]
        public int ID { get; set; }

        [Required]
        [Column(TypeName = "varchar(100)", Order = 1)]
        [MaxLength(100)]
        public string ProcessGUID { get; set; }

        [Required]
        [Column(TypeName = "nvarchar(50)", Order = 2)]
        [MaxLength(50)]
        public string ProcessName { get; set; }

        [Required]
        [Column(TypeName ="nvarchar(20)", Order = 3)]
        [MaxLength(20)]
        public string Version { get; set; }
    }

 2) 默認值賦值

//流程建立
            modelBuilder.Entity<ProcessEntity>(entity =>
            {
                entity.Property(e => e.Version).HasDefaultValue("1");
                entity.Property(e => e.IsUsing).HasDefaultValue(0);
                entity.Property(e => e.StartType).HasDefaultValue(0);
                entity.Property(e => e.EndType).HasDefaultValue(0);
                entity.Property(e => e.CreatedDateTime).HasDefaultValueSql("getdate()");
            });

 3) 生成命令執行

dotnet ef migrations add MyFirstMigration

2.2 MySQL數據庫

    採用的數據訪問組件默認爲：Polemo.EntityFrameworkCore.MySQL。

  1) 實體屬性標識

/// <summary>
    /// 流程實體類
    /// </summary>
    [Table("WfProcess")]
    public class ProcessEntity
    {
        [Key]
        [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
        [Column(Order = 0)]
        public int ID { get; set; }

        [Required]
        [Column(TypeName = "varchar(100)", Order = 1)]
        [MaxLength(100)]
        public string ProcessGUID { get; set; }

        [Required]
        [Column(TypeName = "varchar(50)", Order = 2)]
        [MaxLength(50)]
        public string ProcessName { get; set; }

        [Required]
        [Column(TypeName ="varchar(20)", Order = 3)]
        [MaxLength(20)]
        public string Version { get; set; }
    }

  2) 默認值賦值

//流程建立
            modelBuilder.Entity<ProcessEntity>(entity =>
            {
                entity.Property(e => e.Version).HasDefaultValue("1");
                entity.Property(e => e.IsUsing).HasDefaultValue(0);
                entity.Property(e => e.StartType).HasDefaultValue(0);
                entity.Property(e => e.EndType).HasDefaultValue(0);
            });

  3) 生成命令執行

dotnet ef migrations add MyFirstMigration

3. Slickflow.WebAPI 快速測試

 3.1 路由模式選定：

    仍然選定傳統路由模式，便於接口快速識別和匹配。

app.UseMvc(route => {
                route.MapRoute(
                    name: "defaultApi",
                    template: "api/{controller}/{action}/{id?}");
            });

3.2 數據庫連接串讀取：

var dbType = ConfigurationExtensions.GetConnectionString(Configuration, "WfDBConnectionType");
            var sqlConnectionString = ConfigurationExtensions.GetConnectionString(Configuration, "WfDBConnectionString");

            Slickflow.Data.ConnectionString.DbType = dbType;
            Slickflow.Data.ConnectionString.Value = sqlConnectionString;

3.3 測試接口方法

/// <summary>
        ///  啓動流程測試
        /// </summary>
        /// <param name="runner">運行者</param>
        /// <returns>執行結果</returns>
        [HttpPost]
        public ResponseResult StartProcess([FromBody] WfAppRunner runner)
        {
            using (var session = DbFactory.CreateSession())
            {
                var transaction = session.DbContext.Database.BeginTransaction();
                var wfService = new WorkflowService();
                var result = wfService.StartProcess(runner, session);

                if (result.Status == WfExecutedStatus.Success)
                {
                    transaction.Commit();
                    return ResponseResult.Success();
                }
                else
                {
                    transaction.Rollback();
                    return ResponseResult.Error(result.Message);
                }
            }
        }

3.4 RestClient 測試工具

     引擎接口測試採用RestClient工具，比較方便快捷。一般採用統一的接口方法，將不一樣類型的流程JSON數據格式做爲測試用例來提交測試。

4. 總結

     Slickflow 引擎產品的.NET Core版本實現，用於跨平臺應用的項目開發和業務集成。並且在數據庫的支持上，採用EF Core的Code First數據庫遷移建立，方便用戶開發環境的快速搭建和配置。

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程