package com.vci.server.framework.systemConfig.stafforgmanage.user;
|
|
import java.sql.Connection;
|
import java.sql.PreparedStatement;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.sql.Timestamp;
|
import java.text.DateFormat;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.hibernate.HibernateException;
|
import org.hibernate.type.Type;
|
|
import com.vci.common.objects.UserEntity;
|
import com.vci.common.resource.CommonProperties;
|
import com.vci.server.base.persistence.dao.BaseService;
|
import com.vci.server.base.persistence.dao.HibernateCallback;
|
import com.vci.server.base.persistence.dao.HibernateCallbackExt;
|
import com.vci.server.base.persistence.dao.HibernateTemplate;
|
import com.vci.server.base.persistence.dao.JDBCCallback;
|
import com.vci.server.base.persistence.dao.JDBCRunType;
|
import com.vci.server.base.persistence.dao.JDBCTemplate;
|
import com.vci.server.framework.timer.TimeService;
|
|
public class UserService extends BaseService {
|
public UserService() {}
|
public UserService(UserEntity userEntity) {
|
super(userEntity);
|
}
|
|
/**
|
*
|
* <p>Description:创建人员 </p>
|
*
|
* @author wangxl
|
* @time 2012-5-11
|
* @param user
|
*/
|
public void saveUser(final User user) {
|
new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
user.setUserEntity(userEntity);
|
impl.save(user);
|
|
UserLogonDAOImpl userLogonDAOImpl = new UserLogonDAOImpl();
|
UserLogon userLogon = new UserLogon();
|
userLogon.setPluserOid(user.getId());
|
userLogon.setPlWrongNum((short)0);
|
userLogon.setPlLogonTime(new Timestamp(System.currentTimeMillis()));
|
userLogon.setUserEntity(userEntity);
|
userLogonDAOImpl.save(userLogon);
|
return user;
|
}
|
});
|
}
|
/**
|
* <p>Description: </p>
|
*
|
* @author wangxl
|
* @time 2012-5-11
|
* @param User
|
*/
|
public void updateUser(final User user) {
|
new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
User cUser = impl.getById(user.getId());
|
|
if (cUser == null) {
|
user.setUserEntity(userEntity);
|
impl.saveOrUpdate(user);
|
return user;
|
} else {
|
cUser.setUserName(user.getUserName());
|
if (cUser.getPassword().equals(user.getPassword())) {
|
cUser.setPwdUpdateTime(user.getPwdUpdateTime());
|
} else {
|
cUser.setPwdUpdateTime(new Timestamp(System.currentTimeMillis()));
|
}
|
cUser.setPassword(user.getPassword());
|
cUser.setTrueName(user.getTrueName());
|
cUser.setSpecialties(user.getSpecialties());
|
cUser.setEmail(user.getEmail());
|
cUser.setDesc(user.getDesc());
|
cUser.setUserEntity(userEntity);
|
cUser.setUpdateTime(new Timestamp(System.currentTimeMillis()));
|
cUser.setUpdateUser(user.getUpdateUser());
|
cUser.setGrantor(user.getGrantor());
|
cUser.setStatus(user.getStatus());
|
cUser.setIsDeptLeader(user.getIsDeptLeader());
|
cUser.setSecretGrade(user.getSecretGrade());
|
impl.saveOrUpdate(cUser);
|
return cUser;
|
}
|
}
|
});
|
}
|
|
|
public List getAllUser() {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = " from User";
|
return impl.findEntities(hsql);
|
}
|
});
|
}
|
|
|
public List getUserList() {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = " from User u where u.userName <> 'admin' and u.userType > 0 order by u.trueName";
|
return impl.findEntities(hsql);
|
}
|
});
|
}
|
|
/**
|
* <p>Description: </p>
|
* @author liujw
|
* @time 2013-5-7
|
*/
|
public List getUserListWithOutSanYuan() {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String sql = " select * from pluser u where u.plusername " +
|
" in (select u.plusername from pluser u inner join pluserrole ur on u.plusername <> 'admin' and u.plusertype > 0 and u.pluid = ur.pluseruid and ur.plroleuid " +
|
" in (select r.pluid from plrole r where r.plname <> 'sysAdmin' and r.plname <> 'securityAdmin' and r.plname <> 'auditAdmin' )) order by u.pltruename " ;
|
Object[] values = new Object[0];
|
List list = impl.findEntites(sql, values, "u", User.class);
|
return list;
|
}
|
});
|
}
|
|
/**
|
* 按条件查询用户
|
* @param name
|
* @param userName
|
* @param deptId
|
* @param roleId
|
* @param groupId
|
* @param loginName
|
* @param pageNo
|
* @param pageSize
|
* @return
|
*/
|
public List getUserListByCondition(final String name, final String userName, final String deptId,
|
final String roleId,final String loginName,final int pageNo,final int pageSize,final boolean filterUserType) {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
// String hsql = "from User user where user.userName = :name";
|
// User user = impl.findEntity(hsql, "name", loginName);
|
// int type = user.getUserType();
|
// if (type<2){
|
// type = type + 1;
|
// }
|
|
int V_PAGE_ROWNUM_START = (pageNo - 1) * pageSize;
|
int V_PAGE_ROWNUM_END = (pageNo ) * pageSize;
|
|
StringBuffer sb = new StringBuffer();
|
sb.append(" SELECT * ");
|
sb.append(" FROM (SELECT ROW_.*, ROWNUM RN ");
|
sb.append(" FROM (");
|
|
// sb.append(" select u.* from pluser u where u.pluserType = ");
|
// sb.append(type);
|
// sb.append(" select u.* from pluser u where u.pluserType IN(1,2)");
|
if(filterUserType){
|
sb.append(" select u.* from pluser u where u.pluserType > 1 ");
|
}else{
|
sb.append(" select u.* from pluser u where u.pluserType > 0 ");
|
}
|
|
if (!"".equals(name)){
|
sb.append(" and u.PLTRUENAME like '%"+name+"%' ");
|
}
|
if (!"".equals(userName)){
|
sb.append(" and u.plusername like '%"+userName+"%' ");
|
}
|
if (!"".equals(deptId)){
|
sb.append(" and u.pluid in (select ud.pluseruid from pluserdept ud where ud.pldeptuid = '"+deptId+"' ) ");
|
}
|
if (!"".equals(roleId)){
|
sb.append("and u.pluid in (select ur.pluseruid from PLUSERROLE ur where ur.plroleuid = '"+roleId+"') ");
|
}
|
sb.append(" order by u.PLTRUENAME ");
|
|
sb.append(" )ROW_)");
|
sb.append(" WHERE RN <= ");
|
sb.append( V_PAGE_ROWNUM_END);
|
sb.append(" AND RN > ");
|
sb.append(V_PAGE_ROWNUM_START);
|
|
Object[] values = new Object[0];
|
List<User> list = impl.findEntites(sb.toString(), values, "u", User.class);
|
return list;
|
}
|
});
|
}
|
//add by caill 2016.9.26
|
public List getUserListByConditionUnited(final String name, final String userName, final String deptId,
|
final String roleId,final String loginName,final int pageNo,final int pageSize,final boolean filterUserType) {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
// String hsql = "from User user where user.userName = :name";
|
// User user = impl.findEntity(hsql, "name", loginName);
|
// int type = user.getUserType();
|
// if (type<2){
|
// type = type + 1;
|
// }
|
|
int V_PAGE_ROWNUM_START = (pageNo - 1) * pageSize;
|
int V_PAGE_ROWNUM_END = (pageNo ) * pageSize;
|
|
StringBuffer sb = new StringBuffer();
|
sb.append(" SELECT * ");
|
sb.append(" FROM (SELECT ROW_.*, ROWNUM RN ");
|
sb.append(" FROM (");
|
|
// sb.append(" select u.* from pluser u where u.pluserType = ");
|
// sb.append(type);
|
// sb.append(" select u.* from pluser u where u.pluserType IN(1,2)");
|
if(filterUserType){
|
sb.append(" select u.* from pluser u where u.pluserType > 1 ");
|
}else{
|
sb.append(" select u.* from pluser u where u.pluserType > 0 ");
|
}
|
|
if (!"".equals(name)){
|
sb.append(" and u.PLTRUENAME like '%"+name+"%' ");
|
}
|
if (!"".equals(userName)){
|
sb.append(" and u.plusername like '%"+userName+"%' ");
|
}
|
//add by caill 2016.9.26此处做了级联查询
|
if (!"".equals(deptId)){
|
sb.append(" and u.pluid in (select ud.pluseruid from pluserdept ud where ud.pldeptuid in( select d.pluid from pldept d start with d.pluid = '"+deptId+"' connect by prior d.pluid = d.plparentuid)) ");
|
}
|
if (!"".equals(roleId)){
|
sb.append("and u.pluid in (select ur.pluseruid from PLUSERROLE ur where ur.plroleuid = '"+roleId+"') ");
|
}
|
sb.append(" order by u.PLTRUENAME ");
|
|
sb.append(" )ROW_)");
|
sb.append(" WHERE RN <= ");
|
sb.append( V_PAGE_ROWNUM_END);
|
sb.append(" AND RN > ");
|
sb.append(V_PAGE_ROWNUM_START);
|
|
Object[] values = new Object[0];
|
List<User> list = impl.findEntites(sb.toString(), values, "u", User.class);
|
return list;
|
}
|
});
|
}
|
//add by caill end
|
public int getUserTotalByCondition(final String name, final String userName, final String deptId,
|
final String roleId,final String loginName,final boolean filterUserType ) {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = "from User user where user.userName = :name";
|
User user = impl.findEntity(hsql, "name", loginName);
|
int type = user.getUserType();
|
if (type<2){
|
type = type + 1;
|
}
|
|
int res = 0;
|
|
StringBuffer sb = new StringBuffer();
|
sb.append(" SELECT COUNT(*) ");
|
sb.append(" FROM (");
|
|
//不考虑用户级别 --2013-10-29 by liudi start
|
// sb.append(" select u.* from pluser u where u.pluserType = ");
|
// sb.append(type);
|
if(filterUserType){
|
sb.append(" select u.* from pluser u where u.pluserType >1 ");
|
}else{
|
sb.append(" select u.* from pluser u where u.pluserType >0 ");
|
}
|
//2013-10-29 by liudi end
|
|
if (!"".equals(name)){
|
sb.append(" and u.PLTRUENAME like '%"+name+"%' ");
|
}
|
if (!"".equals(userName)){
|
sb.append(" and u.plusername like '%"+userName+"%' ");
|
}
|
if (!"".equals(deptId)){
|
sb.append(" and u.pluid in (select ud.pluseruid from pluserdept ud where ud.pldeptuid = '"+deptId+"' ) ");
|
}
|
if (!"".equals(roleId)){
|
sb.append("and u.pluid in (select ur.pluseruid from PLUSERROLE ur where ur.plroleuid = '"+roleId+"') ");
|
}
|
sb.append(" order by u.PLTRUENAME ");
|
|
sb.append(" )");
|
|
res = (Integer)new JDBCTemplate().run(new JDBCCallback(
|
new HibernateTemplate().getSessionConnection(),
|
sb.toString(), JDBCRunType.SQL, 0, false, false,new Object[]{}) {
|
@Override
|
public Object execute(ResultSet rst) throws SQLException {
|
int ress = 0;
|
while(rst.next()){
|
ress = rst.getInt(1);
|
|
}
|
return ress;
|
}
|
});
|
return res;
|
|
}
|
|
public List getUserInfoList(final String id) {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = " from User u where u.id = '"+id+"' order by u.trueName";
|
return impl.findEntities(hsql);
|
}
|
public List getUserListByType(final int type) {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = " from User u where u.userName <> 'admin' and u.userName <> 'developer' and u.userName <> 'root' and u.userType = ? order by u.trueName";
|
int a = type;
|
if (a<2){
|
a = a + 1;
|
}
|
Object[] values = {a};
|
return impl.findEntites(hsql, values);
|
}
|
});
|
}
|
public List fetchUserInfoByRoleId(final String roleId , final int type) {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
int a = type;
|
if (a<2){
|
a = a + 1;
|
}
|
//and u.pluserType = "+ a +"
|
String hsql = " select * from pluser u where u.plusername <> 'admin' and u.PLUID in " +
|
" (select ur.pluseruid from pluserrole ur where ur.plroleuid = '"+roleId+"') order by u.pltrueName ";
|
|
Object[] values = new Object[0];
|
List<User> list = impl.findEntites(hsql, values, "u", User.class);
|
return list;
|
}
|
});
|
}
|
public List fetchUsersByRoleId(final String roleId) {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = " select * from pluser u where u.plusername <> 'admin' and u.PLUID in " +
|
" (select ur.pluseruid from pluserrole ur where ur.plroleuid = '"+roleId+"') order by u.pltrueName ";
|
|
Object[] values = new Object[0];
|
List<User> list = impl.findEntites(hsql, values, "u", User.class);
|
return list;
|
}
|
});
|
}
|
public List selectUserByRoleId(final String roleId) {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = " select * from pluser u where u.plusername <> 'admin' and u.PLUID in " +
|
" (select ur.pluseruid from pluserrole ur where ur.plroleuid = '"+roleId+"') order by u.pltrueName ";
|
|
Object[] values = new Object[0];
|
List<User> list = impl.findEntites(hsql, values, "u", User.class);
|
return list;
|
}
|
});
|
}
|
|
/**
|
* 获取部门下的成员
|
* @param deptId
|
* @return
|
*/
|
@SuppressWarnings("rawtypes")
|
public List getUserByDeptId(final String deptId) {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = " select * from pluser u where u.plusername <> 'admin' and u.PLUID in " +
|
" (select ud.pluseruid from pluserdept ud where ud.pldeptuid = '"+deptId+"') order by u.pltrueName ";
|
|
Object[] values = new Object[0];
|
List<User> list = impl.findEntites(hsql, values, "u", User.class);
|
return list;
|
}
|
});
|
}
|
|
|
/**
|
*
|
* <p>获取信号下的所有型号总师: </p>
|
*
|
* @time 2013-3-28
|
* @param modelId 型号ID
|
* @return
|
*/
|
@SuppressWarnings("rawtypes")
|
public List fetchUserInfoByModelId(final String modelId) {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = " select * from pluser u where u.plusername <> 'admin' and u.PLUID in " +
|
" (select ud.PLUSERID from PLMODELUSER ud where ud.PLMODELID = '"+modelId+"') order by u.pltrueName ";
|
|
Object[] values = new Object[0];
|
List<User> list = impl.findEntites(hsql, values, "u", User.class);
|
return list;
|
}
|
});
|
}
|
@SuppressWarnings("rawtypes")
|
public List fetchUserInfoByModel(final String model) {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = " select * from pluser u where u.plusername <> 'admin' and u.PLUID in " +
|
" (select ud.PLUSERID from PLMODELUSER ud where ud.PLMODELID in (" +
|
" select m.PLoid from plmodelconfig m where m .plname = '"+model+"'))";
|
Object[] values = new Object[0];
|
List<User> list = impl.findEntites(hsql, values, "u", User.class);
|
return list;
|
}
|
});
|
}
|
@SuppressWarnings("rawtypes")
|
public List fetchUserInfoByDeptAndRole(final String[] deptIds , final String[] roleIds) {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = " select * from pluser u where u.plusername <> 'admin' and u.PLUID in " +
|
" (select ud.pluseruid from pluserdept ud where ud.pldeptuid = '"+deptIds[0]+"')" +
|
" and u.PLUID in (select ur.pluseruid from PLUSERROLE ur where ur.plroleuid = '"+roleIds[0]+"')" ;
|
Object[] values = new Object[0];
|
List<User> list = impl.findEntites(hsql, values, "u", User.class);
|
return list;
|
}
|
});
|
}
|
|
public List fetchUserInfoByPvolumeId(final String pvolumeId , final int type) {
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
int a = type;
|
if (a<2){
|
a = a + 1;
|
}
|
String hsql = " select * from pluser u where u.plusername <> 'admin' and u.pluserType = "+ a +" and u.PLUID in " +
|
" (select up.pluseruid from pluserpvolume up where up.plpvolumeuid = '"+pvolumeId+"') order by u.pltrueName ";
|
|
Object[] values = new Object[0];
|
List<User> list = impl.findEntites(hsql, values, "u", User.class);
|
return list;
|
}
|
});
|
}
|
|
public boolean deleteUser(final String id) {
|
return (Boolean)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
User User = impl.loadById(id);
|
User.setUserEntity(userEntity);
|
impl.delete(User);
|
|
UserLogonDAOImpl userLogonDAOImpl = new UserLogonDAOImpl();
|
UserLogon userLogon = new UserLogon();
|
userLogon = userLogonDAOImpl.loadById(id);
|
userLogon.setUserEntity(userEntity);
|
userLogonDAOImpl.delete(userLogon);
|
|
return true;
|
}
|
});
|
}
|
|
/**
|
* 按照id 删除成员
|
* @param id
|
* @return
|
*/
|
public boolean deleteUserByHQL(final String id) {
|
return (Boolean)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hql = "delete User u where u.id=:id";
|
impl.deleteQueryObject(hql, "id", id, userEntity);
|
return true;
|
}
|
});
|
}
|
public boolean stopUsers(final String id , final boolean flag) {
|
return (Boolean)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hql = "";
|
if (flag){//停用
|
hql = "update User u set u.status = 1 where u.id=:id";
|
}else {
|
hql = "update User u set u.status = 0 where u.id=:id";
|
}
|
|
impl.deleteQueryObject(hql, "id", id, userEntity);
|
return true;
|
}
|
});
|
}
|
|
/**
|
* 删除指定数组的成员
|
* @param ids
|
* @return
|
*/
|
public boolean deleteUserByHQL(final String[] ids) {
|
return (Boolean)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hql = "delete User u where u.id in (";
|
int len = ids.length;
|
for (int i = 0; i < len; i++) {
|
hql += "?";
|
if (i != len - 1) {
|
hql += ",";
|
}
|
}
|
hql += ")";
|
impl.deleteQueryObject(hql, ids, userEntity);
|
|
return true;
|
}
|
});
|
}
|
|
public User selectUserByName(final String name) {
|
return (User)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = "from User user where user.userName = :name order by user.trueName";
|
return impl.findEntity(hsql, "name", name);
|
}
|
});
|
}
|
|
|
/**
|
* 根据用户名返回用户对象
|
*
|
* @param userName
|
* @param password
|
* @return
|
*/
|
public User getUserObjectByUserName(final String userName) {
|
return (User) new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = " from User u where u.userName = ?";
|
Object[] values = { userName, };
|
List list = impl.findEntites(hsql, values);
|
if (list.size() != 0) {
|
return (User) list.get(0);
|
}
|
return null;
|
}
|
});
|
}
|
|
/**
|
* 验证用户登录
|
* @param userName
|
* @param password
|
* @return
|
*/
|
public User checkLogin(final String userName, final String password){
|
return (User)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = " from User u where u.userName = ?";
|
Object[] values = {userName};
|
List list = impl.findEntites(hsql, values);
|
if(list.size() != 0){
|
User user = (User)list.get(0);
|
if (user.getPassword().equals(password))
|
return user;
|
else
|
return null;
|
//return (User)list.get(0);
|
}
|
return null;
|
}
|
});
|
}
|
|
public int getPwModifyTime(final String userOid){
|
return (Integer)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
int validity = -1;
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = " select p.PLPWMODTIME from PLUSEROPERATION p where p.PLUSEROID = '"+userOid+"'";
|
List list = new ArrayList();
|
Object[] values = new Object[0];
|
Map<String,Type> map = new HashMap<String,Type>();
|
list = impl.findEntitesBySQL(hsql, values,map);
|
if (list.size() != 0 &&list.get(0)!=null){
|
String pwModifyTime = list.get(0).toString();
|
int betweenDay = compare_date(pwModifyTime,new Date());
|
int storagelife = Integer.parseInt(CommonProperties.getStringProperty("logon.pwd.storagelife"));
|
validity = storagelife - betweenDay;
|
}
|
return validity;
|
}
|
});
|
}
|
//两个日期间隔多少天
|
private int compare_date(String DATE1, Date DATE2) {
|
DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
long nd = 1000*24*60*60;//一天的毫秒数
|
Date dt1 = null;
|
try {
|
dt1 = df.parse(DATE1);
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
Date dt2 = DATE2;
|
return (int) ((dt2.getTime() - dt1.getTime()+1000000)/nd);
|
}
|
|
// public int getPwPromptDate(){
|
// return Integer.parseInt(CommonProperties.getStringProperty("logon.pwd.promptdate"));
|
// }
|
/**
|
*
|
* <p>保存型号和型号总师之间的关系: </p>
|
*
|
* @time 2013-3-28
|
* @param modelIds
|
* @param userId
|
* @return
|
*/
|
public boolean saveUserModel(final String[] modelIds , final String[] userIds ){
|
return (Boolean)new HibernateTemplate().runExt(new HibernateCallbackExt() {
|
public Object execute(Connection conn) throws HibernateException,
|
SQLException {
|
String sql = "delete PLMODELUSER ur where ur.PLMODELID = ? ";
|
PreparedStatement pstmt = null;
|
PreparedStatement pstmt1 = null;
|
try {
|
pstmt = conn.prepareStatement(sql);
|
for(String modelId :modelIds ){
|
pstmt.setString(1, modelId);
|
pstmt.execute();
|
}
|
} catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally {
|
if (pstmt != null){
|
pstmt.close();
|
}
|
}
|
try {
|
for(String modelId :modelIds ){
|
for (int i = 0 ; i < userIds.length ; i ++){
|
String hql = "insert into PLMODELUSER values (? , ?)";
|
pstmt1 = conn.prepareStatement(hql);
|
pstmt1.setString(1, userIds[i]);
|
pstmt1.setString(2, modelId);
|
pstmt1.execute();
|
}
|
}
|
}catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally {
|
if (pstmt1 != null){
|
pstmt1.close();
|
}
|
}
|
return true;
|
}
|
});
|
}
|
public boolean saveRights(final String[] roleIds , final String userId ){
|
return (Boolean)new HibernateTemplate().runExt(new HibernateCallbackExt() {
|
public Object execute(Connection conn) throws HibernateException,
|
SQLException {
|
String sql = "delete pluserrole ur where ur.pluseruid = ? ";
|
PreparedStatement pstmt = null;
|
PreparedStatement pstmt1 = null;
|
try {
|
pstmt = conn.prepareStatement(sql);
|
pstmt.setString(1, userId);
|
pstmt.execute();
|
} catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally {
|
if (pstmt != null){
|
pstmt.close();
|
}
|
}
|
try {
|
for (int i = 0 ; i < roleIds.length ; i ++){
|
String hql = "insert into pluserrole values (? , ?)";
|
pstmt1 = conn.prepareStatement(hql);
|
pstmt1.setString(1, userId);
|
pstmt1.setString(2, roleIds[i]);
|
pstmt1.execute();
|
}
|
}catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally {
|
if (pstmt1 != null){
|
pstmt1.close();
|
}
|
}
|
return true;
|
}
|
});
|
}
|
public boolean saveUserDept(final String userId , final String deptId ){
|
return (Boolean)new HibernateTemplate().runExt(new HibernateCallbackExt() {
|
public Object execute(Connection conn) throws HibernateException,
|
SQLException {
|
String sql = "delete pluserdept ud where ud.pluseruid = ?";
|
PreparedStatement pstmt = null;
|
PreparedStatement pstmt1 = null;
|
try {
|
pstmt = conn.prepareStatement(sql);
|
pstmt.setString(1, userId);
|
pstmt.execute();
|
} catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally {
|
if (pstmt != null){
|
pstmt.close();
|
}
|
}
|
if (!"".equals(deptId)){
|
try {
|
String hql = "insert into pluserdept values (? , ?)";
|
pstmt1 = conn.prepareStatement(hql);
|
pstmt1.setString(1, userId);
|
pstmt1.setString(2, deptId);
|
pstmt1.execute();
|
}catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally {
|
if (pstmt1 != null){
|
pstmt1.close();
|
}
|
}
|
}
|
|
return true;
|
}
|
});
|
}
|
public boolean saveUserPasswordStrateg(final String userId , final String passwordStrategId ){
|
return (Boolean)new HibernateTemplate().runExt(new HibernateCallbackExt() {
|
public Object execute(Connection conn) throws HibernateException,
|
SQLException {
|
String sql = "delete PLUSERPASSWORDSTRATEGY ud where ud.pluseruid = ?";
|
PreparedStatement pstmt = null;
|
PreparedStatement pstmt1 = null;
|
try {
|
pstmt = conn.prepareStatement(sql);
|
pstmt.setString(1, userId);
|
pstmt.execute();
|
} catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally {
|
if (pstmt != null){
|
pstmt.close();
|
}
|
}
|
if (!"".equals(passwordStrategId)){
|
try {
|
String hql = "insert into PLUSERPASSWORDSTRATEGY values (? , ?)";
|
pstmt1 = conn.prepareStatement(hql);
|
pstmt1.setString(1, passwordStrategId);
|
pstmt1.setString(2, userId);
|
|
pstmt1.execute();
|
}catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally {
|
if (pstmt1 != null){
|
pstmt1.close();
|
}
|
}
|
}
|
|
return true;
|
}
|
});
|
}
|
|
public void deleteRights(final String userId){
|
new HibernateTemplate().runExt(new HibernateCallbackExt() {
|
public Object execute(Connection conn) throws HibernateException,
|
SQLException {
|
PreparedStatement pstmt = null;
|
String hql1 = "delete from plusercompany uc where uc.pluseruid = ?";
|
String hql2 = "delete from pluserrole ur where ur.pluseruid = ?";
|
String hql3 = "delete from pluserdept ud where ud.pluseruid = ?";
|
String hql4 = "delete from PLUSERPASSWORDSTRATEGY us where us.pluseruid = ?";
|
// try {
|
// pstmt = conn.prepareStatement(hql1);
|
// pstmt.setString(1, userId);
|
// pstmt.execute();
|
// } catch (SQLException e1) {
|
// e1.printStackTrace();
|
// } finally{
|
// pstmt.close();
|
// }
|
try {
|
pstmt = conn.prepareStatement(hql2);
|
pstmt.setString(1, userId);
|
pstmt.execute();
|
} catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally{
|
pstmt.close();
|
}
|
try {
|
pstmt = conn.prepareStatement(hql3);
|
pstmt.setString(1, userId);
|
pstmt.execute();
|
} catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally{
|
pstmt.close();
|
}
|
try {
|
pstmt = conn.prepareStatement(hql4);
|
pstmt.setString(1, userId);
|
pstmt.execute();
|
} catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally{
|
pstmt.close();
|
}
|
|
return null;
|
}
|
});
|
}
|
|
public UserLogon getUserLogonObj(final String userId){
|
return (UserLogon)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserLogonDAOImpl impl = new UserLogonDAOImpl();
|
String hsql = " from UserLogon u where u.pluserOid = ? ";
|
Object[] values = {userId};
|
List<?> list = impl.findEntites(hsql, values);
|
if(list.size() != 0){
|
return (UserLogon)list.get(0);
|
} else {
|
UserLogon userLogon = new UserLogon();
|
userLogon.setPluserOid(userId);
|
userLogon.setPlWrongNum((short)0);
|
userLogon.setPlLogonTime(new Timestamp(System.currentTimeMillis()));
|
userLogon.setUserEntity(userEntity);
|
impl.save(userLogon);
|
|
return userLogon;
|
}
|
//return null;
|
}
|
});
|
}
|
|
public long getSystemTime(){
|
return new TimeService().getDBTime();
|
}
|
|
public void updateLogonInfo(final String userId,final boolean flag){
|
new HibernateTemplate().runExt(new HibernateCallbackExt() {
|
public Object execute(Connection conn) throws HibernateException,
|
SQLException {
|
UserLogonDAOImpl impl = new UserLogonDAOImpl();
|
String hql = "";
|
if (flag){
|
hql = "Update UserLogon u set u.plWrongNum = 0 where u.pluserOid = '"+userId+"'" ;
|
impl.createQuery(hql);
|
}else{
|
hql = "Update PLLOGONINFO u set u.PLWRONGNUM = u.PLWRONGNUM+1 ,u.PLLOGONTIME = ? where u.PLUSERID = '"+userId+"'" ;
|
PreparedStatement pstmt = null;
|
try {
|
pstmt = conn.prepareStatement(hql);
|
pstmt.setTimestamp(1, new Timestamp(System.currentTimeMillis()));
|
pstmt.executeUpdate();
|
} catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally{
|
pstmt.close();
|
}
|
}
|
return "";
|
}
|
});
|
}
|
|
public void deblock(final String[] ids){
|
new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserLogonDAOImpl impl = new UserLogonDAOImpl();
|
|
String hql = "";
|
for (int i = 0 ; i < ids.length ; i ++){
|
hql = "Update UserLogon u set u.plWrongNum = 0 where u.pluserOid = '"+ids[i]+"'";
|
impl.createQuery(hql);
|
}
|
return "";
|
|
}
|
});
|
}
|
|
@SuppressWarnings("unchecked")
|
public List<User> fetchUserInfoByFilterString(final String filterString,final int pageNo, final int pageSize) {
|
// TODO Auto-generated method stub
|
return (List<User>)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
int V_PAGE_ROWNUM_START = (pageNo - 1) * pageSize;
|
int V_PAGE_ROWNUM_END = (pageNo ) * pageSize;
|
UserDAOImpl impl = new UserDAOImpl();
|
StringBuffer sb=new StringBuffer();
|
sb.append(" select * from ( ");
|
sb.append(" select pluser.*, ROWNUM rn from pluser ");
|
sb.append(" where pluid in( ");
|
sb.append(" select pluser.pluid from pluser ");
|
sb.append(" left join pluserrole on pluser.pluid = pluserrole.pluseruid ");
|
sb.append(" left join plrole on plrole.pluid = pluserrole.plroleuid ");
|
sb.append(" left join pluserdept on pluser.pluid = pluserdept.pluseruid");
|
sb.append(" left join pldept on pluserdept.pldeptuid = pldept.pluid ");
|
sb.append(" where pluser.plusername not in ('admin', 'secAdmin', 'developer', 'auditAdmin') ");
|
sb.append(" and pluser.plusertype > 0 ");
|
//加查询条件
|
// sb.append(" and pluser.plstatus = 0 ");
|
sb.append( filterString );
|
sb.append(" ) ");
|
sb.append(" ) WHERE RN >");
|
sb.append(V_PAGE_ROWNUM_START);
|
sb.append(" and RN <= ");
|
sb.append(V_PAGE_ROWNUM_END);
|
Object[] values = new Object[0];
|
List<User> list = impl.findEntites(sb.toString(), values, "u", User.class);
|
return list;
|
}
|
}
|
);
|
}
|
|
public int fetchUserInfoByFilterStringCount(final String filterString) {
|
StringBuffer sb=new StringBuffer();
|
sb.append(" select count(*) from pluser ");
|
sb.append(" where pluid in( ");
|
sb.append(" select pluser.pluid from pluser ");
|
sb.append(" left join pluserrole on pluser.pluid = pluserrole.pluseruid ");
|
sb.append(" left join plrole on plrole.pluid = pluserrole.plroleuid ");
|
sb.append(" left join pluserdept on pluser.pluid = pluserdept.pluseruid");
|
sb.append(" left join pldept on pluserdept.pldeptuid = pldept.pluid ");
|
sb.append(" where pluser.plusername not in ('admin', 'secAdmin', 'developer', 'auditAdmin') ");
|
sb.append(" and pluser.plusertype > 0 ");
|
////加查询条件
|
//sb.append(" and pluser.plstatus = 0 ");
|
sb.append( filterString );
|
sb.append(" ) ");
|
int res=0;
|
res = (Integer)new JDBCTemplate().run(new JDBCCallback(
|
new HibernateTemplate().getSessionConnection(),
|
sb.toString(), JDBCRunType.SQL, 0, false, false,new Object[]{}) {
|
@Override
|
public Object execute(ResultSet rst) throws SQLException {
|
int ress = 0;
|
while(rst.next()){
|
ress = rst.getInt(1);
|
}
|
return ress;
|
}
|
});
|
return res;
|
}
|
public List<User> fetchUserInfosByFilterStringsql(String filterString){
|
// TODO Auto-generated method stub
|
UserDAOImpl impl = new UserDAOImpl();
|
StringBuffer sb=new StringBuffer();
|
sb.append(" select * from pluser ");
|
sb.append(" where pluid in( ");
|
sb.append(" select pluser.pluid from pluser ");
|
sb.append(" left join pluserrole on pluser.pluid = pluserrole.pluseruid ");
|
sb.append(" left join plrole on plrole.pluid = pluserrole.plroleuid ");
|
sb.append(" left join pluserdept on pluser.pluid = pluserdept.pluseruid");
|
sb.append(" left join pldept on pluserdept.pldeptuid = pldept.pluid ");
|
sb.append(" where pluser.plusername not in ('admin', 'secAdmin', 'developer', 'auditAdmin') ");
|
sb.append(" and pluser.plusertype > 0 ");
|
//加查询条件
|
// sb.append(" and pluser.plstatus = 0 ");
|
sb.append( filterString );
|
sb.append(" ) ");
|
Object[] values = new Object[0];
|
List<User> list = impl.findEntites(sb.toString(), values, "u", User.class);
|
return list;
|
|
}
|
|
@SuppressWarnings("unchecked")
|
public List<User> fetchUserInfoByNames(final String[] names) {
|
return (List<User>)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
StringBuffer sb=new StringBuffer();
|
sb.append(" from User u where 1=1 ");
|
|
String userOidstr="";
|
for (String userOid : names) {
|
userOidstr+="".equals(userOidstr)?"'"+userOid+"'":",'"+userOid+"'";
|
}
|
sb.append(" and u.userName in ( ");
|
sb.append(userOidstr);
|
sb.append(")");
|
sb.append("order by u.trueName");
|
Object[] values ={};
|
List<User> list = impl.findEntites(sb.toString(), values);
|
return list;
|
}
|
});
|
}
|
|
public User getUserObjectByoid(final String userOid) {
|
return (User)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hsql = "from User user where user.id = :id order by user.trueName";
|
return impl.findEntity(hsql, "id", userOid);
|
}
|
});
|
}
|
@SuppressWarnings("unchecked")
|
public List<User> getUserObjectByoids(final String[] userOids) {
|
return (List<User>)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
StringBuffer sb=new StringBuffer();
|
sb.append(" from User u where 1=1 ");
|
|
String userOidstr="";
|
for (String userOid : userOids) {
|
userOidstr+="".equals(userOidstr)?"'"+userOid+"'":",'"+userOid+"'";
|
}
|
sb.append(" and u.id in ( ");
|
sb.append(userOidstr);
|
sb.append(")");
|
sb.append("order by u.trueName");
|
Object[] values ={};
|
List<User> list =impl.findEntites(sb.toString() , values);
|
return list;
|
}
|
});
|
}
|
|
public boolean chanageUserPassword(final String idUser, final String pw) {
|
return (Boolean) new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
UserDAOImpl impl = new UserDAOImpl();
|
String hql = "";
|
hql = "update User u set u.password=:pw where u.id=:id";
|
|
impl.updateQueryObject(hql, idUser, new String[] {"pw", "id"}, new String[] {pw, idUser}, userEntity);
|
return true;
|
}
|
});
|
}
|
}
|
