更新日志

2021/08/17

1、框架升级到.Net 5

2、关系型数据库的ORM由Dapper替换为SqlSugar

3、优化整理了WebApi层的代码对很多附件功能进行分类封装，极大减少Startup.cs的配置代码

4、增加上传文件大小可配置功能

5、增加App.Metrics的健康检测（但是需要单独安装其配套软件，默认禁用）

绝影框架（Net 5微服务架构的WebApi框架）

目前本框架支持的数据为：MongoDB、MySql、SqlServer(默认使用的数据库为MongoDB)

系统主键图

代码结构图

把绝影变成一个模板，生成自己的项目

项目层级介绍

1）Shared（共享层）

ASHermed.Shadow.Code - 存放接口返回结果的统一代码 ASHermed.Shadow.ContractModel - 存放接口统一返回结果的Model（无需改动） ASHermed.Shadow.Entity - 存放与数据库表结构一一对应的实体 ASHermed.Shadow.Enum - 存放所有枚举的地方 ASHermed.Shadow.Exception - 存放所有自定义异常的地方 ASHermed.Shadow.Repository - 存放数据库基础仓储的地方 ASHermed.Shadow.Tools - 存放本系统工具类的地方 

2）Model（模型层）

ASHermed.Shadow.Api.ContractModel - 存放项目内所有DTO对象的地方

Inside ---- 【对内使用的DTO对象】： 存放仓储层的DTO对象和一些内部使用的DTO对象 External ---- 【对外使用的DTO对象】： 存放Service层、Controller层的DTO对象 Shared ---- 【共享，一般都是存放需要共享的DTO对象或实体】 Framework ---- 【存放所有Framework使用的DTO对象】  结构示例： Inside [对内DTO对象] Order [模块名称，模块下所有类的命名空间到模块为止] Param [存放传入参数的DTO对象，每个模块都有一套，文件结尾以Param命名] Model [存放返回结果的DTO对象，每个模块都有一套，文件结尾以Model命名] Entity [存放入参或返回结果DTO对象中用到的实体，每个模块都有一套，文件结尾以Entity命名]

External [对外DTO对象] Order [模块名称] v1 [接口版本，1代表版本号，模块下所有类的命名空间到模块为止] Param [存放传入参数的DTO对象，每个模块都有一套，文件结尾以Param命名] Model [存放返回结果的DTO对象，每个模块都有一套，文件结尾以Model命名] Entity [存放入参或返回结果DTO对象中用到的实体，每个模块都有一套，文件结尾以Entity命名] 

3）DataAccess（用户自定义仓储层）

ASHermed.Shadow.Api.IRepository - 存放自定义仓储interface的地方 ASHermed.Shadow.Api.MongoDBRepository - 存放MongoDB自定义数据库仓储的地方 ASHermed.Shadow.Api.MySqlRepository - 存放MySql自定义数据库仓储的地方 ASHermed.Shadow.Api.SqlServerRepository - 存放SqlServer自定义数据库仓储的地方 

4）Framework（对外调用层[通过Api调用第三方系统的地方]）

ASHermed.Shadow.BaseFramework - 存放用户调用第三方接口的HttpClientHelp工具类的层 ASHermed.Shadow.IFramework - 存放Framework 下 interface 的地方 ASHermed.Shadow.LogFramework - 存放接口日志记录的地方（无需改动） ASHermed.SingleSignOnFramework - 存放调用单点登录系统封装的地方 

5）Service（业务逻辑层，可以按照模块拆分出多个Service层也可以只用一个Service层然后用文件夹名称区分不同的模块，可以根据个人喜好来定）

ASHermed.Shadow.Api.IService - 存放 Service 下 interface 的地方 ASHermed.Shadow.Api.Service - 存放Service的地方 

6）WebApi（WebApi层）

ASHermed.Shadow.WebApi - 存放对外Api的地方

框架内置 ORM 对于MongoDB 数据库的使用帮助

MongoDB 与 RDBMS Where 语句比较

MongoDB日常操作语句

mongo 不区分大小写查询

{"APIName":{$regex:/cgi-bin\/user\/getuserinfo/,'$options':'i'}}

mongo 正则匹配查询

{"RequestBody":{$regex:/B27532093400375009/}}

mongo 修改

db.EvaluateRelation.update(               
{"EvaluatorNoId" : "c1363","EvaluatedNoId" : "02255"},  
{ $set: {"IsDeleted" : false} },
{multi:true}
)

mongo 删除多条

db.AddedCount.remove(               
{"_id" : {$in:["c0553.3","02669.3"]}}, 
{multi:true}
)

建立索引

db.APILogs.createIndex({"RequestTime":-1})
db.APILogs.ensureIndex({"APIName":1,"IsError":1})

MongoDB 在C#里面的用法

C#中模糊查询

var filter = Filter.Or(
    Filter.Where(x => x.Email.Contains(keyWord.ToLower())),
    Filter.Where(x => x.WorkerUserId.Contains(keyWord.ToLower())));

C#中不区分大小写模糊查询(非标准写法)

var filter = Filter.Regex(x => x.EnglishName, new MongoDB.Bson.BsonRegularExpression(keyWord, "i"));

C#中不区分大小写模糊查询(标准写法)

var filter = Filter.Or(
         Filter.Regex(x => x.EnglishName, new BsonRegularExpression(new Regex(keyWord, RegexOptions.IgnoreCase))),
         Filter.Regex(x => x.EnglishName, new BsonRegularExpression(keyWord)));

C#分页查询

int skip = (pageNo - 1) * pageSize;

await this.GetListAsync(filter: _filter, sort: Sort.Ascending(x => x.HireDate), limit: pageSize, skip: skip);

C#单条新增

//无状态
await this.InsertAsync(surveyAnswers);
//有状态
await this.InsertAsync(surveyAnswers, writeConcern: WriteConcern.Acknowledged);

C#查询主库

await this.CountAsync(filter: filter, readPreference: ReadPreference.PrimaryPreferred);

C#批量新增

//无状态
this.InsertBatchAsync(surveyAnswers);
//有状态
this.InsertBatchAsync(surveyAnswers, writeConcern: WriteConcern.Acknowledged);

C#更新状态

this.FindOneAndUpdateAsync(filter, update);

C#自增列实现

    public class Question : IAutoIncr<int>
    {
        [BsonId]
        public int ID { get; set; }
	}

C# string为主键，自动赋值

    public class RecommendRelation : IEntity<string>
    {
        [BsonId]
        [BsonRepresentation(BsonType.ObjectId)]
        public string ID { get; set; }
	}

C# 查询部分字段

            var filter = Filter.And(Filter.In(x => x.ID, ids));

            People people = new People();

            var projection = Projection
                .Include(nameof(people.ID))
                .Include(nameof(people.EN_Sup_Org_Name))
                .Include(nameof(people.CN_Sup_Org_Name));

            return this.GetListAsync(filter: filter, projection: projection);

C#更新多层嵌套

{
    "TableName" : "frtest66",
    "MenuName" : "test666",
    "DOAdmin_MenuId" : "676db672-212f-4876-b164-22ded65f4cbd",
    "PermissionList" : [ 
        {
            "PmsID" : "0d27cbe577764b72a160bc84c8aa2203",
            "PmsTag" : [ 
                "64ef17e8-37fb-47fa-b630-1682c137e463"
            ],
            "Remark" : "test",
            "OperateType" : [ 
                1, 
                2, 
                4
            ],
            "Status" : 2,
            "IsFullData" : false,
            "PmsInfos" : [ 
                {
                    "ColumnName" : "Name",
                    "ColumnType" : 1,
                    "ColumnValue" : "张三"
                }
            ]
        }
    ]
}
更新Status字段：通过占位符"$"实现
"update" : { "$set" : { "PermissionList.$.Status" : 1 } }

实现代码:
var filter = Filter.And(
                Filter.Eq(nameof(Sys_SingleTableTemplate.PermissionList) + "." + nameof(Sys_Permission.PmsID), param.PermissionID));
            var update = Update
               .Set(nameof(Sys_SingleTableTemplate.PermissionList) + ".$." + nameof(Sys_Permission.Status), param.Sys_DataState);

  return await this.FindOneAndUpdateAsync(filter, update, writeConcern:      WriteConcern.Acknowledged);

C#更新单个实体

/// <summary>
/// 投放ID集合
/// </summary>
public List<MPPutInInfo> PICMList { get; set; }

/// <summary>
/// 更新券规则投放数据
/// </summary>
/// <param name="mppicrID">后台发券规则ID</param>
/// <param name="mpPutInInfo">投放ID集合</param>
/// <param name="title">后台发券规则标题</param>
/// <param name="updateID">最后修改人ID</param>
/// <param name="updateName">最后修改人姓名</param>
/// <returns></returns>
public Task UpdateCouponPutIn(long mppicrID, MPPutInInfo mpPutInInfo, string title, long updateID, string updateName)
{
	var filter = Filter.And(
	Filter.Eq(nameof(MPPutInCouponRule.ID), mppicrID));

	var update = Update
	.Push(x => x.PICMList, mpPutInInfo)
	.Set(nameof(MPPutInCouponRule.Title), title)
	.Set(nameof(MPPutInCouponRule.UpdateID), updateID)
	.Set(nameof(MPPutInCouponRule.UpdateName), updateName)
	.Set(nameof(MPPutInCouponRule.UpdateTime), DateTime.Now);
	return this.FindOneAndUpdateAsync(filter, update);
}