WorkspaceRepo.cs 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using BO.AppServer.Data.Entity;
  5. using Microsoft.EntityFrameworkCore;
  6. using Quadarax.Foundation.Core.Data.Domain;
  7. using Quadarax.Foundation.Core.Data.Extensions;
  8. using Quadarax.Foundation.Core.Data.Interface;
  9. using Quadarax.Foundation.Core.Data.Interface.Domain;
  10. using Quadarax.Foundation.Core.Data.Repository;
  11. public class WorkspaceRepo : EntityRepository<long, Workspace>
  12. {
  13. public WorkspaceRepo(IUnitOfWork<DataDomain> unitOfWork) : base(unitOfWork)
  14. {
  15. }
  16. public Workspace CreateWorkspace(string name, BillingPlan billingPlan, string apiKeyPassword, bool isDefault, User owner, User creator)
  17. {
  18. var workspace = New();
  19. workspace.Name = name;
  20. workspace.BillingPlanId = billingPlan.Id;
  21. workspace.Created = DateTime.Now;
  22. workspace.CreatedByUser = creator;
  23. workspace.Apikey = Guid.NewGuid();
  24. workspace.Apipassword = apiKeyPassword;
  25. if (workspace.Structures == null)
  26. workspace.Structures = new List<Structure>();
  27. workspace.Structures.Add(new Structure(){Created = DateTime.Now,CreatedByUserId = creator.Id});
  28. workspace.UserWorkspaces = new List<UserWorkspace>();
  29. AppendUser(workspace, owner, isDefault);
  30. return workspace;
  31. }
  32. public void AppendUser(Workspace workspace, User user, bool isDefault)
  33. {
  34. var userWorkspace = new UserWorkspace();
  35. userWorkspace.Workspace = workspace;
  36. userWorkspace.User = user;
  37. userWorkspace.IsDefault = isDefault;
  38. if (isDefault)
  39. {
  40. foreach (var uw in workspace.UserWorkspaces)
  41. uw.IsDefault = false;
  42. }
  43. workspace.UserWorkspaces.Add(userWorkspace);
  44. }
  45. public IQueryable<Workspace> GetAllEmpty(IPaging paging)
  46. {
  47. return Query(paging).Where(x => x.Structures.Any(struc => !struc.Metadocuments.Any()));
  48. }
  49. public IQueryable<Workspace> GetAllNonEmpty(IPaging paging)
  50. {
  51. return Query(paging).Where(x => x.Structures.Any(struc => struc.Metadocuments.Count>0));
  52. }
  53. public IQueryable<Workspace> GetAllByOwner(User owner, IPaging paging)
  54. {
  55. var userWorkspaceSet = Context.GetDbSet<DbSet<UserWorkspace>>();
  56. return userWorkspaceSet.Page(paging.IsDisabled ? (int?)null : paging.Page, paging.PageSize)
  57. .Where(x => x.User == owner).Select(x => x.Workspace);
  58. }
  59. }