聊天记录附件、 报错等

RMYY_CallCenter_Api.Dal/T_Msg_Chat.cs

@@ -47,9 +47,9 @@ namespace RMYY_CallCenter_Api.Dal
         {
             StringBuilder strSql = new StringBuilder();
             strSql.Append("insert into T_Msg_Chat(");
-            strSql.Append("Content,VoiceUrl,CreateDate,FromUserId,ToUserId,ToRoleId,IsToAll,IsDelete)");
+            strSql.Append("Content,VoiceUrl,CreateDate,FromUserId,ToUserId,ToRoleId,IsToAll,IsDelete,Files)");
             strSql.Append(" values (");
-            strSql.Append("@Content,@VoiceUrl,@CreateDate,@FromUserId,@ToUserId,@ToRoleId,@IsToAll,@IsDelete)");
+            strSql.Append("@Content,@VoiceUrl,@CreateDate,@FromUserId,@ToUserId,@ToRoleId,@IsToAll,@IsDelete,@Files)");
             strSql.Append(";select @@IDENTITY");
             SqlParameter[] parameters = {
                     new SqlParameter("@Content", SqlDbType.NText),
@@ -59,7 +59,10 @@ namespace RMYY_CallCenter_Api.Dal
                     new SqlParameter("@ToUserId", SqlDbType.Int,4),
                     new SqlParameter("@ToRoleId", SqlDbType.Int,4),
                     new SqlParameter("@IsToAll", SqlDbType.Int,4),
-                    new SqlParameter("@IsDelete", SqlDbType.Int,4)};
+                    new SqlParameter("@IsDelete", SqlDbType.Int,4),
+                      new SqlParameter("@Files", SqlDbType.NVarChar,100)
+                    
+            };
             parameters[0].Value = model.Content;
             parameters[1].Value = model.VoiceUrl;
             parameters[2].Value = model.CreateDate;
@@ -68,7 +71,7 @@ namespace RMYY_CallCenter_Api.Dal
             parameters[5].Value = model.ToRoleId;
             parameters[6].Value = model.IsToAll;
             parameters[7].Value = model.IsDelete;
-
+            parameters[8].Value = model.Files;
             object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
             if (obj == null)
             {
@@ -177,7 +180,7 @@ namespace RMYY_CallCenter_Api.Dal
         {
 
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("select  top 1 Id,Content,VoiceUrl,CreateDate,FromUserId,ToUserId,ToRoleId,IsToAll,IsDelete from T_Msg_Chat ");
+            strSql.Append("select  top 1 Id,Content,VoiceUrl,CreateDate,FromUserId,ToUserId,ToRoleId,IsToAll,Files,IsDelete from T_Msg_Chat ");
             strSql.Append(" where Id=@Id");
             SqlParameter[] parameters = {
                     new SqlParameter("@Id", SqlDbType.Int,4)
@@ -213,6 +216,11 @@ namespace RMYY_CallCenter_Api.Dal
                 {
                     model.Content = row["Content"].ToString();
                 }
+                
+ if (row["Files"] != null)
+                {
+                    model.Files = row["Files"].ToString();
+                }
                 if (row["VoiceUrl"] != null)
                 {
                     model.VoiceUrl = row["VoiceUrl"].ToString();
@@ -251,7 +259,7 @@ namespace RMYY_CallCenter_Api.Dal
         public DataSet GetList(string strWhere)
         {
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("select Id,Content,VoiceUrl,CreateDate,FromUserId,ToUserId,ToRoleId,IsToAll,IsDelete ");
+            strSql.Append("select Id,Content,VoiceUrl,CreateDate,FromUserId,ToUserId,ToRoleId,IsToAll,IsDelete ,Files");
             strSql.Append(" FROM T_Msg_Chat ");
             if (strWhere.Trim() != "")
             {

RMYY_CallCenter_Api.Model/T_Msg_Chat.cs

@@ -20,6 +20,14 @@ namespace RMYY_CallCenter_Api.Model
         private int? _toroleid;
         private int? _istoall;
         private int? _isdelete;
+        private string _files;
+
+        public string Files
+        {
+            set { _files = value; }
+            get { return _files; }
+        }
+
         /// <summary>
         /// Id
         /// </summary>

RMYY_CallCenter_Api/Controllers/IndexController.cs

@@ -19,6 +19,7 @@ namespace RMYY_CallCenter_Api.Controllers
         private Bll.T_Msg_Chat bllchat = new Bll.T_Msg_Chat();
         private Bll.T_Msg_Chat_Map bllmap = new Bll.T_Msg_Chat_Map();
         private readonly Bll.T_Sys_UserAccount userAccount = new Bll.T_Sys_UserAccount();
+       private Bll.T_Sys_SystemConfig configBll = new Bll.T_Sys_SystemConfig();
         // GET: Index
         /// <summary>
         /// 获取当前用户
@@ -411,6 +412,18 @@ namespace RMYY_CallCenter_Api.Controllers
             return Success("获取成功", dt);
         }
 
+        public DataTable GetFileData(string ids, string prefix)
+        {
+            DataTable dt = DbHelperSQL.Query("select * from T_Sys_Accessories WITH(NOLOCK) where F_FileId in (" + ids + ")").Tables[0];
+
+            foreach (DataRow dr in dt.Rows)
+            {
+                dr["F_FileUrl"] = prefix + dr["F_FileUrl"].ToString();
+            }
+
+            return dt;
+        }
+
         /// <summary>
         /// 即时聊天 - 获取最新通讯(获取双方记录【聊天】)
         /// </summary>
@@ -440,12 +453,30 @@ namespace RMYY_CallCenter_Api.Controllers
                     sql += " and b.CreateDate > '" + start + "' ";
                 }
                 //查询（聊天记录）
-                string sql1 = "SELECT a.Id,a.FromUserId,a.Content,a.IsToAll,a.CreateDate,c.F_UserName FROM dbo.T_Msg_Chat a RIGHT JOIN dbo.T_Msg_Chat_Map b ON b.ChatId = a.Id LEFT JOIN dbo.T_Sys_UserAccount c ON c.F_UserId = a.FromUserId WHERE " + sql + " ORDER BY a.CreateDate ASC";
+                string sql1 = "SELECT a.Id,a.FromUserId,a.Content,a.Files,a.IsToAll,a.CreateDate,c.F_UserName FROM dbo.T_Msg_Chat a RIGHT JOIN dbo.T_Msg_Chat_Map b ON b.ChatId = a.Id LEFT JOIN dbo.T_Sys_UserAccount c ON c.F_UserId = a.FromUserId WHERE " + sql + " ORDER BY a.CreateDate ASC";
                 dt = DbHelperSQL.Query(sql1).Tables[0];
                 recordCount = dt.Rows.Count;
 
-                //修改（设置已读）
-                string sqlwhere = " ISNULL(IsRead,0) = 0 ";
+
+                dt.Columns.Add("FileUrl", typeof(object));
+            
+               var configfj = configBll.GetModelList(" F_ParamCode='FileUrlPath' ").FirstOrDefault();
+
+                foreach (DataRow dr in dt.Rows)
+                {
+                  
+                    if (configfj != null && !string.IsNullOrEmpty(dr["Files"].ToString()))
+                    {
+                        dr["FileUrl"] = GetFileData(dr["Files"].ToString(), configfj.F_ParamValue);
+                    }
+                }
+
+
+
+
+
+                    //修改（设置已读）
+               string sqlwhere = " ISNULL(IsRead,0) = 0 ";
                 if (fromuserId > 0)
                 {
                     sqlwhere += " and FromUserId = " + fromuserId + " ";
@@ -564,6 +595,7 @@ namespace RMYY_CallCenter_Api.Controllers
             model.ToUserId = input.ToUserId;
             model.ToRoleId = input.ToRoleId;
             model.CreateDate = DateTime.Now;
+            model.Files = input.Files;
             //如果用户和角色都为0，则发送所有人
             if (input.ToUserId == 0 && input.ToRoleId == 0)
             {
@@ -640,9 +672,21 @@ namespace RMYY_CallCenter_Api.Controllers
                 sql += " and ISNULL(b.IsRead,0) = " + isread + " ";
             }
             //查询（聊天记录）
-            string sql1 = "SELECT TOP " + top + " a.Id,b.FromUserId,b.ToUserId,a.Content,a.IsToAll,a.CreateDate,b.IsRead,c.F_UserName,c.F_RoleId,c.F_Sex,c.F_See FROM dbo.T_Msg_Chat a RIGHT JOIN dbo.T_Msg_Chat_Map b ON b.ChatId = a.Id LEFT JOIN dbo.T_Sys_UserAccount c ON c.F_UserId = a.FromUserId WHERE " + sql + " ORDER BY a.CreateDate ASC";
+            string sql1 = "SELECT TOP " + top + " a.Id,b.FromUserId,b.ToUserId,a.Content,a.Files,a.IsToAll,a.CreateDate,b.IsRead,c.F_UserName,c.F_RoleId,c.F_Sex,c.F_See FROM dbo.T_Msg_Chat a RIGHT JOIN dbo.T_Msg_Chat_Map b ON b.ChatId = a.Id LEFT JOIN dbo.T_Sys_UserAccount c ON c.F_UserId = a.FromUserId WHERE " + sql + " ORDER BY a.CreateDate ASC";
             dt = DbHelperSQL.Query(sql1).Tables[0];
             recordCount = dt.Rows.Count;
+            dt.Columns.Add("FileUrl", typeof(object));
+
+            var configfj = configBll.GetModelList(" F_ParamCode='FileUrlPath' ").FirstOrDefault();
+
+            foreach (DataRow dr in dt.Rows)
+            {
+
+                if (configfj != null && !string.IsNullOrEmpty(dr["Files"].ToString()))
+                {
+                    dr["FileUrl"] = GetFileData(dr["Files"].ToString(), configfj.F_ParamValue);
+                }
+            }
 
             var obj = new
             {

RMYY_CallCenter_Api/Controllers/InfoController.cs

@@ -183,7 +183,7 @@ namespace RMYY_CallCenter_Api.Controllers
             var date = DateTime.Now;
 
 
-            string sqlhw = "       select a. F_GDID F_Type , a.F_Name,(SELECT COUNT(1) FROM T_Car_WorkOrder WHERE   F_IsDel=0 AND F_Typ in( select F_GDId  from [dbo].[GetValueId](a.F_GDID))  " +
+            string sqlhw = "       select a. F_GDID F_Type , a.F_Name,(SELECT COUNT(1) FROM T_Car_WorkOrder WHERE   F_IsDel=0 AND F_Type in( select F_GDId  from [dbo].[GetValueId](a.F_GDID))  " +
                 "    AND datediff(day , F_CreateTime  , getdate())= 0) COUNT    from T_Sys_Gongdan a" +
                 "     where F_ParentID = 4000 AND F_IsDelete = 0   ";
             DataTable dthw = DbHelperSQL.Query(sqlhw).Tables[0];

RMYY_CallCenter_Api/Models/Input/ChatInput.cs

@@ -7,6 +7,11 @@ namespace RMYY_CallCenter_Api.Models.Input
 {
     public class ChatInput
     {
+
+        /// <summary>
+        /// 附件内容
+        /// </summary>
+               public string Files { get; set; }
         /// <summary>
         /// Id
         /// </summary>