tede/gx_api/GxPress/Service/GxPress.Service.Implement/OftenContact/OftenContactService.Get.cs

using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Datory;
using GxPress.Common.Tools;
using GxPress.Request.App.OftenContact;
using GxPress.Request.GroupChatUser;
using GxPress.Result.App.OftenContact;
using System;

namespace GxPress.Service.Implement.OftenContact
{
    public partial class OftenContactService
    {
        /// <summary>
        /// 获取用户
        /// </summary>
        /// <param name="individualGroupId"></param>
        /// <returns></returns>
        public async Task<IEnumerable<OftenContactInfo>> GetOftenContacts(OftenContactSearchRequest request)
        {
            //获取文件夹数据
            var result = new List<OftenContactInfo>();
            var data = await _repository.GetContactInfosAsync(request);
            foreach (var oftenContact in data)
            {
                if (oftenContact.ChatType == 1)
                {
                    var user = await _userRepository.GetAsync(int.Parse(oftenContact.ContactUserId));
                    if (user == null)
                        continue;
                    oftenContact.Name = user.Name;
                    oftenContact.AvatarUrl = StringUtils.AddDomainMin(user.AvatarUrl);
                    oftenContact.ImId = user.ImId;
                    oftenContact.ToUserId = user.Id;
                }

                if (oftenContact.ChatType == 2)
                {
                    var groupChat = await _groupChatRepository.GetAsync(Q.Where(nameof(Entity.GroupChat.GroupChatImId),
                        oftenContact.ContactUserId));
                    if (groupChat == null)
                        continue;
                    oftenContact.Name = groupChat.Name;
                    oftenContact.AvatarUrl = StringUtils.AddDomainMin(groupChat.AvatarUrl);
                    oftenContact.ImId = groupChat.GroupChatImId;
                    var groupChatUserIsDisturbRequest = new GroupChatUserIsDisturbRequest();
                    groupChatUserIsDisturbRequest.GroupChatId = groupChat.Id;
                    groupChatUserIsDisturbRequest.UserId = oftenContact.UserId;
                    oftenContact.IsDisturb = await groupChatUserRepository.IsDisturbAsync(groupChatUserIsDisturbRequest);
                }
            }
            result = data.ToList();
            return result;
        }
        /// <summary>
        /// 获取聊天界面和验证最新时间
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        public async Task<OftenContactInfoGenericResult> GetOftenContactInfoGenericResult(OftenContactSearchRequest request)
        {
            var result = new OftenContactInfoGenericResult();
            result.OftenContactInfos = await GetOftenContacts(request);
            result.ConfirmationDate = await adminVerifyRepository.GetConfirmationDate(request.UserId);
            if (!string.IsNullOrEmpty(result.ConfirmationDate))
                result.ConfirmationDate = Convert.ToDateTime(result.ConfirmationDate).ToString("yyyy-MM-dd hh:mm:ss");
            return result;
        }

        /// <summary>
        /// 获取用户
        /// </summary>
        /// <param name="individualGroupId"></param>
        /// <returns></returns>
        public async Task<IEnumerable<OftenContactInfo>> GetOftenContactsAll(OftenContactSearchRequest request)
        {

            //获取文件夹数据
            var result = new List<OftenContactInfo>();
            var data = await _repository.GetContactInfoAllAsync(request);
            foreach (var oftenContact in data)
            {
                if (oftenContact.ChatType == 1)
                {
                    var user = await _userRepository.GetAsync(int.Parse(oftenContact.ContactUserId));
                    if (user == null)
                        continue;
                    oftenContact.Name = user.Name;
                    oftenContact.AvatarUrl = StringUtils.AddDomainMin(user.AvatarUrl);
                    oftenContact.ImId = user.ImId;
                    oftenContact.ToUserId = user.Id;
                }

                if (oftenContact.ChatType == 2)
                {
                    var groupChat = await _groupChatRepository.GetAsync(Q.Where(nameof(Entity.GroupChat.GroupChatImId),
                        oftenContact.ContactUserId));
                    if (groupChat == null)
                        continue;
                    oftenContact.Name = groupChat.Name;
                    oftenContact.AvatarUrl = StringUtils.AddDomainMin(groupChat.AvatarUrl);
                    oftenContact.ImId = groupChat.GroupChatImId;
                    var groupChatUserIsDisturbRequest = new GroupChatUserIsDisturbRequest();
                    groupChatUserIsDisturbRequest.GroupChatId = groupChat.Id;
                    groupChatUserIsDisturbRequest.UserId = oftenContact.UserId;
                    oftenContact.IsDisturb = await groupChatUserRepository.IsDisturbAsync(groupChatUserIsDisturbRequest);
                }
            }
            result = data.ToList();
            return result;
        }

    }
}