问题描述
如何在用Microsoft Enterprise Library编写的通用数据层中动态添加业务规则？
我开发了通用数据层。我正在使用企业库进行数据通信。
这是我的代码。
我的存储库
public sealed class DbRepository : IDbRepository
{
private readonly sqlDatabase database;
public DbRepository(Database database)
{
this.database = database as sqlDatabase;
}
public async Task<DbResponseBase<TResult>> GetResponseAsync<TResult,TOutput>(DbRequestBase request) where TResult : class
{
DbCommand cmd = database.GetStoredProcCommand(request.ProcedureName);
SpParameterMapper<TOutput> parameterMapper = new SpParameterMapper<TOutput>();
parameterMapper.AssignParameters(cmd,new object[] { request.InputJson });
DbJsonResponseMapper responseMapper = null;
TResult model = default;
try
{
#region Execute Stored Procedure.
switch (request.RequestType)
{
case DbRequestType.Insert:
case DbRequestType.Update:
case DbRequestType.Delete:
int returnValue = await Task<int>.Factory.FromAsync(database.BeginExecuteNonQuery,database.EndExecuteNonQuery,cmd,null);
break;
case DbRequestType.Scalar:
model = (TResult)await Task<object>.Factory.FromAsync(database.BeginExecuteScalar,database.EndExecuteScalar,null);
break;
case DbRequestType.Select:
responseMapper = await Task.Run(() =>
database
.ExecuteSprocAccessor<DbJsonResponseMapper>(
request.ProcedureName,parameterMapper,new object[] { request.InputJson }
).SingleOrDefault()
);
break;
default:
break;
}
#endregion
}
catch (ArgumentNullException ex1) { throw ex1; }
catch (ArgumentException ex2) { throw ex2; }
catch (Exception ex) { throw new ApplicationException(ex.Message); }
OutputParameter<TOutput> output = parameterMapper.GetourputParameters();
try
{
#region Prepare Result based on Output Parameter.
switch (output.DataType)
{
case DataType.Scalar:
break;
case DataType.Grid:
break;
case DataType.Json:
model = responseMapper.Data?.To<TResult>();
break;
default:
break;
}
}
catch (Exception ex)
{
throw new ApplicationException(ex.Message); ;
}
#endregion
return new DbResponse<TResult,TOutput>
{
OutPutParameters = output,Data = model
};
}
}
internal sealed class SpParameterMapper<T> : IParameterMapper
{
DbCommand _cmd = null;
public OutputParameter<T> GetourputParameters()
{
try
{
return new OutputParameter<T>
{
RetVal = (int)_cmd.Parameters["@RetVal"].Value,DataType = (DataType)_cmd.Parameters["@DataType"].Value,ErrorNumber = _cmd.Parameters["@ErrorNumber"].Value == dbnull.Value ? 0 : (int)_cmd.Parameters["@ErrorNumber"].Value,ErrorMessage = _cmd.Parameters["@ErrorMessage"].Value == dbnull.Value ? string.Empty : (string)_cmd.Parameters["@ErrorMessage"].Value,JsonOutput = _cmd.Parameters["@JsonOutput"].Value == dbnull.Value ? default(T) : ((string)_cmd.Parameters["@JsonOutput"].Value).To<T>()
};
}
catch (Exception)
{
throw new ApplicationException("Error Occured While reading Output Parameter of Stored Procedure.");
}
}
public void AssignParameters(DbCommand command,object[] parameterValues)
{
if (parameterValues == null)
{
throw new ArgumentNullException();
}
if (parameterValues.Count() != 1)
{
throw new ArgumentException("Invalid Stored Procedure Parameter Count.");
}
_cmd = command;
DbParameter[] parametersArray = new DbParameter[] {
command.CreateParameter(),command.CreateParameter(),command.CreateParameter()
};
parametersArray[0].ParameterName = "@Json";
parametersArray[0].Value = parameterValues[0];
parametersArray[1].ParameterName = "@RetVal";
parametersArray[1].DbType = DbType.Int32;
parametersArray[1].Direction = ParameterDirection.Output;
parametersArray[1].Size = Int32.MaxValue;
parametersArray[1].Value = dbnull.Value;
parametersArray[2].ParameterName = "@DataType";
parametersArray[2].DbType = DbType.Int32;
parametersArray[2].Direction = ParameterDirection.Output;
parametersArray[2].Size = Int32.MaxValue;
parametersArray[2].Value = dbnull.Value;
parametersArray[3].ParameterName = "@ErrorNumber";
parametersArray[3].DbType = DbType.Int32;
parametersArray[3].Direction = ParameterDirection.Output;
parametersArray[3].Size = Int32.MaxValue;
parametersArray[3].Value = dbnull.Value;
parametersArray[4].ParameterName = "@ErrorMessage";
parametersArray[4].DbType = DbType.String;
parametersArray[4].Size = 2000;
parametersArray[4].Direction = ParameterDirection.Output;
parametersArray[4].Value = dbnull.Value;
parametersArray[5].ParameterName = "@JsonOutput";
parametersArray[5].DbType = DbType.String;
parametersArray[5].Size = 8000;
parametersArray[5].Direction = ParameterDirection.Output;
parametersArray[5].Value = dbnull.Value;
command.Parameters.AddRange(parametersArray);
}
}
示例Api CRUD端点
[EnableCors(origins: "*",headers: "*",methods: "*")]
[RoutePrefix(RouteConstants.GroupRoutePrefix)]
public class GroupController : ApiController
{
private readonly IDbContext dbContext = null;
public GroupController(IDbContext dbContext)
{
this.dbContext = dbContext;
}
[HttpPost]
[JWTAuthenticationFilter(Roles = "Admin,Coordinator")]
[Route(RouteConstants.GroupList)]
[ApiValidateModel]
public async Task<HttpResponseMessage> List(DefaultDataTableFilterRequest model)
{
var identity = User.Identity as JWTAuthenticationIdentity;
DbRequest request = new DbRequest
{
InputJson = model.ToJson(),ProcedureName = StoredProcedure.GroupList,RequestType = DbRequestType.Select
};
var dbResponse = (DbResponse<List<GroupListviewmodel>,ListOutput>)
(
await (dbContext.DbRepository.GetResponseAsync<List<GroupListviewmodel>,ListOutput>(request))
);
return dbResponse.CreateHttpResponse(Request,Configuration);
}
[HttpPost]
[JWTAuthenticationFilter(Roles = "Admin,Coordinator")]
[Route(RouteConstants.GroupDetails)]
[ApiValidateModel]
public async Task<HttpResponseMessage> Details(int ID)
{
DbRequest request = new DbRequest
{
InputJson = new { ID }.ToJson(),ProcedureName = StoredProcedure.GroupDetails,RequestType = DbRequestType.Select
};
var dbResponse = (DbResponse<Groupviewmodel,object>)
(
await (dbContext.DbRepository.GetResponseAsync<Groupviewmodel,object>(request))
);
return dbResponse.CreateHttpResponse(Request,Coordinator")]
[Route(RouteConstants.GroupSave)]
[ApiValidateModel]
public async Task<HttpResponseMessage> Save(Groupviewmodel model)
{
DbRequest request = new DbRequest
{
InputJson = model.ToJson(),ProcedureName = StoredProcedure.GroupSave,RequestType = DbRequestType.Insert
};
var dbResponse = (DbResponse<object,object>)
(await (dbContext.DbRepository.GetResponseAsync<object,object>(
request
)));
return dbResponse.CreateHttpResponse(Request,Configuration);
}
[HttpPost]
[JWTAuthenticationFilter(Roles = "Admin")]
[Route(RouteConstants.GroupDelete)]
[ApiValidateModel]
public async Task<HttpResponseMessage> Delete(int ID)
{
DbRequest request = new DbRequest
{
InputJson = new { ID,Status = 1 }.ToJson(),ProcedureName = StoredProcedure.GroupDelete,RequestType = DbRequestType.Scalar
};
var dbResponse = (DbResponse<object,object>)
(await (dbContext.DbRepository.GetResponseAsync<object,object>(
request
)));
return dbResponse.CreateHttpResponse(Request,Configuration);
}
}
我有一个通用的存储过程模式，与我的代码兼容。我的存储过程将返回json作为输出。
一切正常。但是问题是，我正在存储的proc中处理业务逻辑，我知道它的优缺点。现在，我试图在.Net层中实现业务逻辑。
我的目标就像添加业务逻辑作为中间件。因此，任何人都可以提出任何想法或任何其他方法来解决我的问题。
我也感谢这种设计的任何批评家。感谢您的耐心等候
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）