WebMeetingController.cs 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Threading.Tasks;
  5. using Datory;
  6. using GxPress.Auth;
  7. using GxPress.Common.Tools;
  8. using GxPress.Entity.WorkMeeting;
  9. using GxPress.Repository.Interface;
  10. using GxPress.Repository.Interface.WorkMeeting;
  11. using GxPress.Request.App.WorkMeeting;
  12. using GxPress.Result;
  13. using Microsoft.AspNetCore.Authorization;
  14. using Microsoft.AspNetCore.Mvc;
  15. using GxPress.Service.Interface.Meeting;
  16. using GxPress.Repository.Interface.MeetingSummaryTodo;
  17. using GxPress.Repository.Interface.FlowAttachment;
  18. using GxPress.Service.Interface.UserMiddle;
  19. using GxPress.Service.Interface.Analyze;
  20. using GxPress.Request.Analyze;
  21. using GxPress.EnumConst;
  22. namespace GxPress.Api.WebControllers
  23. {
  24. /// <summary>
  25. /// 会议
  26. /// </summary>
  27. [Route("api/web/meeting")]
  28. [ApiController]
  29. [Authorize]
  30. public class WebMeetingController : ControllerBase
  31. {
  32. private readonly ILoginContext _loginContext;
  33. private readonly IMeetingLocationRepository _meetingLocationRepository;
  34. private readonly IMeetingOrderRepository _meetingOrderRepository;
  35. private readonly IMeetingRepository _meetingRepository;
  36. private readonly IMeetingRoomRepository _meetingRoomRepository;
  37. private readonly IMeetingSummaryRepository _meetingSummaryRepository;
  38. private readonly IUserRepository _userRepository;
  39. private readonly IMeetingService meetingService;
  40. private readonly IMeetingSummaryTodoRepository meetingSummaryTodoRepository;
  41. private readonly IFlowAttachmentRepository flowAttachmentRepository;
  42. private readonly IUserMiddleService _userMiddleService;
  43. private readonly IAnalyzeService _analyzeService;
  44. private readonly ICommentRepository _commentRepository;
  45. public WebMeetingController(ILoginContext loginContext, IMeetingLocationRepository meetingLocationRepository, IMeetingOrderRepository meetingOrderRepository, IMeetingRepository meetingRepository, IMeetingRoomRepository meetingRoomRepository, IMeetingSummaryRepository meetingSummaryRepository, IUserRepository userRepository, IMeetingService meetingService, IMeetingSummaryTodoRepository meetingSummaryTodoRepository, IFlowAttachmentRepository flowAttachmentRepository, IUserMiddleService userMiddleService, IAnalyzeService analyzeService, ICommentRepository commentRepository)
  46. {
  47. _loginContext = loginContext;
  48. _meetingLocationRepository = meetingLocationRepository;
  49. _meetingOrderRepository = meetingOrderRepository;
  50. _meetingRepository = meetingRepository;
  51. _meetingRoomRepository = meetingRoomRepository;
  52. _meetingSummaryRepository = meetingSummaryRepository;
  53. _userRepository = userRepository;
  54. this.meetingService = meetingService;
  55. this.meetingSummaryTodoRepository = meetingSummaryTodoRepository;
  56. this.flowAttachmentRepository = flowAttachmentRepository;
  57. _userMiddleService = userMiddleService;
  58. _analyzeService = analyzeService;
  59. _commentRepository = commentRepository;
  60. }
  61. /// <summary>
  62. /// 获取会议室列表
  63. /// </summary>
  64. /// <returns></returns>
  65. [HttpGet("rooms")]
  66. [AllowAnonymous]
  67. public async Task<MeetingRoomsResult> ListRoom([FromQuery] MeetingRoomRequest request)
  68. {
  69. var locations = await _meetingLocationRepository.GetListAsync();
  70. var rooms = await _meetingRoomRepository.GetListAsync(request.LocationId);
  71. foreach (var room in rooms)
  72. {
  73. room.Address = await _meetingLocationRepository.GetAddress(room.LocationId);
  74. }
  75. return new MeetingRoomsResult
  76. {
  77. Locations = locations,
  78. Rooms = rooms
  79. };
  80. }
  81. /// <summary>
  82. /// 获取会议室
  83. /// </summary>
  84. /// <returns></returns>
  85. [HttpGet("rooms/{id}")]
  86. public async Task<MeetingRoomResult> RoomGet([FromRoute] int id)
  87. {
  88. var room = await _meetingRoomRepository.GetAsync(id);
  89. room.Address = await _meetingLocationRepository.GetAddress(room.LocationId);
  90. var orderList = await _meetingOrderRepository.GetListAsyncSinceNow(room.Id);
  91. var orders = new SortedDictionary<string, List<int>>();
  92. foreach (var meetingOrder in orderList)
  93. {
  94. var data = meetingOrder.Date.ToString().Insert(4, "-").Insert(7, "-");
  95. var key = StringUtils.GetDate(Convert.ToDateTime(data)).ToString();
  96. // var key = StringUtils.GetDate(meetingOrder.CreatedDate).ToString();
  97. if (orders.TryGetValue(key, out var hourList))
  98. {
  99. hourList.Add(meetingOrder.Hour);
  100. }
  101. else
  102. {
  103. orders[key] = new List<int>
  104. {
  105. meetingOrder.Hour
  106. };
  107. }
  108. }
  109. var orderLists = new List<TimeDictionary>();
  110. //新版
  111. foreach (var item in orderList.Select(n => n.Date).Distinct())
  112. {
  113. var timeDictionary = new TimeDictionary();
  114. timeDictionary.TimeKey = item.ToString();
  115. timeDictionary.TimeValues = orderList.Where(n => n.Date == item).Select(n => n.Hour).Distinct().ToList();
  116. orderLists.Add(timeDictionary);
  117. }
  118. return new MeetingRoomResult
  119. {
  120. RoomName = room.Name,
  121. Disabled = room.Disabled,
  122. Orders = orders,
  123. OrderList = orderLists
  124. };
  125. }
  126. /// <summary>
  127. /// 预定会议室 添加/编辑
  128. /// </summary>
  129. /// <returns></returns>
  130. [HttpPost("rooms/{id}/actions/order")]
  131. public async Task<DefaultResult> Order([FromRoute] int id, [FromBody] MeetingOrderRequest request)
  132. {
  133. var room = await _meetingRoomRepository.GetAsync(id);
  134. var meeting = new Meeting();
  135. if (request.MeetingId == 0)
  136. {
  137. meeting = new Meeting
  138. {
  139. Name = request.Name,
  140. LocationId = room.LocationId,
  141. RoomId = room.Id,
  142. Description = request.Description,
  143. UserId = _loginContext.AccountId,
  144. FileIds = request.FileIds,
  145. UserIds = request.UserIds
  146. };
  147. meeting.Id = await _meetingRepository.InsertAsync(meeting);
  148. }
  149. else
  150. {
  151. meeting = await _meetingRepository.GetAsync(request.MeetingId);
  152. if (!string.IsNullOrWhiteSpace(request.Name))
  153. meeting.Name = request.Name;
  154. if (!string.IsNullOrWhiteSpace(request.Description))
  155. meeting.Description = request.Description;
  156. //删除参会人员
  157. await meetingSummaryTodoRepository.DeleteAsync(Q.Where(nameof(Entity.WorkMeeting.MeetingSummaryTodo.TypeId), 1).Where(nameof(Entity.WorkMeeting.MeetingSummaryTodo.MeetingSummaryId), request.MeetingId));
  158. //删除附件
  159. await flowAttachmentRepository.DeleteAsync(Q.Where(nameof(Entity.WorkFlow.FlowAttachment.TypeId), 2).Where(nameof(Entity.WorkFlow.FlowAttachment.FlowId), request.MeetingId));
  160. //删除会议时间
  161. if (request.Orders.Count > 0)
  162. await _meetingOrderRepository.DeleteAsync(Q.Where(nameof(Entity.WorkMeeting.MeetingOrder.MeetingId), request.MeetingId));
  163. }
  164. //创建附件
  165. foreach (var item in request.flowAttachments)
  166. {
  167. item.FlowId = meeting.Id;
  168. item.TypeId = 2;
  169. }
  170. await flowAttachmentRepository.InsertsAsync(request.flowAttachments);
  171. //新增关联
  172. var meetingSummaryTodos = new List<Entity.WorkMeeting.MeetingSummaryTodo>();
  173. var meetingSummaryTodo = new MeetingSummaryTodo();
  174. meetingSummaryTodo.UserId = _loginContext.AccountId;
  175. meetingSummaryTodo.TypeId = 1;
  176. meetingSummaryTodo.IsAdmin = true;
  177. meetingSummaryTodo.MeetingSummaryId = meeting.Id;
  178. meetingSummaryTodos.Add(meetingSummaryTodo);
  179. foreach (var item in request.UserIds)
  180. {
  181. meetingSummaryTodo = new MeetingSummaryTodo();
  182. meetingSummaryTodo.UserId = item;
  183. meetingSummaryTodo.IsAdmin = false;
  184. meetingSummaryTodo.TypeId = 1;
  185. meetingSummaryTodo.MeetingSummaryId = meeting.Id;
  186. meetingSummaryTodos.Add(meetingSummaryTodo);
  187. }
  188. await meetingSummaryTodoRepository.InsertsAsync(meetingSummaryTodos);
  189. DateTime? startDate = null;
  190. DateTime? endDate = null;
  191. foreach (var requestOrder in request.Orders)
  192. {
  193. if (startDate.HasValue)
  194. {
  195. if (requestOrder < startDate)
  196. {
  197. startDate = requestOrder;
  198. }
  199. }
  200. else
  201. {
  202. startDate = requestOrder;
  203. }
  204. if (endDate.HasValue)
  205. {
  206. if (requestOrder > endDate)
  207. {
  208. endDate = requestOrder;
  209. }
  210. }
  211. else
  212. {
  213. endDate = requestOrder;
  214. }
  215. var order = new MeetingOrder
  216. {
  217. RoomId = room.Id,
  218. MeetingId = meeting.Id,
  219. Date = StringUtils.GetDate(requestOrder),
  220. Hour = requestOrder.Hour
  221. };
  222. await _meetingOrderRepository.InsertAsync(order);
  223. }
  224. meeting.StartDateTime = startDate;
  225. meeting.EndDateTime = endDate;
  226. await _meetingRepository.UpdateAsync(meeting);
  227. return new DefaultResult
  228. {
  229. Value = true
  230. };
  231. }
  232. /// <summary>
  233. /// 删除会议纪要
  234. /// </summary>
  235. /// <param name="id"></param>
  236. /// <returns></returns>
  237. [HttpDelete("summary/{id}")]
  238. public async Task<bool> DeleteSummary(int id)
  239. {
  240. return await _meetingSummaryRepository.DeleteAsync(id);
  241. }
  242. /// <summary>
  243. /// 新增会议纪要
  244. /// </summary>
  245. /// <returns></returns>
  246. [HttpPost("summary")]
  247. public async Task<MeetingSummary> AddSummary([FromBody] MeetingSummaryRequest request)
  248. {
  249. var meeting = await _meetingRepository.GetAsync(request.MeetingId);
  250. var summary = new MeetingSummary
  251. {
  252. MeetingId = meeting.Id,
  253. RoomId = meeting.RoomId,
  254. UserId = _loginContext.AccountId,
  255. Title = request.Title,
  256. Content = request.Content,
  257. UserIds = request.UserIds
  258. };
  259. summary.Id = await _meetingSummaryRepository.InsertAsync(summary);
  260. //判断是不是新版通知
  261. if (request.AddresseeUserMiddles.Count > 0)
  262. {
  263. foreach (var item in request.AddresseeUserMiddles)
  264. {
  265. item.DataSourceId = summary.Id;
  266. item.MiddleType = 400;
  267. }
  268. await _userMiddleService.AddUserMiddleAsync(request.AddresseeUserMiddles);
  269. //获取用户
  270. var users = await _userMiddleService.FindUsersAsync(request.AddresseeUserMiddles, _loginContext.AccountId);
  271. request.UserIds = users.Select(n => n.Id).ToList();
  272. }
  273. //新增关联
  274. var meetingSummaryTodos = new List<Entity.WorkMeeting.MeetingSummaryTodo>();
  275. var meetingSummaryTodo = new MeetingSummaryTodo();
  276. meetingSummaryTodo.UserId = _loginContext.AccountId;
  277. meetingSummaryTodo.IsAdmin = true;
  278. meetingSummaryTodo.TypeId = 2;
  279. meetingSummaryTodo.MeetingSummaryId = summary.Id;
  280. meetingSummaryTodos.Add(meetingSummaryTodo);
  281. foreach (var item in request.UserIds)
  282. {
  283. if (_loginContext.AccountId == item)
  284. continue;
  285. meetingSummaryTodo = new MeetingSummaryTodo();
  286. meetingSummaryTodo.UserId = item;
  287. meetingSummaryTodo.IsAdmin = false;
  288. meetingSummaryTodo.TypeId = 2;
  289. meetingSummaryTodo.MeetingSummaryId = summary.Id;
  290. meetingSummaryTodos.Add(meetingSummaryTodo);
  291. }
  292. await meetingSummaryTodoRepository.InsertsAsync(meetingSummaryTodos);
  293. return summary;
  294. }
  295. /// <summary>
  296. /// 获取会议纪要
  297. /// </summary>
  298. /// <param name="keyword"></param>
  299. /// <param name="typeId">0 是全部 1我发起 2 别人 </param>
  300. /// <param name="meetingId">会议ID</param>
  301. /// <param name="page">页码数</param>
  302. /// <param name="perPage">数量</param>
  303. /// <returns></returns>
  304. [HttpGet("summary/list")]
  305. [AllowAnonymous]
  306. public async Task<IEnumerable<MeetingSummaryResult>> ListSummary(string keyword, int typeId, int meetingId, int page = 1, int perPage = 10)
  307. {
  308. // var summaries = await _meetingSummaryRepository.GetListAsync(keyword, _loginContext.AccountId, typeId, meetingId, page, perPage);
  309. // var userId = _loginContext.AccountId;
  310. // var list = new List<MeetingSummaryResult>();
  311. // foreach (var summary in summaries)
  312. // {
  313. // var meeting = await _meetingRepository.GetAsync(summary.MeetingId);
  314. // if (meeting == null) continue;
  315. // var address = await _meetingLocationRepository.GetAddress(meeting.LocationId);
  316. // if (address == null) continue;
  317. // var userName = await _userRepository.GetNameAsync(summary.UserId);
  318. // if (!string.IsNullOrEmpty(keyword))
  319. // {
  320. // if (!summary.Title.Contains(keyword) && !summary.Content.Contains(keyword) &&
  321. // !userName.Contains(keyword) && !address.Contains(keyword))
  322. // {
  323. // continue;
  324. // }
  325. // }
  326. // var orderList = await _meetingOrderRepository.GetListByMeetingIdAsync(meeting.Id);
  327. // var meetingTimeDictionary = meetingService.GetMeetingTimeDictionary(orderList);
  328. // var meetingSummaryResult = new MeetingSummaryResult()
  329. // {
  330. // Id = summary.Id,
  331. // UserId = summary.UserId,
  332. // UserName = userName,
  333. // Title = summary.Title,
  334. // Content = summary.Content,
  335. // MeetingId = summary.MeetingId,
  336. // UserIds = summary.UserIds,
  337. // MeetingName = meeting.Name,
  338. // Address = address,
  339. // CreatedDate = summary.CreatedDate,
  340. // MeetingTimes = meetingTimeDictionary.Values.First()
  341. // };
  342. // list.Add(meetingSummaryResult);
  343. // }
  344. var summaries = await _meetingSummaryRepository.GetListMeetingSummaryResultAsync(keyword, _loginContext.AccountId, typeId, meetingId, page, perPage);
  345. foreach (var item in summaries)
  346. {
  347. var orderList = await _meetingOrderRepository.GetListByMeetingIdAsync(item.MeetingId);
  348. var meetingTimeDictionary = meetingService.GetMeetingTimeDictionary(orderList);
  349. item.MeetingTimes = meetingTimeDictionary.Values.First();
  350. }
  351. return summaries;
  352. }
  353. /// <summary>
  354. /// 修改会议纪要
  355. /// </summary>
  356. /// <returns></returns>
  357. [HttpPut("summary/{id}")]
  358. public async Task<MeetingSummary> EditSummary([FromRoute] int id, [FromBody] MeetingSummaryRequest request)
  359. {
  360. var summary = await _meetingSummaryRepository.GetAsync(id);
  361. summary.Title = request.Title;
  362. summary.Content = request.Content;
  363. summary.UserIds = request.UserIds;
  364. //获取新版
  365. if (request.AddresseeUserMiddles.Count > 0)
  366. {
  367. await _userMiddleService.DeleteAsync(Q.Where(nameof(Entity.UserMiddle.UserMiddle.MiddleType), 400).Where(nameof(Entity.UserMiddle.UserMiddle.DataSourceId), id));
  368. foreach (var item in request.AddresseeUserMiddles)
  369. {
  370. item.DataSourceId = id;
  371. item.MiddleType = 400;
  372. }
  373. await _userMiddleService.AddUserMiddleAsync(request.AddresseeUserMiddles);
  374. var users = await _userMiddleService.FindUsersAsync(request.AddresseeUserMiddles, summary.UserId);
  375. request.UserIds = users.Select(n => n.Id).ToList();
  376. request.UserIds.Remove(summary.UserId);
  377. }
  378. //删除会议纪要关联用户
  379. await meetingSummaryTodoRepository.DeleteAsync(Q.Where(nameof(Entity.WorkMeeting.MeetingSummaryTodo.TypeId), 2).Where(nameof(Entity.WorkMeeting.MeetingSummaryTodo.MeetingSummaryId), id));
  380. //新增关联
  381. var meetingSummaryTodos = new List<Entity.WorkMeeting.MeetingSummaryTodo>();
  382. var meetingSummaryTodo = new MeetingSummaryTodo();
  383. meetingSummaryTodo.UserId = _loginContext.AccountId;
  384. meetingSummaryTodo.IsAdmin = true;
  385. meetingSummaryTodo.TypeId = 2;
  386. meetingSummaryTodo.MeetingSummaryId = summary.Id;
  387. meetingSummaryTodos.Add(meetingSummaryTodo);
  388. foreach (var item in request.UserIds)
  389. {
  390. meetingSummaryTodo = new MeetingSummaryTodo();
  391. meetingSummaryTodo.UserId = item;
  392. meetingSummaryTodo.IsAdmin = false;
  393. meetingSummaryTodo.TypeId = 2;
  394. meetingSummaryTodo.MeetingSummaryId = summary.Id;
  395. meetingSummaryTodos.Add(meetingSummaryTodo);
  396. }
  397. await meetingSummaryTodoRepository.InsertsAsync(meetingSummaryTodos);
  398. await _meetingSummaryRepository.UpdateAsync(summary);
  399. return summary;
  400. }
  401. /// <summary>
  402. /// 获取会议纪要详情
  403. /// </summary>
  404. /// <returns></returns>
  405. [HttpGet("summary/{id}")]
  406. public async Task<MeetingSummaryResult> GetSummary([FromRoute] int id)
  407. {
  408. var summary = await _meetingSummaryRepository.GetAsync(id);
  409. if (summary == null)
  410. throw new Common.Exceptions.BusinessException("会议纪要不存在");
  411. var meeting = await _meetingRepository.GetAsync(summary.MeetingId);
  412. var address = await _meetingLocationRepository.GetAddress(meeting.LocationId);
  413. //获取新版
  414. var addresseeUserMiddles = await _userMiddleService.FindUserMiddlesAsync(400, id);
  415. var meetingSummaryResult = new MeetingSummaryResult
  416. {
  417. Id = summary.Id,
  418. UserId = summary.UserId,
  419. UserName = await _userRepository.GetNameAsync(summary.UserId),
  420. Title = summary.Title,
  421. Content = summary.Content,
  422. MeetingId = summary.MeetingId,
  423. UserIds = summary.UserIds,
  424. MeetingName = meeting.Name,
  425. Address = address,
  426. CreatedDate = summary.CreatedDate,
  427. AddresseeUserMiddles = addresseeUserMiddles.ToList()
  428. };
  429. //是否是自己创建
  430. meetingSummaryResult.IsAdmin = _loginContext.AccountId == summary.UserId;
  431. var analyzeRequest = new Request.App.Analyze.AnalyzeRequest()
  432. {
  433. TypeValue = AllTypeConst.MeetingSummary.GetHashCode(),
  434. AnalyzeType = 1,
  435. SourceId = meetingSummaryResult.Id,
  436. UserId = _loginContext.AccountId
  437. };
  438. //点赞数量
  439. meetingSummaryResult.PraiseCount = await _analyzeService.CountAsync(analyzeRequest);
  440. //获取话题的评论数量
  441. var commentCount =
  442. await _commentRepository.CountAsync(Q.Where(nameof(Entity.Comment.ArticleId), meetingSummaryResult.Id).Where(nameof(Entity.Comment.TypeValue), analyzeRequest.TypeValue).Where(nameof(Entity.Comment.Pid), 0));
  443. meetingSummaryResult.CommentCount = commentCount;
  444. //获取话题的转发数量
  445. analyzeRequest.AnalyzeType = 4;
  446. var retransmissionCount = await _analyzeService.CountAsync(analyzeRequest);
  447. meetingSummaryResult.RetransmissionCount = retransmissionCount;
  448. meetingSummaryResult.IsRetransmission = await _analyzeService.ExistsAsync(analyzeRequest);
  449. //获取话题的收藏数量
  450. analyzeRequest.AnalyzeType = 3;
  451. var collectCount = await _analyzeService.CountAsync(analyzeRequest);
  452. meetingSummaryResult.CollectCount = collectCount;
  453. //是否收藏
  454. meetingSummaryResult.IsCollect = await _analyzeService.ExistsAsync(analyzeRequest);
  455. //获取话题的点赞数量
  456. analyzeRequest.AnalyzeType = 1;
  457. var praiseCount = await _analyzeService.CountAsync(analyzeRequest);
  458. meetingSummaryResult.PraiseCount = praiseCount;
  459. //是否点赞
  460. meetingSummaryResult.IsPraise = await _analyzeService.ExistsAsync(analyzeRequest);
  461. //获取点赞数据
  462. var request = new PraisePageSearchRequest { SourceId = id, TypeValue = analyzeRequest.TypeValue, Page = 1, PerPage = 3 };
  463. meetingSummaryResult.PraisePagedList = await _analyzeService.GetPraisePageAsync(request);
  464. return meetingSummaryResult;
  465. }
  466. /// <summary>
  467. /// 获取会议纪要详情 web专属
  468. /// </summary>
  469. /// <returns></returns>
  470. [HttpGet("summary/web/{id}")]
  471. [AllowAnonymous]
  472. public async Task<MeetingSummaryResult> GetWebSummary([FromRoute] int id)
  473. {
  474. var summary = await _meetingSummaryRepository.GetAsync(id);
  475. var meeting = await _meetingRepository.GetAsync(summary.MeetingId);
  476. var address = await _meetingLocationRepository.GetAddress(meeting.LocationId);
  477. //获取新版
  478. var addresseeUserMiddles = await _userMiddleService.FindUserMiddlesAsync(400, id);
  479. var meetingSummaryResult = new MeetingSummaryResult
  480. {
  481. Id = summary.Id,
  482. UserId = summary.UserId,
  483. UserName = await _userRepository.GetNameAsync(summary.UserId),
  484. Title = summary.Title,
  485. Content = summary.Content,
  486. MeetingId = summary.MeetingId,
  487. UserIds = summary.UserIds,
  488. MeetingName = meeting.Name,
  489. Address = address,
  490. CreatedDate = summary.CreatedDate,
  491. AddresseeUserMiddles = addresseeUserMiddles.ToList()
  492. };
  493. var analyzeRequest = new Request.App.Analyze.AnalyzeRequest();
  494. return meetingSummaryResult;
  495. }
  496. /// <summary>
  497. /// 获取我的会议
  498. /// </summary>
  499. /// <param name="keyword"></param>
  500. /// <returns></returns>
  501. [HttpGet("current")]
  502. public async Task<IEnumerable<MeetingResult>> ListCurrentMeeting([FromQuery] string keyword)
  503. {
  504. var meetings = await _meetingRepository.GetCurrentListAsync(_loginContext.AccountId, keyword);
  505. var list = new List<MeetingResult>();
  506. foreach (var meeting in meetings)
  507. {
  508. //获取会议房间
  509. var room = await _meetingRoomRepository.GetAsync(meeting.RoomId);
  510. var address = await _meetingLocationRepository.GetAddress(meeting.LocationId);
  511. var orderList = await _meetingOrderRepository.GetListByMeetingIdAsync(meeting.Id);
  512. var orders = new SortedDictionary<string, List<int>>();
  513. foreach (var meetingOrder in orderList)
  514. {
  515. var data = meetingOrder.Date.ToString().Insert(4, "-").Insert(7, "-");
  516. var key = StringUtils.GetDate(Convert.ToDateTime(data)).ToString();
  517. if (orders.TryGetValue(key, out var hourList))
  518. {
  519. hourList.Add(meetingOrder.Hour);
  520. }
  521. else
  522. {
  523. orders[key] = new List<int>
  524. {
  525. meetingOrder.Hour
  526. };
  527. }
  528. }
  529. var meetingTimeDictionary = meetingService.GetMeetingTimeDictionary(orderList);
  530. //状态
  531. var status = 0;
  532. var meetingTimeList = meetingTimeDictionary.Keys.First();
  533. if (meetingTimeList.Count > 0)
  534. {
  535. var meetingTime = meetingTimeList.FirstOrDefault();
  536. var TimeValuelast = meetingTime.TimeValues.Last();
  537. var data = meetingTime.TimeKey.ToString().Insert(4, "-").Insert(7, "-");
  538. var key = Convert.ToDateTime(data).AddHours(TimeValuelast);
  539. if (key < DateTime.Now)
  540. status = 1;
  541. }
  542. list.Add(new MeetingResult
  543. {
  544. Id = meeting.Id,
  545. UserId = meeting.UserId,
  546. UserName = await _userRepository.GetNameAsync(meeting.UserId),
  547. Name = meeting.Name,
  548. Description = meeting.Description,
  549. UserIds = meeting.UserIds,
  550. Address = address,
  551. OrderList = meetingTimeDictionary.Keys.First(),
  552. MeetingTimes = meetingTimeDictionary.Values.First(),
  553. Status = status,
  554. CreatedDate = meeting.CreatedDate,
  555. RoomName = room == null ? "" : room.Name,
  556. Orders = orders
  557. });
  558. }
  559. return list;
  560. }
  561. /// <summary>
  562. /// 获取历史会议
  563. /// </summary>
  564. /// <returns></returns>
  565. [HttpGet("history")]
  566. public async Task<IEnumerable<MeetingResult>> ListHistoryMeeting([FromQuery] string keyword, int page = 1, int perPage = 10)
  567. {
  568. var meetings = await _meetingRepository.GetHistoryListAsync(_loginContext.AccountId, keyword, page, perPage);
  569. var list = new List<MeetingResult>();
  570. foreach (var meeting in meetings)
  571. {
  572. var address = await _meetingLocationRepository.GetAddress(meeting.LocationId);
  573. //获取会议房间
  574. var room = await _meetingRoomRepository.GetAsync(meeting.RoomId);
  575. var orderList = await _meetingOrderRepository.GetListByMeetingIdAsync(meeting.Id);
  576. var orders = new SortedDictionary<string, List<int>>();
  577. foreach (var meetingOrder in orderList)
  578. {
  579. var key = StringUtils.GetDate(meetingOrder.CreatedDate).ToString();
  580. if (orders.TryGetValue(key, out var hourList))
  581. {
  582. hourList.Add(meetingOrder.Hour);
  583. }
  584. else
  585. {
  586. orders[key] = new List<int>
  587. {
  588. meetingOrder.Hour
  589. };
  590. }
  591. }
  592. var meetingTimeDictionary = meetingService.GetMeetingTimeDictionary(orderList);
  593. var meetingTimes = meetingTimeDictionary.Values.First();
  594. //状态
  595. var status = 0;
  596. var meetingTimeList = meetingTimeDictionary.Keys.First();
  597. if (meetingTimeList.Count > 0)
  598. {
  599. var meetingTime = meetingTimeList.FirstOrDefault();
  600. var TimeValuelast = meetingTime.TimeValues.Last();
  601. var data = meetingTime.TimeKey.ToString().Insert(4, "-").Insert(7, "-");
  602. var key = Convert.ToDateTime(data).AddHours(TimeValuelast);
  603. if (key < DateTime.Now)
  604. status = 1;
  605. }
  606. list.Add(new MeetingResult
  607. {
  608. Id = meeting.Id,
  609. UserId = meeting.UserId,
  610. UserName = await _userRepository.GetNameAsync(meeting.UserId),
  611. Name = meeting.Name,
  612. Description = meeting.Description,
  613. UserIds = meeting.UserIds,
  614. Address = address,
  615. CreatedDate = meeting.CreatedDate,
  616. MeetingTimes = meetingTimes,
  617. RoomName = room == null ? "" : room.Name,
  618. Orders = orders,
  619. Status = 1
  620. });
  621. }
  622. return list;
  623. }
  624. /// <summary>
  625. /// 获取会议详情
  626. /// </summary>
  627. /// <returns></returns>
  628. [HttpGet("{id}")]
  629. public async Task<MeetingResult> GetMeeting([FromRoute] int id)
  630. {
  631. var meeting = await _meetingRepository.GetAsync(id);
  632. var room = await _meetingRoomRepository.GetAsync(meeting.RoomId);
  633. var address = await _meetingLocationRepository.GetAddress(meeting.LocationId);
  634. //获取当前会议时间段
  635. var orderList = await _meetingOrderRepository.GetListByMeetingIdAsync(id);
  636. var orders = new SortedDictionary<string, List<int>>();
  637. foreach (var meetingOrder in orderList)
  638. {
  639. var key = StringUtils.GetDate(meetingOrder.CreatedDate).ToString();
  640. if (orders.TryGetValue(key, out var hourList))
  641. {
  642. hourList.Add(meetingOrder.Hour);
  643. }
  644. else
  645. {
  646. orders[key] = new List<int>
  647. {
  648. meetingOrder.Hour
  649. };
  650. }
  651. }
  652. //获取会议上传的文件流
  653. var flowAttachments = await flowAttachmentRepository.GetAllAsync(Q.Where(nameof(Entity.WorkFlow.FlowAttachment.TypeId), 2).Where(nameof(Entity.WorkFlow.FlowAttachment.FlowId), id).OrderByDesc(nameof(Entity.WorkFlow.FlowAttachment.CreatedDate)));
  654. var meetingTimeDictionary = meetingService.GetMeetingTimeDictionary(orderList);
  655. #region //获取当前房间的所有时间
  656. var orderLists = new List<TimeDictionary>();
  657. var orderAllList = await _meetingOrderRepository.GetListAsyncSinceNow(room.Id);
  658. //新版
  659. foreach (var item in orderAllList.Select(n => n.Date).Distinct())
  660. {
  661. var timeDictionary = new TimeDictionary();
  662. timeDictionary.TimeKey = item.ToString();
  663. timeDictionary.TimeValues = orderAllList.Where(n => n.Date == item).OrderBy(n => n.Hour).Select(n => n.Hour).Distinct().ToList();
  664. orderLists.Add(timeDictionary);
  665. }
  666. #endregion
  667. #region 参会人员
  668. var meetingUsersRequest = new MeetingUsersRequest();
  669. meetingUsersRequest.MeetingId = id;
  670. var meetingUserResults = await _meetingRepository.GetUserByMeeting(meetingUsersRequest);
  671. #endregion
  672. return new MeetingResult
  673. {
  674. Id = meeting.Id,
  675. UserId = meeting.UserId,
  676. UserName = await _userRepository.GetNameAsync(meeting.UserId),
  677. Name = meeting.Name,
  678. Description = meeting.Description,
  679. UserIds = meeting.UserIds,
  680. Address = address,
  681. CreatedDate = meeting.CreatedDate,
  682. ImageUrl = room.ImageUrl,
  683. OrderList = meetingTimeDictionary.Keys.First(),
  684. OrderAllList = orderLists,
  685. Orders = orders,
  686. MeetingRoom = room,
  687. FlowAttachments = flowAttachments.ToList(),
  688. MeetingTimes = meetingTimeDictionary.Values.First(),
  689. MeetingUserResults = meetingUserResults,
  690. Disabled = room.Disabled,
  691. Status = meeting.EndDateTime < DateTime.Now ? 1 : 0
  692. };
  693. }
  694. /// <summary>
  695. /// 取消预定
  696. /// </summary>
  697. /// <returns></returns>
  698. [HttpPost("{id}/actions/cancel")]
  699. public async Task<DefaultResult> Cancel([FromRoute] int id)
  700. {
  701. await _meetingRepository.DeleteAsync(id);
  702. return new DefaultResult
  703. {
  704. Value = true
  705. };
  706. }
  707. /// <summary>
  708. /// 获取用户
  709. /// </summary>
  710. /// <returns></returns>
  711. [HttpPost("actions/users")]
  712. public async Task<IEnumerable<MeetingUserResult>> GetUsers([FromBody] MeetingUsersRequest request)
  713. {
  714. return await _meetingRepository.GetUserByMeeting(request);
  715. }
  716. }
  717. }