开发.Net平台应用系统框架--实践

Product.xml
<?xml version="1.0" encoding="gb2312" ?>
<Entity>
<EntityTypeName>Product</EntityTypeName>
<TableName>Product</TableName>
<Columns>
<Column Name="ProductID" DataType="System.String" IsKey="true"></Column>
<Column Name="ProductName" DataType="System.String" IsKey="false"></Column>
<Column Name="ProductTypeID" DataType="System.String" IsKey="false"></Column>
<Column Name="CurrentCount" DataType="System.Decimal" IsKey="false"></Column>
<Column Name="UnitName" DataType="System.String" IsKey="false"></Column>
</Columns>
<RefTable Type="Parent">
<TableName>ProductType</TableName>
<ForeignKey>ProductTypeID</ForeignKey>
<PrimaryKey>ProductTypeID</PrimaryKey>
<Columns>
<Column Name="ProductTypeID" DataType="System.String" IsKey="true"></Column>
<Column Name="ProductTypeName" DataType="System.String" IsKey="false"></Column>
</Columns>
</RefTable>
</Entity>

InDepotForm.xml
<?xml version="1.0" encoding="gb2312" ?>
<Entity>
<EntityTypeName>InDepotForm</EntityTypeName>
<TableName>InDepotForm</TableName>
<Columns>
<Column Name="InDepotID" DataType="System.String" IsKey="true"></Column>
<Column Name="InDepotTime" DataType="System.DateTime" IsKey="false"></Column>
</Columns>
<RefTable Type="Child">
<TableName>InDepotFormDetail</TableName>
<ForeignKey>InDepotID</ForeignKey>
<PrimaryKey>InDepotID</PrimaryKey>
<Columns>
<Column Name="InDepotDetailID" DataType="System.String" IsKey="true"></Column>
<Column Name="InDepotID" DataType="System.String" IsKey="false"></Column>
<Column Name="ProductID" DataType="System.String" IsKey="false"></Column>
<Column Name="InCount" DataType="System.Decimal" IsKey="false"></Column>
</Columns>
</RefTable>
</Entity>

EntityData entity=EntityDataManager.GetEmptyEntity("InDepotForm ");

public class InDepotFormEntityDAO: IEntityDAO
{
private DBCommon db;  //数据访问对象
……//略去构造函数部分。这个部分会建立数据库的连接。
// 插入一个实体
public void InsertEntity(EntityData entity)
{
CheckData(entity);
db.BeginTrans();
try
{
//插入父表内容
foreach(DataRow row in entity.Tables["InDepotForm"].Rows)
db.exeSql(row,SqlManager.GetSqlStruct("InDepotForm","InsertInDepotForm"));
//插入子表内容。如果是细粒度对象，则不会有这段代码。
foreach(DataRow row in entity.Tables["InDepotFormDetail"].Rows)
db.exeSql(row,SqlManager.GetSqlStruct("InDepotForm","InsertInDepotFormDetail"));
//如果没有错误，完成事务处理
db.CommitTrans();
}
catch(Exception e)
{
//否则，回滚事务
db.RollbackTrans();
throw e;
}
}
//修改实体
public void UpdateEntity(EntityData entity){//代码略}
//删除实体
public void DeleteEntity(EntityData entity){//代码略}
//查找实体
public EntityData FindByPrimaryKey(object KeyValue)	{//代码略	}
// 校验数据数据输入的有效性
private void CheckData(EntityData entity){//代码略}

…….//略去其余代码
}

//设置事务处理类型
[Transaction(TransactionOption.Required)]
//继承ServicedComponent，以支持使用Windows的Transaction Service
public class Wharehouse : System.EnterpriseServices.ServicedComponent
{
public Wharehouse(){}
//入库的业务逻辑代码
public void StoreIntoWarehouse(EntityData IndepotForm)
{
//得到入库单明细
DataTable tbl=IndepotForm.Tables["InDepotFormDetail"];
try
{
//对于入库单明细中的每个产品，都要修改原有产品的库存数量
ProductEntityDAO ped=new ProductEntityDAO();
for(int i=0;i<tbl.Rows.Count;i++)
{
//得到入库单明细的一个产品信息
DataRow formdetail=tbl.Rows[i];
string productID=formdetail["ProductID"].ToString();
decimal inCount=(decimal)formdetail["InCount"];
//找到需要修改库存数量的产品
EntityData product=ped.FindByPrimaryKey(productID);
DataRow productRow=product.GetRecord("Product");
//修改产品库存数量
productRow["CurrentCount"]=(decimal)productRow["CurrentCount"]+inCount;
ped.UpdateEntity(product);
}
ped.Dispose();
//保存入库单
InDepotFormEntityDAO inDepotForm=new InDepotFormEntityDAO();
inDepotForm.InsertEntity(IndepotForm);
IndepotForm.Dispose();
//如果成功，结束事务
ContextUtil.SetComplete();
}
catch(Exception ee)
{
//否则，回滚事务
ContextUtil.SetAbort();
throw ee;
}
}
}

//类设计成sealed,不能被继承
public sealed class WharehouseManagement
{
//采用Singleton设计模式，私有的构造函数，使得类不能直接实例化，
//只能调用静态的StoreProductIntoWharehouse方法。
private WharehouseManagement()
{
}
public static void StoreProductIntoWharehouse(EntityData entity)
{
Wharehouse house=new Wharehouse();
house.StoreIntoWarehouse(entity);
}
}

private void btnAdd_Click(object sender, System.EventArgs e)
{
//得到一个InDepotForm实例
EntityData entity=EntityDataManager.GetEmptyEntity("InDepotForm");
DataRow row=entity.GetNewRecord("InDepotForm");
//设置入库单主信息
row["InDepotID"]=valInDepotID.Text;
row["InDepotTime"]=System.DateTime.Parse(valInDepotTime.Text);
entity.AddNewRecord(row,"InDepotForm");
//设置入库单明细信息，这是从DataGrid中读取得
DataTable detail=entity.Tables["InDepotFormDetail"];
for(int i=0;i<gridDetail.Items.Count;i++)
{
DataRow rowdetail=detail.NewRow();
rowdetail["InDepotID"]=valInDepotID.Text;
rowdetail["InDepotDetailID"]=gridDetail.Items[i].Cells[0].Text;
rowdetail["ProductID"]=gridDetail.Items[i].Cells[1].Text;
rowdetail["InCount"]=decimal.Parse(gridDetail.Items[i].Cells[2].Text.Trim());
detail.Rows.Add(rowdetail);
}
//执行入库操作
WharehouseManagement.StoreProductIntoWharehouse(entity);
}