转载

互联网菜鸟历险记之一

在公司做一个Offline的服务管理系统，功能很简单主要是记录服务申请单，审批以及监控等。这个系统的架构是同事搭建的（像我这种菜鸟公司也不会让我搭建），架构很常规，三层架构，但是同事说另外加上了领域层（他也没有给我讲清楚，但是我看到在这一层上，都是一些log，metric的记录行为）。

为了低耦合高内聚的目的，我们使用了IOC框架（通过IOC相当于初始化，省去了New，可以直接调用，但是IOC有个IOC容器在配置文件XML中，需要你将接口与其实现类一一对应好（MapTo），除了关系对应还有文件的路径，命名空间，构造函数参数等），Core层（也就是业务逻辑层，或者是服务接口层），在这一层在接口中定义服务方法，然后继承实现，所操作的实体对象都是接口类，这些实体接口类的实例化在Data层中，然而IOC实现了Core对Data层无依赖关系。在Controller中（也就是Web层）对服务进行调用是通过IOC实现的，通过IOC Resolver方法创建服务对象（IOC的初始化放在Global.asax文件的Application_Start()方法中，Global.asax文件首先被调用，其中包括着过滤器，错误日志处理，路由规则，还有就是IOC的初始化。），在创建服务对象时，将数据仓库注入到服务对象中，这样就可以直接使用服务对象调用仓库中的数据库处理方法了。因为仓库的接口类是在Core层中定义的，所以注入的时候是注入的仓库类接口对象，而仓库接口的具体实现是在Data层，操作着不同的数据实体类（具体实现的对象了），完成数据层的方法（无非是一些增删改查一类的，当然其中有一些函数，像对实体对象的增加，修改等，直接调用基类中已经封装好的就行），只有那些具体的需求的方法自己拼sql写即可。

以上是整个系统的设计思路，其中的一些细节才是关键。

1.如何写权限？因为在系统中分为管理员，审核人，用户这三种角色，我们是用enum类型定义

public enum RoleType

{

Admin = 1,

User = 2,

Auditor =3

}

在web层的Controller中每个控制器都继承于一个BaseController（这个类是自己定义的），在这个类中，我们写上权限的判别方法。通过

public static UserInfo CurrentUser

{

get

{

var obj = System.Web.HttpContext.Current.Session["user"];

try

{

if (obj == null)

{

// Get windows user

var loggedUser = System.Web.HttpContext.Current.User.Identity;

if (loggedUser != null && loggedUser.IsAuthenticated)

{

string userName = loggedUser.Name;

userName = userName.Substring(userName.IndexOf('//') + 1);

UserInfo user = new UserInfo();

user.UserName = userName;

//to-do find role

IUserService svc = IoC.Resolve<IUserService>();//这就是ioc通过用户服务接口实现用户服务对象的初始化

var roleInfo = svc.GetUserInfo(userName);用户服务调用数据库查询，判断数据库中是否已经存在该用户

if (roleInfo != null)

{

user.RoleId = roleInfo.RoleId;

}

else

{

//如果数据库没有该用户，则该用户是默认的用户即为User

user.RoleId = (int)RoleType.User;

var repo = IoC.Resolve<IUserRoleRepository>();//通过IOC将用户仓库类反转（相当于初始化，省去了New），repo可以直接调用IUserRoleRepository中的方法

var entity = repo.GetEntityInstance();

entity.RoleId = user.RoleId;

entity.Operator = user.UserName;

repo.Add(entity);

}

System.Web.HttpContext.Current.Session.Add("user", user);

obj = user;

}

catch (Exception ex)

{

LogFormat.Write(LogFormat.BusinessError, "Auth-Exception", "获取用户验证信息时发生错误！", ex, LogErrorLevel.Error);

}

return (obj == null) ? null : obj as UserInfo;

}

这个方法就是获取UserInfo类的对象CurrentUser，在如下的方法中进行调用：

protected override void OnActionExecuted(ActionExecutedContext filterContext)

{

ViewBag.UserName = CurrentUser.UserName;

ViewBag.RoldId = CurrentUser.RoleId;

base.OnActionExecuted(filterContext);

}

当然退出登录的方法也是写在里面：

public void LogOff()

{

Session.Abandon();

CasAuthentication.SingleSignOut();

}

这样在Controller中每个action上加上[Authorize][HttpGet]，[ActionAuth(RoleType.User)]标签，其中 ActionAuth就是可以控制权限了

2.在Global.asax文件中需要些路由配置，不然系统找不到你的action，RouteConfig.RegisterRoutes(RouteTable.Routes); 所以在RouteConfig类中定义一个static的方法RegisterRoutes，将你用到的Controller中的Action都配置出来如下：

routes.IgnoreRoute("{resource}.axd/{*pathInfo}");

routes.MapRoute(

name: "BaseServiceMaintainanceIndex",

url: "Maintain/BaseService/Index",

defaults: new { controller = "Maintain", action = "SearchIndex"}//默认的参数

);

3.在Controller中使用System.Linq，可以方便写程序，例如你查询了一个List<T>,你需要按照时间降序排序，则可以用list.OrderByDescending(c => c.DataChange_LastTime).ToList();

4.分页，分页的机制主要是url传入参数，页码，行数之后，通过数据端limt{0页码}{1行数} 把数据返回，对了，还要返回整体的总数据便于前端计算分多少页。在Controller中处理页码行数用ViewData["PagerRecord"] = pager;返回到View层Pager pager = ViewData["PagerRecord"] as Pager;，在View层通过 ViewDataDictionary viewData = new ViewDataDictionary(); viewData 对象封装页面需要传递的信息（这个类ViewDataDictionary 很重要，当两个页面cshtml之间数据进行传递时就会用到它），在A页中使用@Html.Partial("PagerPartial", pager, viewData)，在页面传递时，有时会用到路由参数，因为页面传递时要刷新页面，要保证刷新页面不变，所以路由参数必须一致所以本次还用到RouteValueDictionary dict = new RouteValueDictionary();最后赋值完毕之后，将之赋值给viewData对象

5.本次查询系统由于参数太多，所以在Core层使用了参数类，还有查询返回值也是用了结果类：其中Data就是返回的数据List，有一些操作也是用返回类实现的

//查询结果类

public class PagerResult<T>

{

public int PageIndex { get; set; }

public int TotalCount { get; set; }

public IList<T> Data { get; set; }}

//操作结果类

[Serializable]

public class ModifyResult

{

private string _status = "success";private string _message = "提交成功！";

/// <summary>

/// 修改状态

/// </summary>

public virtual string status

{

get { return _status; }

set { _status = value; }

}

/// <summary>

/// 信息

/// </summary>

public virtual string message

{

get { return _message; }

set { _message = value; }

}

public class SuccessResult :ModifyResult

{

public override string message

{

get

{

return "提交成功!";

}

public override string status

{

get

{

return "success";

}

6.编程需要注意一点，不要在数据库端写select all 然后在业务逻辑层使用foreach()进行循环遍历，这样既能拖垮数据库又会给业务层带来压力，最好的办法是通过参数传入数据端进行查询，举个例子：Appid与sid相同的记录不能存在两条，所以在新增或者更新时需要判断，写一个check函数，getListByAppid(string appid){}这样返回一个List 然后在业务层对resultList进行判断，使用Linq：resultList.Where(t=>t.sid ==e.sid);e.sid是你要判断数据的sid。实在不行你也可以写getListByXid(string appid,int sid){}判断有无返回值就可以了。

7.关于多张表的插入，删除，更新操作，需要保持几张表同步更新/变化，所以你需要使用事务原则。在C#中我目前是用using (TransactionScope tsCope = new TransactionScope()) {}需要引入System.Transactions，在保证代码完整的完成事务操作的地方加上tsCope.Complete();

using (TransactionScope tsCope = new TransactionScope())

{

data.DataChange_CreateTime = DateTime.Now;

data.DataChange_LastTime = DateTime.Now;

Object iresult = _dataRepo.Add(data);

int iReturn = ConvertHelper.ToInt32(iresult);

if (iReturn != 0)

{

string operatorid = data.Operator;

//将操作信息写入Log库

IOperatorLog ol = IoC.Resolve<IOperatorLog>();

ol.WriteLogInfo(iReturn, operatorid, LogMessage.Commit_Service_Application);

res = new SuccessResult();

tsCope.Complete();

}

else

{

res = new FailedResult();

}

8.因为Core层没有依赖Data层（这是解除耦合必须的），所以有时候你在Core想初始化Data层的数据实体，这是不可能的，怎么办呢？要处理数据不能一直把数据传递到Data层再做操作吧，那样多麻烦。遇到这样的问题你就要在Core层调用相应实体仓库接口中定义一个返回数据实例化的方法，例如我在AppForm服务中调用AppFormEntity，但是没有办法new一个AppFormEntity，所以我在IAPPFormRepository（这个类还是在Core层）中写一个函数 IAppFormEntity CreateEntity();但是其实现类APPFormRepository在Data层了，哈哈，

public IAppFormEntity CreateEntity()

{

return new AppFormEntity();

}

这就OK了吧！！当然比较明智的是，在IAPPFormRepository所继承的基类中写一个泛型接口方法并在其实现类中实现。例如IRepository接口中写：TEntity GetEntityInstance();

在Repository中写

public TInterface GetEntityInstance()

{

return new TEntity();

}

然后，IAPPFormRepository继承IRepository，其实现类APPFormRepository需要继承Repository与IAPPFormRepository

9.数据库多参数查询时，需要拼sql，怎么拼比较好呢？我在这使用了一种很常规的方式，用List<string>拼接实现的，具体实现如下：

public static StringBuilder GenerateSearchSql(SearchParams sp)

{

StringBuilder sql = new StringBuilder(ConstSqlStr.SQL_APP_COUNT);//这是SQL语句，联表查询，没有包含where条件

List<string> wheres = new List<string>();

List<StatementParameter> listParameter = new List<StatementParameter>();//参数话查询

if (sp.Pid != 0)

{

wheres.Add(" a.Pid=@Pid ");

listParameter.Add(new StatementParameter { Name = "@Pid", Direction = ParameterDirection.Input, DbType = DbType.Int32, Value = sp.Pid });

}

if (!string.IsNullOrEmpty(sp.AppId))

{

wheres.Add(" a.AppId = @AppId ");

listParameter.Add(new StatementParameter { Name = "@AppId", Direction = ParameterDirection.Input, DbType = DbType.AnsiString, Value = sp.AppId });

}

if (!string.IsNullOrEmpty(sp.ApplicantId))

{

wheres.Add(" a.ApplicantId = @ApplicantId ");

listParameter.Add(new StatementParameter { Name = "@ApplicantId", Direction = ParameterDirection.Input, DbType = DbType.AnsiString, Value = sp.ApplicantId });

}

if (!string.IsNullOrEmpty(sp.ServiceName))

{

wheres.Add(" s.ServiceName = @ServiceName ");

listParameter.Add(new StatementParameter { Name = "@ServiceName", Direction = ParameterDirection.Input, DbType = DbType.AnsiString, Value = sp.ServiceName });

}

if (!string.IsNullOrEmpty(sp.UnitName))

{

wheres.Add(" r.UnitName = @UnitName ");

listParameter.Add(new StatementParameter { Name = "@UnitName", Direction = ParameterDirection.Input, DbType = DbType.AnsiString, Value = sp.UnitName });

}

if (sp.Status != 0)

{

wheres.Add(" a.Status = @Status ");

listParameter.Add(new StatementParameter { Name = "@Status", Direction = ParameterDirection.Input, DbType = DbType.Int32, Value = sp.Status });

}

//判断用户是否选择了条件

if (wheres.Count > 0)//说明是有条件的查询

{

string wh = string.Join(" and ", wheres.ToArray());将条件用 and 拼接，

sql.Append(" where " + wh);//当把所有的条件用and 连接完成之后，再在前面加上where 即可

}