录音文件导出

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

@@ -33,4 +33,6 @@
   <!-- ================== 5：Redis配置 ================== -->
   <add key="Redis_Server" value="192.168.4.18" />
   <add key="Redis_Port" value="6379" />
+  <!-- 录音存储地址 -->
+  <add key="Sound_recording" value="D:\\CallCenter_Sound\" />
 </appSettings>

codegit/CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Controllers/tel/CallrecordsController.cs

@@ -5,7 +5,9 @@ using CallCenterApi.Interface.Controllers.Base;
 using System;
 using System.Collections.Generic;
 using System.Data;
+using System.IO;
 using System.Linq;
+using System.Net;
 using System.Web;
 using System.Web.Mvc;
 
@@ -124,6 +126,130 @@ namespace CallCenterApi.Interface.Controllers.tel
 
             return Content(obj.ToJson());
         }
+   
+        private string filePath = Configs.GetValue("Sound_recording");
+        /// <summary>
+        /// 导出录音文件
+        /// </summary>
+        /// <returns></returns>
+        public ActionResult ExitSound(string phone, string usercode)
+        {
+            int userId = CurrentUser.UserData.F_UserId;
+            Model.T_Sys_UserAccount userModel = new BLL.T_Sys_UserAccount().GetModel(userId);
+
+            string sql = "";
+
+            string callstate = HttpUtility.UrlDecode(RequestString.GetQueryString("callstate"));
+            string calltype = HttpUtility.UrlDecode(RequestString.GetQueryString("calltype"));
+            string starttime = HttpUtility.UrlDecode(RequestString.GetQueryString("starttime"));
+            string endtime = HttpUtility.UrlDecode(RequestString.GetQueryString("endtime"));
+            string dept = HttpUtility.UrlDecode(RequestString.GetQueryString("dept"));
+            string dealtype = HttpUtility.UrlDecode(RequestString.GetQueryString("dealtype"));
+            if (!string.IsNullOrEmpty(userModel.groupcode))
+            {
+                sql += " and groupcode = '" + userModel.groupcode + "' ";
+            }
+
+            if (usercode != null && usercode.Trim() != "")
+            {
+                sql += " and UserCode='" + usercode + "'";
+            }
+            if (dept != null && dept.Trim() != "")
+            {
+                sql += " and F_DeptId='" + dept.Trim() + "'";
+            }
+            if (dealtype != null && dealtype.Trim() != "")
+            {
+                //处理方式
+                sql += " and DealType = " + dealtype + " ";
+            }
+            if (phone != null && phone.Trim() != "")
+            {
+                sql += " and CallNumber like '%" + phone + "%'";
+            }
+            if (callstate.Trim() != "")
+            {
+                sql += " and CallState='" + callstate + "'";
+            }
+            if (calltype.Trim() != "")
+            {
+                sql += " and CallType='" + calltype + "'";
+            }
+            if (starttime.Trim() != "")
+            {
+                sql += " and datediff(day,BeginTime,'" + starttime + "')<=0 ";
+            }
+            if (endtime.Trim() != "")
+            {
+                sql += " and datediff(day,BeginTime,'" + endtime + "')>=0 ";
+            }
+            var CallList = new BLL.T_Call_CallRecords().GetModelList("FilePath !='' "+ sql);
+            var config = new BLL.T_Sys_SystemConfig().GetModelList(" F_ParamCode='PlayPath' ").FirstOrDefault();
+            // 如果文件不存在，创建文件； 如果存在，覆盖文件 
+            try
+            {
+                if (!Directory.Exists(filePath))
+                {
+                    Directory.CreateDirectory(filePath);
+                }
+                if (CallList!=null )
+                {
+                    foreach (var it in CallList)
+                    {
+                        string FilePath = "";
+                        if (it.FilePath != "" && config != null && !string.IsNullOrEmpty(config.F_ParamValue))
+                        {
+                            var ym = config.F_ParamValue;
+                            if (ym.Substring(ym.Length - 1) == "/")
+                            {
+                                ym = ym.Substring(0, ym.Length - 1);
+                            }
+                            FilePath = ym + it.FilePath.Substring(it.FilePath.IndexOf(':') + 1).Replace('\\', '/');
+                        }
+                      
+                       
+                        string filename = "l"+ it.FilePath.Split ('l')[1];
+                        filename = filename.Split('.')[0] + "_" + it.CallNumber + ".mp3";
+                        try
+                        {
+                            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(FilePath);
+                            HttpWebResponse response = request.GetResponse() as HttpWebResponse;
+                            Stream responseStream = response.GetResponseStream();
+                            string[] sArray = filename.Split(new string[] { "\\" }, StringSplitOptions.RemoveEmptyEntries);
+                            string flie = @"" + filePath +"\\"+ sArray[0] + "\\" + sArray[1] + "\\" + sArray[2];
+                            if (!Directory.Exists(flie))
+                            {
+                                Directory.CreateDirectory(flie);
+                            }
+                            if (System.IO.File.Exists(flie + "\\" + sArray[3]))
+                            {
+                                continue;
+                            }
+                            Stream stream = new FileStream(flie + "\\"+ sArray[3], FileMode.Create);
+                            byte[] bArr = new byte[1024];
+                            int size = responseStream.Read(bArr, 0, bArr.Length);
+                            while (size > 0)
+                            {
+                                stream.Write(bArr, 0, size);
+                                size = responseStream.Read(bArr, 0, bArr.Length);
+                            }
+                            stream.Close();
+                            responseStream.Close();
+                        }
+                        catch (Exception e)
+                        {
+                            continue;
+                        }
+                    }
+                }
+                return Success("导出成功");
+            }
+
+            catch (Exception e)
+            {
+                throw;
+            }
+        }
 
         /// <summary>
         /// 获取实体