优雅就一个字——设计模式之数据上传接口

///<summary>
///处理流程基类
///</summary>
publicabstractclassProcessFlowBase:IProcessFlow
{
protectedProcessFlowBase(ProcessFlowBaseprocessFlowWhenRight=default(ProcessFlowBase),ProcessFlowBaseprocessFlowWhenWrong=default(ProcessFlowBase))
{
this.NextProcessFlowWhenRight=processFlowWhenRight;
this.NextProcessFlowWhenWrong=processFlowWhenWrong;
this.IsRight=true;
this.IsEnd=false;
}

protectedIDbConnectionDbConnection{get;set;}

protectedIDbCommandDbCommand{get;set;}

protectedIDbTransactionDbTransaction{privateget;set;}

///<summary>
///当前流程是否处理通过
///</summary>
privateboolIsRight{get;set;}

///<summary>
///流程是否结束
///</summary>
privateboolIsEnd{get;set;}

///<summary>
///下一个流程,当流程处理操作通过的时候
///</summary>
privateProcessFlowBaseNextProcessFlowWhenRight{set;get;}

///<summary>
///下一个流程,当流程处理操作不通过的时候
///</summary>
privateProcessFlowBaseNextProcessFlowWhenWrong{get;set;}

///<summary>
///处理
///</summary>
///<paramname="dataContext"></param>
publicvoidProcess(DataContextdataContext)
{
this.ProcessTemplate(dataContext);
this.RecordLog(dataContext);
if(this.IsEnd)return;
if(this.IsRight)
{
if(this.NextProcessFlowWhenRight==default(ProcessFlowBase))return;
this.NextProcessFlowWhenRight.SetParameters(this.DbConnection,this.DbCommand,this.DbTransaction);
this.NextProcessFlowWhenRight.Process(dataContext);
}
else
{
if(this.NextProcessFlowWhenWrong==default(ProcessFlowBase))return;
this.NextProcessFlowWhenWrong.SetParameters(this.DbConnection,this.DbCommand,this.DbTransaction);
this.NextProcessFlowWhenWrong.Process(dataContext);
}
}

///<summary>
///流程处理模板方法，供子类实现
///</summary>
///<paramname="dataContext"></param>
protectedabstractvoidProcessTemplate(DataContextdataContext);

///<summary>
///记录日志，供子类实现
///</summary>
///<paramname="dataContext"></param>
protectedvirtualvoidRecordLog(DataContextdataContext)
{
LogHelper.Record(dataContext);
}

///<summary>
///结束本次流程
///</summary>
protectedvoidEndProcessFlow()
{
this.IsEnd=true;
}

///<summary>
///确定下一流程，后续候选流程名单在调用构造函数的时候已经初始化好
///</summary>
///<paramname="rightFlowOrWrongFlow"></param>
protectedvoidSetNextFlow(RightFlowOrWrongFlowrightFlowOrWrongFlow)
{
this.IsRight=rightFlowOrWrongFlow==RightFlowOrWrongFlow.Right;
}

///<summary>
///回滚操作流程
///</summary>
protectedvoidRollBackProcessFlow()
{
this.DbTransaction.Rollback();
this.DbConnection.Close();
}

///<summary>
///提交事物操作
///</summary>
protectedvoidCommitProcessFlow()
{
this.DbTransaction.Commit();
this.DbConnection.Close();
}

///<summary>
///设置下一流程单例属性
///</summary>
///<paramname="param"></param>
privatevoidSetParameters(paramsobject[]param)
{
vardbConnection=param[0]asIDbConnection;
vardbCommand=param[1]asIDbCommand;
vardbTransaction=param[2]asIDbTransaction;
this.DbConnection=dbConnection;
this.DbCommand=dbCommand;
this.DbTransaction=dbTransaction;
}
}

///<summary>
///检验授权码流程，此流程应当作为所有业务流程的入口流程。会在此类中做一些特别的处理
///</summary>
publicclassCheckToken:ProcessFlowBase
{
publicCheckToken(ProcessFlowBaseprocessFlowWhenRight=default(ProcessFlowBase),
ProcessFlowBaseprocessFlowWhenWrong=default(ProcessFlowBase))
:base(processFlowWhenRight,processFlowWhenWrong)
{
//这个流程作为所有业务处理的入口流程，所以，我在这里要写入一段初始化流程事务对象的代码，仅执行一次
base.DbConnection=LogHelper.CreateDbConnection();
base.DbConnection.Open();
base.DbCommand=base.DbConnection.CreateCommand();
base.DbTransaction=base.DbConnection.BeginTransaction();
}

protectedoverridevoidProcessTemplate(DataContextdataContext)
{
//查询授权码是否存在
varsbSelectSql=newStringBuilder();
sbSelectSql.AppendFormat(@"SomeSQLHere",dataContext.AuthCode,dataContext.PartCode);
dataContext.SQL=base.DbCommand.CommandText=sbSelectSql.ToString();
varany=Convert.ToInt32(base.DbCommand.ExecuteScalar());
if(any>0)
{
base.SetNextFlow(RightFlowOrWrongFlow.Right);
}
else
{
dataContext.StatusCode="1001";
base.RollBackProcessFlow();
base.EndProcessFlow();
}
}

///<summary>
///记录日志
///</summary>
///<paramname="dataContext"></param>
protectedoverridevoidRecordLog(DataContextdataContext)
{
}
}

///<summary>
///读取包含数据的XML文件
///</summary>
publicclassLoadXElement:ProcessFlowBase
{
publicLoadXElement(ProcessFlowBaseprocessFlowWhenRight=default(ProcessFlowBase),ProcessFlowBaseprocessFlowWhenWrong=default(ProcessFlowBase))
:base(processFlowWhenRight,processFlowWhenWrong){}

protectedoverridevoidProcessTemplate(DataContextdataContext)
{
try
{
using(varmemoryStream=newMemoryStream(dataContext.Buffer))
{
dataContext.DataXElement=XElement.Load(memoryStream);
}
varfolderPath=HttpContext.Current.Server.MapPath("/ModuleSources/FileStore/AppFile/TunnelMeasure/Surface");
if(!Directory.Exists(folderPath))
Directory.CreateDirectory(folderPath);
varxmlPath=
string.Format(
folderPath+"/{0}_01_{1}.xml",
dataContext.PartCode,DateTime.Now.ToString("yyyy-MM-ddHH-mm-ss"));
using(varfileStream=newFileStream(xmlPath,FileMode.OpenOrCreate,FileAccess.ReadWrite))
{
dataContext.DataXElement.Save(fileStream);
}
dataContext.XMLPath=xmlPath;
}
catch(Exception)
{
//读取文件流失败
dataContext.StatusCode="1002";
base.RollBackProcessFlow();
base.EndProcessFlow();
return;
}
base.SetNextFlow(RightFlowOrWrongFlow.Right);
}
}