前段时间，我负责一款APP的接口开发，其中有一个新增的操作，逻辑比较复杂，涉及到9个数据表的数据改动，而且表又跨库，这9个表呢，个别在别处还有单表操作，所以为了复用之前的数据层，笔者直接想到了使用分布式事务TransactionScope，在业务层直接调用多个DAO类的方法。
{ "data": { "customer": { "CustomerName": "Ikki里", "Mobile": "13988888888", "Address": " " }, "product": { "Name": "", "CPU": "", "Color": 0 }, "productCI": [ "1,2", "2,1", "3,0" ], "productCheck": [ "227,", "231,A+" ], "productPic": [ { "ViewUrl": "http://imageup.xxxx.com/xxxxx/09/03/85b9213e-7bf3-4312-b59f-276ea0f9ac70_901.png", "ImgText": "左前", "PicPath": "/xxxx/09/03/85b9213e-7bf3-4312-b59f-276ea0f9ac70_{0}.png", "DictID": 349 } ], "productPrice": { "PriceMax": "66.0", "PriceMin": "1.0", "Note": "abc", }, } }
private string Add(HttpContext context)
{
string result = string.Empty;
using (System.Transactions.TransactionScope scope = new System.Transactions.TransactionScope())
{
#region 1、客户资料
CustomerDao.Add();
or CustomerDao.Update ();
#endregion
#region 2、产品信息，
ProductDao.Add();
or ProductDao.Update ();
#endregion
#region 4、图片信息
PicDao.Add();
or PicDao.Update ();
#endregion
#region 5、回收价格
PriceDao.Add();
or PriceDao.Update ();
#endregion
#region 3、产品描述信息
ProductDesDao.Add();
or ProductDesDao.Update ();
#endregion
scope.Complete();
result = ERP.Common.Json.JsonHelper.ReturnJson(1, "保存成功！");
}
return result;
}
难道真的要把每个DAO下的方法复制粘贴出来，然后拼SQL，对参数？简直难以想像，那样还意味着以后要维护两套DAO方法，并且是同一功能。关键是明天早上是必须要交付给客户的，现在已经晚上快10点了...
1 public ResultModel SaveAll(Dictionary<string, object> dicParam)
2 {
3 ResultModel ret = new ResultModel();
4 ret.Status = 0;
5 ret.Message = "";
6 lock (padlock)
7 {
8 IDbTransaction trans = null;
9 try
10 {
11 using (var conn = new SqlConnection(DbConnString))
12 {
13 conn.Open();
14 trans = conn.BeginTransaction();
15 Dictionary<string, object> _param = new Dictionary<string, object>();
16 var sql = string.Empty;
17 var countSql = string.Empty;
18 var delSql = string.Empty;
19 //1、客户资料
20 int sellerId = 0;
21 _param = (Dictionary<string, object>)dicParam["sellerCarInfo"];
22 SellerCarInfoModel sellerModel = (SellerCarInfoModel)_param["model"];
23 sql = _param["sql"].ToString();
24 if (sellerModel.ID > 0)
25 {
26 conn.Execute(sql.ToString(), sellerModel, trans);
27 sellerId = sellerModel.ID;
28 }
29 else {
30 countSql = _param["countSql"].ToString();
31 int cnt = conn.ExecuteScalar<int>(countSql, null, trans);
32 sellerModel.CustomerNo = string.Format("PC{0}{1}", DateTime.Now.ToString("yyMMdd"), (cnt + 1).ToString().PadLeft(4, ‘0‘));
33 sellerId =conn.ExecuteScalar<int>(sql.ToString(), sellerModel, trans);
34 }
35 DebugLog("1、客户资料", sql, sellerModel);
36 //2、车辆信息，不含车况
37 //1),基本信息，手续信息、图片信息、配置信息
38 int carId = 0;
39 _param = (Dictionary<string, object>)dicParam["carBaseInfo"];
40 CarBaseInfoModel carBaseInfoModel = (CarBaseInfoModel)_param["model"];
41 sql = _param["sql"].ToString();
42 if (carBaseInfoModel.ID > 0)
43 {
44 conn.Execute(sql.ToString(), carBaseInfoModel, trans);
45 carId = carBaseInfoModel.ID;
46 }
47 else
48 {
49 carId = conn.ExecuteScalar<int>(sql.ToString(), carBaseInfoModel, trans);
50 }
51 DebugLog("2、车辆基本信息，手续信息", sql, carBaseInfoModel);
52 //2)配置信息
53 _param = (Dictionary<string, object>)dicParam["carCi"];
54 List<CarCIModel> listCi = (List<CarCIModel>)_param["list"];
55 sql = _param["insertSql"].ToString();
56 delSql= _param["delSql"].ToString();
57 if (listCi.Count > 0) {
58 conn.ExecuteScalar(string.Format(delSql, carId),null,trans);
59 foreach (var item in listCi)
60 {
61 item.CarID = carId;
62 conn.ExecuteScalar(sql, item, trans);
63 }
64 }
65 //3)图片信息
66 _param = (Dictionary<string, object>)dicParam["carPic"];
67 List<AssessImageModel> listPic = (List<AssessImageModel>)_param["list"];
68 sql = _param["insertSql"].ToString();
69 delSql = _param["delSql"].ToString();
70 if (listPic.Count > 0)
71 {
72 conn.ExecuteScalar(string.Format(delSql, carId), null, trans);
73 foreach (var item in listPic)
74 {
75 item.CarInfoID = carId;
76 conn.ExecuteScalar(sql, item, trans);
77 }
78 }
79 //3、 [PingguCarInfo] 车冗余表信息
80 int redundanceCarId = 0;
81 _param = (Dictionary<string, object>)dicParam["pingguCarInfo"];
82 PingguCarInfo pingguCarInfo = (PingguCarInfo)_param["model"];
83 sql = _param["sql"].ToString();
84 if (pingguCarInfo.Id > 0)
85 {
86 conn.Execute(sql.ToString(), pingguCarInfo, trans);
87 redundanceCarId = pingguCarInfo.Id;
88 }
89 else
90 {
91 redundanceCarId = conn.ExecuteScalar<int>(sql.ToString(), pingguCarInfo, trans);
92 }
93 DebugLog("3、 [PingguCarInfo] 车冗余表信息", sql, pingguCarInfo);
94 //4、创建评估单
95 int pingguId = 0;
96 _param = (Dictionary<string, object>)dicParam["pingguOrder"];
97 PingguOrderModel pingguOrder = (PingguOrderModel)_param["model"];
98 pingguOrder.CarInfoId = carId;
99 pingguOrder.SellerId = sellerId;
100 pingguOrder.RedundanceCarId = redundanceCarId;
101 sql = _param["sql"].ToString();
102 countSql = _param["countSql"].ToString();
103 int _cnt = conn.ExecuteScalar<int>(countSql, null, trans);
104 pingguOrder.PingguNo = string.Format("A{0}{1}", DateTime.Now.ToString("yyyyMMdd"), (_cnt + 1).ToString().PadLeft(4, ‘0‘));
105 pingguId =conn.ExecuteScalar<int>(sql.ToString(), pingguOrder, trans);
106 DebugLog("4、创建评估单", sql, pingguOrder);
107 //5、车况检测信息
108 _param = (Dictionary<string, object>)dicParam["carCheck"];
109 List<CarCheckItemsModel> listCheck = (List<CarCheckItemsModel>)_param["list"];
110 sql = _param["insertSql"].ToString();
111 delSql = _param["delSql"].ToString();
112 if (listCheck.Count > 0)
113 {
114 conn.ExecuteScalar(string.Format(delSql, pingguId), null, trans);
115 foreach (var item in listCheck)
116 {
117 item.CarId = pingguId;
118 conn.ExecuteScalar(sql, item, trans);
119 }
120 }
121
122 //6、保存CarStoreAssociation关系
123 _param = (Dictionary<string, object>)dicParam["carStoreAss"];
124 Model.CarManage.CarStoreAssociation carStore = (Model.CarManage.CarStoreAssociation)_param["model"];
125 sql = _param["sql"].ToString();
126 carStore.CarID = carId;
127 conn.ExecuteScalar(sql.ToString(), carStore, trans);
128 DebugLog("6、保存CarStoreAssociation关系", sql, carStore);
129 ret.Status = 1;
130 ret.Message = "";
131 // throw new Exception();
132 trans.Commit();
133 }
134 }
135 catch (Exception ex)
136 {
137 ret.Status = 500;
138 ret.Message = ex.Message;
139 Log4NetHelper.Error("APP保存车辆信息时出错：" + ex.Message, ex);
140 trans.Rollback();
141 }
142 }
143 return ret;
144 }
现在想想，其实就是一个思路的问题，并没有什么难点，项目代码就不贴了，如果真有需要，留下个邮箱好了
原文：http://www.cnblogs.com/net515/p/5922608.html