tede/gx_api/GxPress/Service/GxPress.Service.Implement/Collection/CollectionService.cs

using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using AutoMapper;
using Datory;
using GxPress.Common.Exceptions;
using GxPress.Common.Page;
using GxPress.Common.Tools;
using GxPress.Entity.WorkMeeting;
using GxPress.EnumConst;
using GxPress.Repository.Interface;
using GxPress.Repository.Interface.Collection;
using GxPress.Repository.Interface.Missive;
using GxPress.Repository.Interface.Note;
using GxPress.Repository.Interface.WorkMeeting;
using GxPress.Request.App.Analyze;
using GxPress.Request.App.Collection;
using GxPress.Request.App.Middle;
using GxPress.Result;
using GxPress.Result.App.Collection;
using GxPress.Service.Interface.Analyze;
using GxPress.Service.Interface.Article;
using GxPress.Service.Interface.Collection;
using GxPress.Service.Interface.Middle;
using GxPress.Service.Interface.UserMiddle;
using GxPress.Repository.Interface.Media;
using Newtonsoft.Json;

namespace GxPress.Service.Implement.Collection
{
    public class CollectionService : ICollectionService
    {
        private readonly ICollectionRepository _collectionRepository;
        private readonly IMiddleService _middleService;
        private readonly IArticleRepository _articleRepository;
        private readonly ITopicRepository _topicRepository;
        private readonly IMiddleRepository _middleRepository;
        private readonly INoteRepository _noteRepository;
        private readonly IUserRepository _userRepository;
        private readonly IArticleService _articleService;
        private readonly INoticeRepository _noticeRepository;
        private readonly IMissiveRepository _missiveRepository;
        private readonly IGroupRepository _groupRepository;
        private readonly IMeetingSummaryRepository _meetingSummaryRepository;
        private readonly IMeetingRepository meetingRepository;
        private readonly IMapper _mapper;
        private readonly IFolderUserRepository _folderUserRepository;
        private readonly IAnalyzeService _analyzeService;
        private readonly IFileLibraryRepository fileLibraryRepository;
        private readonly IUserMiddleService _userMiddleService;
        private readonly IMediaRepository mediaRepository;
        public CollectionService(ICollectionRepository collectionRepository, IMiddleService middleService,
            IArticleRepository articleRepository, ITopicRepository topicRepository, IMiddleRepository middleRepository,
            INoteRepository noteRepository, IUserRepository userRepository, IArticleService articleService, INoticeRepository noticeRepository,
            IMissiveRepository missiveRepository, IMapper mapper,
            IGroupRepository groupRepository, IMeetingSummaryRepository meetingSummaryRepository,
            IFolderUserRepository folderUserRepository,
            IAnalyzeService analyzeService,
            IFileLibraryRepository fileLibraryRepository, IUserMiddleService userMiddleService, IMediaRepository mediaRepository, IMeetingRepository meetingRepository)
        {
            _collectionRepository = collectionRepository;
            _middleService = middleService;
            _articleRepository = articleRepository;
            _topicRepository = topicRepository;
            _middleRepository = middleRepository;
            _noteRepository = noteRepository;
            _userRepository = userRepository;
            _articleService = articleService;
            _noticeRepository = noticeRepository;
            _missiveRepository = missiveRepository;
            _mapper = mapper;
            _groupRepository = groupRepository;
            _meetingSummaryRepository = meetingSummaryRepository;
            _folderUserRepository = folderUserRepository;
            _analyzeService = analyzeService;
            this.fileLibraryRepository = fileLibraryRepository;
            _userMiddleService = userMiddleService;
            this.mediaRepository = mediaRepository;
            this.meetingRepository = meetingRepository;
        }

        /// <summary>
        /// 插入
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        public async Task<bool> Insert(CollectionInRequest request)
        {
            var collection = new Entity.Collection
            {
                CollectionDataId = request.CollectionDataId,
                CollectionType = request.CollectionType,
                UserId = request.UserId,
                SourceUserId = request.SourceUserId,
                EndCollectionDataId = request.CollectionDataId,
                EndCollectionType = request.CollectionType,
            };
            var resultJson = await StructCollectionData(request.CollectionDataId, request.CollectionType, request.SourceUserId);
            if (resultJson.ArticleImgUrl != null && resultJson.ArticleImgUrl.Count > 0)
            {
                for (int i = 0; i < resultJson.ArticleImgUrl.Count; i++)
                    resultJson.ArticleImgUrl[i] = StringUtils.RemoveDomain(resultJson.ArticleImgUrl[i]);
            }
            collection.ResultJson = JsonConvert.SerializeObject(resultJson);
            var query = new SqlKata.Query();
            query.Where(nameof(Entity.Collection.UserId), request.UserId)
                                 .Where(nameof(Entity.Collection.CollectionType), request.CollectionType)
                                 .Where(nameof(Entity.Collection.CollectionDataId), request.CollectionDataId);
            if (request.SourceUserId > 0)
                query.Where(nameof(Entity.Collection.SourceUserId), request.SourceUserId);
            //查询是否存在
            var findCollection = await _collectionRepository.GetAsync(query);
            var analyzeRequest = new AnalyzeRequest
            {
                UserId = request.UserId,
                AnalyzeType = 3,
                SourceId = request.CollectionDataId,
                TypeValue = request.CollectionType,// 10 会议纪要 0 文章 1 话题 2 通知 3 笔记  4站内信 12 收藏文件夹 13 笔记文件夹
                SourceUserId = request.SourceUserId
            };

            if (findCollection != null)
            {
                await _collectionRepository.DeleteAsync(findCollection.Id);
                await _middleRepository.DeleteAsync(Q.Where(nameof(Entity.Middle.Middle.FolderType), 3).Where(nameof(Entity.Middle.Middle.MiddleId), findCollection.Id).Where(nameof(Entity.Middle.Middle.UserId), request.UserId));
                var analyze = await _analyzeService.GetAnalyzeAsync(analyzeRequest);
                if (analyze != null)
                    await _analyzeService.DeleteAsync(analyze.Id);
                return true;
            }
            //
            if (request.CollectionType == AllTypeConst.TopicNoteAll.GetHashCode() || request.CollectionType == AllTypeConst.TopicNoteFolder.GetHashCode())
            {
                await _analyzeService.SetAnalyzeAsync(analyzeRequest);
            }
            //收藏媒体
            if (request.CollectionType == AllTypeConst.Book.GetHashCode() || request.CollectionType == AllTypeConst.Curriculum.GetHashCode() || request.CollectionType == AllTypeConst.Audio.GetHashCode() || request.CollectionType == AllTypeConst.Video.GetHashCode())
            {
                var media = await mediaRepository.GetAsync(request.CollectionDataId);
                collection.Title = media.Title;
                analyzeRequest.TypeValue = request.CollectionType;
                await _analyzeService.SetAnalyzeAsync(analyzeRequest);
            }
            //收藏文章
            if (request.CollectionType == AllTypeConst.Article.GetHashCode())
            {
                var article = await _articleRepository.GetArticleAsync(request.CollectionDataId);
                collection.Title = article.Title;
                analyzeRequest.TypeValue = request.CollectionType;
                await _analyzeService.SetAnalyzeAsync(analyzeRequest);
            }
            //话题
            else if (request.CollectionType == AllTypeConst.Topic.GetHashCode())
            {
                var topic = await _topicRepository.GetAsync(request.CollectionDataId);
                collection.Title = topic.Title;
                if (string.IsNullOrEmpty(collection.Title))
                    collection.Title = GetCollctionTitle(topic.Content);
                //收藏
                analyzeRequest.TypeValue = request.CollectionType;
                await _analyzeService.SetAnalyzeAsync(analyzeRequest);
            }
            //收藏收藏
            else if (request.CollectionType == AllTypeConst.Collect.GetHashCode())
            {
                //获取
                var collectionEntity = await _collectionRepository.GetAsync(request.CollectionDataId);
                collection.EndCollectionDataId = collectionEntity.EndCollectionDataId;
                collection.EndCollectionType = collectionEntity.EndCollectionType;
            }
            //笔记
            else if (request.CollectionType == AllTypeConst.Note.GetHashCode() || request.CollectionType == AllTypeConst.TopicNote.GetHashCode())
            {
                //收藏
                analyzeRequest.TypeValue = request.CollectionType;
                await _analyzeService.SetAnalyzeAsync(analyzeRequest);
                var note = await _noteRepository.GetAsync(request.CollectionDataId);
                collection.Title = note.Title;
                if (string.IsNullOrEmpty(collection.Title))
                    collection.Title = GetCollctionTitle(note.Content);
            }
            //通知
            else if (request.CollectionType == AllTypeConst.Notice.GetHashCode())
            {
                //通知
                analyzeRequest.TypeValue = request.CollectionType;
                await _analyzeService.SetAnalyzeAsync(analyzeRequest);
                var notice = await _noticeRepository.GetAsync(request.CollectionDataId);
                collection.Title = notice.Title;
                if (string.IsNullOrEmpty(collection.Title))
                    collection.Title = GetCollctionTitle(notice.Content);
            }
            //站内信
            else if (request.CollectionType == AllTypeConst.Missive.GetHashCode())
            {
                var notice = await _noticeRepository.GetAsync(request.CollectionDataId);
                collection.Title = notice.Title;
                //站内信
                analyzeRequest.TypeValue = request.CollectionType;
                await _analyzeService.SetAnalyzeAsync(analyzeRequest);
                if (string.IsNullOrEmpty(collection.Title))
                    collection.Title = GetCollctionTitle(notice.Content);
            }
            //收藏会议
            if (request.CollectionType == AllTypeConst.Meeting.GetHashCode())
            {
                var meeting = await meetingRepository.GetAsync(request.CollectionDataId);
                if (meeting == null)
                    throw new BusinessException("会议无效");
                collection.Title = meeting.Name;
                //收藏会议
                analyzeRequest.TypeValue = request.CollectionType;
                await _analyzeService.SetAnalyzeAsync(analyzeRequest);
            }
            //文件
            if (request.CollectionType == AllTypeConst.File.GetHashCode())
            {
                //获取文件信息
                var fileLibrary = await fileLibraryRepository.GetFileLibraryByIdAsync(collection.CollectionDataId);
                if (fileLibrary == null)
                    throw new BusinessException("文件不存在");
                collection.Title = fileLibrary.FileName;
            }
            //会议纪要
            if (request.CollectionType == AllTypeConst.MeetingSummary.GetHashCode())
            {
                var meetingSummary = await _meetingSummaryRepository.GetAsync(Q.Where(nameof(MeetingSummary.Id), request.CollectionDataId));
                if (meetingSummary == null)
                    throw new BusinessException("会议纪要无效");
                collection.Title = meetingSummary.Title;
                //会议纪要
                analyzeRequest.TypeValue = request.CollectionType;
                await _analyzeService.SetAnalyzeAsync(analyzeRequest);
            }
            //收藏、笔记文件
            if (request.CollectionType == AllTypeConst.NoteFolder.GetHashCode() || request.CollectionType == AllTypeConst.CollectFolder.GetHashCode())
            {
                if (request.CollectionDataId > 0)
                {
                    var middle = await _middleRepository.GetMiddleAsync(request.CollectionDataId);
                    if (middle == null)
                        throw new BusinessException("文件夹无效");
                    collection.Title = middle.FolderName;
                }
                else
                {
                    var user = await _userRepository.GetAsync(request.SourceUserId);
                    if (user == null)
                        throw new BusinessException("用户不存在！");
                    collection.Title = $"{user.Name}的";
                    collection.Title += request.CollectionType == AllTypeConst.CollectFolder.GetHashCode() ? "收藏" : "笔记";
                }
                //笔记文件
                analyzeRequest.TypeValue = request.CollectionType;
                await _analyzeService.SetAnalyzeAsync(analyzeRequest);
            }

            var collectionId = await _collectionRepository.InsertAsync(collection);
            //添加收藏信息
            var middleInsertTypeRequest = new MiddleInsertTypeRequest
            {
                AttributeValue = 1,
                FolderId = request.FolderId,
                FolderType = AllTypeConst.Collect.GetHashCode(),
                MiddleId = collectionId,
                MiddleSonId = 0,
                UserId = request.UserId
            };
            return await _middleService.AddOrUpdateAsync(middleInsertTypeRequest);
        }
        /// <summary>
        /// 收藏无文件夹分页列表
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        public async Task<PagedList<CollectionNoFolderResult>> GetCollectionNoFolderPageListAsync(CollectionPageSearchRequest request)
        {
            var result = await _collectionRepository.GetCollectionNoFolderPageListAsync(request);
            if (result == null || result.Items == null)
                return new PagedList<CollectionNoFolderResult>();
            foreach (var item in result.Items)
            {
                if (string.IsNullOrEmpty(item.FolderName))
                    item.FolderName = "根目录";
                //item.Data = await StructCollectionData(item.CollectionDataId, item.CollectionType, item.SourceUserId);
                item.Data = JsonConvert.DeserializeObject<CollectionContentJsonData>(item.ResultJson);
                if (item.Data != null)
                {
                    item.Data.File = StringUtils.RemoveDomain(item.Data.File);
                    item.Data.MinFile = StringUtils.RemoveDomain(item.Data.MinFile);
                    item.Data.File = StringUtils.AddDomain(item.Data.File);
                    item.Data.MinFile = StringUtils.AddDomain(item.Data.MinFile);
                }
                if (item.Data.ArticleImgUrl != null && item.Data.ArticleImgUrl.Count > 0)
                {
                    for (int i = 0; i < item.Data.ArticleImgUrl.Count; i++)
                    {
                        item.Data.ArticleImgUrl[i] = StringUtils.RemoveDomain(item.Data.ArticleImgUrl[i]);
                        item.Data.ArticleImgUrl[i] = StringUtils.AddDomain(item.Data.ArticleImgUrl[i]);
                    }
                }
                if (string.IsNullOrWhiteSpace(item.Title))
                {
                    item.Title = "";
                    if (item.Data.Type == AllTypeConst.Article.GetHashCode())
                        item.Title = item.Data.Title;
                    else if (item.Data.Type == AllTypeConst.TopicNoteAll.GetHashCode())
                        item.Title = item.Data.Title;
                    else if (item.Data.Type == AllTypeConst.TopicNoteFolder.GetHashCode())
                        item.Title = item.Data.Title;
                    else if (item.Data.Type == AllTypeConst.Text.GetHashCode())
                        item.Title = item.Data.Title;
                    else if (item.Data.Type == AllTypeConst.MeetingSummary.GetHashCode())
                        item.Title = item.Data.Title;
                    else
                    {
                        if (item.Data.Data != null)
                        {
                            if (item.Data.Type == AllTypeConst.Text.GetHashCode())
                                item.Title = item.Data.Text;
                            else if (item.Data.Data.Type == AllTypeConst.Text.GetHashCode())
                                item.Title = item.Data.Data.Text;
                            else if (item.Data.Data.Type == AllTypeConst.Image.GetHashCode())
                                item.Data.Title = "[图片]";
                            else
                                item.Data.Title = "[附件]";
                            item.Title = item.Data.Title;
                        }

                    }
                }
            }
            return result;
        }
        /// <summary>
        /// 查询结果
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        public async Task<PagedList<CollectionListPageResult>> PageListAsync(CollectionPageSearchRequest request)
        {
            var result = await _collectionRepository.PageListAsync(request);

            if (request.FolderId > 0)
            {
                var middle = await _middleRepository.GetMiddleAsync(request.FolderId);
                result.RoleId = middle != null ? middle.RoleId : 0;
                result.ParentId = middle.ParentId;
            }
            //是否收藏和转发数量
            if (request.VisitUserId > 0)
            {
                var user = await _userRepository.GetAsync(request.VisitUserId);
                result.Author = user.Name;
                var analyzeRequest = new AnalyzeRequest();
                analyzeRequest.SourceUserId = request.VisitUserId;
                analyzeRequest.AnalyzeType = 3;
                analyzeRequest.CommentId = 0;
                analyzeRequest.SourceId = request.FolderId;
                analyzeRequest.UserId = request.UserId;
                analyzeRequest.TypeValue = AllTypeConst.CollectFolder.GetHashCode();
                result.IsCollect = await _analyzeService.ExistsSourceUserAsync(analyzeRequest);
                analyzeRequest.AnalyzeType = 4;
                result.RetransmissionCount = await _analyzeService.RetransmissionCountAsync(analyzeRequest);
            }
            foreach (var item in result.Items)
            {
                //item.Data = await StructCollectionData(item.CollectionDataId, item.CollectionType, item.SourceUserId);
                item.Data = JsonConvert.DeserializeObject<CollectionContentJsonData>(item.ResultJson);
                if (item.Data != null)
                {
                    item.Data.File = StringUtils.RemoveDomain(item.Data.File);
                    item.Data.MinFile = StringUtils.RemoveDomain(item.Data.MinFile);
                    item.Data.File = StringUtils.AddDomain(item.Data.File);
                    item.Data.MinFile = StringUtils.AddDomain(item.Data.MinFile);
                }
                if (item.Data.ArticleImgUrl != null && item.Data.ArticleImgUrl.Count > 0)
                {
                    for (int i = 0; i < item.Data.ArticleImgUrl.Count; i++)
                    {
                        item.Data.ArticleImgUrl[i] = StringUtils.RemoveDomain(item.Data.ArticleImgUrl[i]);
                        item.Data.ArticleImgUrl[i] = StringUtils.AddDomain(item.Data.ArticleImgUrl[i]);
                    }
                }
                if (string.IsNullOrWhiteSpace(item.Title))
                {
                    item.Title = "";
                    if (item.Data.Type == AllTypeConst.Article.GetHashCode())
                        item.Title = item.Data.Title;
                    else if (item.Data.Type == AllTypeConst.TopicNoteAll.GetHashCode())
                        item.Title = item.Data.Title;
                    else if (item.Data.Type == AllTypeConst.TopicNoteFolder.GetHashCode())
                        item.Title = item.Data.Title;
                    else if (item.Data.Type == AllTypeConst.Text.GetHashCode())
                        item.Title = item.Data.Title;
                    else if (item.Data.Type == AllTypeConst.MeetingSummary.GetHashCode())
                        item.Title = item.Data.Title;
                    else if (item.Data.Type == AllTypeConst.MeetingSummary.GetHashCode())
                        item.Title = item.Data.Title;
                    else
                    {
                        if (item.Data.Data != null)
                        {
                            if (item.Data.Type == AllTypeConst.Text.GetHashCode())
                                item.Title = item.Data.Text;
                            else if (item.Data.Data.Type == AllTypeConst.Text.GetHashCode())
                                item.Title = item.Data.Data.Text;
                            else if (item.Data.Data.Type == AllTypeConst.Image.GetHashCode())
                                item.Title = "[图片]";
                            else
                                item.Title = "[附件]";
                        }
                    }
                }

            }
            return result;
        }

        /// <summary>
        /// 递归获取不是收藏的数据
        /// </summary>
        /// <param name="middleId"></param>
        /// <returns></returns>
        public async Task<Entity.Collection> GetCollectionRecursion(int middleId)
        {
            //var middle = await _middleRepository.GetMiddleAsync(middleId);
            var collection = await _collectionRepository.GetAsync(middleId);
            if (collection.CollectionType == AllTypeConst.Collect.GetHashCode())
                await GetCollectionRecursion(collection.CollectionType);
            return collection;
        }
        /// <summary>
        /// 笔记解析
        /// </summary>
        /// <param name="data"></param>
        /// <returns></returns>
        public async Task<CollectionContentJsonData> AnalyzeAsync(List<CollectionContentJsonData> data)
        {
            var result = new CollectionContentJsonData();
            var fileCount = data.Count(n => n.Type == AllTypeConst.File.GetHashCode());
            //提取图片
            if (data.Any(n => n.Type == AllTypeConst.Image.GetHashCode()))
            {
                var contentJsonData = new CollectionContentJsonData { FileCount = fileCount, Type = AllTypeConst.Image.GetHashCode() };
                //获取图片
                var imgList = data.Where(n => n.Type == AllTypeConst.Image.GetHashCode());
                contentJsonData.ArticleImgUrl = imgList.Select(n => StringUtils.AddDomain(n.File)).ToList();
                result = (contentJsonData);
                return result;
            }
            //提取文字
            if (data.Any(n => n.Type == AllTypeConst.Text.GetHashCode()))
            {
                var contentJsonData = new CollectionContentJsonData { FileCount = fileCount, Type = AllTypeConst.Text.GetHashCode() };
                //获取图片
                var textList = data.Where(n => n.Type == AllTypeConst.Text.GetHashCode());
                contentJsonData.Text = textList.FirstOrDefault().Text;
                result = (contentJsonData);
                return result;
            }
            //获取
            foreach (var item in data.Where(n => n.Type != AllTypeConst.Text.GetHashCode() && n.Type != AllTypeConst.File.GetHashCode()))
            {
                return await StructCollectionData(item.Id, item.Type, 0);
            }
            return result;
        }

        /// <summary>
        /// 构造收藏Data 收藏类型 1文章 2话题 3 收藏 4笔记 5通知 6站内信  7小组 8会议
        /// </summary>
        /// <param name="collectionDataId"></param>
        /// <param name="collectionType"></param>
        /// <param name="isReturn"></param>
        /// <returns></returns>
        public async Task<CollectionContentJsonData> StructCollectionData(int collectionDataId, int collectionType, int sourceUserId, bool isReturn = false)
        {
            var list = new CollectionContentJsonData();
            //1文章 2话题 3 收藏 4笔记 5通知 6站内信  7小组 8会议 14工作流审核 300 文件 400会议纪要
            //文章类型
            if (collectionType == GxPress.EnumConst.AllTypeConst.Article.GetHashCode())
            {
                var articleResult = await _articleService.GetAsync(collectionDataId, 0);
                if (articleResult == null)
                    return new CollectionContentJsonData();
                var articleImgUrl = new List<string>();
                if (articleResult.ImageUrls != null)
                    foreach (var block in articleResult.ImageUrls)
                        articleImgUrl.Add(StringUtils.AddDomain(block));
                list = new CollectionContentJsonData
                {
                    Author = articleResult.Author,
                    Title = articleResult.Title,
                    CreatedData = articleResult.AddDate,
                    Type = collectionType,
                    Id = articleResult.Id,
                    ArticleImgUrl = articleImgUrl,
                    ReadCount = articleResult.ReadCount,
                    Press = articleResult.Source
                };

            }
            if (collectionType == GxPress.EnumConst.AllTypeConst.TopicNoteAll.GetHashCode())
            {
                var user = await _userRepository.GetAsync(sourceUserId);
                if (user == null)
                    return new CollectionContentJsonData();
                list = new CollectionContentJsonData
                {
                    Author = user.Name,
                    Title = user.Name + "话题本",
                    Type = collectionType,
                    Id = user.Id,
                    SourceUserId = sourceUserId
                };
            }
            if (collectionType == GxPress.EnumConst.AllTypeConst.TopicNoteFolder.GetHashCode())
            {
                var middle = await _middleRepository.GetMiddleAsync(collectionDataId);
                if (middle == null)
                    return new CollectionContentJsonData();
                var user = await _userRepository.GetAsync(sourceUserId);
                if (user == null)
                    return new CollectionContentJsonData();
                list = new CollectionContentJsonData
                {
                    Name = middle.FolderName,
                    Title = middle.FolderName,
                    Type = collectionType,
                    Id = middle.Id,
                    Author = user.Name,
                    SourceUserId = sourceUserId
                };
            }
            //话题类型
            if (collectionType == GxPress.EnumConst.AllTypeConst.Topic.GetHashCode())
            {
                var topic = await _topicRepository.GetAsync(collectionDataId);
                if (topic == null)
                    return new CollectionContentJsonData();
                //获取是否存在小组
                var group = new Entity.Group();
                if (topic.GroupId > 0)
                {
                    group = await _groupRepository.GetAsync(topic.GroupId);
                    if (group == null)
                        return new CollectionContentJsonData();
                }
                //查询ID
                var user = await _userRepository.GetAsync(topic.UserId);
                if (user == null)
                    return new CollectionContentJsonData();
                list = new CollectionContentJsonData
                {
                    Author = user.Name,
                    Title = topic.Title,
                    CreatedData = topic.CreatedDate,
                    Type = collectionType,
                    Id = topic.Id,
                    File = StringUtils.AddDomain(user.AvatarUrl),
                    ReadCount = topic.ReadCount,
                    Name = user.Name,
                    AvatarUrl = StringUtils.AddDomain(user.AvatarUrl),
                    Data = await GetCollectionContentJsonData(topic.Content),
                    NickName = user.Nick,
                    IsGroup = group.Id > 0,
                    GroupId = group.Id > 0 ? group.Id : 0,
                    GroupName = group.Id > 0 ? group.Name : ""
                };
            }

            //收藏
            if (collectionType == GxPress.EnumConst.AllTypeConst.Collect.GetHashCode())
            {
                var collection = await GetCollectionRecursion(collectionDataId);
                list = await StructCollectionData(collection.EndCollectionDataId, collection.EndCollectionType, collection.SourceUserId);
                //list.Type = 8;
            }

            //笔记
            if (collectionType == GxPress.EnumConst.AllTypeConst.Note.GetHashCode() || collectionType == GxPress.EnumConst.AllTypeConst.TopicNote.GetHashCode())
            {
                var note = await _noteRepository.GetAsync(collectionDataId);
                if (note != null)
                {
                    var user = await _userRepository.GetAsync(note.UserId);
                    if (user == null)
                        return new CollectionContentJsonData();
                    list = (new CollectionContentJsonData
                    {
                        Author = user.Name,
                        NickName = user.Nick,
                        Name = user.Name,
                        Title = note.Title,
                        CreatedData = note.CreatedDate,
                        Type = collectionType,
                        Id = note.Id,
                        File = "",
                        AvatarUrl = StringUtils.AddDomain(user.AvatarUrl),
                        Data = await GetCollectionContentJsonData(note.Content)
                    });
                }
            }

            //通知
            if (collectionType == GxPress.EnumConst.AllTypeConst.Notice.GetHashCode()
             || collectionType == GxPress.EnumConst.AllTypeConst.Missive.GetHashCode()
             || collectionType == GxPress.EnumConst.AllTypeConst.Anonymity.GetHashCode())
            {
                var notice = await _noticeRepository.GetAsync(collectionDataId);
                if (notice == null)
                    return new CollectionContentJsonData();
                var user = await _userRepository.GetAsync(notice.UserId);
                if (user == null)
                    return new CollectionContentJsonData();
                list = (new CollectionContentJsonData
                {
                    Author = notice.TypeValue == AllTypeConst.Anonymity.GetHashCode() ? "匿名" : user.Name,
                    Title = string.IsNullOrEmpty(notice.Title) ? string.Empty : notice.Title,
                    CreatedData = notice.CreatedDate,
                    Type = collectionType,
                    Id = notice.Id,
                    File = "",
                    AvatarUrl = StringUtils.AddDomain(user.AvatarUrl),
                    Name = user.Name,
                    Data = await GetCollectionContentJsonData(notice.Content),
                    NickName = user.Nick
                });
            }

            // //站内信
            // if (collectionType == GxPress.EnumConst.AllTypeConst.Missive.GetHashCode())
            // {
            //     var missive = await _missiveRepository.GetAsync(collectionDataId);
            //     if (missive == null)
            //         return new CollectionContentJsonData();
            //     var user = await _userRepository.GetAsync(missive.UserId);
            //     if (user == null)
            //         return new CollectionContentJsonData();
            //     list = new CollectionContentJsonData
            //     {
            //         Author = user.Name,
            //         Title = missive.Title,
            //         CreatedData = missive.CreatedDate,
            //         Type = collectionType,
            //         Id = missive.Id,
            //         File = "",
            //         AvatarUrl = StringUtils.AddDomain(user.AvatarUrl),
            //         Name = user.Name,
            //         Data = await GetCollectionContentJsonData(missive.Content),
            //         NickName = user.Nick,
            //         MissiveType = missive.MissiveType
            //     };
            // }

            //小组
            if (collectionType == GxPress.EnumConst.AllTypeConst.Group.GetHashCode())
            {
                var group = await _groupRepository.GetAsync(collectionDataId);
                if (group == null)
                    return new CollectionContentJsonData();
                var user = await _userRepository.GetAsync(group.UserId);
                if (user == null)
                    return new CollectionContentJsonData();
                list = new CollectionContentJsonData
                {
                    Author = user.Name,
                    Title = group.Name,
                    CreatedData = group.CreatedDate,
                    Type = collectionType,
                    Id = group.Id,
                    File = StringUtils.AddDomain(group.AvatarUrl),
                    Name = user.Name,
                    NickName = user.Nick
                };
            }
            //会议
            if (collectionType == GxPress.EnumConst.AllTypeConst.Meeting.GetHashCode())
            {
                var meetingSummary = await _meetingSummaryRepository.GetAsync(Q.Where(nameof(MeetingSummary.MeetingId), collectionDataId));
                if (meetingSummary == null)
                    return new CollectionContentJsonData();
                var user = await _userRepository.GetAsync(meetingSummary.UserId);
                if (user == null)
                    return new CollectionContentJsonData();
                list = new CollectionContentJsonData
                {
                    Author = "",
                    Title = meetingSummary.Title,
                    CreatedData = meetingSummary.CreatedDate,
                    Type = collectionType,
                    Id = meetingSummary.Id,
                    File = "",
                    Name = user.Name,
                    NickName = user.Nick
                };
            }
            //工作流

            // 文件
            if (collectionType == GxPress.EnumConst.AllTypeConst.File.GetHashCode())
            {
                var fileLibrary = await fileLibraryRepository.GetFileLibraryByIdAsync(collectionDataId);
                if (fileLibrary == null)
                    return new CollectionContentJsonData();
                // var user = await _userRepository.GetAsync(fileLibrary.UserId);
                list = new CollectionContentJsonData
                {
                    Author = "",
                    Title = fileLibrary.FileName,
                    CreatedData = fileLibrary.CreatedData,
                    Type = collectionType,
                    Id = fileLibrary.Id,
                    File = StringUtils.AddDomain(fileLibrary.FileUrl),
                    MinFile = fileLibrary.FileType == "image" ? StringUtils.AddDomainMin(fileLibrary.FileUrl) : "",
                    AvatarUrl = "",
                    FileName = fileLibrary.FileName,
                    Name = "",
                    Data = new CollectionContentJsonData(),
                    NickName = "",
                    FileSize = fileLibrary.Size
                };
            }
            // 会议纪要
            if (collectionType == GxPress.EnumConst.AllTypeConst.MeetingSummary.GetHashCode())
            {
                var meetingSummary = await _meetingSummaryRepository.GetAsync(collectionDataId);
                if (meetingSummary == null)
                    return new CollectionContentJsonData();
                var user = await _userRepository.GetAsync(meetingSummary.UserId);
                if (user == null)
                    return new CollectionContentJsonData();
                list = new CollectionContentJsonData
                {
                    Author = user.Name,
                    Title = meetingSummary.Title,
                    CreatedData = meetingSummary.CreatedDate,
                    Type = collectionType,
                    Id = meetingSummary.Id,
                    File = "",
                    MinFile = "",
                    AvatarUrl = "",
                    FileName = "",
                    Name = "",
                    Data = new CollectionContentJsonData(),
                    NickName = user.Nick,
                    FileSize = 0
                };
            }
            //收藏笔记文件夹
            if (collectionType == GxPress.EnumConst.AllTypeConst.NoteFolder.GetHashCode() || collectionType == GxPress.EnumConst.AllTypeConst.CollectFolder.GetHashCode())
            {
                if (sourceUserId == 0)
                    return new CollectionContentJsonData();
                var user = await _userRepository.GetAsync(sourceUserId);
                if (user == null)
                    return new CollectionContentJsonData();
                list = new CollectionContentJsonData
                {
                    Author = user.Name,
                    Title = "",
                    Type = collectionType,
                    Id = 0,
                    File = "",
                    MinFile = "",
                    AvatarUrl = "",
                    FileName = "",
                    Name = "",
                    Data = new CollectionContentJsonData(),
                    NickName = user.Nick,
                    FileSize = 0
                };
            }
            return list;
        }


        /// <summary>
        /// 获取收藏详情
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public async Task<CollectionResult> GetCollectionDetailAsync(int id)
        {
            var collection = await _collectionRepository.GetAsync(id);
            if (collection == null)
                throw new BusinessException("收藏不存在");
            var result = _mapper.Map<CollectionResult>(collection);
            result.Data = await StructCollectionData(result.CollectionDataId, result.CollectionType, 0);
            return result;
        }

        public async Task<CollectionContentJsonData> GetCollectionContentJsonData(string json)
        {
            var data = JsonConvert.DeserializeObject<List<CollectionContentJsonData>>(json);
            return await AnalyzeAsync(data);
        }
        /// <summary>
        /// 
        /// </summary>
        /// <param name="content"></param>
        /// <returns></returns>
        public string GetCollctionTitle(string content)
        {
            if (!string.IsNullOrEmpty(content))
            {

                var forCount = 1;
                var contentJsonData = JsonConvert.DeserializeObject<List<ContentJsonData>>(content);
                foreach (var jsonData in contentJsonData)
                {
                    if (jsonData.TypeValue == AllTypeConst.Text.GetHashCode() && forCount == 1)
                        //文本
                        return jsonData.Text;
                    else
                        break;
                }
            }
            return "";
        }

        public async Task<bool> UpdateResultJosnAsync()
        {
            var query = Q.NewQuery();
            query.WhereNull(nameof(Entity.Collection.ResultJson));
            query.Limit(100);
            var result = await _collectionRepository.GetAllAsync(query);
            foreach (var item in result)
            {
                var jsonResult = await StructCollectionData(item.CollectionDataId, item.CollectionType, item.SourceUserId);
                if (jsonResult.ArticleImgUrl != null && jsonResult.ArticleImgUrl.Count > 0)
                {
                    for (int i = 0; i < jsonResult.ArticleImgUrl.Count; i++)
                        jsonResult.ArticleImgUrl[i] = StringUtils.RemoveDomain(jsonResult.ArticleImgUrl[i]);
                }
                item.ResultJson = JsonConvert.SerializeObject(jsonResult);
                await _collectionRepository.UpdateAsync(item);
            }
            return true;
        }
    }
}