NETCore 同步AD域组织和用户

BitAdminCore为没有自主开发框架的小团队，提供快速项目搭建及开发能力。

框架演示：http://bit.bitdao.cn

框架源码：https://github.com/chenyinxin/cookiecutter-bitadmin-core

---

不解释，直接上代码

        //配置以下四个参数，开放389端口。
        string domainName = "bitdao.cn";
        string domainRoot = "组织单位";
        string domainUser = "user";
        string domainPass = "password";

  public ActionResult Sync()
        {
            try
            {
                //连接域
                DirectoryEntry domain = new DirectoryEntry();
                domain.Path = string.Format("LDAP://{0}", domainName);
                domain.Username = domainUser;
                domain.Password = domainPass;
                domain.AuthenticationType = AuthenticationTypes.Secure;
                domain.RefreshCache();

                DirectoryEntry entryOU = domain.Children.Find("OU=" + domainRoot);
                DirectorySearcher mySearcher = new DirectorySearcher(entryOU, "(objectclass=organizationalUnit)"); //查询组织单位
                DirectoryEntry root = mySearcher.SearchRoot;   //查找根OU

                if (root.Properties.Contains("ou") && root.Properties.Contains("objectGUID"))
                {
                    string rootOuName = root.Properties["ou"][0].ToString();
                    byte[] bGUID = root.Properties["objectGUID"][0] as byte[];
                    Guid id = new Guid(bGUID);

                    departments.Add(new SysDepartment() { DepartmentId = id, DepartmentCode = id.ToString(), DepartmentName = rootOuName, DepartmentFullName = rootOuName });

                    SyncSubOU(root, id);
                }

                //入库
                foreach (var d in departments)
                {
                    var department = dbContext.SysDepartment.Find(d.DepartmentId);
                    if (department == null)
                        dbContext.SysDepartment.Add(d);
                    else
                    {
                        department.DepartmentName = d.DepartmentName;
                        department.DepartmentFullName = d.DepartmentFullName;
                        department.ParentId = d.ParentId;
                    }
                    dbContext.SaveChanges();
                }
                foreach (var u in users)
                {
                    var user = dbContext.SysUser.Find(u.UserId);
                    if (user == null)
                    {
                        u.CreateBy = u.UserId;
                        u.CreateTime = DateTime.Now;
                        dbContext.SysUser.Add(u);
                    }
                    else
                    {
                        user.UserCode = u.UserCode;
                        user.UserName = u.UserName;
                        user.DepartmentId = u.DepartmentId;
                        user.Mobile = u.Mobile;
                        user.Email = u.Email;
                        user.UpdateBy = u.UserId;
                        user.UpdateTime = DateTime.Now;
                    }
                    dbContext.SaveChanges();
                }


                return Json(new { Code = 0, Msg = "同步成功！" });
            }
            catch (Exception ex)
            {
                LogHelper.SaveLog(ex);
                return Json(new { Code = 1, Msg = "服务器异常，请联系管理员！" });
            }
        }

        List<SysUser> users = new List<SysUser>();
        List<SysDepartment> departments = new List<SysDepartment>();

        private void SyncSubOU(DirectoryEntry entry, Guid parentId)
        {
            foreach (DirectoryEntry subEntry in entry.Children)
            {
                string entrySchemaClsName = subEntry.SchemaClassName;

                string[] arr = subEntry.Name.Split('=');
                string categoryStr = arr[0];
                string nameStr = arr[1];

                byte[] bGUID = subEntry.Properties["objectGUID"][0] as byte[];
                Guid id = new Guid(bGUID);

                switch (entrySchemaClsName)
                {
                    case "organizationalUnit":
                        departments.Add(new SysDepartment() { DepartmentId = id, ParentId = parentId, DepartmentCode = id.ToString(), DepartmentName = nameStr, DepartmentFullName = nameStr });

                        SyncSubOU(subEntry, id);
                        break;
                    case "user":
                        users.Add(new SysUser()
                        {
                            UserId = id,
                            UserCode = subEntry.Properties["samaccountName"][0].ToString(),
                            DepartmentId = parentId,
                            UserName = subEntry.Properties["displayName"][0].ToString(),
                            Email = subEntry.Properties.Contains("mail") ? subEntry.Properties["mail"][0].ToString() : "",
                            Mobile = subEntry.Properties.Contains("telephoneNumber") ? subEntry.Properties["telephoneNumber"][0].ToString() : ""
                        });

                        break;
                }
            }
        }