1.BLL业务逻辑代码
/// <summary> /// 处理“店铺竞品销售数据”导入文件 /// </summary> /// <param name="filePath">文件物理路径</param> /// <param name="ownerId">品牌Id</param> /// <param name="saleYM">竞品数据销售年月</param> /// <param name="msg">处理过程中出现的错误消息</param> /// <returns></returns> public bool HandleImportExcel(string filePath, string ownerId, string saleYM, out string msg) { using (DaoTransactionScope ts = new DaoTransactionScope(true)) { msg = ""; // 返回给UI层的错误消息 #region 1.0 设置连接Excel组件的连接字符串 // 获取导入文件的扩展名 string fileExt = Path.GetExtension(filePath).ToLower(); // Excel组件连接字符串 string excelConnStr = string.Empty; if (fileExt.Equals(".xlsx")) { // "HDR=Yes;" 表示第一行是标题行, 不是数据。"HDR=No;" 则表示从第一行开始就是数据。 excelConnStr = string.Format(@"Provider=Microsoft.ACE.OLEDB.12.0;Data Source={0};Extended Properties='Excel 12.0;HDR=No;IMEX=1'", filePath); } else if (fileExt.Equals(".xls")) { excelConnStr = string.Format(@"Provider=Microsoft.Jet.OLEDB.4.0;Data Source={0};Extended Properties='Excel 8.0;HDR=No;IMEX=1'", filePath); } else { // "不是Excel文件，请重新选择文件导入！"; msg = this.GetResourceString("NotExcelFile"); return false; } #endregion string loginUser = this.LoginUser; // 总部营业日期 string hqAccountDate = Convert.ToDateTime(new BLSystemInfo().GetSysValue(2033, 1)).ToString("yyyyMM"); DLSalesOtherMakerSearch dal = new DLSalesOtherMakerSearch(); OleDbConnection oleConn = null; // 连接Excel文件的连接对象 DataSet ds = null; DataTable dtExcel = null; // 存储Excel文件数据的内存表 DataTable dtInsert = null; // 存储处理后的Excel文件数据的内存表 try { #region 2.0 通过OleDbConnection对象从Excel文件中获取数据并存放在内存DataTable中（变量：dtExcel） oleConn = new OleDbConnection(excelConnStr); oleConn.Open(); DataTable schemaTable = oleConn.GetOleDbSchemaTable(OleDbSchemaGuid.Tables, null); // 获取Excel中sheet名称 string tableName = string.Format("[{0}]", schemaTable.Rows[0][2].ToString().Trim()); string sql = string.Format("select * from {0}", tableName); ds = new DataSet(); using (OleDbDataAdapter adapter = new OleDbDataAdapter(sql, oleConn)) { adapter.Fill(ds, tableName); } // 第1，2,3行都是标题行 dtExcel = ds.Tables[tableName]; if (dtExcel.Rows.Count <= 3) { // "选择的文件没有需要导入的数据，请重新选择文件导入！"; msg = this.GetResourceString("ExcelFileNoData"); return false; } // 判断Excel中是否存在相同的店铺号，若存在则提示用户，不导入 // 根据店号进行分组 var storeList = from s in dtExcel.AsEnumerable() where s.Field<string>(0) != null group s by new { f = s.Field<string>(0).ToUpper() } into g select new { StoreId = g.Key.f, StoreCount = g.Count() }; // 查出有多行店号的数据 storeList = storeList.Where(item => item.StoreCount > 1); if (storeList.Count() > 0) { string storeIds = string.Empty; storeList.ToList().ForEach(item => storeIds += item.StoreId + ","); // [{0}]店铺存在多行销售数据，请删除多余行的数据，每个店铺只保留一行！ msg = this.GetResourceString("StoreSalesDataRepeated", storeIds.Substring(0, storeIds.Length - 1)); return false; } #endregion #region 3.0 判断Excel表中的数据是否合法并转换存放在符合数据库表结构的内存表中（变量：dtInsert） // 创建要插入到数据库中的内存表dtInsert dtInsert = dal.GetOtherMakerSaleTblScheme(); // Excel中的第三行是竞品品牌名称，故从第四行开始循环遍历dtExcel（注意下标为3） DataRow rowExcel; DataRow rowInsert; // 获取所有竞品品牌主档数据 List<OtherMakerMasTbl> otherMakerMasList = dal.GetOtherMakerMasList(); if (otherMakerMasList == null || otherMakerMasList.Count <= 0) { // 没有竞品品牌主档数据，请联系系统管理员重新导入！ msg = this.GetResourceString("OtherMakerMasDataNotExist"); return false; } // 循环遍历Excel中的第三行竞品品牌名称，获取对应的竞品品牌代码，并替换掉竞品品牌名称 // 从第二列开始循环遍历竞品品牌 OtherMakerMasTbl otherMakerMasModel = null; string notExistOtherMakerStr = string.Empty; Dictionary<string, string> dicOtherMakerMas = new Dictionary<string, string>(); for (int j = 1; j < dtExcel.Columns.Count; j++) { otherMakerMasModel = otherMakerMasList.SingleOrDefault(item => item.OtherMakerNm.Trim().Equals(dtExcel.Rows[2][j].ToString().Trim())); if (otherMakerMasModel == null) { // 在竞品品牌主档中未找到 {0} 该品牌对应的数据，请仔细核对数据重新导入！ //msg = this.GetResourceString("OtherMakerNotFound", dtExcel.Rows[2][j].ToString().Trim()); notExistOtherMakerStr += "[" + dtExcel.Rows[2][j].ToString().Trim() + "],"; } else { dicOtherMakerMas.Add(otherMakerMasModel.OtherMakerCd, otherMakerMasModel.OtherMakerNm.Trim()); dtExcel.Rows[2][j] = otherMakerMasModel.OtherMakerCd; } } if (!string.IsNullOrEmpty(notExistOtherMakerStr)) { msg = this.GetResourceString("OtherMakerNotFound", notExistOtherMakerStr.Substring(0, notExistOtherMakerStr.Length - 1)); return false; } for (int i = 3; i < dtExcel.Rows.Count; i++) { rowExcel = dtExcel.Rows[i]; // 从第二列开始循环遍历竞品品牌 for (int j = 1; j < dtExcel.Columns.Count; j++) { // 如果店号为空，则Continue if (dtExcel.Rows[i][0] == null || string.IsNullOrEmpty(dtExcel.Rows[i][0].ToString())) { continue; } // 如果金额数字为空，则Continue if (dtExcel.Rows[i][j] == null || string.IsNullOrEmpty(dtExcel.Rows[i][j].ToString())) { continue; } rowInsert = dtInsert.NewRow(); rowInsert["OwnerId"] = ownerId; rowInsert["CustomerCd"] = dtExcel.Rows[i][0]; rowInsert["OtherMakerCd"] = dtExcel.Rows[2][j].ToString(); rowInsert["OtherSaleYM"] = saleYM; try { rowInsert["OtherSaleMoney"] = Convert.ToDecimal(dtExcel.Rows[i][j]); } catch (Exception) { // 店号为{0}的竞品品牌{1}填写的金额数字{2}有误，请重新导入 msg += this.GetResourceString("SaleAmoutError", dtExcel.Rows[i][0], dicOtherMakerMas[dtExcel.Rows[2][j].ToString()], dtExcel.Rows[i][j]) + "<br/>"; continue; } rowInsert["SCHInput"] = "1"; rowInsert["DayEndNo"] = dtExcel.Rows[i][0] + hqAccountDate; rowInsert["BCCD"] = loginUser; rowInsert["UpdateMan"] = loginUser; rowInsert["UpdateTime"] = DateTime.Now; rowInsert["Origsys"] = "2"; dtInsert.Rows.Add(rowInsert); } } if (!string.IsNullOrEmpty(msg)) { return false; } #endregion #region 4.0 创建数据库临时表#temp，并把dtInsert内存表中的数据插入到临时表，再判断数据有效性并导入到正式表中 msg = dal.InsertOtherMakerSaleToTempTable(dtInsert); if (!string.IsNullOrEmpty(msg)) { return false; } #endregion } catch (Exception) { throw; } finally { #region 资源释放 if (oleConn != null) { oleConn.Dispose(); oleConn.Close(); } if (dtInsert != null) { dtInsert.Dispose(); } if (dtExcel != null) { dtExcel.Dispose(); } if (ds != null) { ds.Dispose(); } #endregion } ts.Complete(); return true; } }