OftenContactService.Get.cs 2.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. using System.Collections.Generic;
  2. using System.Linq;
  3. using System.Threading.Tasks;
  4. using Datory;
  5. using GxPress.Common.Tools;
  6. using GxPress.Entity;
  7. using GxPress.Request.App.OftenContact;
  8. using GxPress.Request.GroupChatUser;
  9. using GxPress.Result.App.OftenContact;
  10. namespace GxPress.Service.Implement.OftenContact
  11. {
  12. public partial class OftenContactService
  13. {
  14. /// <summary>
  15. /// 获取用户
  16. /// </summary>
  17. /// <param name="individualGroupId"></param>
  18. /// <returns></returns>
  19. public async Task<IEnumerable<OftenContactInfo>> GetOftenContacts(OftenContactSearchRequest request)
  20. {
  21. //获取文件夹数据
  22. var result = new List<OftenContactInfo>();
  23. var data = await _repository.GetContactInfosAsync(request);
  24. foreach (var oftenContact in data)
  25. {
  26. if (oftenContact.ChatType == 1)
  27. {
  28. var user = await _userRepository.GetAsync(int.Parse(oftenContact.ContactUserId));
  29. if (user == null)
  30. continue;
  31. oftenContact.Name = user.Name;
  32. oftenContact.AvatarUrl = StringUtils.AddDomainMin(user.AvatarUrl);
  33. oftenContact.ImId = user.ImId;
  34. oftenContact.ToUserId = user.Id;
  35. }
  36. if (oftenContact.ChatType == 2)
  37. {
  38. var groupChat = await _groupChatRepository.GetAsync(Q.Where(nameof(Entity.GroupChat.GroupChatImId),
  39. oftenContact.ContactUserId));
  40. if (groupChat == null)
  41. continue;
  42. oftenContact.Name = groupChat.Name;
  43. oftenContact.AvatarUrl = StringUtils.AddDomainMin(groupChat.AvatarUrl);
  44. oftenContact.ImId = groupChat.GroupChatImId;
  45. var groupChatUserIsDisturbRequest = new GroupChatUserIsDisturbRequest();
  46. groupChatUserIsDisturbRequest.GroupChatId = groupChat.Id;
  47. groupChatUserIsDisturbRequest.UserId = oftenContact.UserId;
  48. oftenContact.IsDisturb = await groupChatUserRepository.IsDisturbAsync(groupChatUserIsDisturbRequest);
  49. }
  50. }
  51. result = data.ToList();
  52. return result;
  53. }
  54. }
  55. }