NETCore 同步AD域组织和用户

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

  1   public ActionResult Sync()
  2         {
  3             try
  4             {
  5                 //连接域
  6                 DirectoryEntry domain = new DirectoryEntry();
  7                 domain.Path = string.Format("LDAP://{0}", domainName);
  8                 domain.Username = domainUser;
  9                 domain.Password = domainPass;
 10                 domain.AuthenticationType = AuthenticationTypes.Secure;
 11                 domain.RefreshCache();
 12 
 13                 DirectoryEntry entryOU = domain.Children.Find("OU=" + domainRoot);
 14                 DirectorySearcher mySearcher = new DirectorySearcher(entryOU, "(objectclass=organizationalUnit)"); //查询组织单位
 15                 DirectoryEntry root = mySearcher.SearchRoot;   //查找根OU
 16 
 17                 if (root.Properties.Contains("ou") && root.Properties.Contains("objectGUID"))
 18                 {
 19                     string rootOuName = root.Properties["ou"][0].ToString();
 20                     byte[] bGUID = root.Properties["objectGUID"][0] as byte[];
 21                     Guid id = new Guid(bGUID);
 22 
 23                     departments.Add(new SysDepartment() { DepartmentId = id, DepartmentCode = id.ToString(), DepartmentName = rootOuName, DepartmentFullName = rootOuName });
 24 
 25                     SyncSubOU(root, id);
 26                 }
 27 
 28                 //入库
 29                 foreach (var d in departments)
 30                 {
 31                     var department = dbContext.SysDepartment.Find(d.DepartmentId);
 32                     if (department == null)
 33                         dbContext.SysDepartment.Add(d);
 34                     else
 35                     {
 36                         department.DepartmentName = d.DepartmentName;
 37                         department.DepartmentFullName = d.DepartmentFullName;
 38                         department.ParentId = d.ParentId;
 39                     }
 40                     dbContext.SaveChanges();
 41                 }
 42                 foreach (var u in users)
 43                 {
 44                     var user = dbContext.SysUser.Find(u.UserId);
 45                     if (user == null)
 46                     {
 47                         u.CreateBy = u.UserId;
 48                         u.CreateTime = DateTime.Now;
 49                         dbContext.SysUser.Add(u);
 50                     }
 51                     else
 52                     {
 53                         user.UserCode = u.UserCode;
 54                         user.UserName = u.UserName;
 55                         user.DepartmentId = u.DepartmentId;
 56                         user.Mobile = u.Mobile;
 57                         user.Email = u.Email;
 58                         user.UpdateBy = u.UserId;
 59                         user.UpdateTime = DateTime.Now;
 60                     }
 61                     dbContext.SaveChanges();
 62                 }
 63 
 64 
 65                 return Json(new { Code = 0, Msg = "同步成功！" });
 66             }
 67             catch (Exception ex)
 68             {
 69                 LogHelper.SaveLog(ex);
 70                 return Json(new { Code = 1, Msg = "服务器异常，请联系管理员！" });
 71             }
 72         }
 73 
 74         List<SysUser> users = new List<SysUser>();
 75         List<SysDepartment> departments = new List<SysDepartment>();
 76 
 77         private void SyncSubOU(DirectoryEntry entry, Guid parentId)
 78         {
 79             foreach (DirectoryEntry subEntry in entry.Children)
 80             {
 81                 string entrySchemaClsName = subEntry.SchemaClassName;
 82 
 83                 string[] arr = subEntry.Name.Split(‘=‘);
 84                 string categoryStr = arr[0];
 85                 string nameStr = arr[1];
 86 
 87                 byte[] bGUID = subEntry.Properties["objectGUID"][0] as byte[];
 88                 Guid id = new Guid(bGUID);
 89 
 90                 switch (entrySchemaClsName)
 91                 {
 92                     case "organizationalUnit":
 93                         departments.Add(new SysDepartment() { DepartmentId = id, ParentId = parentId, DepartmentCode = id.ToString(), DepartmentName = nameStr, DepartmentFullName = nameStr });
 94 
 95                         SyncSubOU(subEntry, id);
 96                         break;
 97                     case "user":
 98                         users.Add(new SysUser()
 99                         {
100                             UserId = id,
101                             UserCode = subEntry.Properties["samaccountName"][0].ToString(),
102                             DepartmentId = parentId,
103                             UserName = subEntry.Properties["displayName"][0].ToString(),
104                             Email = subEntry.Properties.Contains("mail") ? subEntry.Properties["mail"][0].ToString() : "",
105                             Mobile = subEntry.Properties.Contains("telephoneNumber") ? subEntry.Properties["telephoneNumber"][0].ToString() : ""
106                         });
107 
108                         break;
109                 }
110             }
111         }