知识库附件问题

codegit/CallCenterApi/CallCenterApi.DAL/T_Sys_Accessories.cs

@@ -41,9 +41,9 @@ namespace CallCenterApi.DAL
         {
             StringBuilder strSql = new StringBuilder();
             strSql.Append("insert into T_Sys_Accessories(");
-            strSql.Append("F_FileName,F_FileType,F_FileUrl,F_UserCode,F_AddTime,F_Size)");
+            strSql.Append("F_FileName,F_FileType,F_FileUrl,F_UserCode,F_AddTime,F_Size,F_OriName)");
             strSql.Append(" values (");
-            strSql.Append("@F_FileName,@F_FileType,@F_FileUrl,@F_UserCode,@F_AddTime,@F_Size)");
+            strSql.Append("@F_FileName,@F_FileType,@F_FileUrl,@F_UserCode,@F_AddTime,@F_Size,@F_OriName)");
             strSql.Append(";select @@IDENTITY");
             SqlParameter[] parameters = {
                     new SqlParameter("@F_FileName", SqlDbType.NVarChar,100),
@@ -51,13 +51,16 @@ namespace CallCenterApi.DAL
                     new SqlParameter("@F_FileUrl", SqlDbType.NVarChar,200),
                     new SqlParameter("@F_UserCode", SqlDbType.NVarChar,20),
                     new SqlParameter("@F_AddTime", SqlDbType.DateTime),
-                    new SqlParameter("@F_Size", SqlDbType.BigInt,8)};
+                    new SqlParameter("@F_Size", SqlDbType.BigInt,8),
+                    new SqlParameter("@F_OriName", SqlDbType.NVarChar,500)
+            };
             parameters[0].Value = model.F_FileName;
             parameters[1].Value = model.F_FileType;
             parameters[2].Value = model.F_FileUrl;
             parameters[3].Value = model.F_UserCode;
             parameters[4].Value = model.F_AddTime;
             parameters[5].Value = model.F_Size;
+            parameters[6].Value = model.F_OriName;
 
             object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
             if (obj == null)
@@ -81,7 +84,8 @@ namespace CallCenterApi.DAL
             strSql.Append("F_FileUrl=@F_FileUrl,");
             strSql.Append("F_UserCode=@F_UserCode,");
             strSql.Append("F_AddTime=@F_AddTime,");
-            strSql.Append("F_Size=@F_Size");
+            strSql.Append("F_Size=@F_Size,");
+            strSql.Append("F_OriName=@F_OriName ");
             strSql.Append(" where F_FileId=@F_FileId");
             SqlParameter[] parameters = {
                     new SqlParameter("@F_FileName", SqlDbType.NVarChar,100),
@@ -90,6 +94,7 @@ namespace CallCenterApi.DAL
                     new SqlParameter("@F_UserCode", SqlDbType.NVarChar,20),
                     new SqlParameter("@F_AddTime", SqlDbType.DateTime),
                     new SqlParameter("@F_Size", SqlDbType.BigInt,8),
+                    new SqlParameter("@F_OriName", SqlDbType.NVarChar,500),
                     new SqlParameter("@F_FileId", SqlDbType.Int,4)};
             parameters[0].Value = model.F_FileName;
             parameters[1].Value = model.F_FileType;
@@ -97,7 +102,8 @@ namespace CallCenterApi.DAL
             parameters[3].Value = model.F_UserCode;
             parameters[4].Value = model.F_AddTime;
             parameters[5].Value = model.F_Size;
-            parameters[6].Value = model.F_FileId;
+            parameters[6].Value = model.F_OriName;
+            parameters[7].Value = model.F_FileId;
 
             int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
             if (rows > 0)
@@ -161,7 +167,7 @@ namespace CallCenterApi.DAL
         {
 
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("select  top 1 F_FileId,F_FileName,F_FileType,F_FileUrl,F_UserCode,F_AddTime,F_Size from T_Sys_Accessories ");
+            strSql.Append("select  top 1 * from T_Sys_Accessories ");
             strSql.Append(" where F_FileId=@F_FileId");
             SqlParameter[] parameters = {
                     new SqlParameter("@F_FileId", SqlDbType.Int,4)
@@ -217,6 +223,11 @@ namespace CallCenterApi.DAL
                 {
                     model.F_Size = long.Parse(row["F_Size"].ToString());
                 }
+                if (row["F_OriName"] != null)
+                {
+                    model.F_OriName = row["F_OriName"].ToString();
+                }
+
             }
             return model;
         }
@@ -227,7 +238,7 @@ namespace CallCenterApi.DAL
         public DataSet GetList(string strWhere)
         {
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("select F_FileId,F_FileName,F_FileType,F_FileUrl,F_UserCode,F_AddTime,F_Size ");
+            strSql.Append("select * ");
             strSql.Append(" FROM T_Sys_Accessories ");
             if (strWhere.Trim() != "")
             {
@@ -247,7 +258,7 @@ namespace CallCenterApi.DAL
             {
                 strSql.Append(" top " + Top.ToString());
             }
-            strSql.Append(" F_FileId,F_FileName,F_FileType,F_FileUrl,F_UserCode,F_AddTime,F_Size ");
+            strSql.Append(" * ");
             strSql.Append(" FROM T_Sys_Accessories ");
             if (strWhere.Trim() != "")
             {

codegit/CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Configs/system.config

@@ -26,4 +26,13 @@
   <add key="MessageUrl" value="http://jiayi.800100.net/sycw/index.html?menucode=GDXQ" />
   <!-- ================== 4：公司名称中需截取掉的字符串 ================== -->
   <add key="keystring" value="有限公司,公司,科技,网络,信息,河南,河南省,洛阳,洛阳市,郑州,郑州市,南阳,南阳市,新乡,新乡市,有限、商贸、市"/>
+  <!-- ================== 5：IVR文件上传FTP配置参数 ================== -->
+  <!-- 设置FTP -->
+  <add key="ftp" value="192.168.4.18" />
+  <!-- 设置账户名 -->
+  <add key="account" value="bingbing" />
+  <!-- 设置密码 -->
+  <add key="password" value="Bing123456" />
+  <!-- 文件保存位置 -->
+  <add key="saveloc" value="\upload_wav\" />
 </appSettings>

codegit/CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Controllers/knowledge/KnowledgeController.cs

@@ -462,41 +462,73 @@ namespace CallCenterApi.Interface.Controllers.knowledge
         {
             try
             {
+                if (file == null) return Error("参数传入失败");
+                if (Request.Files.Count == 0) return Error("保存失败");
+
                 string userCode = CurrentUser.UserData.F_UserCode;
                 string filePathName = string.Empty;
+                #region 保存文件到本地路径
                 string path = "/Upload/Files/" + DateTime.Now.ToString("yyyy/MM/dd") + "/";
                 string localPath = Server.MapPath(Path.Combine(HttpRuntime.AppDomainAppPath, path));
-                if (Request.Files.Count == 0)
-                {
-                    return Error("保存失败");
-                }
                 string ex = Path.GetExtension(file.FileName);
+                string oriname = Path.GetFileNameWithoutExtension(file.FileName);
                 filePathName = DateTime.Now.ToString("yyyyMMddHHmmssfff") + "_" + Guid.NewGuid().ToString("N") + ex;
                 if (!System.IO.Directory.Exists(localPath))
                 {
                     System.IO.Directory.CreateDirectory(localPath);
                 }
-                file.SaveAs(Path.Combine(localPath, filePathName));
-                #region 添加日志
-                Model.T_Sys_Accessories model_T_Sys_Accessories = new Model.T_Sys_Accessories();
-                model_T_Sys_Accessories.F_AddTime = DateTime.Now;//上传时间
-                model_T_Sys_Accessories.F_FileName = filePathName;//附件名称
-                model_T_Sys_Accessories.F_FileType = type;//附件类型
-                model_T_Sys_Accessories.F_FileUrl = path + filePathName;//附件地址
-                model_T_Sys_Accessories.F_Size = size;
-                model_T_Sys_Accessories.F_UserCode = userCode;//上传人  
-                int fid = new BLL.T_Sys_Accessories().Add(model_T_Sys_Accessories);
-
+                string physicalpath = Path.Combine(localPath, filePathName);
+                file.SaveAs(physicalpath);
+                #endregion
+                #region 读取配置的上传路径-原文件和修改过格式的文件均上传至此
+                string savedir = Configs.GetValue("saveloc");
+                if (!System.IO.Directory.Exists(savedir))
+                {
+                    System.IO.Directory.CreateDirectory(savedir);
+                }
                 #endregion
-                if (fid > 0)
+                if (!string.IsNullOrEmpty(physicalpath))
                 {
-                    //返回附件的ID
-                    model_T_Sys_Accessories.F_FileId = fid;//修改为返回对象以便查看图片
-                    return Success("文件成功", model_T_Sys_Accessories);
+                    #region 上传到ftp
+                    uploadFile upfile = new uploadFile();
+                    //通过读取配置文件，获取数据库
+                    string _ftp = Configs.GetValue("ftp");
+                    string _acc = Configs.GetValue("account");
+                    string _pwd = Configs.GetValue("password");
+
+                    upfile.ftpPath = _ftp;
+                    upfile.ftpUserID = _acc;
+                    upfile.ftpPassword = _pwd;
+                    //20180207 原文件同时保存
+                    string uploadBeforres = upfile.UploadLocalToFtp(physicalpath);
+                    #endregion
+                    if (uploadBeforres.Equals("上传成功！"))
+                    {
+                        #region 添加日志
+                        Model.T_Sys_Accessories model_T_Sys_Accessories = new Model.T_Sys_Accessories();
+                        model_T_Sys_Accessories.F_AddTime = DateTime.Now;//上传时间
+                        model_T_Sys_Accessories.F_FileName = filePathName;//附件名称
+                        model_T_Sys_Accessories.F_FileType = type;//附件类型
+                        model_T_Sys_Accessories.F_FileUrl = (filePathName).Replace('\\', '/');//附件地址
+                        model_T_Sys_Accessories.F_Size = size;
+                        model_T_Sys_Accessories.F_UserCode = userCode;//上传人  
+                        model_T_Sys_Accessories.F_OriName = oriname;
+                        int fid = new BLL.T_Sys_Accessories().Add(model_T_Sys_Accessories);
+                        #endregion
+                        if (fid > 0)
+                        {
+                            //返回附件的ID
+                            model_T_Sys_Accessories.F_FileId = fid;//修改为返回对象以便查看图片
+                            return Success("文件上传成功", model_T_Sys_Accessories);
+                        }
+                        else
+                            return Success("文件上传成功，日志记录失败");
+                    }
+                    else
+                        return Error("文件上传失败，请重新上传，失败原因：" + uploadBeforres);
                 }
                 else
-                    return Success("文件失败");
-
+                    return Error("格式修改出错，请重新上传");
             }
             catch (Exception ex)
             {

codegit/CallCenterApi/CallCenterApi.Model/T_Sys_Accessories.cs

@@ -22,6 +22,7 @@ namespace CallCenterApi.Model
         private string _f_usercode;
         private DateTime? _f_addtime;
         private long? _f_size;
+        private string _f_oriname;
         /// <summary>
         /// 附件id
         /// </summary>
@@ -78,6 +79,21 @@ namespace CallCenterApi.Model
             set { _f_size = value; }
             get { return _f_size; }
         }
+        /// <summary>
+        /// 文件原名
+        /// </summary>
+        public string F_OriName
+        {
+            get
+            {
+                return _f_oriname;
+            }
+
+            set
+            {
+                _f_oriname = value;
+            }
+        }
         #endregion Model
     }
 }

codegit/CallCenterCommon/CallCenter.Utility/uploadFile.cs

@@ -0,0 +1,189 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Net;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace CallCenter.Utility
+{
+    public class uploadFile
+    {
+        public string ftpPath;
+        public string ftpUserID;
+        public string ftpPassword;
+
+        /// <summary>
+        /// 上传文件
+        /// </summary>
+        /// <param name="fileinfo">需要上传的文件</param>
+        public string UploadLocalToFtp(string localFile)
+        {
+            string res = "";
+            if (!File.Exists(localFile))
+            {
+                res = "文件：“" + localFile + "” 不存在！";
+                return res;
+            }
+            FileInfo fileInf = new FileInfo(localFile);
+            //改后文件
+            #region 改后文件
+            //string temp_filename = localFile.Split('\\').Last().Split('.')[0] + "_temp";
+            //string localfileAft = Path.GetDirectoryName(localFile) + "\\" + temp_filename + ".wav";
+            //FileInfo fileInfAft = new FileInfo(localfileAft);
+            #endregion
+            string ftpURI = "ftp://" + ftpPath + "/";
+            string uri = ftpURI + fileInf.Name;
+            //string uriAft = ftpURI + fileInfAft.Name;
+            FtpWebRequest reqFTP;
+            //20180209
+            //System.GC.Collect();
+            reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));// 根据uri创建FtpWebRequest对象   
+            reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);// ftp用户名和密码  
+            reqFTP.KeepAlive = false;// 默认为true，连接不会被关闭 // 在一个命令之后被执行  
+            reqFTP.Method = WebRequestMethods.Ftp.UploadFile;// 指定执行什么命令  
+            reqFTP.UseBinary = true;// 指定数据传输类型  
+            reqFTP.UsePassive = true;
+            reqFTP.ContentLength = fileInf.Length;// 上传文件时通知服务器文件的大小  
+            int buffLength = 2048;// 缓冲大小设置为2kb  
+            byte[] buff = new byte[buffLength];
+            int contentLen;
+
+            // 打开一个文件流 (System.IO.FileStream) 去读上传的文件  
+            //FileStream fs = fileInf.OpenRead();
+            using (FileStream fs = new FileStream(localFile, FileMode.Open, FileAccess.Read, FileShare.ReadWrite))
+            {
+                try
+                {
+                    res += uri + localFile;
+                    using (Stream strm = reqFTP.GetRequestStream())// 把上传的文件写入流
+                    {
+                        //StreamReader strm = new StreamReader(fs, System.Text.Encoding.Default);
+                        contentLen = fs.Read(buff, 0, buffLength);// 每次读文件流的2kb 
+                        while (contentLen != 0)// 流内容没有结束  
+                        {
+                            // 把内容从file stream 写入 upload stream  
+                            strm.Write(buff, 0, contentLen);
+                            contentLen = fs.Read(buff, 0, buffLength);
+                        }
+                        //StringBuilder sb = new StringBuilder();
+                        //while (!strm.EndOfStream)
+                        //{
+                        //    sb.AppendLine(strm.ReadLine() + "<br>");
+                        //}
+                    }
+                    // 关闭两个流  
+                    //strm.Close();
+                    fs.Close();
+                    res = "上传成功！";
+                }
+                catch (Exception ex)
+                {
+                    res += "上传文件【" + ftpPath + "/" + fileInf.Name + "】时，发生错误：" + ex.Message + "<br/>。路径：" + localFile;
+                }
+            }
+            //FtpWebRequest reqFTP1;
+            ////20180209
+            ////System.GC.Collect();
+            //reqFTP1 = (FtpWebRequest)FtpWebRequest.Create(new Uri(uriAft));// 根据uri创建FtpWebRequest对象   
+            //reqFTP1.Credentials = new NetworkCredential(ftpUserID, ftpPassword);// ftp用户名和密码  
+            //reqFTP1.KeepAlive = false;// 默认为true，连接不会被关闭 // 在一个命令之后被执行  
+            //reqFTP1.Method = WebRequestMethods.Ftp.UploadFile;// 指定执行什么命令  
+            //reqFTP1.UseBinary = true;// 指定数据传输类型  
+            //reqFTP1.UsePassive = true;
+            //reqFTP1.ContentLength = fileInfAft.Length;// 上传文件时通知服务器文件的大小  
+            //int buffLengthaft = 2048;// 缓冲大小设置为2kb  
+            //byte[] buffaft = new byte[buffLengthaft];
+            //int contentLenaft;
+
+            // 打开一个文件流 (System.IO.FileStream) 去读上传的文件  
+            //FileStream fs = fileInf.OpenRead();
+            //using (FileStream fs1 = new FileStream(localfileAft, FileMode.Open, FileAccess.Read, FileShare.ReadWrite))
+            //{
+            //    try
+            //    {
+            //        res += uriAft + localfileAft;
+            //        using (Stream strm1 = reqFTP1.GetRequestStream())// 把上传的文件写入流
+            //        {
+            //            //StreamReader strm = new StreamReader(fs, System.Text.Encoding.Default);
+            //            contentLenaft = fs1.Read(buffaft, 0, buffLengthaft);// 每次读文件流的2kb 
+            //            while (contentLenaft != 0)// 流内容没有结束  
+            //            {
+            //                // 把内容从file stream 写入 upload stream  
+            //                strm1.Write(buffaft, 0, contentLenaft);
+            //                contentLenaft = fs1.Read(buffaft, 0, buffLengthaft);
+            //            }
+            //            //StringBuilder sb = new StringBuilder();
+            //            //while (!strm.EndOfStream)
+            //            //{
+            //            //    sb.AppendLine(strm.ReadLine() + "<br>");
+            //            //}
+            //        }
+            //        // 关闭两个流  
+            //        //strm.Close();
+            //        fs1.Close();
+            //        res = "上传成功！";
+            //    }
+            //    catch (Exception ex)
+            //    {
+            //        res += "上传文件【" + ftpPath + "/" + fileInf.Name + "】时，发生错误：" + ex.Message + "<br/>。路径：" + localFile;
+            //    }
+            //}
+            return res;
+        }
+
+        /// <summary>  
+        /// 判断ftp服务器上该目录是否存在  
+        /// </summary>  
+        /// <param name="ftpPath">FTP路径目录</param>  
+        /// <param name="dirName">目录上的文件夹名称</param>  
+        /// <returns></returns>  
+        private bool CheckDirectoryExist(string ftpPath, string dirName)
+        {
+            bool flag = true;
+            try
+            {
+                //实例化FTP连接  
+                FtpWebRequest ftp = (FtpWebRequest)FtpWebRequest.Create(ftpPath + dirName);
+                ftp.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
+                ftp.Method = WebRequestMethods.Ftp.ListDirectory;
+                FtpWebResponse response = (FtpWebResponse)ftp.GetResponse();
+                response.Close();
+            }
+            catch (Exception)
+            {
+                flag = false;
+            }
+            return flag;
+        }
+
+        /// <summary>  
+        /// 创建文件夹    
+        /// </summary>    
+        /// <param name="ftpPath">FTP路径</param>    
+        /// <param name="dirName">创建文件夹名称</param>    
+        public void MakeDir(string ftpPath, string dirName)
+        {
+            FtpWebRequest reqFTP;
+            try
+            {
+                string ui = (ftpPath + dirName).Trim();
+                reqFTP = (FtpWebRequest)FtpWebRequest.Create(ui);
+                reqFTP.Method = WebRequestMethods.Ftp.MakeDirectory;
+                reqFTP.UseBinary = true;
+                reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
+                FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
+                Stream ftpStream = response.GetResponseStream();
+                ftpStream.Close();
+                response.Close();
+                //Response.Write("文件夹【" + dirName + "】创建成功！<br/>");
+            }
+            catch (Exception ex)
+            {
+                //Response.Write("新建文件夹【" + dirName + "】时，发生错误：" + ex.Message);
+            }
+
+        }
+    }
+}