MiddleService.cs 55 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Threading.Tasks;
  5. using GxPress.Common.Exceptions;
  6. using GxPress.Repository.Interface;
  7. using GxPress.Request.App.Middle;
  8. using GxPress.Request.Notice;
  9. using GxPress.Service.Interface.Middle;
  10. using Datory;
  11. using GxPress.Entity.Middle;
  12. using GxPress.Result.App.Middle;
  13. using System.Transactions;
  14. using GxPress.Repository.Interface.Collection;
  15. using GxPress.Repository.Interface.Note;
  16. using GxPress.Repository.Interface.Missive;
  17. using GxPress.Common.Tools;
  18. using GxPress.Repository.Interface.Analyze;
  19. using GxPress.Service.Interface.UserMiddle;
  20. using GxPress.Repository.Interface.RecordFolder;
  21. using GxPress.Service.Interface.Analyze;
  22. using GxPress.Request.App.Analyze;
  23. using GxPress.EnumConst;
  24. using System.Transactions;
  25. using GxPress.Request.UserMiddle;
  26. using Dapper;
  27. namespace GxPress.Service.Implement.Middle
  28. {
  29. public class MiddleService : IMiddleService
  30. {
  31. private readonly IMiddleRepository _middleRepository;
  32. private readonly IFolderUserRepository _folderUserRepository;
  33. private readonly IUserRepository _userRepository;
  34. private readonly ICollectionRepository _collectionRepository;
  35. private readonly INoteRepository _noteRepository;
  36. private readonly IMissiveRepository _missiveRepository;
  37. private readonly IGroupRepository _groupRepository;
  38. private readonly IAnalyzeRepository _analyzeRepository;
  39. private readonly INoticeRepository _noticeRepository;
  40. private readonly IUserMiddleService _userMiddleService;
  41. private readonly IAddresseeRepository _addresseeRepository;
  42. private readonly IRecordFolderRepository recordFolderRepository;
  43. private readonly IAnalyzeService analyzeService;
  44. public MiddleService(IMiddleRepository middleRepository, IFolderUserRepository folderUserRepository,
  45. IUserRepository userRepository, ICollectionRepository collectionRepository, INoteRepository noteRepository,
  46. IMissiveRepository missiveRepository, IGroupRepository groupRepository, INoticeRepository noticeRepository, IAnalyzeRepository analyzeRepository, IUserMiddleService userMiddleService, IAddresseeRepository addresseeRepository, IRecordFolderRepository recordFolderRepository, IAnalyzeService analyzeService)
  47. {
  48. _middleRepository = middleRepository;
  49. _folderUserRepository = folderUserRepository;
  50. _userRepository = userRepository;
  51. _collectionRepository = collectionRepository;
  52. _noteRepository = noteRepository;
  53. _missiveRepository = missiveRepository;
  54. _groupRepository = groupRepository;
  55. _noticeRepository = noticeRepository;
  56. _analyzeRepository = analyzeRepository;
  57. _userMiddleService = userMiddleService;
  58. _addresseeRepository = addresseeRepository;
  59. this.recordFolderRepository = recordFolderRepository;
  60. this.analyzeService = analyzeService;
  61. }
  62. /// <summary>
  63. /// 添加文件夹
  64. /// </summary>
  65. /// <param name="request"></param>
  66. /// <returns></returns>
  67. public async Task<MiddleInResult> InsertAsync(MiddleInsertRequest request)
  68. {
  69. var folderRoleId = new List<int> { 1, 2, 3 };
  70. if (!folderRoleId.Contains(request.RoleId) && (request.FolderType == 3 || request.FolderType == 4))
  71. throw new BusinessException("文件夹权限有误!");
  72. var query = Q.NewQuery();
  73. query.Where(nameof(Entity.Middle.Middle.UserId), request.UserId);
  74. query.Where(nameof(Entity.Middle.Middle.AttributeValue), 2);
  75. query.Where(nameof(Entity.Middle.Middle.FolderType), request.FolderType);
  76. if (request.FolderType == AllTypeConst.Note.GetHashCode())
  77. {
  78. if (request.RoleId == 1 || request.RoleId == 3)
  79. query.WhereIn(nameof(Entity.Middle.Middle.RoleId), new List<int> { 1, 3 });
  80. else
  81. query.Where(nameof(Entity.Middle.Middle.RoleId), request.RoleId);
  82. }
  83. query.Where(nameof(Entity.Middle.Middle.FolderName), request.FolderName);
  84. query.Where(nameof(Entity.Middle.Middle.ParentId), request.ParentId);
  85. query.Where(nameof(Entity.Middle.Middle.IsDelete), false);
  86. var oldMiddle = await _middleRepository.GetMiddleAsync(query);
  87. if (string.IsNullOrEmpty(request.FolderName))
  88. throw new BusinessException("文件名称未填写!");
  89. if (oldMiddle != null)
  90. throw new BusinessException("文件夹名称重复,请重新命名!");
  91. var middle = new Entity.Middle.Middle
  92. {
  93. FolderName = request.FolderName,
  94. FolderType = request.FolderType,
  95. IsTop = false,
  96. AttributeValue = 2,
  97. ParentId = request.ParentId,
  98. RoleId = request.RoleId,
  99. UserId = request.UserId,
  100. Sort = 0
  101. };
  102. //存在父级
  103. var middleDto = new Entity.Middle.Middle();
  104. if (request.ParentId > 0)
  105. {
  106. //获取父级数据
  107. middleDto = await _middleRepository.GetMiddleAsync(request.ParentId);
  108. if (middleDto != null)
  109. {
  110. middle.RoleId = middleDto.RoleId;
  111. request.RoleId = middleDto.RoleId;
  112. if (middleDto.ParentId == 0)
  113. middle.MiddleSonId = middleDto.Id;
  114. else middle.MiddleSonId = middleDto.MiddleSonId;
  115. }
  116. }
  117. if (request.RoleId == 0)
  118. middle.RoleId = 1;
  119. if (request.RoleId == 3)
  120. {
  121. if (request.UserIds == null)
  122. request.UserIds = new List<int>();
  123. if (request.UserIds.Count == 0 && request.UserMiddles.Count == 0 && request.ParentId == 0)
  124. throw new BusinessException("共享用户必须");
  125. }
  126. if (request.RoleId > 0)
  127. middle.RoleId = request.RoleId;
  128. var middleId = await _middleRepository.InsertAsync(middle);
  129. if (middle.ParentId == 0)
  130. {
  131. middle = await _middleRepository.GetMiddleAsync(middleId);
  132. if (middle != null)
  133. {
  134. middle.MiddleSonId = middleId;
  135. await _middleRepository.UpdateAsync(middle);
  136. }
  137. }
  138. await _middleRepository.UpdateAsync(Q.Set(nameof(Entity.Middle.Middle.Sort), middleId)
  139. .Where(nameof(Entity.Middle.Middle.Id), middleId));
  140. if (request.RoleId == 3 && request.ParentId == 0)
  141. //添加人员
  142. await InsertFolderUsers(request, middleId);
  143. var result = new MiddleInResult()
  144. {
  145. Id = middleId,
  146. Name = request.FolderName
  147. };
  148. return result;
  149. }
  150. /// <summary>
  151. /// 添加文件夹用户
  152. /// </summary>
  153. /// <param name="userIds"></param>
  154. /// <param name="middleId"></param>
  155. /// <returns></returns>
  156. public async Task<bool> InsertFolderUsers(MiddleInsertRequest request, int middleId)
  157. {
  158. //添加
  159. if (request.UserMiddles.Count > 0)
  160. {
  161. foreach (var item in request.UserMiddles)
  162. {
  163. item.DataSourceId = middleId;
  164. item.MiddleType = request.FolderType;
  165. }
  166. //添加中间表
  167. await _userMiddleService.AddUserMiddleAsync(request.UserMiddles);
  168. var users = await _userMiddleService.FindUsersAsync(request.UserMiddles, middleId);
  169. request.UserIds = users.Select(n => n.Id).ToList();
  170. }
  171. if (request.UserIds.Count > 0)
  172. {
  173. var users = await _userRepository.GetAllAsync(Q.WhereIn(nameof(Entity.User.Id), request.UserIds));
  174. //插入用户
  175. var folderUsers = new List<FolderUser>();
  176. foreach (var user in users)
  177. {
  178. var folderUser = new FolderUser();
  179. folderUser.UserId = user.Id;
  180. folderUser.UserName = user.Name;
  181. folderUser.MiddleId = middleId;
  182. folderUsers.Add(folderUser);
  183. }
  184. return await _folderUserRepository.InsertsAsync(folderUsers.ToList());
  185. }
  186. return false;
  187. }
  188. /// <summary>
  189. /// 修改文件夹名称
  190. /// </summary>
  191. /// <param name="request"></param>
  192. /// <returns></returns>
  193. public async Task<bool> UpdateNameAsync(MiddleUpdateNameRequest request)
  194. {
  195. var middle =
  196. await _middleRepository.GetMiddleAsync(Q.Where(nameof(Entity.Middle.Middle.Id), request.MiddleId)
  197. .Where(nameof(Entity.Middle.Middle.AttributeValue), 1));
  198. if (middle == null)
  199. throw new BusinessException("文件不存在");
  200. return await _middleRepository.UpdateAsync(
  201. Q.Set(nameof(Entity.Middle.Middle.FolderName), request.FolderName).Where(
  202. nameof(Entity.Middle.Middle.Id),
  203. request.MiddleId));
  204. }
  205. /// <summary>
  206. /// 添加数据
  207. /// </summary>
  208. /// <param name="request"></param>
  209. /// <returns></returns>
  210. public async Task<int> InsertAsync(MiddleInsertTypeRequest request)
  211. {
  212. var middle = new Entity.Middle.Middle
  213. {
  214. MiddleId = request.MiddleId,
  215. FolderType = request.FolderType,
  216. IsTop = false,
  217. AttributeValue = request.AttributeValue,
  218. ParentId = request.FolderId,
  219. UserId = request.UserId,
  220. MiddleSonId = request.MiddleSonId,
  221. IsAdmin = request.IsAdmin,
  222. NoticeAddresseeType = request.NoticeAddresseeType,
  223. //Title = request.Title,
  224. IsRead = false,
  225. IsUpload = false,
  226. //TitleLong = request.TitleLong,
  227. //Content = "",
  228. //AddressUser = request.AddressUser,
  229. // CcUser = request.CcUser,
  230. // CcUserComplete = request.CcUserComplete,
  231. //AddressUserComplete = request.AddressUserComplete,
  232. IsRecall = false
  233. };
  234. if (request.AttributeValue == 0)
  235. middle.AttributeValue = 1;
  236. var middleId = await _middleRepository.InsertAsync(middle);
  237. await _middleRepository.UpdateAsync(Q.Set(nameof(Entity.Middle.Middle.Sort), middleId)
  238. .Where(nameof(Entity.Middle.Middle.Id), middleId));
  239. return middleId;
  240. }
  241. /// <summary>
  242. /// 添加数据
  243. /// </summary>
  244. /// <param name="request"></param>
  245. /// <returns></returns>
  246. public async Task<bool> AddOrUpdateAsync(MiddleInsertTypeRequest request)
  247. {
  248. var middle = await _middleRepository.GetMiddleAsync(Q
  249. .Where(nameof(Entity.Middle.Middle.UserId), request.UserId)
  250. .Where(nameof(Entity.Middle.Middle.AttributeValue), 3)
  251. .Where(nameof(Entity.Middle.Middle.FolderType), request.FolderType));
  252. if (middle == null)
  253. {
  254. middle = new Entity.Middle.Middle
  255. {
  256. MiddleId = request.MiddleId,
  257. FolderType = request.FolderType,
  258. IsTop = false,
  259. AttributeValue = request.AttributeValue,
  260. ParentId = request.FolderId,
  261. UserId = request.UserId,
  262. MiddleSonId = request.MiddleSonId
  263. };
  264. var middleId = await _middleRepository.InsertAsync(middle);
  265. //修改Middle sort
  266. await _middleRepository.UpdateAsync(Q.Where(nameof(Entity.Middle.Middle.Id), middleId).Set(nameof(Entity.Middle.Middle.Sort), middleId));
  267. return true;
  268. }
  269. return await _middleRepository.UpdateAsync(Q.Set(nameof(Entity.Middle.Middle.IsDelete), false)
  270. .Where(nameof(Entity.Middle.Middle.UserId), request.UserId)
  271. .Where(nameof(Entity.Middle.Middle.AttributeValue), 3));
  272. }
  273. /// <summary>
  274. /// 排序
  275. /// </summary>
  276. /// <param name="request"></param>
  277. /// <returns></returns>
  278. public async Task<bool> MiddleSortAsync(MiddleSortRequest request)
  279. {
  280. return await _middleRepository.SetSortAsync(request);
  281. }
  282. /// <summary>
  283. /// 设置置顶
  284. /// </summary>
  285. /// <param name="id"></param>
  286. /// <returns></returns>
  287. public async Task<bool> SetTopAsync(int id)
  288. {
  289. return await _middleRepository.SetTopAsync(id);
  290. }
  291. /// <summary>
  292. /// 删除 1 通知 2话题 3 收藏 4笔记 5 普通站内信 6匿名站内信 7 小组
  293. /// </summary>
  294. /// <param name="request"></param>
  295. /// <returns></returns>
  296. public async Task<bool> DeleteAsync(NoticeDeRequest request)
  297. {
  298. try
  299. {
  300. var query = Q.NewQuery();
  301. using TransactionScope transactionScope = new TransactionScope();
  302. var middleIds = request.MiddleIds;
  303. //获取
  304. await _middleRepository.GetAllMiddleChildrenByParentIdAsync(request.MiddleIds, middleIds);
  305. request.MiddleIds = middleIds;
  306. //查询middle
  307. var middles = await _middleRepository.FindAsync(Q.WhereIn(nameof(Entity.Middle.Middle.Id), request.MiddleIds));
  308. var ids = middles.Select(n => n.MiddleId).ToList();
  309. //收藏
  310. if (request.FolderType == AllTypeConst.Collect.GetHashCode())
  311. {
  312. //查询收藏
  313. var collections = await _collectionRepository.GetAllAsync(Q.WhereIn(nameof(Entity.Collection.Id), ids));
  314. foreach (var item in collections)
  315. {
  316. var analyzeRequest = new AnalyzeRequest()
  317. {
  318. AnalyzeType = 3,
  319. SourceId = item.CollectionDataId,
  320. UserId = item.UserId
  321. };
  322. // //删除文章收藏
  323. // if (item.CollectionType == AllTypeConst.Article.GetHashCode())
  324. // {
  325. // analyzeRequest.TypeValue = item.CollectionType;
  326. // var analyze = await analyzeService.GetAnalyzeAsync(analyzeRequest);
  327. // if (analyze != null)
  328. // await _analyzeRepository.DeleteAsync(analyze.Id);
  329. // }
  330. // //删除话题收藏
  331. // if (item.CollectionType == AllTypeConst.Topic.GetHashCode())
  332. // {
  333. // analyzeRequest.TypeValue = item.CollectionType;
  334. // var analyze = await analyzeService.GetAnalyzeAsync(analyzeRequest);
  335. // if (analyze != null)
  336. // await _analyzeRepository.DeleteAsync(analyze.Id);
  337. // }
  338. // //删除笔记收藏
  339. // if (item.CollectionType == AllTypeConst.Note.GetHashCode() || item.CollectionType == AllTypeConst.TopicNote.GetHashCode()
  340. // || item.CollectionType == AllTypeConst.TopicNoteAll.GetHashCode() || item.CollectionType == AllTypeConst.TopicNoteFolder.GetHashCode())
  341. // {
  342. // analyzeRequest.TypeValue = item.CollectionType;
  343. // var analyze = await analyzeService.GetAnalyzeAsync(analyzeRequest);
  344. // if (analyze != null)
  345. // await _analyzeRepository.DeleteAsync(analyze.Id);
  346. // }
  347. //删除通知收藏
  348. if (item.CollectionType == AllTypeConst.Notice.GetHashCode())
  349. {
  350. analyzeRequest.TypeValue = item.CollectionType;
  351. var analyze = await analyzeService.GetAnalyzeAsync(analyzeRequest);
  352. if (analyze != null)
  353. await _analyzeRepository.DeleteAsync(analyze.Id);
  354. query = Q.NewQuery();
  355. query.Where(nameof(Entity.Addressee.UserId), request.UserId);
  356. query.WhereIn(nameof(Entity.Addressee.SourceId), ids);
  357. query.Set(nameof(Entity.Addressee.IsDelete), true);
  358. await _addresseeRepository.UpdateAsync(query);
  359. }
  360. //删除站内信收藏
  361. else if (item.CollectionType == AllTypeConst.Missive.GetHashCode())
  362. {
  363. analyzeRequest.TypeValue = item.CollectionType;
  364. var analyze = await analyzeService.GetAnalyzeAsync(analyzeRequest);
  365. if (analyze != null)
  366. await _analyzeRepository.DeleteAsync(analyze.Id);
  367. query = Q.NewQuery();
  368. query.Where(nameof(Entity.Addressee.UserId), request.UserId);
  369. query.WhereIn(nameof(Entity.Addressee.SourceId), ids);
  370. query.Set(nameof(Entity.Addressee.IsDelete), true);
  371. await _addresseeRepository.UpdateAsync(query);
  372. }
  373. else
  374. {
  375. analyzeRequest.TypeValue = item.CollectionType;
  376. var analyze = await analyzeService.GetAnalyzeAsync(analyzeRequest);
  377. if (analyze != null)
  378. await _analyzeRepository.DeleteAsync(analyze.Id);
  379. }
  380. // //删除收藏会议
  381. // if (item.CollectionType == AllTypeConst.Meeting.GetHashCode())
  382. // {
  383. // analyzeRequest.TypeValue = item.CollectionType;
  384. // var analyze = await analyzeService.GetAnalyzeAsync(analyzeRequest);
  385. // if (analyze != null)
  386. // await _analyzeRepository.DeleteAsync(analyze.Id);
  387. // }
  388. // //删除收藏会议纪要
  389. // if (item.CollectionType == AllTypeConst.MeetingSummary.GetHashCode())
  390. // {
  391. // analyzeRequest.TypeValue = item.CollectionType;
  392. // var analyze = await analyzeService.GetAnalyzeAsync(analyzeRequest);
  393. // if (analyze != null)
  394. // await _analyzeRepository.DeleteAsync(analyze.Id);
  395. // }
  396. // //收藏笔记文件夹
  397. // if (item.CollectionType == AllTypeConst.NoteFolder.GetHashCode() || item.CollectionType == AllTypeConst.CollectFolder.GetHashCode())
  398. // {
  399. // analyzeRequest.TypeValue = item.CollectionType;
  400. // var analyze = await analyzeService.GetAnalyzeAsync(analyzeRequest);
  401. // if (analyze != null)
  402. // await _analyzeRepository.DeleteAsync(analyze.Id);
  403. // }
  404. // //媒体
  405. // var mediaConst = new List<int>{
  406. // //视频
  407. // AllTypeConst.Video.GetHashCode(),
  408. // //音频
  409. // AllTypeConst.Audio.GetHashCode(),
  410. // //书籍
  411. // AllTypeConst.Book.GetHashCode(),
  412. // //课程
  413. // AllTypeConst.Curriculum.GetHashCode(),
  414. // //视频
  415. // AllTypeConst.Journal.GetHashCode(),
  416. // //名栏
  417. // AllTypeConst.StarColumn.GetHashCode(),
  418. // //公众号
  419. // AllTypeConst.PublicNumber.GetHashCode(),
  420. // //刊期
  421. // AllTypeConst.Magazine.GetHashCode(),
  422. // };
  423. // if (mediaConst.Contains(item.CollectionType))
  424. // {
  425. // analyzeRequest.TypeValue = item.CollectionType;
  426. // var analyze = await analyzeService.GetAnalyzeAsync(analyzeRequest);
  427. // if (analyze != null)
  428. // await _analyzeRepository.DeleteAsync(analyze.Id);
  429. // }
  430. }
  431. //删除收藏
  432. request.IsDelete = true;
  433. //删除
  434. await _collectionRepository.RecursionDeleteAsync(request.MiddleIds);
  435. }
  436. //删除笔记
  437. if (request.FolderType == AllTypeConst.Note.GetHashCode())
  438. {
  439. await _noteRepository.UpdateAsync(Q.WhereIn(nameof(Entity.Note.Note.Id), ids).Set(nameof(Entity.Note.Note.IsDelete), true));
  440. //删除默认共享文件夹
  441. await recordFolderRepository.DeleteAsync(request.FolderType, request.UserId, request.MiddleIds);
  442. }
  443. //小组
  444. if (request.FolderType == AllTypeConst.Group.GetHashCode())
  445. await _groupRepository.DeleteAsync(Q.WhereIn(nameof(Entity.Group.Id), ids));
  446. //删除收件箱
  447. if (request.FolderType == AllTypeConst.Inbox.GetHashCode())
  448. {
  449. query = Q.NewQuery();
  450. query.Where(nameof(Entity.Addressee.UserId), request.UserId);
  451. query.WhereIn(nameof(Entity.Addressee.SourceId), ids);
  452. query.Set(nameof(Entity.Addressee.IsDelete), true);
  453. query.Set(nameof(Entity.Addressee.IsRead), true);
  454. await _addresseeRepository.UpdateAsync(query);
  455. //request.IsDelete = true;
  456. }
  457. if (request.FolderType == AllTypeConst.Inbox.GetHashCode())
  458. {
  459. foreach (var item in middles)
  460. {
  461. if (item.AttributeValue == 2)
  462. {
  463. //永久删除文件夹
  464. await _middleRepository.DeleteAsync(Q.Where(nameof(Entity.Middle.Middle.Id), item.Id));
  465. //修改文件夹下级数据
  466. await _middleRepository.UpdateAsync(Q.Set(nameof(Entity.Middle.Middle.IsDelete), 1).Where(nameof(Entity.Middle.Middle.ParentId), item.Id));
  467. }
  468. }
  469. }
  470. //删除信源以及文件夹
  471. if (request.FolderType == AllTypeConst.Wechat.GetHashCode())
  472. {
  473. foreach (var middle in middles)
  474. {
  475. //判断是否文件夹
  476. if (middle.AttributeValue == 2)
  477. {
  478. query = Q.NewQuery();
  479. query.Set(nameof(Entity.Middle.Middle.ParentId), 0);
  480. query.Where(nameof(Entity.Middle.Middle.Id), middle.Id);
  481. query.Where(nameof(Entity.Middle.Middle.FolderType), AllTypeConst.Wechat.GetHashCode());
  482. await _middleRepository.UpdateAsync(query);
  483. }
  484. }
  485. }
  486. await _middleRepository.DeleteAsync(request);
  487. transactionScope.Complete();
  488. }
  489. catch (Exception ex)
  490. {
  491. throw new BusinessException(ex.Message);
  492. }
  493. return true;
  494. }
  495. public async Task<bool> RecoverDeleteAsync(NoticeDeRequest request)
  496. {
  497. return await _middleRepository.RecoverDeleteAsync(request);
  498. }
  499. /// <summary>
  500. /// 移动到
  501. /// </summary>
  502. /// <param name="request"></param>
  503. /// <returns></returns>
  504. public async Task<bool> SetMove(MiddleMoveRequest request)
  505. {
  506. if (request.ParentId == 0 && request.TypeId == -AllTypeConst.Note.GetHashCode())
  507. request.Ids = await _middleRepository.GetMiddleIsFolderAsync(request.Ids);
  508. try
  509. {
  510. using (var transactionScope = new TransactionScope())
  511. {
  512. var middle = await _middleRepository.GetMiddleAsync(Q.Where(nameof(Entity.Middle.Middle.Id), request.ParentId));
  513. if (request.ParentId > 0 && middle != null)
  514. {
  515. //获取父级子集集合
  516. var ids = await _middleRepository.GetAllMiddleChildrenByParentIdAsync(request.Ids.ToList(), request.Ids.ToList());
  517. //修改
  518. await _middleRepository.UpdateAsync(Q.Set(nameof(Entity.Middle.Middle.RoleId), middle.RoleId).WhereIn(nameof(Entity.Middle.Middle.Id), ids));
  519. await _middleRepository.UpdateAsync(Q.Set(nameof(Entity.Middle.Middle.ParentId), request.ParentId).Set(nameof(Entity.Middle.Middle.RoleId), middle.RoleId).WhereIn(nameof(Entity.Middle.Middle.Id), request.Ids));
  520. //修改共享
  521. await _middleRepository.UpdateAsync(Q.Set(nameof(Entity.Middle.Middle.MiddleSonId), middle.MiddleSonId).WhereIn(nameof(Entity.Middle.Middle.Id), ids));
  522. }
  523. if (request.ParentId == 0)
  524. {
  525. middle = await _middleRepository.GetMiddleAsync(Q.Where(nameof(Entity.Middle.Middle.Id), request.Ids.First()));
  526. if (middle.RoleId == 3)
  527. {
  528. /// <summary>
  529. /// 获取共享人员
  530. /// </summary>
  531. /// <returns></returns>
  532. var userMiddles = await _userMiddleService.FindUserMiddlesAsync(middle.FolderType, middle.MiddleSonId);
  533. foreach (var id in request.Ids)
  534. {
  535. var userMiddleInRequest = new List<UserMiddleInRequest>();
  536. foreach (var userMiddle in userMiddles)
  537. {
  538. userMiddleInRequest.Add(new UserMiddleInRequest
  539. {
  540. MiddleType = userMiddle.MiddleType,
  541. SourceType = userMiddle.SourceType,
  542. SourceId = userMiddle.SourceId,
  543. SourceName = userMiddle.SourceName,
  544. DataSourceId = id,
  545. SourceTypeValue = userMiddle.SourceTypeValue
  546. });
  547. }
  548. //添加共享人员
  549. await _userMiddleService.AddUserMiddleAsync(userMiddleInRequest);
  550. }
  551. }
  552. //修改
  553. await _middleRepository.UpdateAsync(Q.Set(nameof(Entity.Middle.Middle.ParentId), request.ParentId).WhereIn(nameof(Entity.Middle.Middle.Id), request.Ids));
  554. foreach (var item in request.Ids)
  555. {
  556. var ids = await _middleRepository.GetAllMiddleChildrenByParentIdAsync(new List<int> { item }, new List<int> { });
  557. await _middleRepository.UpdateAsync(Q.Set(nameof(Entity.Middle.Middle.MiddleSonId), item).WhereIn(nameof(Entity.Middle.Middle.Id), ids));
  558. }
  559. }
  560. transactionScope.Complete();
  561. }
  562. }
  563. catch
  564. {
  565. return false;
  566. }
  567. return true;
  568. }
  569. /// <summary>
  570. /// 恢复全部
  571. /// </summary>
  572. /// <param name="folderType"></param>
  573. /// <returns></returns>
  574. public async Task<bool> RecoverAllAsync(int folderType, int userId)
  575. {
  576. var query = Q.NewQuery();
  577. query.Set(nameof(Entity.Middle.Middle.IsDelete), false);
  578. query.Where(nameof(Entity.Middle.Middle.FolderType), AllTypeConst.Inbox.GetHashCode());
  579. query.Where(nameof(Entity.Middle.Middle.UserId), userId);
  580. return await _middleRepository.UpdateAsync(query);
  581. }
  582. /// <summary>
  583. /// 修改文件夹名称
  584. /// </summary>
  585. /// <param name="request"></param>
  586. /// <returns></returns>
  587. public async Task<bool> UpdateFolderNameAsync(MiddleFolderNameRequest request)
  588. {
  589. var middle = await _middleRepository.GetMiddleAsync(request.Id);
  590. if (middle == null)
  591. throw new BusinessException("文件夹不存在");
  592. var oldMiddle = await _middleRepository.GetMiddleAsync(Q
  593. .Where(nameof(Entity.Middle.Middle.UserId), request.UserId)
  594. .Where(nameof(Entity.Middle.Middle.AttributeValue), 2)
  595. .Where(nameof(Entity.Middle.Middle.FolderType), middle.FolderType)
  596. .Where(nameof(Entity.Middle.Middle.FolderName), request.FolderName)
  597. .Where(nameof(Entity.Middle.Middle.IsDelete), false));
  598. if (oldMiddle != null && oldMiddle.Id != middle.Id)
  599. throw new BusinessException("文件夹名称重复,请重新命名!");
  600. return await _middleRepository.UpdateFolderNameAsync(request);
  601. }
  602. /// <summary>
  603. /// 查询文件夹
  604. /// </summary>
  605. /// <param name="request"></param>
  606. /// <returns></returns>
  607. public async Task<List<MiddleSearchFolderResult>> SearchFolderAsync(MiddleSearchFolderRequest request)
  608. {
  609. var query = Q.NewQuery();
  610. query.Where(nameof(Entity.Middle.Middle.ParentId), request.ParentId)
  611. .Where(nameof(Entity.Middle.Middle.AttributeValue), 2);
  612. query.Where(nameof(Entity.Middle.Middle.FolderType), request.TypeId);
  613. query.Where(nameof(Entity.Middle.Middle.UserId), request.UserId)
  614. .Where(nameof(Entity.Middle.Middle.IsDelete), false);
  615. if (request.FolderIds != null && request.FolderIds.Count > 0)
  616. query.WhereNotIn(nameof(Entity.Middle.Middle.Id), request.FolderIds);
  617. if (!string.IsNullOrWhiteSpace(request.KeyWord))
  618. query.WhereLike(nameof(Entity.Middle.Middle.FolderName), $"%{request.KeyWord}%");
  619. if (request.TypeId == AllTypeConst.TopicNote.GetHashCode())
  620. query.WhereIn(nameof(Entity.Middle.Middle.RoleId), new List<int> { 1, 3 });
  621. if (request.TypeId == AllTypeConst.Note.GetHashCode())
  622. query.WhereIn(nameof(Entity.Middle.Middle.RoleId), new List<int> { 2 });
  623. var middles = await _middleRepository.FindAsync(query.OrderByDesc(nameof(Entity.Middle.Middle.IsSystemDefault), nameof(Entity.Middle.Middle.IsTop), nameof(Entity.Middle.Middle.Sort), nameof(Entity.Middle.Middle.LastModifiedDate)));
  624. List<MiddleSearchFolderResult> result = new List<MiddleSearchFolderResult>();
  625. foreach (var item in middles)
  626. {
  627. MiddleSearchFolderResult middleSearchFolderResult = new MiddleSearchFolderResult
  628. {
  629. Name = item.FolderName,
  630. Id = item.Id,
  631. IsDisable = request.FolderIds.Any(n => n.Equals(item.Id)),
  632. RoleId = item.RoleId,
  633. IsFolder = await _middleRepository.IsFolderAsync(item.Id),
  634. IsTop = item.IsTop,
  635. IsSystemDefault = item.IsSystemDefault,
  636. ParentId = item.ParentId
  637. };
  638. if (item.RoleId == 3)
  639. {
  640. var sourceId = item.Id;
  641. if (item.ParentId != 0)
  642. sourceId = item.MiddleSonId;
  643. var userMiddles = await _userMiddleService.FindUserMiddlesAsync(item.FolderType, sourceId);
  644. // var folderUsers = await _folderUserRepository.GetAllAsync(Q.Where(nameof(FolderUser.MiddleId), item.Id).OrderByDesc(nameof(FolderUser.CreatedDate)).Take(10));
  645. middleSearchFolderResult.EnjoyUser = StringUtils.ObjectCollectionToString(userMiddles.Select(n => n.SourceName), "、");
  646. }
  647. result.Add(middleSearchFolderResult);
  648. }
  649. return result;
  650. }
  651. /// <summary>
  652. /// 查询文件夹包含父级
  653. /// </summary>
  654. /// <param name="request"></param>
  655. /// <returns></returns>
  656. public async Task<MiddleSearchFolderByParendIsResult> SearchFolderAndParentIdAsync(MiddleSearchFolderRequest request)
  657. {
  658. var query = Q.NewQuery();
  659. query.Where(nameof(Entity.Middle.Middle.ParentId), request.ParentId)
  660. .Where(nameof(Entity.Middle.Middle.AttributeValue), 2);
  661. query.Where(nameof(Entity.Middle.Middle.FolderType), request.TypeId);
  662. query.Where(nameof(Entity.Middle.Middle.UserId), request.UserId)
  663. .Where(nameof(Entity.Middle.Middle.UserId), request.UserId)
  664. .Where(nameof(Entity.Middle.Middle.IsDelete), false).WhereNotIn(nameof(Entity.Middle.Middle.Id), request.FolderIds);
  665. if (!string.IsNullOrWhiteSpace(request.KeyWord))
  666. query.WhereLike(nameof(Entity.Middle.Middle.FolderName), $"%{request.KeyWord}%");
  667. if (request.TypeId == AllTypeConst.TopicNote.GetHashCode())
  668. query.WhereIn(nameof(Entity.Middle.Middle.RoleId), new List<int> { 1, 3 });
  669. if (request.TypeId == AllTypeConst.Note.GetHashCode())
  670. query.WhereIn(nameof(Entity.Middle.Middle.RoleId), new List<int> { 2 });
  671. var middles = await _middleRepository.FindAsync(query.OrderByDesc(nameof(Entity.Middle.Middle.IsTop), nameof(Entity.Middle.Middle.Sort), nameof(Entity.Middle.Middle.LastModifiedDate)));
  672. var middle = await _middleRepository.GetMiddleAsync(Q.Where(nameof(Entity.Middle.Middle.Id), request.ParentId));
  673. var result = new MiddleSearchFolderByParendIsResult() { Name = middle == null ? "" : middle.FolderName };
  674. if (middle != null && middle.ParentId > 0)
  675. {
  676. middle = await _middleRepository.GetMiddleAsync(Q.Where(nameof(Entity.Middle.Middle.Id), middle.ParentId));
  677. result.Id = middle == null ? 0 : middle.Id;
  678. result.Name = middle == null ? "" : middle.FolderName;
  679. }
  680. result.Item = new List<MiddleSearchFolderResult>();
  681. foreach (var item in middles)
  682. {
  683. MiddleSearchFolderResult middleSearchFolderResult = new MiddleSearchFolderResult
  684. {
  685. Name = item.FolderName,
  686. Id = item.Id,
  687. IsDisable = request.FolderIds.Any(n => n.Equals(item.Id)),
  688. RoleId = item.RoleId,
  689. IsFolder = await _middleRepository.IsFolderAsync(item.Id),
  690. IsTop = item.IsTop,
  691. ParentId = item.ParentId
  692. };
  693. if (item.RoleId == 3)
  694. {
  695. var sourceId = item.Id;
  696. if (item.ParentId != 0)
  697. sourceId = item.MiddleSonId;
  698. var userMiddles = await _userMiddleService.FindUserMiddlesAsync(item.FolderType, sourceId);
  699. // var folderUsers = await _folderUserRepository.GetAllAsync(Q.Where(nameof(FolderUser.MiddleId), item.Id).OrderByDesc(nameof(FolderUser.CreatedDate)).Take(10));
  700. middleSearchFolderResult.EnjoyUser = StringUtils.ObjectCollectionToString(userMiddles.Select(n => n.SourceName), "、");
  701. }
  702. result.Item.Add(middleSearchFolderResult);
  703. }
  704. return result;
  705. }
  706. /// <summary>
  707. /// 修改权限
  708. /// </summary>
  709. /// <param name="request"></param>
  710. /// <returns></returns>
  711. public async Task<bool> UpdateFolderRoleAsync(MiddleUpdateFolderRoleRequest request)
  712. {
  713. var middle = await _middleRepository.GetMiddleAsync(request.MiddleId);
  714. if (middle == null)
  715. throw new BusinessException("文件夹不存在");
  716. var oldMiddle = await _middleRepository.GetMiddleAsync(Q
  717. .Where(nameof(Entity.Middle.Middle.UserId), middle.UserId)
  718. .Where(nameof(Entity.Middle.Middle.AttributeValue), 2)
  719. .Where(nameof(Entity.Middle.Middle.FolderType), middle.FolderType)
  720. .Where(nameof(Entity.Middle.Middle.FolderName), request.FolderName)
  721. .Where(nameof(Entity.Middle.Middle.ParentId), middle.ParentId).Where(nameof(Entity.Middle.Middle.IsDelete), false));
  722. if (string.IsNullOrEmpty(request.FolderName))
  723. throw new BusinessException("文件名称未填写");
  724. if (oldMiddle != null && oldMiddle.Id != middle.Id)
  725. throw new BusinessException("文件夹名称重复,请重新命名!");
  726. if (middle.RoleId == 3)
  727. {
  728. if (request.RoleId != 3)
  729. {
  730. //删除共享用户
  731. await _folderUserRepository.DeleteAsync(Q.Where(nameof(Entity.Middle.FolderUser.MiddleId), middle.Id));
  732. //删除
  733. await _userMiddleService.DeleteAsync(middle.Id, middle.FolderType);
  734. }
  735. }
  736. if (request.RoleId == 3 && middle.ParentId == 0)
  737. {
  738. if (request.UserIds.Count == 0 && request.UserMiddles.Count == 0)
  739. throw new BusinessException("共享成员必须");
  740. //添加人员
  741. await _folderUserRepository.DeleteAsync(Q.Where(nameof(FolderUser.MiddleId), request.MiddleId));
  742. var middleInsertRequest = new MiddleInsertRequest();
  743. middleInsertRequest.UserIds = request.UserIds;
  744. middleInsertRequest.UserMiddles = request.UserMiddles;
  745. middleInsertRequest.FolderType = middle.FolderType;
  746. if (request.UserMiddles.Count > 0)
  747. {
  748. //删除原有的数据
  749. await _userMiddleService.DeleteAsync(middle.Id, middle.FolderType);
  750. //await _userMiddleService.AddUserMiddleAsync(request.UserMiddles);
  751. //查询用户
  752. // var users = await _userMiddleService.FindUsersAsync(request.UserMiddles, middle.UserId);
  753. // middleInsertRequest.UserIds = users.Select(n => n.Id).ToList();
  754. }
  755. await InsertFolderUsers(middleInsertRequest, request.MiddleId);
  756. }
  757. middle.RoleId = request.RoleId;
  758. middle.FolderName = request.FolderName;
  759. await _middleRepository.UpdateAsync(middle);
  760. //修改子集权限
  761. if (middle.ParentId == 0)
  762. await _middleRepository.UpdateAsync(Q.Set(nameof(Entity.Middle.Middle.RoleId), request.RoleId).Where(nameof(Entity.Middle.Middle.MiddleSonId), middle.Id));
  763. return true;
  764. }
  765. /// <summary>
  766. /// 修改共享文件夹下的所有文件夹属性
  767. /// </summary>
  768. /// <param name="request"></param>
  769. /// <returns></returns>
  770. public async Task<bool> UpdateChildrenMiddleFolder(MiddleUpdateFolderRoleRequest request)
  771. {
  772. //获取下级数据
  773. var middles = await _middleRepository.GetMiddleChildrenAsync(request.MiddleId);
  774. if (middles.Count() == 0)
  775. return true;
  776. foreach (var item in middles)
  777. {
  778. if (request.UserMiddles.Count > 0)
  779. {
  780. var middleInsertRequest = new MiddleInsertRequest();
  781. middleInsertRequest.UserIds = request.UserIds;
  782. middleInsertRequest.UserMiddles = request.UserMiddles;
  783. //删除原有的数据
  784. await _userMiddleService.DeleteAsync(item.Id, item.FolderType);
  785. await _userMiddleService.AddUserMiddleAsync(request.UserMiddles);
  786. //查询用户
  787. var users = await _userMiddleService.FindUsersAsync(request.UserMiddles, item.UserId);
  788. middleInsertRequest.UserIds = users.Select(n => n.Id).ToList();
  789. //插入共享成员
  790. await InsertFolderUsers(middleInsertRequest, request.MiddleId);
  791. item.RoleId = request.RoleId;
  792. item.FolderName = request.FolderName;
  793. //修改
  794. await _middleRepository.UpdateAsync(item);
  795. request.MiddleId = item.Id;
  796. //修改下级权限和共享范围人
  797. await UpdateChildrenMiddleFolder(request);
  798. }
  799. }
  800. return true;
  801. }
  802. /// <summary>
  803. /// 根据文件夹ID获取文件夹信息
  804. /// </summary>
  805. /// <param name="middleId"></param>
  806. /// <returns></returns>
  807. public async Task<MiddleFolderInfoResult> GetFolderInfo(int middleId)
  808. {
  809. if (middleId == 0)
  810. throw new Common.Exceptions.BusinessException("文件夹不存在");
  811. var result = new MiddleFolderInfoResult();
  812. var middle = await _middleRepository.GetMiddleAsync(middleId);
  813. result.Id = middle.Id;
  814. result.FolderName = middle.FolderName;
  815. result.FolderType = middle.FolderType;
  816. result.UserId = middle.UserId;
  817. result.RoleId = middle.RoleId;
  818. result.FolderUsers = await _folderUserRepository.GetAllAsync(middleId);
  819. //获取共享人员
  820. if (result.RoleId == 3)
  821. {
  822. var sourceId = middle.Id;
  823. if (middle.ParentId > 0)
  824. sourceId = middle.MiddleSonId;
  825. var userMiddles = await _userMiddleService.FindUserMiddlesAsync(middle.FolderType, sourceId);
  826. result.EnjoyUser = StringUtils.ObjectCollectionToString(userMiddles.Select(n => n.SourceName), "、");
  827. // var folderUsers = await _folderUserRepository.GetAllAsync(Q.Where(nameof(FolderUser.MiddleId), middle.Id).OrderByDesc(nameof(FolderUser.CreatedDate)).Take(10));
  828. // result.EnjoyUser = StringUtils.ObjectCollectionToString(folderUsers.Select(n => n.UserName), "、");
  829. }
  830. result.UserMiddles = await _userMiddleService.FindUserMiddlesAsync(middle.FolderType, middleId);
  831. return result;
  832. }
  833. /// <summary>
  834. /// 获取默认的共享文件夹范围
  835. /// </summary>
  836. /// <param name="userId"></param>
  837. /// <returns></returns>
  838. public async Task<MiddleDefaultResult> GetEnjoyDefaultAsync(int userId, int folderType)
  839. {
  840. var recordFolder = await recordFolderRepository.GetAsync(folderType, userId);
  841. var result = new MiddleDefaultResult();
  842. result.IsDefault = recordFolder != null;
  843. result.FolderName = recordFolder == null ? "" : recordFolder.FolderName;
  844. result.FolderType = recordFolder == null ? 0 : recordFolder.FolderType;
  845. result.MiddleId = recordFolder == null ? 0 : recordFolder.FolderId;
  846. return result;
  847. }
  848. /// <summary>
  849. /// 根据类型搜索文件夹
  850. /// </summary>
  851. /// <param name="request"></param>
  852. /// <returns></returns>
  853. public async Task<IEnumerable<Entity.Middle.Middle>> GetSearchFolderResult(MiddleSearchFolderRequest request)
  854. {
  855. var query = Q.NewQuery();
  856. query.Where(nameof(Entity.Middle.Middle.FolderType), request.TypeId);
  857. query.Where(query.WhereLike(nameof(Entity.Middle.Middle.FolderName), $"%{request.KeyWord}%"));
  858. query.Where(nameof(Entity.Middle.Middle.UserId), request.UserId);
  859. query.OrderByDesc(nameof(Entity.Middle.Middle.IsTop), nameof(Entity.Middle.Middle.LastModifiedDate));
  860. return await _middleRepository.GetAllAsync(query);
  861. }
  862. /// <summary>
  863. /// 获取话题 笔记共享范围文件夹
  864. /// </summary>
  865. /// <param name="request"></param>
  866. /// <returns></returns>
  867. public async Task<List<MiddleSearchFolderResult>> SearchNoteFolderAsync(MiddleSearchFolderRequest request)
  868. {
  869. string sqlStr = string.Empty;
  870. if (!string.IsNullOrWhiteSpace(request.KeyWord))
  871. sqlStr += $" and FolderName like '%{request.KeyWord}%'";
  872. string sql = $@"SELECT
  873. *
  874. FROM
  875. tede_middle
  876. WHERE
  877. FolderType ={request.TypeId} AND AttributeValue = 2 {sqlStr}
  878. AND UserId = {request.UserId}
  879. AND RoleId IN ({MiddleRoleConst.Publicity.GetHashCode()} , {MiddleRoleConst.Share.GetHashCode()})
  880. AND IsDelete = 0
  881. AND ParentId ={request.ParentId}
  882. ORDER BY IsSystemDefault DESC,AttributeValue desc , IsTop DESC , {nameof(Entity.Middle.Middle.LastModifiedDate)} DESC,Sort DESC";
  883. var database = new Database(DatabaseType.MySql, ConfigHelper.GetValue("Database:ConnectionString"));
  884. var connection = database.GetConnection();
  885. var middles = await connection.QueryAsync<Entity.Middle.Middle>(sql);
  886. List<MiddleSearchFolderResult> result = new List<MiddleSearchFolderResult>();
  887. if (request.TypeId == AllTypeConst.TopicNote.GetHashCode() && request.ParentId == 0 && string.IsNullOrWhiteSpace(request.KeyWord))
  888. {
  889. result.Add(new MiddleSearchFolderResult
  890. {
  891. Name = "草稿箱",
  892. Id = 0,
  893. IsDisable = false,
  894. RoleId = 1,
  895. IsFolder = false,
  896. IsTop = false,
  897. FileCount = await _noteRepository.GetDraftCountAsync(request.UserId, true),
  898. IsSystemDefault = true,
  899. IsDraft = true
  900. });
  901. }
  902. foreach (var item in middles)
  903. {
  904. MiddleSearchFolderResult middleSearchFolderResult = new MiddleSearchFolderResult
  905. {
  906. Name = item.FolderName,
  907. Id = item.Id,
  908. IsDisable = request.FolderIds.Any(n => n.Equals(item.Id)),
  909. RoleId = item.RoleId,
  910. IsFolder = await _middleRepository.IsFolderAsync(item.Id),
  911. IsTop = item.IsTop,
  912. FileCount = await _middleRepository.CountAsync(Q.Where(nameof(Entity.Middle.Middle.ParentId), item.Id).Where(nameof(Entity.Middle.Middle.IsDelete), false).Where(nameof(Entity.Middle.Middle.FolderType), request.TypeId)),
  913. IsSystemDefault = item.IsSystemDefault
  914. };
  915. if (item.RoleId == MiddleRoleConst.Share.GetHashCode())
  916. {
  917. var sourceId = item.Id;
  918. if (item.ParentId != 0)
  919. sourceId = item.MiddleSonId;
  920. var userMiddles = await _userMiddleService.FindUserMiddlesAsync(item.FolderType, sourceId);
  921. // var folderUsers = await _folderUserRepository.GetAllAsync(Q.Where(nameof(FolderUser.MiddleId), item.Id).OrderByDesc(nameof(FolderUser.CreatedDate)).Take(10));
  922. middleSearchFolderResult.EnjoyUser = StringUtils.ObjectCollectionToString(userMiddles.Select(n => n.SourceName), "、");
  923. //middleSearchFolderResult.EnjoyUser = StringUtils.ObjectCollectionToString(folderUsers.Select(n => n.UserName), "、");
  924. }
  925. result.Add(middleSearchFolderResult);
  926. }
  927. return result;
  928. }
  929. /// <summary>
  930. /// 获取话题最近使用的文件夹
  931. /// </summary>
  932. /// <param name="request"></param>
  933. /// <returns></returns>
  934. public async Task<List<MiddleSearchFolderResult>> GetLatelyTopicFolderAsync(int userId)
  935. {
  936. //获取用户最近发布的话题
  937. var folderIds = await _noteRepository.GetLatelyFolderIdAsync(userId, true);
  938. var query = Q.NewQuery();
  939. query.Where(nameof(Entity.Middle.Middle.AttributeValue), 2)
  940. .Where(nameof(Entity.Middle.Middle.FolderType), AllTypeConst.TopicNote.GetHashCode())
  941. .Where(nameof(Entity.Middle.Middle.UserId), userId)
  942. .Where(nameof(Entity.Middle.Middle.IsDelete), false)
  943. .WhereIn(nameof(Entity.Middle.Middle.Id), folderIds);
  944. query.WhereIn(nameof(Entity.Middle.Middle.RoleId), new List<int>() { 1, 3 });
  945. var models = await _middleRepository.FindAsync(query.OrderByDesc(nameof(Entity.Middle.Middle.CreatedDate)));
  946. var middles = new List<Entity.Middle.Middle>();
  947. foreach (var folderId in folderIds.Distinct())
  948. {
  949. foreach (var item in models)
  950. {
  951. if (item.Id == folderId)
  952. {
  953. middles.Add(item);
  954. break;
  955. }
  956. }
  957. }
  958. List<MiddleSearchFolderResult> result = new List<MiddleSearchFolderResult>();
  959. foreach (var item in middles)
  960. {
  961. MiddleSearchFolderResult middleSearchFolderResult = new MiddleSearchFolderResult
  962. {
  963. Name = item.FolderName,
  964. Id = item.Id,
  965. IsDisable = false,
  966. RoleId = item.RoleId,
  967. IsFolder = await _middleRepository.IsFolderAsync(item.Id),
  968. IsTop = item.IsTop
  969. };
  970. if (item.RoleId == 3)
  971. {
  972. var sourceId = item.Id;
  973. if (item.ParentId != 0)
  974. sourceId = item.MiddleSonId;
  975. var userMiddles = await _userMiddleService.FindUserMiddlesAsync(item.FolderType, sourceId);
  976. // var folderUsers = await _folderUserRepository.GetAllAsync(Q.Where(nameof(FolderUser.MiddleId), item.Id).OrderByDesc(nameof(FolderUser.CreatedDate)).Take(10));
  977. middleSearchFolderResult.EnjoyUser = StringUtils.ObjectCollectionToString(userMiddles.Select(n => n.SourceName), "、");
  978. //middleSearchFolderResult.EnjoyUser = StringUtils.ObjectCollectionToString(folderUsers.Select(n => n.UserName), "、");
  979. }
  980. result.Add(middleSearchFolderResult);
  981. }
  982. return result;
  983. }
  984. /// <summary>
  985. /// 获取笔记最近使用的文件夹
  986. /// </summary>
  987. /// <param name="request"></param>
  988. /// <returns></returns>
  989. public async Task<List<MiddleSearchFolderResult>> GetLatelyNoteFolderAsync(int userId)
  990. {
  991. //获取用户最近发布的话题
  992. var folderIds = await _noteRepository.GetLatelyFolderIdAsync(userId, false);
  993. var query = Q.NewQuery();
  994. query.Where(nameof(Entity.Middle.Middle.AttributeValue), 2)
  995. .Where(nameof(Entity.Middle.Middle.FolderType), AllTypeConst.Note.GetHashCode())
  996. .Where(nameof(Entity.Middle.Middle.UserId), userId)
  997. .Where(nameof(Entity.Middle.Middle.IsDelete), false)
  998. .WhereIn(nameof(Entity.Middle.Middle.Id), folderIds);
  999. query.WhereIn(nameof(Entity.Middle.Middle.RoleId), new List<int>() { 2 });
  1000. var models = await _middleRepository.FindAsync(query.OrderByDesc(nameof(Entity.Middle.Middle.CreatedDate)));
  1001. var middles = new List<Entity.Middle.Middle>();
  1002. foreach (var folderId in folderIds.Distinct())
  1003. {
  1004. foreach (var item in models)
  1005. {
  1006. if (item.Id == folderId)
  1007. {
  1008. middles.Add(item);
  1009. break;
  1010. }
  1011. }
  1012. }
  1013. List<MiddleSearchFolderResult> result = new List<MiddleSearchFolderResult>();
  1014. foreach (var item in middles)
  1015. {
  1016. MiddleSearchFolderResult middleSearchFolderResult = new MiddleSearchFolderResult
  1017. {
  1018. Name = item.FolderName,
  1019. Id = item.Id,
  1020. IsDisable = false,
  1021. RoleId = item.RoleId,
  1022. IsFolder = await _middleRepository.IsFolderAsync(item.Id),
  1023. IsTop = item.IsTop
  1024. };
  1025. if (item.RoleId == 3)
  1026. {
  1027. var sourceId = item.Id;
  1028. if (item.ParentId != 0)
  1029. sourceId = item.MiddleSonId;
  1030. var userMiddles = await _userMiddleService.FindUserMiddlesAsync(item.FolderType, sourceId);
  1031. // var folderUsers = await _folderUserRepository.GetAllAsync(Q.Where(nameof(FolderUser.MiddleId), item.Id).OrderByDesc(nameof(FolderUser.CreatedDate)).Take(10));
  1032. middleSearchFolderResult.EnjoyUser = StringUtils.ObjectCollectionToString(userMiddles.Select(n => n.SourceName), "、");
  1033. //middleSearchFolderResult.EnjoyUser = StringUtils.ObjectCollectionToString(folderUsers.Select(n => n.UserName), "、");
  1034. }
  1035. result.Add(middleSearchFolderResult);
  1036. }
  1037. return result;
  1038. }
  1039. /// <summary> =-
  1040. /// 删除全部
  1041. /// </summary>
  1042. /// <param name="folderType"></param>
  1043. /// <param name="userId"></param>
  1044. /// <returns></returns>
  1045. public async Task<bool> DeleteAllAsync(int folderType, int userId)
  1046. {
  1047. var query = Q.NewQuery();
  1048. query.Where(nameof(Entity.Middle.Middle.FolderType), AllTypeConst.Inbox.GetHashCode());
  1049. query.Where(nameof(Entity.Middle.Middle.UserId), userId);
  1050. query.Where(nameof(Entity.Middle.Middle.IsDelete), true);
  1051. return await _middleRepository.DeleteAsync(query);
  1052. }
  1053. }
  1054. }