using Bootstrap.Security.DataAccess; using System; using System.Collections.Generic; using System.Linq; namespace Bootstrap.DataAccess { /// /// /// public class Group { /// /// 获得/设置 群组主键ID /// public string Id { get; set; } /// /// 获得/设置 群组名称 /// public string GroupName { get; set; } /// /// 获得/设置 群组描述 /// public string Description { get; set; } /// /// 获取/设置 用户群组关联状态 checked 标示已经关联 '' 标示未关联 /// public string Checked { get; set; } /// /// 查询所有群组信息 /// /// /// public virtual IEnumerable Retrieves() => DbManager.Db.Fetch("select * from Groups"); /// /// 删除群组信息 /// /// public virtual bool Delete(IEnumerable value) { bool ret = false; var ids = string.Join(",", value); var db = DbManager.Db; try { db.BeginTransaction(); db.Execute($"delete from UserGroup where GroupID in ({ids})"); db.Execute($"delete from RoleGroup where GroupID in ({ids})"); db.Execute($"delete from Groups where ID in ({ids})"); db.CompleteTransaction(); ret = true; } catch (Exception e) { db.AbortTransaction(); throw e; } return ret; } /// /// 保存新建/更新的群组信息 /// /// /// public virtual bool Save(Group p) { DbManager.Db.Save(p); return !p.Id.IsNullOrEmpty(); } /// /// 根据用户查询部门信息 /// /// /// public virtual IEnumerable RetrievesByUserId(string userId) => DbManager.Db.Fetch("select g.ID, g.GroupName, g.Description, case ug.GroupID when g.ID then 'checked' else '' end Checked from Groups g left join UserGroup ug on g.ID = ug.GroupID and UserID = @0", userId); /// /// 根据角色ID指派部门 /// /// /// public virtual IEnumerable RetrievesByRoleId(string roleId) => DbManager.Db.Fetch("select g.ID, g.GroupName, g.Description, case rg.GroupID when g.ID then 'checked' else '' end Checked from Groups g left join RoleGroup rg on g.ID = rg.GroupID and RoleID = @0", roleId); /// /// 保存用户部门关系 /// /// /// /// public virtual bool SaveByUserId(string userId, IEnumerable groupIds) { var ret = false; var db = DbManager.Db; try { db.BeginTransaction(); //删除用户部门表中该用户所有的部门关系 db.Execute("delete from UserGroup where UserID = @0", userId); db.InsertBulk("UserGroup", groupIds.Select(g => new { UserID = userId, GroupID = g })); db.CompleteTransaction(); ret = true; } catch (Exception ex) { db.AbortTransaction(); throw ex; } return ret; } /// /// 根据角色ID以及选定的部门ID,保到角色部门表 /// /// /// /// public virtual bool SaveByRoleId(string roleId, IEnumerable groupIds) { bool ret = false; var db = DbManager.Db; try { db.BeginTransaction(); //删除角色部门表该角色所有的部门 db.Execute("delete from RoleGroup where RoleID = @0", roleId); db.InsertBulk("RoleGroup", groupIds.Select(g => new { RoleID = roleId, GroupID = g })); db.CompleteTransaction(); ret = true; } catch (Exception ex) { db.AbortTransaction(); throw ex; } return ret; } /// /// /// /// /// public virtual IEnumerable RetrievesByUserName(string userName) => DbHelper.RetrieveGroupsByUserName(userName); } }