userinfodao.java

实现办公自动化系统

package com.oa.struts.login.model;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import com.oa.struts.vo.*;
import com.oa.util.DBConn;
import javax.servlet.http.HttpSession;;

public class userInfoDAO 
{
	private DBConn tj = new DBConn();
	private Connection conn = null; 
	private Statement st = null;
	private PreparedStatement ps = null;
	private ResultSet rs = null;
	public boolean checkUser(int userId,String passWord,HttpSession session)
	{
		System.out.println("checkUser(int userId,String passWord,HttpSession session)");
		
		boolean flag=false;
		try {
			//System.out.println("userId="+userId+"@@@@@@@@@passWord="+passWord+"@@@@@@@@@");
			conn=tj.getConnection();
			conn.setAutoCommit(false);
			String sql="select * from tb_userInfo where flag=0 and userId=? and passWord=?";
			ps = conn.prepareStatement(sql);
			ps.setInt(1,userId);
			ps.setString(2,passWord);
			rs = ps.executeQuery();
			int id=0;
			String realName=null;  //真实姓名
			int userRole=0; //角色
			int departID; //所属部门号
			String resume=null;  //自我简介
			if(rs!=null)
			{
				System.out.println("1$$$$$$$$$$$$$$$$$$$$$$$$$$$$44");
				LoginInfo loginInfo=new LoginInfo();
				flag=true;
				while(rs.next())
				{
					id=rs.getInt("ID");
					realName=rs.getString("REALNAME");
					departID=rs.getInt("DEPTID");
					Statement stmt=conn.createStatement();
					ResultSet rs1=stmt.executeQuery("select * from tb_user_actor where userid="+userId);
					while(rs1.next())
					{
						userRole=rs1.getInt("ACTORID");
					}
					//将登录用户的信息封装在LoginInfo类中
					loginInfo.setId(id);
					loginInfo.setDeptId(departID);
					loginInfo.setPassWord(passWord);
					loginInfo.setRealName(realName);
					loginInfo.setUserId(userId);
					loginInfo.setUserRole(userRole);
					session.setAttribute("LoginInfo", loginInfo);
				}
				
			}
			else
			{
				session.setAttribute("loginFlag", "false");
				System.out.println("2$$$$$$$$$$$$$$$$$$$$$$$$$$$$44");
			}
		    conn.commit();
		} catch (SQLException e) {
			
			try {
				if(conn!=null)
				{
					conn.rollback();//事务回滚
				}
			} catch (SQLException e1) {
				
				e1.printStackTrace();
			}
			e.printStackTrace();
		}
		finally
		{
			try {
				if(conn!=null)
				{
					conn.close();
				}
				if(ps!=null)
				{
					ps.close();
				}
				if(rs!=null)
				{
					rs.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return flag;
	}
	public boolean insertUser(UserInfo userInfo)
	{
		int i;
		boolean flag=false;
		try {
			conn = tj.getConnection();
			conn.setAutoCommit(false);
			String sqlInfo="insert into tb_userinfo values(userinfo_seq.nextval,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
			ps = conn.prepareStatement(sqlInfo);
			ps.setInt(1,userInfo.getUserId());
			ps.setString(2, userInfo.getPassWord());
			ps.setString(3, userInfo.getRealName());
			ps.setInt(4, userInfo.getDepartID());
			ps.setInt(5, userInfo.getUserSex());;
			ps.setString(6, userInfo.getUserBirth());
			ps.setString(7,userInfo.getUserNational());
			ps.setString(8, userInfo.getUserTel());
			ps.setString(9, userInfo.getUserDepTel());
			ps.setString(10, userInfo.getUserEmail());
			ps.setString(11, userInfo.getUserInterest());
			ps.setString(12, userInfo.getUserAddress());
			ps.setString(13, userInfo.getUserCode());
			ps.setString(14, userInfo.getUserPost());
			ps.setString(15, userInfo.getResume());
			ps.setInt(16, 0);
			ps.setInt(17, 0);
			i = ps.executeUpdate();
			if(i>0)
			{
				flag=true;
			}
		    conn.commit();
		} catch (SQLException e) {
			
			try {
				if(conn!=null)
				{
					conn.rollback();//事务回滚
				}
			} catch (SQLException e1) {
				
				e1.printStackTrace();
			}
			e.printStackTrace();
		}
		finally
		{
			try {
				if(conn!=null)
				{
					conn.close();
				}
				if(ps!=null)
				{
					ps.close();
				}
				if(rs!=null)
				{
					rs.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return flag;
	
	}
    
	
}