码迷，mamicode.com
首页 > 编程语言 > 详细

java调用域控服务实现部门用户增删改查

时间：2019-06-11 19:08:36      阅读：109      评论：0      收藏：0      [点我收藏+]

标签：组织   click   add   arch   ipa   工厂   中间   stack   ogg   

 原创内容，爬取请指明出处：https://www.cnblogs.com/Lucy151213/p/11005298.html

公司做大后，用到的系统就会越来越多，来个新员工，需要在HR系统添加，然后再到域控系统添加，可能还需要到NC，OA等系统添加账号。后来公司引入总线系统，来个新员工只需要在HR系统添加账号，HR系统把员工信息下发到总线系统，总线系统再下发到其他各个系统，这样能保证数据的一致性。

我负责的那块就是让域控系统接收总线系统下发的员工信息。我在域控服务与总线系统中间搭建一层restful的服务，用于接收解析总线请求，调用相应域控方法。

在开发过程中花最多时间的地方是在证书认证那块，针对修改密码这种包含敏感信息的方法，需用LDAP协议才能实现。

技术图片

  • 域控服务安装

什么是域控服务，参考下面的链接可以对域控有个大概了解：

https://www.cnblogs.com/cnjavahome/p/9029665.html

怎么安装AD证书，我是参考如下文章安装的：

https://blog.csdn.net/hc1017/article/details/81293323

  • 证书导出

导出证书步骤也可以参考上面的链接：https://blog.csdn.net/hc1017/article/details/81293323 。需要注意一点是链接里面证书导出选择的是’DER编码二进制X.509(.CER)(D)’，我们这里需要选择’Base64编码X.509(.CER)(S)’，我之前选择DER那种格式就是不成功，换成Base64才成功的(几种格式试出来的o(╥﹏╥)o)。

技术图片

给导出的证书取名为cert.cer，文件长这样：

技术图片

执行下面的命令(需把keytool所在目录设置为系统变量，位置在：C:\Program Files\Java\jre1.8.0_102\bin)：

keytool -importcert -keystore F:/yourpath/security.keystore -storepass 123456 -keypass 123456 -alias security -file F:/cert.cer

技术图片

生成一个叫做security.keystore的文件，将这个文件拷贝到你的Java目录下面，如：C:\Program Files\Java\jre1.8.0_102\lib\security

  • 中间服务开发

部门或者员工都有编号这个属性，但是域控服务没有这个属性，我把部门编号，员工编号放在域控的属性‘描述’里面，对应的字段叫做‘description’。

全局文件配置如下：

技术图片

①添加更新部门

技术图片 
Properties env = new Properties();
        env.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.ldap.LdapCtxFactory");
        env.put(Context.SECURITY_AUTHENTICATION, "simple");//LDAP访问安全级别："none","simple","strong"
        env.put(Context.SECURITY_PRINCIPAL, ADMINNAME);// AD User
        env.put(Context.SECURITY_CREDENTIALS, ADMINPASSWORD);// AD Password
        env.put(Context.PROVIDER_URL, LDAPURL);// LDAP工厂类


        LdapContext ctx = null;
        try {
            ctx = new InitialLdapContext(env, null);
            SearchControls searchCtls = new SearchControls();
            searchCtls.setSearchScope(SearchControls.SUBTREE_SCOPE);
            String searchFilter = "(&(objectClass=organizationalUnit)(description=" + departId + "))";//查询这个部门信息
            String searchBase = "OU=实际情况,DC=实际情况,DC=com";//在整个公司查找指定description
            String returnedAtts[] = {"name", "description", "distinguishedName"};//用于获取组织机构

            searchCtls.setReturningAttributes(returnedAtts);
            boolean isDepartExits = false;
            NamingEnumeration<SearchResult> answer = ctx.search(searchBase, searchFilter, searchCtls);
            while (answer.hasMoreElements()) {//理论上id是不会重复的，所以这边parentDC只会赋值一次
                isDepartExits = true;//如果找到值，那么就表示有这个部门，就更新
                SearchResult sr = answer.next();
                Attributes Attrs = sr.getAttributes();//得到符合条件的属性集
                if (Attrs != null) {
                    for (NamingEnumeration ne = Attrs.getAll(); ne.hasMore(); ) {
                        Attribute Attr = (Attribute) ne.next();//得到下一个属性
                        if ("distinguishedName".equals(Attr.getID())) {
                            for (NamingEnumeration e = Attr.getAll(); e.hasMore(); ) {
                                String userInfo = e.next().toString();
                                departDC = userInfo;
                                System.out.print(userInfo);
                            }
                        }
                        System.out.println("");
                    }
                }
            }

            if (isDepartExits) {//这个部门id存在，那么如果传入的部门名称不相同，就更新部门名称，相同就不做处理
                if (!isNullOrEmpty(departDC)) {
                    String[] dcs = departDC.split(",");
                    if (dcs.length > 0) {//名称不相同表示修改了部门名称，那么就修改
                        if (!((dcs[0].substring(dcs[0].indexOf("=") + 1)).equals(departName))) {
                            String newDc = "OU=" + departName + departDC.substring(departDC.indexOf(","), departDC.length());
                            ctx.rename(departDC, newDc);
                            retMsg.setSuccess(true);
                            retMsg.setMsg("更新成功");
                            retMsg.setUid(departId);
                            logger.info("更新部门成功。   departId:"+departId+"  departDC:"+departDC);
                        } else {
                            retMsg.setSuccess(true);
                            retMsg.setMsg("部门名字未做修改，不处理");
                            retMsg.setUid(departId);
                            logger.info("部门名称未做修改，不予更新。  departId:"+departId+"  departDC:"+departDC);
                        }

                    }
                }
            } else {//添加新部门，首先检查父id是否有效
                String searchFilter1 = "(&(objectClass=organizationalUnit)(description=" + parentId + "))";//查询父id信息
                NamingEnumeration<SearchResult> answer1 = ctx.search(searchBase, searchFilter1, searchCtls);
                while (answer1.hasMoreElements()) {//理论上id是不会重复的，所以这边parentDC只会赋值一次
                    SearchResult sr = answer1.next();
                    Attributes Attrs = sr.getAttributes();//得到符合条件的属性集
                    if (Attrs != null) {
                        for (NamingEnumeration ne = Attrs.getAll(); ne.hasMore(); ) {
                            Attribute Attr = (Attribute) ne.next();//得到下一个属性
                            if ("distinguishedName".equals(Attr.getID())) {
                                for (NamingEnumeration e = Attr.getAll(); e.hasMore(); ) {
                                    String userInfo = e.next().toString();
                                    parentDC = userInfo;
                                }
                            }
                        }
                    }
                }

                if (isNullOrEmpty(parentDC)) {
                    logger.error("父组织的id不存在。 departId:"+departId);
                    return getNoParamDataMessage("父组织的id不存在");
                } else {
                    ldapGroupDN = "OU=" + departName + "," + parentDC;
                    //查询这个departId是否存在
                    try {
                        Attributes attrs = ctx.getAttributes(parentDC);//note......
                        NamingEnumeration<String> nEnum = attrs.getIDs();
                        //如果没有报错，说明有这个组织的dn，那么如果明知不相同
                        Attributes attrs1 = new BasicAttributes();
                        attrs1.put("objectClass", "organizationalunit");
                        attrs1.put("description", departId);//部门的id放在description下面
                        ctx.createSubcontext(ldapGroupDN, attrs1);
                        retMsg.setSuccess(true);
                        retMsg.setMsg("添加成功");
                        retMsg.setUid(departId);
                        logger.info("部门添加成功。 departId:"+departId+"  departDC:"+ldapGroupDN);
                    } catch (Exception ex) {
                        logger.error("添加部门发生异常。departId："+departId+"  departDC："+ldapGroupDN+"  。ex："+ex.getMessage());
                        logger.error("stack:"+ex.getStackTrace());
                    }

                }
            }


            ctx.close();
        } catch (NamingException e) {
            logger.error("添加或者更新部门发生异常。departId："+departId+"  stack:"+e.getStackTrace());
            retMsg.setUid(departId);
            retMsg.setSuccess(false);
            retMsg.setMsg("失败");
            ctx.close();
        }
View Code

②删除部门

和上面的代码类似，在获取到departDC后执行：ctx.destroySubcontext(departDC);

③添加更新用户

之前写的挫，每次添加更新我就创建一次连接，有一次传很多用户过来，然后速度就很慢，所有把创建连接提出来。

循环调用添加/更新用户方法：

技术图片 
LdapContext ctx = null;
        LdapContext sslCtx = null;
        try {
            Properties env = new Properties();
            env.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.ldap.LdapCtxFactory");
            env.put(Context.SECURITY_AUTHENTICATION, "simple");//LDAP访问安全级别："none","simple","strong"
            env.put(Context.SECURITY_PRINCIPAL, ADMINNAME);// AD User
            env.put(Context.SECURITY_CREDENTIALS, ADMINPASSWORD);// AD Password
            env.put(Context.PROVIDER_URL, LDAPURL);// LDAP工厂类
            ctx = new InitialLdapContext(env, null);
            sslCtx = getSslConn();
            for (UserEntity u :
                    users) {
                dataMessageList.add(ADHelpUtil.addUserNew(u,ctx,sslCtx));
            }
            ctx.close();
            sslCtx.close();
        }catch (Exception ex){
            logger.error("新方法添加用户异常。ex:"+ex.getMessage());
            try {
                ctx.close();
                sslCtx.close();
            } catch (NamingException e) {
                e.printStackTrace();
            }
        }
View Code

获取SSL连接代码如下：

技术图片 
Properties env = new Properties();
        env.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.ldap.LdapCtxFactory");
        env.put(Context.SECURITY_AUTHENTICATION, "simple");//LDAP访问安全级别："none","simple","strong"
        env.put(Context.SECURITY_PRINCIPAL, ADMINNAME);// AD User
        env.put(Context.SECURITY_CREDENTIALS, ADMINPASSWORD);// AD Password
        env.put(Context.SECURITY_PROTOCOL, "ssl");
        env.put(Context.PROVIDER_URL, LDAPSURL);// LDAP工厂类
        System.setProperty("javax.net.ssl.trustStore", TRUST_STORE_PATH);
        System.setProperty("javax.net.ssl.trustStorePassword", TRUST_STORE_PASSWORD);
        LdapContext ctx = null;
        try {
            ctx = new InitialLdapContext(env, null);
            return ctx;
        }catch (Exception ex){
            System.out.println("Problem resetting password: " + ex);
            ex.printStackTrace();
        }
View Code

添加方法代码片段如下：

技术图片 
try {
            SearchControls searchCtls = new SearchControls();
            searchCtls.setSearchScope(SearchControls.SUBTREE_SCOPE);
            String searchFilter = "(&(objectClass=user)(description=" + uid + "))";//查询这个用户信息
            String searchBase = "OU=实际情况,DC=实际情况,DC=com";//在整个公司查找指定description
            String returnedAtts[] = {"name", "description", "distinguishedName"};//用于获取组织机构

            searchCtls.setReturningAttributes(returnedAtts);
            boolean isUserExits = false;
            NamingEnumeration<SearchResult> answer = ctx.search(searchBase, searchFilter, searchCtls);
            if(answer.hasMoreElements()){//理论上id是不会重复的，所以这边usertDC只会赋值一次
                isUserExits = true;//如果找到值，那么就表示有这个部门，就更新
                userDC = getDistinguishedName(answer);
            }


            //检测部门编号查询部门是否存在，不存在抛挫，代码省略
            //检测传入的员工经理是否有效，无需抛挫，代码省略

            if (isUserExits) {//用户存在，如果名或姓或部门id有变化，就修改
                if (!isNullOrEmpty(userDC)) {
                    //如果用户cancel=1，就直接停用，不用去修改其他属性
                    if("1".equals(canceld)){//启用停用需要使用ssl协议
                        ModificationItem[] mods = new ModificationItem[1];
                        mods[0] = new ModificationItem(DirContext.REPLACE_ATTRIBUTE,
                                new BasicAttribute("userAccountControl",
                                        Integer.toString(DONT_EXPIRE_PASSWORD+UF_NORMAL_ACCOUNT+ACCOUNTDISABLE)));
                        if(null!=sslCtx){
                            sslCtx.modifyAttributes(userDC, mods);
                            logger.error("禁用客户成功 userid:"+uid+"  userDC:"+userDC);
                        }else {
                            logger.error("禁用客户失败，SSL失败 userid:"+uid+"  userDC:"+userDC);
                            return getNoParamDataMessage("禁用客户失败，SSL失败");
                        }
                        mods = null;
                    }else {
                        String curDepDC = userDC.substring(userDC.indexOf(",") + 1, userDC.length());
                        String newDc = userDC;
                        if (!curDepDC.equals(departDC)) {//说明用户是要修改所在部门
                            newDc = userDC.substring(0, userDC.indexOf(",")) + "," + departDC;
                            ctx.rename(userDC, newDc);//换部门
                        }
                        //修改员工属性
                        //设置属性
                        Attributes attrs = new BasicAttributes();
                        attrs.put("displayName", lastName + firstName);
                        attrs.put("description", uid);
                        attrs.put("mail", email);
                        attrs.put("userPrincipalName", email);

                        if(null!=company&&!"".equals(company))
                            attrs.put("company", company);
                        if(null!=title&&!"".equals(title))
                            attrs.put("title", title);
                        if(null!=officePhone&&!"".equals(officePhone))
                            attrs.put("telephoneNumber", officePhone);
                        if(null!=mobile&&!"".equals(mobile))
                            attrs.put("mobile", mobile);
                        if(!isNullOrEmpty(managerDC))
                            attrs.put("manager",managerDC);
                        if(departDC.length()!=0) {
                            int ind1 = departDC.indexOf("=");
                            int ind2 = departDC.indexOf(",");
                            if(ind1!=-1 && ind2!=-1)
                                attrs.put(new BasicAttribute("department", departDC.substring(ind1+1,ind2)));
                        }
                        ctx.modifyAttributes(newDc, DirContext.REPLACE_ATTRIBUTE, attrs);
                    }
                }
            } else {//添加新用户
                Attribute objclass = new BasicAttribute("objectclass");
                objclass.add("top");
                objclass.add("user");
                Attributes attrs1 = new BasicAttributes();
                attrs1.put(objclass);
                attrs1.put(new BasicAttribute("givenname", firstName));
                attrs1.put(new BasicAttribute("sn", lastName));
                attrs1.put(new BasicAttribute("displayName", lastName + firstName));
                attrs1.put(new BasicAttribute("description", uid));
                attrs1.put(new BasicAttribute("mail", email));
                if(departDC.length()!=0) {
                    int ind1 = departDC.indexOf("=");
                    int ind2 = departDC.indexOf(",");
                    if(ind1!=-1 && ind2!=-1)
                        attrs1.put(new BasicAttribute("department", departDC.substring(ind1+1,ind2)));
                }
                attrs1.put(new BasicAttribute("sAMAccountName", email.substring(0, email.indexOf("@"))));
                attrs1.put(new BasicAttribute("userPrincipalName", email));
                if(null!=company && !"".equals(company))
                    attrs1.put(new BasicAttribute("company", company));
                if(null!=title && !"".equals(title))
                    attrs1.put(new BasicAttribute("title", title));
                if(null!=officePhone && !"".equals(officePhone))
                    attrs1.put(new BasicAttribute("telephoneNumber", officePhone));
                if(null!=mobile && !"".equals(mobile))
                    attrs1.put(new BasicAttribute("mobile", mobile));
                if(!isNullOrEmpty(managerDC))
                    attrs1.put(new BasicAttribute("manager",managerDC));

                String newDc = "CN=" + lastName + firstName + "," + departDC;//新用户的dn
                ctx.createSubcontext(newDc,attrs1);


                ModificationItem[] mods = new ModificationItem[2];
                String newQuotedPassword = "\"" + COMMON_PASSWORD + "\"";
                byte[] newUnicodePassword = newQuotedPassword.getBytes("UTF-16LE");
                mods[0] = new ModificationItem(DirContext.REPLACE_ATTRIBUTE,
                        new BasicAttribute("unicodePwd", newUnicodePassword));
                mods[1] = new ModificationItem(DirContext.REPLACE_ATTRIBUTE,
                        new BasicAttribute("userAccountControl",
                                Integer.toString(UF_NORMAL_ACCOUNT
                                        + UF_PASSWORD_EXPIRED + UF_PASSWD_NOTREQD)));
                if(null!=sslCtx){
                    sslCtx.modifyAttributes(newDc, mods);
                }

                mods = null;
            }
        }catch (NameAlreadyBoundException ex){
            logger.error("异常：uid:"+uid+" userDC:"+userDC+" ex:"+ex.getMessage());
        }
        catch (Exception e) {
            logger.error("异常：uid:"+uid+" userDC:"+userDC+" ex:"+e.getMessage());
        }
View Code

④删除用户

核心代码，查询到userDC后，执行：ctx.destroySubcontext(userDC);

⑤获取员工列表(传入上级部门编号)

与上面的代码雷同，省略

⑥获取部门列表(传入上级部门编号)

与上面的代码雷同，省略

 

java调用域控服务实现部门用户增删改查

标签：组织   click   add   arch   ipa   工厂   中间   stack   ogg   

原文地址：https://www.cnblogs.com/Lucy151213/p/11005298.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！