281 lines
11 KiB
Plaintext
281 lines
11 KiB
Plaintext
|
package th.co.muangthai.endrprint.util;
|
||
|
|
|
||
|
|
import org.apache.log4j.Logger;
|
||
|
|
import org.hibernate.SQLQuery;
|
||
|
|
import org.hibernate.Session;
|
||
|
|
import th.co.muangthai.endrprint.dao.serviceImp.CommonServiceImp;
|
||
|
|
import th.co.muangthai.endrprint.dao.serviceInterface.CommonServiceInterface;
|
||
|
|
import th.co.muangthai.endrprint.model.bean.form.master.EndrUserLoginForm;
|
||
|
|
import th.co.muangthai.endrprint.model.bean.form.master.MstOperidTabForm;
|
||
|
|
import th.co.muangthai.endrprint.model.bean.master.MstOperidTabBean;
|
||
|
|
import th.co.muangthai.endrprint.model.hibernate.HibernateUtil;
|
||
|
|
import th.co.muangthai.endrprint.util.ADAuthenticator.*;
|
||
|
|
|
||
|
|
import javax.naming.Context;
|
||
|
|
import javax.naming.NamingEnumeration;
|
||
|
|
import javax.naming.NamingException;
|
||
|
|
import javax.naming.directory.Attributes;
|
||
|
|
import javax.naming.directory.SearchControls;
|
||
|
|
import javax.naming.directory.SearchResult;
|
||
|
|
import javax.naming.ldap.InitialLdapContext;
|
||
|
|
import javax.naming.ldap.LdapContext;
|
||
|
|
import java.math.BigDecimal;
|
||
|
|
import java.util.Date;
|
||
|
|
import java.util.Hashtable;
|
||
|
|
import java.util.List;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Created by IntelliJ IDEA.
|
||
|
|
* User: Huato
|
||
|
|
* Date: 8/14/12
|
||
|
|
* Time: 1:31 PM
|
||
|
|
* To change this template use File | Settings | File Templates.
|
||
|
|
*/
|
||
|
|
public class ADAuthenticator {
|
||
|
|
|
||
|
|
private final static String CONTEXT_FACTORY = "com.sun.jndi.ldap.LdapCtxFactory";
|
||
|
|
private final static String AUTHENTICATION = "simple";
|
||
|
|
|
||
|
|
private final static String SEARCH_BASE = "DC=muangthai,DC=co,DC=th";
|
||
|
|
private final static String PROVIDER_URL = "ldap://10.1.0.5:389";
|
||
|
|
private final static String ATTRIBUTE_FOR_USER = "sAMAccountName";
|
||
|
|
//private final static String DN = "CN=Administrator,CN=Users,DC=muangthai,DC=co,DC=th";
|
||
|
|
private final static String DOMAIN = "muangthai";
|
||
|
|
|
||
|
|
public final String[] ATTRIBUTES = { "name", "physicalDeliveryOfficeName"};
|
||
|
|
private static Logger log = Logger.getLogger(ADAuthenticator.class);
|
||
|
|
|
||
|
|
public static EndrUserLoginForm authenticate(String userId, String password) {
|
||
|
|
|
||
|
|
try {
|
||
|
|
String searchFilter = "(&(objectClass=person)(" + ATTRIBUTE_FOR_USER + "=" + userId + "))";
|
||
|
|
// String searchFilter = ATTRIBUTE_FOR_USER + "=" + userId;
|
||
|
|
|
||
|
|
SearchControls searchCtls = new SearchControls();
|
||
|
|
//searchCtls.setReturningAttributes(ATTRIBUTES);
|
||
|
|
searchCtls.setSearchScope(SearchControls.SUBTREE_SCOPE);
|
||
|
|
|
||
|
|
//Integer.parseInt("r");
|
||
|
|
|
||
|
|
Hashtable environment = new Hashtable();
|
||
|
|
environment.put(Context.INITIAL_CONTEXT_FACTORY, CONTEXT_FACTORY);
|
||
|
|
environment.put(Context.PROVIDER_URL, PROVIDER_URL);
|
||
|
|
environment.put(Context.SECURITY_AUTHENTICATION, AUTHENTICATION);
|
||
|
|
environment.put(Context.SECURITY_PRINCIPAL, DOMAIN + "\\" + userId);
|
||
|
|
environment.put(Context.SECURITY_CREDENTIALS, password);
|
||
|
|
|
||
|
|
EndrUserLoginForm userBean = null;
|
||
|
|
|
||
|
|
LdapContext ctxGC = new InitialLdapContext(environment, null);
|
||
|
|
|
||
|
|
NamingEnumeration answer = ctxGC.search(SEARCH_BASE, searchFilter, searchCtls);
|
||
|
|
|
||
|
|
while (answer.hasMoreElements()) {
|
||
|
|
SearchResult sr = (SearchResult) answer.next();
|
||
|
|
|
||
|
|
Attributes attributes = sr.getAttributes();
|
||
|
|
|
||
|
|
userBean = new EndrUserLoginForm();
|
||
|
|
userBean.setUserId(userId);
|
||
|
|
userBean.setUserPassword(password);
|
||
|
|
userBean.setFirstname(attributes.get("cn") == null ? null : attributes.get("cn").get().toString());
|
||
|
|
//userBean.setFirstname(attributes.get("name") == null ? null :attributes.get("name").toString());
|
||
|
|
}
|
||
|
|
return userBean;
|
||
|
|
} catch (NamingException namingException) {
|
||
|
|
namingException.printStackTrace();
|
||
|
|
}
|
||
|
|
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
public static MstOperidTabForm queryAllUser(String userId, String password) {
|
||
|
|
|
||
|
|
String searchFilter = "(&(objectClass=user))";
|
||
|
|
// String searchFilter = "(&(objectClass=person)(" + ATTRIBUTE_FOR_USER + "=mtl83200))";
|
||
|
|
// String searchFilter = "(&(objectClass=person)(" + ATTRIBUTE_FOR_USER + "=" + userId + "))";
|
||
|
|
// String searchFilter = ATTRIBUTE_FOR_USER + "=" + userId;
|
||
|
|
|
||
|
|
SearchControls searchCtls = new SearchControls();
|
||
|
|
//searchCtls.setReturningAttributes(ATTRIBUTES);
|
||
|
|
searchCtls.setSearchScope(SearchControls.SUBTREE_SCOPE);
|
||
|
|
// searchCtls.setCountLimit(10000);
|
||
|
|
|
||
|
|
Hashtable environment = new Hashtable();
|
||
|
|
environment.put(Context.INITIAL_CONTEXT_FACTORY, CONTEXT_FACTORY);
|
||
|
|
environment.put(Context.PROVIDER_URL, PROVIDER_URL);
|
||
|
|
environment.put(Context.SECURITY_AUTHENTICATION, AUTHENTICATION);
|
||
|
|
environment.put(Context.SECURITY_PRINCIPAL, DOMAIN + "\\" + userId);
|
||
|
|
environment.put(Context.SECURITY_CREDENTIALS, password);
|
||
|
|
|
||
|
|
MstOperidTabForm userBean = new MstOperidTabForm();
|
||
|
|
|
||
|
|
try {
|
||
|
|
LdapContext ctxGC = new InitialLdapContext(environment, null);
|
||
|
|
|
||
|
|
NamingEnumeration answer = ctxGC.search("DC=muangthai,DC=co,DC=th", searchFilter, searchCtls);
|
||
|
|
int count = 1;
|
||
|
|
Date now = new Date();
|
||
|
|
while (answer.hasMoreElements()) {
|
||
|
|
SearchResult sr = (SearchResult) answer.next();
|
||
|
|
|
||
|
|
Attributes attributes = sr.getAttributes();
|
||
|
|
|
||
|
|
userBean.setUserid(userId);
|
||
|
|
userBean.setFirstName(attributes.get("cn") == null ? null : attributes.get("cn").get().toString());
|
||
|
|
|
||
|
|
userId = (String)attributes.get("sAMAccountName").get();
|
||
|
|
if ("matching".equals(userId))
|
||
|
|
{
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
CommonServiceInterface userService = new CommonServiceImp();
|
||
|
|
// if (userId != null && (userId.startsWith("MTL") || userId.startsWith("mtl")
|
||
|
|
// || userId.startsWith("mtg") || userId.startsWith("MTG")
|
||
|
|
// ))
|
||
|
|
if (1 == 1)
|
||
|
|
{
|
||
|
|
|
||
|
|
userId = userId.toLowerCase();
|
||
|
|
String userName = (String)attributes.get("cn").get();
|
||
|
|
|
||
|
|
MstOperidTabBean user = (MstOperidTabBean)userService.searchClassByPK(new MstOperidTabBean(),userId.toLowerCase());
|
||
|
|
if (user == null)
|
||
|
|
{
|
||
|
|
user = new MstOperidTabBean();
|
||
|
|
user.setOperid("");
|
||
|
|
user.setUserid(userId);
|
||
|
|
user.setIdentifield(null);
|
||
|
|
|
||
|
|
user.setOperName(userName);
|
||
|
|
user.setLicienseName(userName);
|
||
|
|
|
||
|
|
user.setDepcode(null);
|
||
|
|
user.setDepartment(null);
|
||
|
|
user.setTeam(null);
|
||
|
|
user.setFlag(null);
|
||
|
|
|
||
|
|
userService.updateTable(user);
|
||
|
|
log.info("insert user id : " + userId + " : " + userName);
|
||
|
|
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
user.setOperName(userName);
|
||
|
|
userService.updateTable(user);
|
||
|
|
log.info("update user id : " + userId + " : " + userName);
|
||
|
|
}
|
||
|
|
|
||
|
|
//System.out.println(user);
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
return userBean;
|
||
|
|
} catch (NamingException namingException) {
|
||
|
|
namingException.printStackTrace();
|
||
|
|
}
|
||
|
|
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
public static MstOperidTabForm queryAllUser2(String userId, String password, String userUpdate) {
|
||
|
|
|
||
|
|
// String searchFilter = "(&(objectClass=user))";
|
||
|
|
//String searchFilter = "(&(objectClass=person)(" + ATTRIBUTE_FOR_USER + "=mtl83200))";
|
||
|
|
String searchFilter = "(&(objectClass=person)(" + ATTRIBUTE_FOR_USER + "=" + userUpdate + "))";
|
||
|
|
// String searchFilter = ATTRIBUTE_FOR_USER + "=" + userId;
|
||
|
|
|
||
|
|
SearchControls searchCtls = new SearchControls();
|
||
|
|
//searchCtls.setReturningAttributes(ATTRIBUTES);
|
||
|
|
searchCtls.setSearchScope(SearchControls.SUBTREE_SCOPE);
|
||
|
|
// searchCtls.setCountLimit(10000);
|
||
|
|
|
||
|
|
Hashtable environment = new Hashtable();
|
||
|
|
environment.put(Context.INITIAL_CONTEXT_FACTORY, CONTEXT_FACTORY);
|
||
|
|
environment.put(Context.PROVIDER_URL, PROVIDER_URL);
|
||
|
|
environment.put(Context.SECURITY_AUTHENTICATION, AUTHENTICATION);
|
||
|
|
environment.put(Context.SECURITY_PRINCIPAL, DOMAIN + "\\" + userId);
|
||
|
|
environment.put(Context.SECURITY_CREDENTIALS, password);
|
||
|
|
|
||
|
|
MstOperidTabForm userBean = new MstOperidTabForm();
|
||
|
|
|
||
|
|
try {
|
||
|
|
LdapContext ctxGC = new InitialLdapContext(environment, null);
|
||
|
|
|
||
|
|
NamingEnumeration answer = ctxGC.search("DC=muangthai,DC=co,DC=th", searchFilter, searchCtls);
|
||
|
|
int count = 1;
|
||
|
|
Date now = new Date();
|
||
|
|
while (answer.hasMoreElements()) {
|
||
|
|
SearchResult sr = (SearchResult) answer.next();
|
||
|
|
|
||
|
|
Attributes attributes = sr.getAttributes();
|
||
|
|
|
||
|
|
userBean.setUserid(userId);
|
||
|
|
userBean.setFirstName(attributes.get("cn") == null ? null : attributes.get("cn").get().toString());
|
||
|
|
|
||
|
|
userId = (String)attributes.get("sAMAccountName").get();
|
||
|
|
if ("matching".equals(userId))
|
||
|
|
{
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
return userBean;
|
||
|
|
} catch (NamingException namingException) {
|
||
|
|
namingException.printStackTrace();
|
||
|
|
}
|
||
|
|
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
public static void main(String[] args) throws Exception {
|
||
|
|
|
||
|
|
// String userId = "cadministrator";
|
||
|
|
// String password = "$t@rPlatt1nuM";
|
||
|
|
|
||
|
|
// String userId = "matching";
|
||
|
|
// String password = "12345";
|
||
|
|
|
||
|
|
String filterName = "anupong";
|
||
|
|
String password = "anupong_h";
|
||
|
|
|
||
|
|
ADAuthenticator ldap = new ADAuthenticator();
|
||
|
|
MstOperidTabBean att = null;
|
||
|
|
ldap.queryAllUser(filterName, password);
|
||
|
|
|
||
|
|
Session session = HibernateUtil.getCurrentSession();
|
||
|
|
String sql = "select * from user_login a \n" +
|
||
|
|
" where user_name is null ";
|
||
|
|
SQLQuery query = session.createSQLQuery(sql);
|
||
|
|
query.addEntity(MstOperidTabBean.class);
|
||
|
|
List<MstOperidTabBean> list = query.list();
|
||
|
|
for (MstOperidTabBean bean : list)
|
||
|
|
{
|
||
|
|
ldap.queryAllUser2(filterName, password, bean.getUserid());
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
if (att == null) {
|
||
|
|
|
||
|
|
} else {
|
||
|
|
|
||
|
|
try {
|
||
|
|
int count = 1;
|
||
|
|
|
||
|
|
// for (NamingEnumeration e = att.getAll(); e.hasMore(); ) {
|
||
|
|
// String tempStr = e.next().toString();
|
||
|
|
// System.out.println("[" +(count++)+ "] " + tempStr);
|
||
|
|
// }
|
||
|
|
// System.out.println();
|
||
|
|
} catch (Exception e) {
|
||
|
|
e.printStackTrace();
|
||
|
|
}
|
||
|
|
// System.out.println("[FOUND] " + att.get("name").toString());
|
||
|
|
// System.out.println("[FOUND] " + (VSMUtil.isNotEmpty(att.get("Description")) ? att.get("Description").toString() : "Description:"));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|