1

gx_api/GxPress/Api/GxPress.Api/AppControllers/OftenContactController.cs

@@ -7,6 +7,10 @@ using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Logging;
 using GxPress.Service.Interface.OftenContact;
+using System.Collections.Generic;
+using GxPress.Result.Chat;
+using GxPress.Service.Interface.Chat;
+
 namespace GxPress.Api.AppControllers
 {
     /// <summary>
@@ -21,12 +25,14 @@ namespace GxPress.Api.AppControllers
         private readonly IOftenContactRepository _repository;
         private readonly ILoginContext _loginContext;
         private readonly IOftenContactService _oftenContactService;
-        public OftenContactController(ILogger<OftenContactController> logger, IOftenContactRepository repository, ILoginContext loginContext, IOftenContactService oftenContactService)
+        private readonly IChatSearchService chatSearchService;
+        public OftenContactController(ILogger<OftenContactController> logger, IOftenContactRepository repository, ILoginContext loginContext, IOftenContactService oftenContactService, IChatSearchService chatSearchService)
         {
             _logger = logger;
             _repository = repository;
             _loginContext = loginContext;
             _oftenContactService = oftenContactService;
+            this.chatSearchService = chatSearchService;
         }
 
         /// <summary>
@@ -106,5 +112,20 @@ namespace GxPress.Api.AppControllers
         {
             return await _repository.DeleteAsync(oftenContactIds.OftenContactIds);
         }
+        /// <summary>
+        /// 搜索单聊
+        /// </summary>
+        /// <param name="keyWord"></param>
+        /// <returns></returns>
+        [HttpGet("search/{keyWord}")]
+        public async Task<IEnumerable<ChatSearchResult>> GetChatSearchAsync(string keyWord)
+        {
+            var result = new List<ChatSearchResult>();
+            result.AddRange(await chatSearchService.GetChatFolderNameSearchAsync(keyWord, _loginContext.AccountId));
+            result.AddRange(await chatSearchService.GetGroupChatNameSearchAsync(keyWord, _loginContext.AccountId));
+            result.AddRange(await chatSearchService.GetChatSearchAsync(keyWord, _loginContext.AccountId));
+            result.AddRange(await chatSearchService.GetFriendUserInfoResult(keyWord, _loginContext.AccountId));
+            return result;
+        }
     }
 }

gx_api/GxPress/Model/GxPress.Result/Chat/ChatResult.cs

@@ -0,0 +1,51 @@
+using System;
+
+namespace GxPress.Result.Chat
+{
+    public class ChatResult
+    {
+
+    }
+    /// <summary>
+    /// 
+    /// </summary>
+    public class ChatSearchResult
+    {
+        /// <summary>
+        /// 文件夹ID
+        /// </summary>
+        /// <value></value>
+        public int Id { get; set; }
+        /// <summary>
+        /// 名称 单聊 群聊 通讯录
+        /// </summary>
+        /// <value></value>
+        public string Name { get; set; }
+        /// <summary>
+        /// 环信ID
+        /// </summary>
+        /// <value></value>
+        public string ImId { get; set; }
+        /// <summary>
+        /// 头像 单聊 群聊 通讯录
+        /// </summary>
+        /// <value></value>
+        public string AvatarUrl { get; set; }
+        /// <summary>
+        /// 更新时间
+        /// </summary>
+        /// <value></value>
+        public DateTime? LastModifiedDate { get; set; }
+        /// <summary>
+        /// 部门名称
+        /// </summary>
+        /// <value></value>
+        public string DepartmentName { get; set; }
+        /// <summary>
+        ///  0 用户 1单聊 2群聊 3文件夹
+        /// </summary>
+        /// <value></value>
+        public int TypeValue { get; set; }
+
+    }
+}

gx_api/GxPress/Service/GxPress.Service.Implement/Chat/ChatSearchService.cs

@@ -0,0 +1,156 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Dapper;
+using Datory;
+using GxPress.Common.Tools;
+using GxPress.EnumConst;
+using GxPress.Result.Chat;
+using GxPress.Service.Interface;
+using GxPress.Service.Interface.Chat;
+
+namespace GxPress.Service.Implement.Chat
+{
+    public class ChatSearchService : IChatSearchService
+    {
+        private readonly IUserService userService;
+        public ChatSearchService(IUserService userService)
+        {
+            this.userService = userService;
+        }
+        /// <summary>
+        /// 搜索单聊
+        /// </summary>
+        /// <param name="keyWord"></param>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+        public async Task<IEnumerable<ChatSearchResult>> GetChatSearchAsync(string keyWord, int userId)
+        {
+            if (string.IsNullOrEmpty(keyWord))
+                return new List<ChatSearchResult>();
+            var chatConstValue = AllTypeConst.Wechat.GetHashCode();
+            string sqlStr = string.Empty;
+            if (!string.IsNullOrEmpty(keyWord))
+                sqlStr += $" and c.Name like '%{keyWord}%'";
+            var sql = $@"SELECT 
+                            c.Id, c.Name,c.Phone as ImId,c.AvatarUrl,b.LastModifiedDate
+                        FROM
+                            tede_middle a
+                                INNER JOIN
+                            tede_often_contact b ON a.middleId = b.Id
+                                INNER JOIN
+                            tede_user c ON c.Id = b.ContactUserId
+                        WHERE
+                            a.FolderType = {chatConstValue} AND a.UserId = {userId}
+                                AND a.IsDelete = 0
+                                AND b.ChatType = 1 {sqlStr}";
+            var database = new Database(DatabaseType.MySql, ConfigHelper.GetValue("Database:ConnectionString"));
+            var connection = database.GetConnection();
+            var result = await connection.QueryAsync<ChatSearchResult>(sql);
+            foreach (var item in result)
+            {
+                item.TypeValue = 1;
+                item.AvatarUrl = StringUtils.AddDomainMin(item.AvatarUrl);
+            }
+            return result;
+        }
+
+        /// <summary>
+        /// 搜索信源文件夹
+        /// </summary>
+        /// <param name="keyWord"></param>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+        public async Task<IEnumerable<ChatSearchResult>> GetChatFolderNameSearchAsync(string keyWord, int userId)
+        {
+            if (string.IsNullOrEmpty(keyWord))
+                return new List<ChatSearchResult>();
+            var chatConstValue = AllTypeConst.Wechat.GetHashCode();
+            string sqlStr = string.Empty;
+            if (!string.IsNullOrEmpty(keyWord))
+                sqlStr += $" and a.FolderName like '%{keyWord}%'";
+            var sql = $@"SELECT 
+                                a.Id,a.FolderName as Name,a.LastModifiedDate
+                                FROM
+                                    tede_middle a
+                                WHERE
+                                    a.FolderType = {chatConstValue} AND a.UserId = {userId}
+                                        AND a.IsDelete = 0
+                                        AND a.AttributeValue = 2 {sqlStr}";
+            var database = new Database(DatabaseType.MySql, ConfigHelper.GetValue("Database:ConnectionString"));
+            var connection = database.GetConnection();
+            var result = await connection.QueryAsync<ChatSearchResult>(sql);
+            foreach (var item in result)
+            {
+                item.TypeValue = 3;
+                item.AvatarUrl = StringUtils.AddDomainMin(item.AvatarUrl);
+            }
+            return result;
+        }
+        /// <summary>
+        /// 搜索信源群聊
+        /// </summary>
+        /// <param name="keyWord"></param>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+        public async Task<IEnumerable<ChatSearchResult>> GetGroupChatNameSearchAsync(string keyWord, int userId)
+        {
+            if (string.IsNullOrEmpty(keyWord))
+                return new List<ChatSearchResult>();
+            var chatConstValue = AllTypeConst.Wechat.GetHashCode();
+            string sqlStr = string.Empty;
+            if (!string.IsNullOrEmpty(keyWord))
+                sqlStr += $" AND d.Name LIKE '%{keyWord}%'";
+            var sql = $@"SELECT 
+                                d.Id,
+                                d.Name,
+                                d.AvatarUrl,
+                                d.GroupChatImId AS ImId,
+                                d.CreatedDate AS LastModifiedDate
+                            FROM
+                                tede_middle a
+                                    INNER JOIN
+                                tede_often_contact b ON a.middleId = b.Id
+                                    INNER JOIN
+                                tede_group_chat d ON d.GroupChatImId = b.ContactUserId
+                            WHERE
+                                a.FolderType = {chatConstValue} AND a.UserId ={userId}
+                                    AND a.IsDelete = 0
+                                    AND b.ChatType = 2
+                                    {sqlStr}
+                            ORDER BY d.CreatedDate DESC;";
+            var database = new Database(DatabaseType.MySql, ConfigHelper.GetValue("Database:ConnectionString"));
+            var connection = database.GetConnection();
+            var result = await connection.QueryAsync<ChatSearchResult>(sql);
+            foreach (var item in result)
+            {
+                item.TypeValue = 2;
+                item.AvatarUrl = StringUtils.AddDomainMin(item.AvatarUrl);
+            }
+            return result;
+        }
+        /// <summary>
+        /// 查询好友
+        /// </summary>
+        /// <param name="keyWord"></param>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+        public async Task<IEnumerable<ChatSearchResult>> GetFriendUserInfoResult(string keyWord, int userId)
+        {
+            var users = await userService.GetFriendUserInfoResult(userId, keyWord);
+            var result = new List<ChatSearchResult>();
+            foreach (var item in users)
+            {
+                result.Add(new ChatSearchResult
+                {
+                    Id = item.Id,
+                    Name = item.Name,
+                    AvatarUrl = item.AvatarUrl,
+                    DepartmentName = item.DepartmentName,
+                    ImId = item.Phone
+                });
+            }
+            return result;
+        }
+
+    }
+}

gx_api/GxPress/Service/GxPress.Service.Interface/Chat/IChatSearchService.cs

@@ -0,0 +1,38 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using GxPress.Result.Chat;
+
+namespace GxPress.Service.Interface.Chat
+{
+    public interface IChatSearchService : IService
+    {
+        /// <summary>
+        /// 搜索单聊
+        /// </summary>
+        /// <param name="keyWord"></param>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+        Task<IEnumerable<ChatSearchResult>> GetChatSearchAsync(string keyWord, int userId);
+        /// <summary>
+        /// 搜索信源文件夹
+        /// </summary>
+        /// <param name="keyWord"></param>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+        Task<IEnumerable<ChatSearchResult>> GetChatFolderNameSearchAsync(string keyWord, int userId);
+        /// <summary>
+        /// 搜索信源群聊
+        /// </summary>
+        /// <param name="keyWord"></param>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+        Task<IEnumerable<ChatSearchResult>> GetGroupChatNameSearchAsync(string keyWord, int userId);
+        /// <summary>
+        /// 查询好友
+        /// </summary>
+        /// <param name="keyWord"></param>
+        /// <param name="userId"></param>
+        /// <returns></returns>
+        Task<IEnumerable<ChatSearchResult>> GetFriendUserInfoResult(string keyWord, int userId);
+    }
+}