no message

src/Bailun.Discuz.Application/WeiPan/WeiPanService.cs

@@ -224,13 +224,12 @@ namespace Bailun.Discuz.Application.WeiPan
             var apiOutput = HttpHelper.PostAsync<GetFileListRequest, GetFileListResponse>(apiUrl, getFileListRequest);
             return apiOutput;
         }
-        List<WeipanUserFiles> weipanUserFileList = null;
+
         /// <summary>
         /// 递归获取所有首页下的所有文件列表数据
         /// </summary>
         public async Task<List<FileListTreeDto>> GetFileListTree(string userId, string fildId)
         {
-            weipanUserFileList = new List<WeipanUserFiles>();
             List<FileListTreeDto> fileListTreeDtos = new List<FileListTreeDto>();
             //判断缓存中是否有值，如果有值直接读取
             var redisKey = Constants.File_List_Tree;
@@ -270,7 +269,6 @@ namespace Bailun.Discuz.Application.WeiPan
                                     weipanUserFiles.UserId = userId;
                                     weipanUserFiles.FatherFileId = fildId;
                                     weipanUserFiles.File_Id = u.fileid;
-                                    weipanUserFileList.Add(weipanUserFiles);
                                     await _weipanUserFilesRepository.AddAsync(weipanUserFiles, true);
                                 }
                             }
@@ -304,7 +302,6 @@ namespace Bailun.Discuz.Application.WeiPan
                 {
                     throw new Exception(apiOutput.errmsg);
                 }
-                _weipanUserFilesRepository.BulkInsert(weipanUserFileList.ToArray());
                 RedisHelper.HSet(redisKey, userId + "_" + fildId, fileListTreeDtos);
             }
             return fileListTreeDtos;
@@ -327,7 +324,6 @@ namespace Bailun.Discuz.Application.WeiPan
         /// <param name="token"></param>
         /// <param name="start"></param>
         /// <returns></returns>
-        
         public async  Task<List<FileListTreeDto>> GetChildrens(string userId, string fatherid, string token, int start,string parentId)
         {
 
@@ -375,7 +371,7 @@ namespace Bailun.Discuz.Application.WeiPan
                             weipanUserFiles.UserId = userId;
                             weipanUserFiles.FatherFileId = parentId;
                             weipanUserFiles.File_Id = i.fileid;
-                            weipanUserFileList.Add(weipanUserFiles);
+                            await _weipanUserFilesRepository.AddAsync(weipanUserFiles, true);
                         }
                     }
                 }
@@ -666,16 +662,19 @@ namespace Bailun.Discuz.Application.WeiPan
             return null;
         }
 
-        public async Task<List<string>> GetNoticeUserNames(string fileId)
+        public async Task<List<string>> GetNoticeUserNames(string fileId,string fileCreateUseid)
         {
             List<string> result = new List<string>();
             var userFiles = await _weipanUserFilesRepository.Query().AsNoTracking().Where(u => u.File_Id == fileId).ToListAsync();
             foreach (var item in userFiles)
             {
-                var user = await _usersRepository.Query().AsNoTracking().Where(i => i.UserId == item.UserId).FirstOrDefaultAsync();
-                if (user != null)
+                if(item.UserId!= fileCreateUseid)
                 {
-                    result.Add("@"+user.UserName);
+                    var user = await _usersRepository.Query().AsNoTracking().Where(i => i.UserId == item.UserId).FirstOrDefaultAsync();
+                    if (user != null)
+                    {
+                        result.Add("@" + user.UserName);
+                    }
                 }
             }
             return result;
@@ -717,7 +716,7 @@ namespace Bailun.Discuz.Application.WeiPan
                 var apiUrl = $"http://discuz.bailuntec.com/api/threads";
                 var res = JsonHelper.ToObject<PublishTieZiResponse>(Client_Post(publishTieZiRequest.ToJson(), apiUrl, "Bearer " + token));
                 //通知对应的用户
-                var users = await GetNoticeUserNames(weiPanFile.FileId);
+                var users = await GetNoticeUserNames(weiPanFile.FileId, weiPanFile.FileCreateUseid);
                 resultId = res.data.id;
                 PostNoticeByNewTieZi(users, resultId, token);
             }