1

gx_api/GxPress/Service/GxPress.Service.Implement/Topic/TopicService.Add.cs

@@ -52,76 +52,8 @@ namespace GxPress.Service.Implement.Topic
                         topic.Content = JsonConvert.SerializeObject(contentJsonData);
                     }
                     var topicId = await _topicRepository.InsertAsync(topic);
-                    //创建话题管理员
-                    var topicAddressee = new TopicAddressee
-                    {
-                        IsAdmin = true,
-                        IsRead = true,
-                        TopicId = topicId,
-                        UserId = request.UserId,
-                        IsUpload = false
-                    };
-                    //获取用用户
-                    var user = await _userRepository.GetAsync(request.UserId);
-                    topicAddressee.UserName = user.Name;
-                    await _topicAddresseeRepository.InsertAsync(topicAddressee);
-                    //获取小组成员
-                    if (request.GroupId > 0)
-                    {
-                        var groupUsers =
-                            await _groupUserRepository.GetAllAsync(Q.Where(nameof(GroupUser.GroupId), request.GroupId));
-                        request.TopicAddresseeUserIds = groupUsers.Select(n => n.UserId).ToList();
-                    }
-                    //获取共享文件夹成员
-                    if (request.FolderId > 0)
-                    {
-                        var middle = await _middleRepository.GetMiddleAsync(request.FolderId);
-                        if (middle.AttributeValue == 2 && middle.RoleId == 1)
-                        {
-                            var users = await _userRepository.GetAllAsync(Q.Where(nameof(Entity.User.Id), ">", 0));
-                            request.TopicAddresseeUserIds = users.Select(n => n.Id).ToList();
-                        }
-                        else
-                        {
-                            var folderUsers = await _folderUserRepository.GetAllAsync(request.FolderId);
-                            request.TopicAddresseeUserIds = folderUsers.Select(n => n.UserId).ToList();
-                        }
-                        // //另存为笔记
-                        // var noteRequest = new NoteInRequest
-                        // {
-                        //     Title = request.Title,
-                        //     Content = request.Content,
-                        //     UserId = request.UserId,
-                        //     FolderId = request.FolderId,
-                        //     HtmlContent = request.HtmlContent,
-                        //     IsTopic=true
-                        // };
-                        // await _noteService.InsertNoteAsync(noteRequest);
-                        //设置默认共享文件夹
-                        await _middleRepository.UpdateAsync(Q.Set(nameof(Entity.Middle.Middle.IsDefault), false).Where(nameof(Entity.Middle.Middle.UserId), request.UserId).WhereIn(nameof(Entity.Middle.Middle.RoleId), new List<int> { 1, 3 }));
-                        //修改默认
-                        await _middleRepository.UpdateAsync(Q.Set(nameof(Entity.Middle.Middle.IsDefault), true).Where(nameof(Entity.Middle.Middle.Id), request.FolderId));
-                    }
-                    var topicAddressees = new List<TopicAddressee>();
-                    //
-                    request.TopicAddresseeUserIds.Add(request.UserId);
-                    //创建话题讨论成员
-                    foreach (var item in request.TopicAddresseeUserIds)
-                    {
-                        if (item == request.UserId)
-                            continue;
-                        //创建话题管理员
-                        topicAddressee = new TopicAddressee
-                        {
-                            TopicId = topicId,
-                            UserId = item
-                        };
-                        topicAddressees.Add(topicAddressee);
-                    }
-                    //添加话题阅读成员
-                    await _topicAddresseeRepository.InsertAsync(topicAddressees);
                     //修改话题访问量
-                    await _visitService.AddVisit(request.UserId, 2, topicId);
+                    await _visitService.AddVisit(request.UserId, GxPress.EnumConst.AllTypeConst.Topic.GetHashCode(), topicId);
                     transactionScope.Complete();
                 }
             }