roledaoimpl.java

基于Java的地图数据管理软件。使用MySQL数据库管理系统。

/* 创建日期：Dec 10, 2006
 * 作　　者：朱　闰
 * 公　　司：安徽通途信息技术有限公司
 */

package com.tongtu.Dao.role.roleDao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.tongtu.Dao.role.RoleDAO;
import com.tongtu.comm.sql.DBOperator;
import com.tongtu.util.City;
import com.tongtu.util.County;
import com.tongtu.util.CurrentUser;
import com.tongtu.util.PlanDetail;
import com.tongtu.util.RoleInfo;
import com.tongtu.util.Town;
import com.tongtu.util.UserInfo;
import com.tongtu.util.UserRole;
import com.tongtu.util.Village;

public class RoleDAOImpl implements RoleDAO{

	/**
	 * 添加角色
	 */
	public boolean addRole(RoleInfo ri) {
		DBOperator dbo = new DBOperator();
		String query = "insert into tt_role(roleName,privilege,createTime) values('";
		query += ri.getRoleName() + "','";
		query += ri.getPrivilege()+ "',curdate())";
		try {
			System.out.println(query);
			dbo.setPrepareStatement(query);
			dbo.executeUpdate();
			CurrentUser.saveLog(query); //保存当前用户操作记录
			return true;
		} catch (Exception e) {
		} finally {
			dbo.close();
		}
		return false;
	}

	/**
	 * 获取角色列表
	 */
	public List getRoleList() {
		DBOperator dbo = new DBOperator();
		List roleList = new ArrayList();
		try {
			String sqlStr = "select * from tt_role ";
			System.out.println(sqlStr);
			dbo.setPrepareStatement(sqlStr);
			ResultSet rs = dbo.executeQuery();
			while (rs.next()) {
				RoleInfo ri = new RoleInfo();
				ri.setRoleName(rs.getString("roleName"));
				ri.setRoleId(rs.getInt("roleId"));
				ri.setPrivilege(rs.getString("privilege"));
				ri.setCreateTime(rs.getDate("createtime"));
				roleList.add(ri);
			}
			rs.close();
			//CurrentUser.saveLog(sqlStr); //保存当前用户操作记录
			return roleList;
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			dbo.close();
		}
		return null;
	}

	/**
	 * 更新角色信息
	 */
	public boolean updateRoleInfo(RoleInfo ri, int roleId) {
		DBOperator dbo = new DBOperator();
		String query = " update tt_role set rolename = '";
		      query += ri.getRoleName() + "',privilege = '";
		      query += ri.getPrivilege() + "',modifiedTime =";
		      query += "curdate() where roleId = " + roleId;
		try {
			System.out.println(query);
			dbo.setPrepareStatement(query);
			dbo.executeUpdate();
			CurrentUser.saveLog(query); //保存当前用户操作记录
			return true;
		} catch (Exception e) {
		} finally {
			dbo.close();
		}
		return false;
	}

	/**
	 * 根据角色ID删除角色信息
	 */
	public boolean deleteRoleById(int roleId) {
		DBOperator dbo = new DBOperator();
		String query = " delete from tt_role where roleId=" + roleId;
		try {
			dbo.setPrepareStatement(query);
			dbo.executeUpdate();
			//CurrentUser.saveLog(query); //保存当前用户操作记录
			return true;
		} catch (Exception e) {

		} finally {
			dbo.close();
		}
		return false;
	}

	/**
	 * 添加用户角色
	 */
	public boolean addUserRole(UserRole ur) {
		DBOperator dbo = new DBOperator();
		String query = "insert into tt_userrole(roleId,userId,createTime) values(";
		query += ur.getRoleId() + ",";
		query += ur.getUserId() + ",";
		query +=  "curdate())";
		try {
			System.out.println(query);
			dbo.setPrepareStatement(query);
			dbo.executeUpdate();
			//CurrentUser.saveLog(query); //保存当前用户操作记录
			return true;
		} catch (Exception e) {
		} finally {
			dbo.close();
		}
		return false;
	}

	/**
	 * 根据用户ID删除用户对应的角色
	 */
	public boolean delUserRoleByUser(int userId) {
		DBOperator dbo = new DBOperator();
		String query = " delete from tt_userrole where userid=" + userId;
		try {
			dbo.setPrepareStatement(query);
			dbo.executeUpdate();
			//CurrentUser.saveLog(query); //保存当前用户操作记录
			return true;
		} catch (Exception e) {

		} finally {
			dbo.close();
		}
		return false;
	}

	/**
	 * 判断角色名是否重复
	 */
	public int IsHasRoleName(String roleName) {
		DBOperator dbo = new DBOperator();
		int isHas = 0;
		try {
			String sqlStr = "select count(roleId) as maxInt from tt_role where roleName = '" + roleName + "'";
			System.out.println(sqlStr);
			dbo.setPrepareStatement(sqlStr);
			ResultSet rs = dbo.executeQuery();
			while (rs.next()) {
				isHas = rs.getInt("maxInt");
			}
			rs.close();
			return isHas;
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			dbo.close();
		}
		return 0;
	}

	/**
	 * 根据用户ID获取角色列表
	 */
	public List getUserRoleList(int userId) {
		DBOperator dbo = new DBOperator();
		List roleList = new ArrayList();
		try {
			String sqlStr = "select * from tt_userrole where userId=" + userId;
			System.out.println(sqlStr);
			dbo.setPrepareStatement(sqlStr);
			ResultSet rs = dbo.executeQuery();
			while (rs.next()) {
				UserRole ri = new UserRole();
			    ri.setRoleId(rs.getInt("roleId"));
			    ri.setUserId(rs.getInt("userId"));
				roleList.add(ri);
			}
			rs.close();
			//CurrentUser.saveLog(sqlStr); //保存当前用户操作记录
			return roleList;
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			dbo.close();
		}
		return null;
	}

	public String getPrivileById(int userId) {
		DBOperator dbo = new DBOperator();
		List roleList = new ArrayList();
		String privilStr = new String();
		try {
			String sqlStr = "select a.privilege from tt_role a,tt_userrole b where a.roleId=b.roleid and b.userId=" + userId;
			System.out.println(sqlStr);
			dbo.setPrepareStatement(sqlStr);
			ResultSet rs = dbo.executeQuery();
			while (rs.next()) {
		    roleList.add(rs.getString("privilege"));
			}
			rs.close();
			//CurrentUser.saveLog(sqlStr); //保存当前用户操作记录
		
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			dbo.close();
		}
		for (int i = 0; roleList != null&&i<roleList.size();i++){
			 String priStr = (String)roleList.get(i);
			 privilStr += priStr;
		}
		return privilStr;
	}

	public int IsHasUserLink(int roleId) {
		DBOperator dbo = new DBOperator();
		int isHas = 0;
		try {
			String sqlStr = "select count(userId) as maxInt from tt_userrole where roleid =" + roleId + "";
			System.out.println(sqlStr);
			dbo.setPrepareStatement(sqlStr);
			ResultSet rs = dbo.executeQuery();
			while (rs.next()) {
				isHas = rs.getInt("maxInt");
			}
			rs.close();
			return isHas;
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			dbo.close();
		}
		return 0;
	}

	public RoleInfo getRoleInfo(int roleId) {
		DBOperator dbo = new DBOperator();
		try {
			String sqlStr = "select * from tt_role where roleId=" + roleId;
			System.out.println(sqlStr);
			RoleInfo ri = new RoleInfo();
			dbo.setPrepareStatement(sqlStr);
			ResultSet rs = dbo.executeQuery();
			while (rs.next()) {
			
				ri.setRoleName(rs.getString("roleName"));
				ri.setRoleId(rs.getInt("roleId"));
				ri.setPrivilege(rs.getString("privilege"));
				ri.setCreateTime(rs.getDate("createtime"));
			}
			rs.close();
			//CurrentUser.saveLog(sqlStr); //保存当前用户操作记录
			return ri;
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			dbo.close();
		}
		return null;
	}

	public String getTownCode(String townName ,String code) {
		DBOperator dbo = new DBOperator();
		String townCode = "";
		int rowCount = 0;
		try {
			String sqlStr = "select townCode from tt_town where (townName like '%" + townName + "%' or LOCATE(townname,'" + townName + "') <>0 ) and left(townCode,6)='" + code +  "'";
			System.out.println(sqlStr);
			dbo.setPrepareStatement(sqlStr);
			ResultSet rs = dbo.executeQuery();