logindao.java

公司自己开发的工作流引擎

package cn.com.iaspec.workflow.privilege.dao;

import java.sql.*;
import java.util.*;
import org.apache.log4j.*;
import cn.com.iaspec.workflow.db.*;
import cn.com.iaspec.workflow.exception.*;
import cn.com.iaspec.workflow.organize.dao.*;
import cn.com.iaspec.workflow.vo.db.*;
import cn.com.iaspec.workflow.vo.workflow.*;
import cn.com.iaspec.workflow.util.*;

/**
 *
 * <p>Title:登录DAO</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */
public class LoginDAO{
  //private static Logger logger=Logger.getLogger(cn.com.iaspec.workflow.privilege.dao.LoginDAO.class);
  public LoginDAO(){

  }

  /**
   * 登录验证
   * @param loginName String 用户名
   * @param password String 密码
   * @throws Exception
   */
  public void login(String loginName,String password)
      throws Exception{
    Connection conn=null;
    Statement stm=null;
    try{
      String sql="";
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      //验证用户名
      sql="SELECT count(*) as count  from wf_user where login_id = '"+loginName+
          "' ";
      //logger.info("......login sql:"+sql);
      //System.out.println("......login sql:"+sql);
      ResultSet rs=stm.executeQuery(sql);
      while(rs.next()){
        if(rs.getInt("count")<1){
          throw new IncorrectLoginIdException("用户名不正确，请您输入正确的用户名。");
        }
      }
      //验证密码
      String md5Password=MD5Util.MD5Encode(loginName+password);
      sql="SELECT count(*) as count  from wf_user where password = '"+
          md5Password+"' and login_id = '"+loginName+"' ";
      //logger.info("......login sql:"+sql);
      rs=stm.executeQuery(sql);
      while(rs.next()){
        if(rs.getInt("count")<1){
          throw new IncorrectPasswordException("密码不正确，请您输入正确的密码。");
        }
      }
     System.out.println("......login success");
    }
    finally{
      //WorkflowDBConnectionManager.getInstance().close(stm);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

  /**
   * 通过用户登录名称取得用户信息
   * @param loginName String
   * @throws Exception
   * @return UserInfo
   */
  public UserInfo getUserInfoByLoginName(String loginName)
      throws Exception{
    UserInfo userInfo=new UserInfo();
    WfUserDAO userDAO=new WfUserDAO();
    WfUser user=userDAO.getUserInfoByLoginId(loginName);

    WfOrganizationDAO orgDAO=new WfOrganizationDAO();
    List orgList=orgDAO.getUserOrgInfoByUserId(user.getUserId());

    userInfo.setOrgList(orgList);
    userInfo.setLoginName(loginName);
    userInfo.setUserId(user.getUserId());
    userInfo.setUserName(user.getUserName());
    userInfo.setUserPosition(user.getUserPosition());
    //userInfo.setExtFieldList(user.getExtFieldList());
    //userInfo.setExtFieldList(null);
   // userInfo.setExtFieldList(user.getExtFieldList());
    return userInfo;

  }

  /**
   * 修改用户口令
   * @param loginId 用户登录id
   * @param password 新密码
   * @throws Exception
   */
  public void modifyUserPassword(String loginId,String password)
      throws Exception{
    Connection conn=null;
    Statement stm=null;
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      String md5Password=MD5Util.MD5Encode(loginId+password);
      String sql=" update wf_user set password='"+md5Password+"' where login_id='"+loginId+"' ";
      //logger.info("......query sql:"+sql);
      stm.executeUpdate(sql);
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }
}