记一次代码重构

      前段时间，我负责一款APP的接口开发，其中有一个新增的操作，逻辑比较复杂，涉及到9个数据表的数据改动，而且表又跨库，这9个表呢，个别在别处还有单表操作，所以为了复用之前的数据层，笔者直接想到了使用分布式事务TransactionScope，在业务层直接调用多个DAO类的方法。

        再说下这个新增操作吧，这个APP是用来回收某产品的，所以这个新增操作是创建一个二手产品的订单，首页是五个项目，如图（下图中各具体项只是为说明数据结构），

         

        资料从左向右填写，每次填完信息暂存在本地，点创建回收订单，信息提交到后台接口，其中【产品信息】下的配置信息和【产品描述】【图片信息】的全部信息采用配置字典表分别存储，产品描述关联到订单，而配置信息和图片则关联到产品。全部本地信息以JSON格式提交，格式如下

{
    "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",
        },
       
      
    }
}

 

       一切进行得还算顺利，但当把程序部署到正式环境时，问题出现了，提示分布式事务未被初始化之类的错误，具体想不起来了，尝试了网上的一些解决方法，比如本地DTC的一些设置，但都无效果，最后只好放弃了，又想到两个解决方案，第一，在DAO层中重写一个大的方法，包含全部的数据操作方法，在DAO类中DbTransaction 事务；第二，使用存储过程，但想到要给存储过程传这么多参数进去，我还是放弃了。好吧，就按第一种解决思路来。

        重构的定义是在不改变系统的外部功能的前提下，只对内部的结构进行重新的整理，换到我现在的环境就是APP已经开发测试完成，所以我的接口的任何改变都不应该让APP感觉到我的变化，接下来我做的事就是对现在的代码重构，顿时觉得自己做一件很高大上的事，哈哈。

       先说下之前的操作方法吧，代码太多了，我就简单示例下    

  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点了...

        终于想到一个比较靠谱，又敏捷的方法，为了保险，我新建一个类，专门用来组织SQL和参数，把原来的DAO方法复制到这个类中，然后不执行SQL，而是用一个字典返回SQL+参数，这样在上层调用接收到这个字典，用字典的原因是由于每个DAO方法的参数类型不同，这样方便接收。把所有5个要执行的操作都接收完成后，再写一个总的保存方法，这个方法里可以用IDbTransaction事务来保证安全。原来的单个表操作的方法也可以直接用这样的方式来调用保存，不受影响，最重要的是APP端不用做任务的改动。

      总的保存方法如下：

 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
 {  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、客户资料
                        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),基本信息，手续信息、图片信息、配置信息
                        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
 {  49                             carId = conn.ExecuteScalar<int>(sql.ToString(), carBaseInfoModel, trans);  50  }  51                         DebugLog("2、车辆基本信息，手续信息", sql, carBaseInfoModel);  52                         //2)配置信息
                        _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)图片信息
                        _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] 车冗余表信息
                        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
 {  91                             redundanceCarId = conn.ExecuteScalar<int>(sql.ToString(), pingguCarInfo, trans);  92  }  93                         DebugLog("3、 [PingguCarInfo] 车冗余表信息", sql, pingguCarInfo);  94                         //4、创建评估单
                        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、车况检测信息
                        _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                     
                        //6、保存CarStoreAssociation关系 
                        _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();
 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         }

       现在想想，其实就是一个思路的问题，并没有什么难点，项目代码就不贴了，如果真有需要，留下个邮箱好了