添加客户信息导入

codegit/CallCenterApi/CallCenterApi.BLL/T_Cus_CustomerBase.cs

@@ -147,7 +147,22 @@ namespace CallCenterApi.BLL
         //{
         //return dal.GetList(PageSize,PageIndex,strWhere);
         //}
+        /// <summary>
+        /// 是否存在该记录
+        /// </summary>
+        public bool PhoneExists(string F_Mobile)
+        {
+            return dal.PhoneExists(F_Mobile);
+        }
 
+        /// <summary>
+        /// 删除一条数据
+        /// </summary>
+        public bool PhoneDelete(string F_Mobile)
+        {
+
+            return dal.PhoneDelete(F_Mobile);
+        }
         #endregion  BasicMethod
         #region  ExtensionMethod
 

codegit/CallCenterApi/CallCenterApi.BLL/T_Cus_CustomerExport.cs

@@ -0,0 +1,124 @@
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace CallCenterApi.BLL
+{
+    /// <summary>
+	/// T_Cus_CustomerBase
+	/// </summary>
+	public partial class T_Cus_CustomerExport
+    {
+        private readonly CallCenterApi.DAL.T_Cus_CustomerExport dal = new CallCenterApi.DAL.T_Cus_CustomerExport();
+        public T_Cus_CustomerExport()
+        { }
+        #region  BasicMethod
+        /// <summary>
+        /// 增加一条数据
+        /// </summary>
+        public int Add(CallCenterApi.Model.T_Cus_CustomerExport model)
+        {
+            return dal.Add(model);
+        }
+
+        /// <summary>
+        /// 删除一条数据
+        /// </summary>
+        public bool Delete(int F_FileID)
+        {
+
+            return dal.Delete(F_FileID);
+        }
+        /// <summary>
+        /// 删除一条数据
+        /// </summary>
+        public bool DeleteList(string F_FileIDlist)
+        {
+            return dal.DeleteList(F_FileIDlist);
+        }
+
+        /// <summary>
+        /// 得到一个对象实体
+        /// </summary>
+        public CallCenterApi.Model.T_Cus_CustomerExport GetModel(int F_FileID)
+        {
+
+            return dal.GetModel(F_FileID);
+        }
+
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public DataSet GetList(string strWhere)
+        {
+            return dal.GetList(strWhere);
+        }
+        /// <summary>
+        /// 获得前几行数据
+        /// </summary>
+        public DataSet GetList(int Top, string strWhere, string filedOrder)
+        {
+            return dal.GetList(Top, strWhere, filedOrder);
+        }
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public List<CallCenterApi.Model.T_Cus_CustomerExport> GetModelList(string strWhere)
+        {
+            DataSet ds = dal.GetList(strWhere);
+            return DataTableToList(ds.Tables[0]);
+        }
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public List<CallCenterApi.Model.T_Cus_CustomerExport> DataTableToList(DataTable dt)
+        {
+            List<CallCenterApi.Model.T_Cus_CustomerExport> modelList = new List<CallCenterApi.Model.T_Cus_CustomerExport>();
+            int rowsCount = dt.Rows.Count;
+            if (rowsCount > 0)
+            {
+                CallCenterApi.Model.T_Cus_CustomerExport model;
+                for (int n = 0; n < rowsCount; n++)
+                {
+                    model = dal.DataRowToModel(dt.Rows[n]);
+                    if (model != null)
+                    {
+                        modelList.Add(model);
+                    }
+                }
+            }
+            return modelList;
+        }
+
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public DataSet GetAllList()
+        {
+            return GetList("");
+        }
+
+        /// <summary>
+        /// 分页获取数据列表
+        /// </summary>
+        public int GetRecordCount(string strWhere)
+        {
+            return dal.GetRecordCount(strWhere);
+        }
+        /// <summary>
+        /// 分页获取数据列表
+        /// </summary>
+        public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
+        {
+            return dal.GetListByPage(strWhere, orderby, startIndex, endIndex);
+        }
+
+        #endregion  BasicMethod
+        #region  ExtensionMethod
+
+        #endregion  ExtensionMethod
+    }
+}

codegit/CallCenterApi/CallCenterApi.DAL/T_Cus_CustomerBase.cs

@@ -126,7 +126,7 @@ namespace CallCenterApi.DAL
                     new SqlParameter("@F_RelationShipClassID", SqlDbType.Int,4),
                     new SqlParameter("@F_CityID", SqlDbType.Int,4),
                     new SqlParameter("@F_AutoFlag", SqlDbType.SmallInt,2),
-                    new SqlParameter("@F_Result", SqlDbType.NVarChar,20)
+                    new SqlParameter("@F_Result", SqlDbType.NVarChar,100)
             };
             parameters[0].Value = model.F_CustomerName;
             parameters[1].Value = model.F_CustomerCode;
@@ -815,6 +815,15 @@ namespace CallCenterApi.DAL
                 {
                     model.F_CityID = int.Parse(row["F_CityID"].ToString());
                 }
+                //2017-11-2
+                if (row["F_AutoFlag"] != null && row["F_AutoFlag"].ToString() != "")
+                {
+                    model.F_AutoFlag = int.Parse(row["F_AutoFlag"].ToString());
+                }
+                if (row["F_Result"] != null)
+                {
+                    model.F_Result = row["F_Result"].ToString();
+                }
             }
             return model;
         }
@@ -927,6 +936,48 @@ namespace CallCenterApi.DAL
 			return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
 		}*/
 
+        //2017-11-2
+        /// <summary>
+        /// 是否存在该记录
+        /// </summary>
+        public bool PhoneExists(string  F_Mobile)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select count(1) from T_Cus_CustomerBase");
+            strSql.Append(" where F_Mobile=@F_Mobile");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_Mobile", SqlDbType.NVarChar,100)
+            };
+            parameters[0].Value = F_Mobile;
+
+            return DbHelperSQL.Exists(strSql.ToString(), parameters);
+        }
+
+        /// <summary>
+        /// 根据手机号删除一条数据
+        /// </summary>
+        public bool PhoneDelete(string F_Mobile)
+        {
+
+            StringBuilder strSql = new StringBuilder();
+            //strSql.Append("delete from T_Cus_CustomerBase ");
+            strSql.Append("update T_Cus_CustomerBase set F_DeleteFlag=1");
+            strSql.Append(" where F_Mobile=@F_Mobile");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_Mobile", SqlDbType.NVarChar,100)
+            };
+            parameters[0].Value = F_Mobile;
+
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
+            if (rows > 0)
+            {
+                return true;
+            }
+            else
+            {
+                return false;
+            }
+        }
         #endregion  BasicMethod
         #region  ExtensionMethod
 

codegit/CallCenterApi/CallCenterApi.DAL/T_Cus_CustomerExport.cs

@@ -0,0 +1,279 @@
+using CallCenterApi.DB;
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Data.SqlClient;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace CallCenterApi.DAL
+{
+    /// <summary>
+	/// 数据访问类:T_Cus_CustomerExport
+	/// </summary>
+	public partial class T_Cus_CustomerExport
+    {
+        public T_Cus_CustomerExport()
+        { }
+        #region  BasicMethod
+
+        /// <summary>
+        /// 增加一条数据
+        /// </summary>
+        public int Add(CallCenterApi.Model.T_Cus_CustomerExport model)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("insert into T_Cus_CustomerExport(");
+            strSql.Append("F_TypeGroup,F_FileOldName,F_FileNewName,F_FilePath,F_FileFix,F_FileType,F_FileSize,F_InputUserCode,F_InputUserID,F_InputDate)");
+            strSql.Append(" values (");
+            strSql.Append("@F_TypeGroup,@F_FileOldName,@F_FileNewName,@F_FilePath,@F_FileFix,@F_FileType,@F_FileSize,@F_InputUserCode,@F_InputUserID,@F_InputDate)");
+            strSql.Append(";select @@IDENTITY");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_TypeGroup", SqlDbType.Int,4),
+                    new SqlParameter("@F_FileOldName", SqlDbType.NVarChar,500),
+                    new SqlParameter("@F_FileNewName", SqlDbType.NVarChar,500),
+                    new SqlParameter("@F_FilePath", SqlDbType.NText),
+                    new SqlParameter("@F_FileFix", SqlDbType.NVarChar,50),
+                    new SqlParameter("@F_FileType", SqlDbType.Int,4),
+                    new SqlParameter("@F_FileSize", SqlDbType.Int,4),
+                    new SqlParameter("@F_InputUserCode", SqlDbType.NVarChar,50),
+                    new SqlParameter("@F_InputUserID", SqlDbType.Int,4),
+                    new SqlParameter("@F_InputDate", SqlDbType.DateTime)};
+            parameters[0].Value = model.F_TypeGroup;
+            parameters[1].Value = model.F_FileOldName;
+            parameters[2].Value = model.F_FileNewName;
+            parameters[3].Value = model.F_FilePath;
+            parameters[4].Value = model.F_FileFix;
+            parameters[5].Value = model.F_FileType;
+            parameters[6].Value = model.F_FileSize;
+            parameters[7].Value = model.F_InputUserCode;
+            parameters[8].Value = model.F_InputUserID;
+            parameters[9].Value = model.F_InputDate;
+
+            object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
+            if (obj == null)
+            {
+                return 0;
+            }
+            else
+            {
+                return Convert.ToInt32(obj);
+            }
+        }
+        /// <summary>
+        /// 删除一条数据
+        /// </summary>
+        public bool Delete(int F_FileID)
+        {
+
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("delete from T_Cus_CustomerExport ");
+            strSql.Append(" where F_FileID=@F_FileID");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_FileID", SqlDbType.Int,4)
+            };
+            parameters[0].Value = F_FileID;
+
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
+            if (rows > 0)
+            {
+                return true;
+            }
+            else
+            {
+                return false;
+            }
+        }
+        /// <summary>
+        /// 批量删除数据
+        /// </summary>
+        public bool DeleteList(string F_FileIDlist)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("delete from T_Cus_CustomerExport ");
+            strSql.Append(" where F_FileID in (" + F_FileIDlist + ")  ");
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString());
+            if (rows > 0)
+            {
+                return true;
+            }
+            else
+            {
+                return false;
+            }
+        }
+
+
+        /// <summary>
+        /// 得到一个对象实体
+        /// </summary>
+        public CallCenterApi.Model.T_Cus_CustomerExport GetModel(int F_FileID)
+        {
+
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select  top 1 F_FileID,F_TypeGroup,F_FileOldName,F_FileNewName,F_FilePath,F_FileFix,F_FileType,F_FileSize,F_InputUserCode,F_InputUserID,F_InputDate from T_Cus_CustomerExport ");
+            strSql.Append(" where F_FileID=@F_FileID");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_FileID", SqlDbType.Int,4)
+            };
+            parameters[0].Value = F_FileID;
+
+            CallCenterApi.Model.T_Cus_CustomerExport model = new CallCenterApi.Model.T_Cus_CustomerExport();
+            DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
+            if (ds.Tables[0].Rows.Count > 0)
+            {
+                return DataRowToModel(ds.Tables[0].Rows[0]);
+            }
+            else
+            {
+                return null;
+            }
+        }
+
+
+        /// <summary>
+        /// 得到一个对象实体
+        /// </summary>
+        public CallCenterApi.Model.T_Cus_CustomerExport DataRowToModel(DataRow row)
+        {
+            CallCenterApi.Model.T_Cus_CustomerExport model = new CallCenterApi.Model.T_Cus_CustomerExport();
+            if (row != null)
+            {
+                if (row["F_FileID"] != null && row["F_FileID"].ToString() != "")
+                {
+                    model.F_FileID = int.Parse(row["F_FileID"].ToString());
+                }
+                if (row["F_TypeGroup"] != null && row["F_TypeGroup"].ToString() != "")
+                {
+                    model.F_TypeGroup = int.Parse(row["F_TypeGroup"].ToString());
+                }
+                if (row["F_FileOldName"] != null)
+                {
+                    model.F_FileOldName = row["F_FileOldName"].ToString();
+                }
+                if (row["F_FileNewName"] != null)
+                {
+                    model.F_FileNewName = row["F_FileNewName"].ToString();
+                }
+                if (row["F_FilePath"] != null)
+                {
+                    model.F_FilePath = row["F_FilePath"].ToString();
+                }
+                if (row["F_FileFix"] != null)
+                {
+                    model.F_FileFix = row["F_FileFix"].ToString();
+                }
+                if (row["F_FileType"] != null && row["F_FileType"].ToString() != "")
+                {
+                    model.F_FileType = int.Parse(row["F_FileType"].ToString());
+                }
+                if (row["F_FileSize"] != null && row["F_FileSize"].ToString() != "")
+                {
+                    model.F_FileSize = int.Parse(row["F_FileSize"].ToString());
+                }
+                if (row["F_InputUserCode"] != null)
+                {
+                    model.F_InputUserCode = row["F_InputUserCode"].ToString();
+                }
+                if (row["F_InputUserID"] != null && row["F_InputUserID"].ToString() != "")
+                {
+                    model.F_InputUserID = int.Parse(row["F_InputUserID"].ToString());
+                }
+                if (row["F_InputDate"] != null && row["F_InputDate"].ToString() != "")
+                {
+                    model.F_InputDate = DateTime.Parse(row["F_InputDate"].ToString());
+                }
+            }
+            return model;
+        }
+
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public DataSet GetList(string strWhere)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select F_FileID,F_TypeGroup,F_FileOldName,F_FileNewName,F_FilePath,F_FileFix,F_FileType,F_FileSize,F_InputUserCode,F_InputUserID,F_InputDate ");
+            strSql.Append(" FROM T_Cus_CustomerExport ");
+            if (strWhere.Trim() != "")
+            {
+                strSql.Append(" where " + strWhere);
+            }
+            return DbHelperSQL.Query(strSql.ToString());
+        }
+
+        /// <summary>
+        /// 获得前几行数据
+        /// </summary>
+        public DataSet GetList(int Top, string strWhere, string filedOrder)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select ");
+            if (Top > 0)
+            {
+                strSql.Append(" top " + Top.ToString());
+            }
+            strSql.Append(" F_FileID,F_TypeGroup,F_FileOldName,F_FileNewName,F_FilePath,F_FileFix,F_FileType,F_FileSize,F_InputUserCode,F_InputUserID,F_InputDate ");
+            strSql.Append(" FROM T_Cus_CustomerExport ");
+            if (strWhere.Trim() != "")
+            {
+                strSql.Append(" where " + strWhere);
+            }
+            strSql.Append(" order by " + filedOrder);
+            return DbHelperSQL.Query(strSql.ToString());
+        }
+
+        /// <summary>
+        /// 获取记录总数
+        /// </summary>
+        public int GetRecordCount(string strWhere)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select count(1) FROM T_Cus_CustomerExport ");
+            if (strWhere.Trim() != "")
+            {
+                strSql.Append(" where " + strWhere);
+            }
+            object obj = DbHelperSQL.GetSingle(strSql.ToString());
+            if (obj == null)
+            {
+                return 0;
+            }
+            else
+            {
+                return Convert.ToInt32(obj);
+            }
+        }
+        /// <summary>
+        /// 分页获取数据列表
+        /// </summary>
+        public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("SELECT * FROM ( ");
+            strSql.Append(" SELECT ROW_NUMBER() OVER (");
+            if (!string.IsNullOrEmpty(orderby.Trim()))
+            {
+                strSql.Append("order by T." + orderby);
+            }
+            else
+            {
+                strSql.Append("order by T.F_FileID desc");
+            }
+            strSql.Append(")AS Row, T.*  from T_Cus_CustomerExport T ");
+            if (!string.IsNullOrEmpty(strWhere.Trim()))
+            {
+                strSql.Append(" WHERE " + strWhere);
+            }
+            strSql.Append(" ) TT");
+            strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
+            return DbHelperSQL.Query(strSql.ToString());
+        }
+
+        #endregion  BasicMethod
+        #region  ExtensionMethod
+
+        #endregion  ExtensionMethod
+    }
+}

codegit/CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Controllers/customer/CustomerController.cs

@@ -9,6 +9,8 @@ using System.Data;
 using CallCenter.Utility;
 using CallCenterApi.Common;
 using CallCenterApi.DB;
+using System.IO;
+using System.Data.SqlClient;
 
 namespace CallCenterApi.Interface.Controllers.customer
 {
@@ -252,5 +254,292 @@ namespace CallCenterApi.Interface.Controllers.customer
             }
             return res;
         }
+
+        //2017-11-2 导入客户信息
+        int vfileid = 0;
+        // 导入客户信息读取填入数据库
+        public ActionResult CustomerInput()
+        {
+            ActionResult res = NoToken("未知错误，请重新登录");
+            if (Request.IsAuthenticated)
+            {
+                DataTable dtres = new DataTable();
+                string errres = "";
+                int i = 0;
+                int count = 0;//导入成功的条数
+                string Excelsource = "";
+                int rcount = 0;
+                int ccount = 0;
+                System.Text.StringBuilder strBuilder = null;
+                //Excelsource = Server.MapPath(this.Request.ApplicationPath + "\\ExcelData\\") + filename.ToString();
+                Excelsource = uploadexcel();
+                #region 将文件中的数据导入数据库
+
+                try
+                {
+
+                    //************************将文件中的数据导入数据库*************************//
+                    DataSet dt = ReadEcxel(Excelsource, 0);
+                    try
+                    {
+                        if (dt != null && dt.Tables[0].Rows.Count != 0)
+                        {
+                            rcount = dt.Tables[0].Rows.Count;
+                            ccount = dt.Tables[0].Columns.Count;
+                            strBuilder = new System.Text.StringBuilder();//用于如果导入失败，删除已经导入过的
+
+                            DataTable dtInputData = dt.Tables[0];//要导入的电话号码
+                            List<string> sqlList = new List<string>();
+                            List<string> lstsql = new List<string>();
+                            int ilns = dt.Tables[0].Columns.Count;
+                            DataSet dsnew = new DataSet();
+
+
+                            #region MyRegion
+                            using (SqlConnection coon = new SqlConnection(DbHelperSQL.connectionString))
+                            {
+                                try
+                                {
+                                    coon.Open();
+                                    int colscount = dtInputData.Columns.Count;//列数
+                                    int rowscount = dtInputData.Rows.Count;//行数
+                                    Model.T_Cus_CustomerBase modelcus = new Model.T_Cus_CustomerBase();
+                                    
+                                    if (rowscount > 0)
+                                    {
+                                        foreach (DataRow dr in dtInputData.Rows)
+                                        {
+                                            sqlList.Clear();
+                                            lstsql.Clear();
+                                            if (dr[2].ToString() != "")
+                                            {
+                                                string dddddd = dr[2].ToString();
+                                                #region 导入表内容
+                                                #region 保存字段
+                                                modelcus.F_CustomerName = dr[0].ToString();//姓名
+                                                modelcus.F_Mobile= dr[1].ToString();//手机号
+                                                modelcus.F_Address = dr[2].ToString();//地址
+                                                //modelcus.F_Address = dr[3].ToString();//地址
+                                                                                      //if (dr[3].ToString() != "")
+                                                                                      //{
+                                                modelcus.F_AutoFlag = Convert.ToInt32(dr[3]);//自动标记
+                                                   // modelcus.F_AutoFlag = Utils.StrToInt(RequestString.GetFormString(dr[3].ToString()), 0);//Convert.ToInt32(dr[3].ToString());//自动标记
+                                                //}
+                                                modelcus.F_Result = dr[4].ToString();//结果统计
+                                                #endregion 保存
+                                               
+                                                
+                                                //先判断是否有此号码，若有则将删除标志置为1再添加新信息
+                                                if (new BLL.T_Cus_CustomerBase().PhoneExists(modelcus.F_Mobile))//存在则删除
+                                                {
+                                                    new BLL.T_Cus_CustomerBase().PhoneDelete(modelcus.F_Mobile);
+                                                }
+                                                int rmw = new BLL.T_Cus_CustomerBase().Add(modelcus);
+                                                if (rmw > 0)
+                                                {
+                                                    count += 1;//导入成功，+1
+                                                }
+                                                #endregion
+                                                //int rmw = new BLL.T_Vis_Telphone().Add(modelPhoneImport);
+
+                                            }
+
+                                        }
+                                        dtres = dtInputData;
+
+                                    }
+                                    else
+                                    {
+                                        errres += "该文档的内容为空";
+                                    }
+                                }
+                                catch (Exception ex)
+                                {
+                                    if (coon.State == ConnectionState.Open)
+                                    {
+                                        coon.Close();
+                                    }
+                                    i++;
+                                    errres += i.ToString() + ".导入出现异常，共导入" + count + "条数据，请从第" + (count + 2).ToString() + "行开始导入;\n";
+                                    if (strBuilder.Length > 0)
+                                    {
+                                        errres += "重复的号码为：" + strBuilder.ToString() + "\n";
+                                    }
+                                }
+                                finally
+                                {
+                                    if (coon.State == ConnectionState.Open)
+                                    {
+                                        coon.Close();
+                                    }
+                                }
+
+
+                            }//****************using*********
+
+                            #endregion
+
+                        }
+                        else
+                        {
+                            i++;
+                            errres += i.ToString() + ".Excel中无数据;\n";
+                        }
+
+                    }
+                    catch
+                    {
+                        i++;
+                        errres += i.ToString() + ".导入出现异常，导入失败;\n";
+                    }
+                    finally
+                    {
+                        dt.Clear();
+                        dt.Dispose();
+                    }
+
+                }
+                catch
+                {
+                    errres += i.ToString() + ".Excel格式不正确，系统错误，导入失败;\n";
+                }
+
+                #endregion
+                if (errres != "")
+                {
+                    res = Error("导入失败！错误信息：" + errres);
+                }
+                else
+                {
+                    string info = "本文件有" + rcount.ToString() + "行" + ccount.ToString() + "列数据";
+                    res = Success("导入成功！" + info, vfileid);
+                }
+            }
+
+            return res;
+        }
+        #region 上传文件
+        private string uploadexcel()
+        {
+            string Excelsource = "";
+            try
+            {
+                //HttpFileCollection hfc = System.Web.HttpContext.Current.Request.Files;
+                HttpPostedFile _upfile = RequestString.GetFile("upFile");
+                if (_upfile != null)
+                {
+                    string imgPath = "";
+
+                    string newFileName = DateTime.Now.ToString("yyyyMMddHHmmss");
+                    newFileName = newFileName + "_" + _upfile.FileName;
+                    if (!Directory.Exists(Server.MapPath(this.Request.ApplicationPath + "\\ExcelData")))
+                    {
+                        Directory.CreateDirectory(Server.MapPath(this.Request.ApplicationPath + "\\ExcelData"));
+                    }
+
+                    imgPath = this.Request.ApplicationPath + "/ExcelData/" + newFileName.ToString();
+                    string PhysicalPath = Server.MapPath(imgPath);
+                    _upfile.SaveAs(PhysicalPath);
+
+                    Excelsource = Server.MapPath(this.Request.ApplicationPath + "\\ExcelData\\") + newFileName.ToString();
+
+                    Model.T_Cus_CustomerExport filesmodel = new Model.T_Cus_CustomerExport();
+                    filesmodel.F_FileNewName = newFileName;
+                    filesmodel.F_FileOldName = _upfile.FileName;
+                    filesmodel.F_FilePath = Excelsource;
+                    filesmodel.F_FileType = 1;
+                    filesmodel.F_TypeGroup = 0;
+                    filesmodel.F_FileFix = _upfile.FileName.Substring(_upfile.FileName.LastIndexOf('.') + 1);
+                    filesmodel.F_InputDate = DateTime.Now;
+                    filesmodel.F_InputUserCode = CurrentUser.UserData.F_UserCode;
+                    filesmodel.F_InputUserID = CurrentUser.UserData.F_UserId;
+
+                    vfileid = new BLL.T_Cus_CustomerExport().Add(filesmodel);
+                }
+            }
+            catch (Exception ex) { }
+            return Excelsource;
+        }
+        #endregion
+
+        #region 读取Excel文件,返一个DataTable
+        private DataSet ReadEcxel(string FileName, int Rows)
+        {
+            return ToDataTable(FileName);
+        }
+
+        /// <summary>
+        /// 读取Excel文件到DataSet中
+        /// </summary>
+        /// <param name="filePath">文件路径</param>
+        /// <returns></returns>
+        private DataSet ToDataTable(string filePath)
+        {
+            DataSet ds = new DataSet();
+            DataTable dt = null;
+
+            try
+            {
+                FileStream fs = new FileStream(filePath, FileMode.Open, FileAccess.Read);
+
+                NPOI.SS.UserModel.IWorkbook book = null;
+                if (filePath.IndexOf(".xlsx") > 0) // 2007版本
+                    book = new NPOI.XSSF.UserModel.XSSFWorkbook(fs);
+                else if (filePath.IndexOf(".xls") > 0) // 2003版本
+                    book = new NPOI.HSSF.UserModel.HSSFWorkbook(fs);
+                //NPOI.HSSF.UserModel.HSSFWorkbook book = new NPOI.HSSF.UserModel.HSSFWorkbook(fs);
+
+                NPOI.SS.UserModel.ISheet sheet = book.GetSheetAt(0);
+
+
+                NPOI.SS.UserModel.IRow row = sheet.GetRow(0);
+
+
+                int firstCellNum = row.FirstCellNum;
+                int lastCellNum = row.LastCellNum;
+                //if (firstCellNum == lastCellNum) continue;
+
+                dt = new DataTable(sheet.SheetName);
+                //for (int i = firstCellNum; i < lastCellNum; i++)
+                for (int i = firstCellNum; i < 50; i++)
+                {
+                    if (row.GetCell(i) != null)
+                    {
+                        dt.Columns.Add(row.GetCell(i).ToString() + i.ToString(), typeof(string));
+                    }
+                    else
+                    {
+                        dt.Columns.Add(i.ToString(), typeof(string));
+                    }
+                }
+
+                for (int i = 1; i <= sheet.LastRowNum; i++)
+                {
+                    if (sheet.GetRow(i).GetCell(2) != null && sheet.GetRow(i).GetCell(2).ToString() != "")
+                    {
+                        DataRow newRow = dt.Rows.Add();
+                        for (int j = firstCellNum; j < 50; j++)
+                        {
+                            if (sheet.GetRow(i).GetCell(j) != null)
+                            {
+                                newRow[j] = sheet.GetRow(i).GetCell(j).ToString();
+                            }
+                            else
+                            {
+                                newRow[j] = "";
+                            }
+                        }
+                    }
+                }
+
+                ds.Tables.Add(dt);
+            }
+            catch (Exception ex)
+            {
+                //SysLog.WriteLog(ex);
+            }
+            return ds;
+        }
+        #endregion
     }
 }

codegit/CallCenterApi/CallCenterApi.Model/T_Cus_CustomerExport.cs

@@ -0,0 +1,121 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace CallCenterApi.Model
+{
+    /// <summary>
+	/// T_Cus_CustomerExport:实体类(属性说明自动提取数据库字段的描述信息)
+	/// </summary>
+	[Serializable]
+    public partial class T_Cus_CustomerExport
+    {
+        public T_Cus_CustomerExport()
+        { }
+        #region Model
+        private int _f_fileid;
+        private int? _f_typegroup;
+        private string _f_fileoldname;
+        private string _f_filenewname;
+        private string _f_filepath;
+        private string _f_filefix;
+        private int? _f_filetype;
+        private int? _f_filesize;
+        private string _f_inputusercode;
+        private int? _f_inputuserid;
+        private DateTime? _f_inputdate;
+        /// <summary>
+        /// 文件ID
+        /// </summary>
+        public int F_FileID
+        {
+            set { _f_fileid = value; }
+            get { return _f_fileid; }
+        }
+        /// <summary>
+        /// 所属的组别：0 95005,1 电销
+        /// </summary>
+        public int? F_TypeGroup
+        {
+            set { _f_typegroup = value; }
+            get { return _f_typegroup; }
+        }
+        /// <summary>
+        /// 文件名称
+        /// </summary>
+        public string F_FileOldName
+        {
+            set { _f_fileoldname = value; }
+            get { return _f_fileoldname; }
+        }
+        /// <summary>
+        /// 文件新名称
+        /// </summary>
+        public string F_FileNewName
+        {
+            set { _f_filenewname = value; }
+            get { return _f_filenewname; }
+        }
+        /// <summary>
+        /// 文件路径
+        /// </summary>
+        public string F_FilePath
+        {
+            set { _f_filepath = value; }
+            get { return _f_filepath; }
+        }
+        /// <summary>
+        /// 文件前缀
+        /// </summary>
+        public string F_FileFix
+        {
+            set { _f_filefix = value; }
+            get { return _f_filefix; }
+        }
+        /// <summary>
+        /// 文件类型:电销：0 老客户，1 新客户
+        /// </summary>
+        public int? F_FileType
+        {
+            set { _f_filetype = value; }
+            get { return _f_filetype; }
+        }
+        /// <summary>
+        /// 文件大小
+        /// </summary>
+        public int? F_FileSize
+        {
+            set { _f_filesize = value; }
+            get { return _f_filesize; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string F_InputUserCode
+        {
+            set { _f_inputusercode = value; }
+            get { return _f_inputusercode; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int? F_InputUserID
+        {
+            set { _f_inputuserid = value; }
+            get { return _f_inputuserid; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public DateTime? F_InputDate
+        {
+            set { _f_inputdate = value; }
+            get { return _f_inputdate; }
+        }
+        #endregion Model
+
+
+    }
+}