PostUserManage.cs 3.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091
  1. using Central.Control.Domain;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Linq;
  5. using System.Text;
  6. namespace MES.Production.Service.ServiceImp
  7. {
  8. /// <summary>
  9. /// 岗位人员关系业务实现类
  10. /// add 作者: 季健国 QQ:181589805 by 2016-09-08
  11. /// </summary>
  12. public class PostUserManage : RepositoryBase<SYS_POST_USER>, IService.IPostUserManage
  13. {
  14. /// <summary>
  15. /// 根据岗位ID获取人员列表
  16. /// </summary>
  17. public List<SYS_USER> GetUserListByPostId(string postId)
  18. {
  19. try
  20. {
  21. string sql = @"select * from sys_user t where exists(select u.fk_userid from sys_post_user u
  22. inner join sys_post_department p
  23. on u.fk_post_departmentid=p.id
  24. where t.id=u.fk_userid and p.fk_post_id in (" + postId + ") group by u.fk_userid)";
  25. return this.SelectBySql<SYS_USER>(sql);
  26. }
  27. catch (Exception e) { throw e.InnerException; }
  28. }
  29. /// <summary>
  30. /// 根据用户ID获取所持有的岗位集合
  31. /// </summary>
  32. public List<SYS_POST> GetPostListByUserId(string userId)
  33. {
  34. return this.LoadAll(p => userId.Contains(p.FK_USERID.ToString())).Select(p => p.SYS_POST_DEPARTMENT.SYS_POST).ToList();
  35. }
  36. /// <summary>
  37. /// 添加岗位人员关系
  38. /// </summary>
  39. /// <param name="userId">人员ID</param>
  40. /// <param name="postId">岗位ID集合</param>
  41. /// <returns></returns>
  42. public bool SavePostUser(int userId, string postId)
  43. {
  44. try
  45. {
  46. if (this.IsExist(p => p.FK_USERID == userId))
  47. {
  48. //存在之后再对比是否一致
  49. var postlist = this.LoadAll(p => p.FK_USERID == userId).Select(p => p.FK_POST_DEPARTMENTID.ToString()).ToList();
  50. var oldCount = postlist.Cast<string>().ToList();
  51. var newpostId = postId.Split(',').ToList();
  52. if (oldCount.Count == newpostId.Count && oldCount.All(newpostId.Contains)) return true;
  53. //删除原有关系
  54. this.Delete(p => p.FK_USERID == userId);
  55. }
  56. if (!string.IsNullOrEmpty(postId))
  57. {
  58. //添加现有关系
  59. var list = postId.Split(',').Select(item => new SYS_POST_USER()
  60. {
  61. FK_USERID = userId,
  62. FK_POST_DEPARTMENTID =int.Parse(item)
  63. }).ToList();
  64. return this.SaveList(list) > 0;
  65. }
  66. return true;
  67. }
  68. catch (Exception e) { throw e.InnerException; }
  69. }
  70. /// <summary>
  71. /// 根据岗位集合获取岗位名称,部门-岗位模式
  72. /// </summary>
  73. public dynamic GetPostNameBySysPostUser(ICollection<SYS_POST_USER> collection)
  74. {
  75. //岗位部门关系ID集合
  76. string post_departmentid = collection.Select(p => p.FK_POST_DEPARTMENTID).Aggregate(string.Empty, (current, t) => current + "'" + t + "',").TrimEnd(',');
  77. try
  78. {
  79. string sql = @"select d.name+'-'+p.postname as postname,s.id from SYS_DISTRIBUTORS d inner join
  80. sys_post_department s on d.id=s.fk_department_id
  81. inner join sys_post p on p.id=s.fk_post_id
  82. where s.id in (" + post_departmentid + ")";
  83. return this.ExecuteSqlQuery(sql);
  84. }
  85. catch (Exception e) { throw e.InnerException; }
  86. }
  87. }
  88. }