颐和api

Sys_Work_UserRepository.cs 4.5KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120
  1. using MadRunFabric.Common;
  2. using MadRunFabric.Common.Options;
  3. using MadRunFabric.Model;
  4. using Microsoft.Extensions.Logging;
  5. using Microsoft.Extensions.Options;
  6. using System;
  7. using System.Collections.Generic;
  8. using System.Text;
  9. using System.Linq;
  10. using SignTokenApi.IRepositories;
  11. using MongoDB.Driver;
  12. namespace SignTokenApi.Repositories
  13. {
  14. public class Sys_Work_UserRepository : BaseRepository<Sys_Work_User, string>, ISys_Work_UserRepository
  15. {
  16. protected readonly ILogger<BaseRepository<Sys_Work_User, string>> _logger;
  17. protected readonly IMongoCollection<Pro_Project_Info> _collection_pro_project_info;
  18. protected readonly IMongoCollection<Sys_DictionaryValue> _collection_sys_dictionaryvalue;
  19. public Sys_Work_UserRepository(IOptions<MongodbOptions> settings, ILogger<BaseRepository<Sys_Work_User, string>> logger) : base(settings, logger)
  20. {
  21. _collection_pro_project_info = _context.GetCollection<Pro_Project_Info>(); //获取集合
  22. _collection_sys_dictionaryvalue = _context.GetCollection<Sys_DictionaryValue>();
  23. _logger = logger;
  24. }
  25. /// <summary>
  26. /// 获取分页
  27. /// </summary>
  28. /// <param name="projectid"></param>
  29. /// <param name="keyword"></param>
  30. /// <param name="userinfo"></param>
  31. /// <param name="pageindex"></param>
  32. /// <param name="pagesize"></param>
  33. /// <param name="recordcount"></param>
  34. /// <returns></returns>
  35. public IEnumerable<object> GetListsByPage(string keyword, string projectid, UserInfoModel userinfo, int pageIndex, int pageSize, out int recordCount)
  36. {
  37. var query =
  38. from p in _collection.AsQueryable()
  39. join proje in _collection_pro_project_info.AsQueryable() on p.projectid equals proje.id into projeDefa
  40. join dic_protype in _collection_sys_dictionaryvalue.AsQueryable() on p.usertype equals dic_protype.id into dic_usertypeDefa
  41. where p.isdelete == 0
  42. select new
  43. {
  44. p.id,
  45. p.projectid,
  46. projectname = projeDefa.Count() > 0 ? projeDefa.First().project_name : "",
  47. p.mobile,
  48. p.usertype,
  49. usertypename = dic_usertypeDefa.Count() > 0 ? dic_usertypeDefa.First().name : null,
  50. p.username,
  51. p.sex,
  52. p.remark,
  53. p.createby,
  54. p.createname,
  55. p.createtime,
  56. p.isdelete
  57. };
  58. #region 查询条件
  59. if (!string.IsNullOrEmpty(projectid))
  60. query = query.Where(it => it.projectid.Equals(projectid));
  61. if (!string.IsNullOrEmpty(keyword))
  62. query = query.Where(it => it.username.Contains(keyword) || it.username.Contains(keyword));
  63. if (userinfo.isallproject == 0)
  64. query = query.Where(it => userinfo.projectlist.Contains(it.projectid));
  65. #endregion
  66. recordCount = query.Count();
  67. var list = query.Skip((pageIndex - 1) * pageSize).Take(pageSize);
  68. return list;
  69. }
  70. /// <summary>
  71. /// 获取详情
  72. /// </summary>
  73. /// <param name="id"></param>
  74. /// <returns></returns>
  75. public object GetDetails(string id)
  76. {
  77. var query =
  78. from p in _collection.AsQueryable()
  79. join proje in _collection_pro_project_info.AsQueryable() on p.projectid equals proje.id into projeDefa
  80. join dic_protype in _collection_sys_dictionaryvalue.AsQueryable() on p.usertype equals dic_protype.id into dic_usertypeDefa
  81. where p.isdelete == 0 && p.id == id
  82. select new
  83. {
  84. p.id,
  85. p.projectid,
  86. projectname = projeDefa.Count() > 0 ? projeDefa.First().project_name : "",
  87. p.mobile,
  88. p.usertype,
  89. usertypename = dic_usertypeDefa.Count() > 0 ? dic_usertypeDefa.First().name : null,
  90. p.username,
  91. p.sex,
  92. p.remark,
  93. p.createby,
  94. p.createname,
  95. p.createtime,
  96. p.isdelete
  97. };
  98. var model = query.FirstOrDefault();
  99. if (model != null)
  100. {
  101. return model;
  102. }
  103. return null;
  104. }
  105. }
  106. }