增加 上传语音文件并转换格式 接口

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

@@ -25,4 +25,11 @@
   <add key="WechatAppid" value="wx957c2297c315e6a5" />
   <!-- 设置微信appsecret -->
   <add key="WechatAppsecret" value="6c2d1f9fd32f906c315f03398800d474" />
+  <!-- ================== 4：IVR文件上传FTP配置参数 ================== -->
+  <!-- 设置FTP -->
+  <add key="ftp" value="192.168.1.30" />
+  <!-- 设置账户名 -->
+  <add key="account" value="ceshi" />
+  <!-- 设置密码 -->
+  <add key="password" value="123456" />
 </appSettings>

codegit/CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Controllers/UploadFileController.cs

@@ -0,0 +1,126 @@
+using CallCenter.Utility;
+using CallCenterApi.Interface.Controllers.Base;
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.IO;
+using System.Linq;
+using System.Text;
+using System.Threading;
+using System.Web;
+using System.Web.Mvc;
+
+namespace CallCenterApi.Interface.Controllers
+{
+    public class UploadFileController : BaseController
+    {
+        // GET: UploadFile
+        //public ActionResult Index()
+        //{
+        //    return View();
+        //}
+
+        public ActionResult UploadToFTP()
+        {
+            ActionResult res = NoToken("未知错误，请重新登录");
+            #region 前后端分离上传并修改文件格式
+            //string fullFileName = this.txtfileUpload.FileName; //文件路径名
+            HttpPostedFile _upFile = RequestString.GetFile("upFile");
+            if (_upFile != null)
+            {
+                string datename = DateTime.Now.ToString("yyyyMMddHHMMss");
+                string fullFileName = datename + "_" + _upFile.FileName;
+                string path = Server.MapPath(this.Request.ApplicationPath + "~/upload/");
+                if (!System.IO.Directory.Exists(path))
+                {
+                    System.IO.Directory.CreateDirectory(path);
+                }
+                path = path + fullFileName;
+                string physicalpath = Server.MapPath(path);
+                _upFile.SaveAs(physicalpath);
+
+                #region 修改音频格式
+                if (!string.IsNullOrEmpty(physicalpath))
+                {
+                    //通过cmd执行ffmpeg改变音频采样率
+                    Process p = new Process();
+                    p.StartInfo.FileName = "cmd.exe";
+                    p.StartInfo.UseShellExecute = false;
+                    p.StartInfo.RedirectStandardOutput = true;
+                    p.StartInfo.RedirectStandardInput = true;
+                    p.StartInfo.RedirectStandardError = true;
+                    p.StartInfo.CreateNoWindow = true;
+                    //p.StartInfo.Arguments = "ffmpeg -i "+fileName+ " -ar 16000 "+ namePart + "New.wav";//参数以空格分隔，如果某个参数为空，可以传入””
+
+                    //p.Start();
+                    ////先进入cmd命令
+                    ////再打开FFmpeg.exe
+                    string ffmpegLocation = System.Threading.Thread.GetDomain().BaseDirectory;
+                    ////p.StandardInput.WriteLine("exit");
+                    //p.StandardInput.WriteLine("cd d/ " + ffmpegLocation + "ffmpeg.exe");
+                    //p.StandardInput.WriteLine(ffmpegLocation.TrimEnd('\\'));
+
+                    //判断是否存在文件夹，不存在则创建
+                    string voices_path = ffmpegLocation + "temp_voices";
+                    if (!Directory.Exists(voices_path))
+                    {
+                        Directory.CreateDirectory(voices_path);
+                    }
+                    string temp_filename = physicalpath.Split('/').Last().Split('.')[0] + "_temp_";
+
+                    p.Start();
+                    //先进入cmd命令
+                    //再打开FFmpeg.exe
+                    //p.StandardInput.WriteLine("exit");
+                    p.StandardInput.WriteLine("cd d/ " + ffmpegLocation + "ffmpeg.exe");
+                    p.StandardInput.WriteLine(ffmpegLocation.TrimEnd('\\'));
+
+                    //p.StandardInput.WriteLine("ffmpeg -i " + temp_filename + i + ".mp3 -f pcm -ar 16000 -ac 1 -ab 16 " + namepart.Replace(@"/", @"\"));
+                    //string changefile = "ffmpeg -i " + physicalpath + " -acodec pcm_s16le -f s16le -ar 16000 -ac 1 " + ffmpegLocation + temp_filename + ".pcm";
+                    string changefile = "ffmpeg -i " + physicalpath + " -acodec pcm_s16le -f s16le -ar 8000 -ac 1 " + ffmpegLocation + temp_filename + ".pcm";
+
+                    p.StandardInput.WriteLine(changefile);
+                    Thread.Sleep(3000);
+                    p.StandardInput.WriteLine("exit");
+                    //Kill 是终止没有图形化界面的进程的唯一方法。
+                    p.Kill();
+
+                    #region 上传
+                    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;
+                    //FileInfo fi = new FileInfo(path);
+                    FileInfo fi = new FileInfo(physicalpath);
+                    //string res = upfile.UploadLocalToFtp(path);
+                    //string res = upfile.UploadLocalToFtp(physicalpath);
+                    string uploadres = upfile.UploadLocalToFtp(ffmpegLocation + temp_filename + ".pcm");
+                    if (uploadres == "上传成功！")
+                    {
+                        //写入日志
+                        string logfile = Server.MapPath("~/log.txt");
+                        if (!System.IO.File.Exists(logfile))
+                        {
+                            System.IO.File.Create(logfile);
+                        }
+                        //开始写入
+                        string str = DateTime.Now.ToString() + " 文件" + fullFileName + "上传成功";
+                        System.IO.File.AppendAllLines(logfile, new string[] { str }, Encoding.GetEncoding("gb2312"));
+                        res = Success("上传成功");
+                    }
+                    #endregion
+                }
+                #endregion
+            }
+            else
+                res = Error("参数传入失败");
+            #endregion
+            return res;
+        }
+    }
+}

codegit/CallCenterCommon/CallCenter.Utility/uploadFile.cs

@@ -0,0 +1,122 @@
+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);
+            string ftpURI = "ftp://" + ftpPath + "/";
+            string uri = ftpURI + fileInf.Name;
+            FtpWebRequest reqFTP;
+
+            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.ContentLength = fileInf.Length;// 上传文件时通知服务器文件的大小  
+            int buffLength = 2048;// 缓冲大小设置为2kb  
+            byte[] buff = new byte[buffLength];
+            int contentLen;
+
+            // 打开一个文件流 (System.IO.FileStream) 去读上传的文件  
+            FileStream fs = fileInf.OpenRead();
+            try
+            {
+                Stream strm = reqFTP.GetRequestStream();// 把上传的文件写入流  
+                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);
+                }
+                // 关闭两个流  
+                strm.Close();
+                fs.Close();
+                res = "上传成功！";
+            }
+            catch (Exception ex)
+            {
+                res = "上传文件【" + ftpPath + "/" + fileInf.Name + "】时，发生错误：" + ex.Message + "<br/>";
+            }
+            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);
+            }
+
+        }
+    }
+}