taskmanagerserviceimpl.java

大唐电信的管理系统

package task.business;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import task.domain.Task;

public class TaskManagerServiceImpl implements TaskManagerService {

	public static final String table_employee = "t_employee";

	public static final String table_user = "t_user";

	public static final String table_task = "t_task";

	public static final String c_employee_id = "id";

	public static final String c_employee_name = "name";

	public static final String c_employee_password = "password";

	public static final String c_employee_birthday = "birthday";

	public static final String c_employee_position = "position";

	public static final String c_employee_hire_date = "hire_date";

	public static final String c_employee_manager_id = "manager_id";

	public static final String c_employee_experience = "experience";

	public static final String c_employee_major = "major";

	public static final String c_degree = "degree";

	public static final String c_task_id = "id";

	public static final String c_task_name = "name";

	public static final String c_task_description = "description";

	public static final String c_task_start = "start";

	public static final String c_task_end = "end";

	public static final String c_task_exp_start = "exp_start";

	public static final String c_task_exp_end = "exp_end";

	public static final String c_task_manager_id = "manager_id";

	public static final String c_task_clerk_id = "clerk_id";

	public static final String c_task_state = "state";

	public static final String sql_addTask = "insert into " + table_task + "("
			+ c_task_name + "," + c_task_description + "," + c_task_exp_start
			+ "," + c_task_exp_end + "," + c_task_manager_id + ","
			+ c_task_clerk_id + "," + c_task_state + ") "
			+ "values(?,?,?,?,?,?,?)";

	public static final String sql_getClerkIdName = "select " + c_employee_id
			+ "," + c_employee_name + " from " + table_employee + " where "
			+ table_employee + "." + c_employee_manager_id + "=?";

	public static final String sql_getTask = "select * from " + table_task
			+ " where " + c_task_manager_id + "=? and " + c_task_state + "=?";

	public static final String sql_getTaskForClerk = "select * from "
			+ table_task + " where " + c_task_clerk_id + "=? and "
			+ c_task_state + "=?";

	public static final String sql_validateUser = "select count(*) from "
			+ table_employee + " where " + c_employee_id + "=? and "
			+ c_employee_password + "=? and " + c_employee_position + "=?";

	public void addTask(Task task) throws Exception {
		Connection con = null;
		try {
			con = ConnectionFactory.getConnection();
			PreparedStatement stmt = con.prepareStatement(sql_addTask);
			stmt.setString(1, task.getName());
			stmt.setString(2, task.getDescription());
			stmt.setDate(3, new java.sql.Date(task.getExpStart().getTime()));
			stmt.setDate(4, new java.sql.Date(task.getExpStart().getTime()));
			stmt.setString(5, task.getManagerId());
			stmt.setString(6, task.getClerkId());
			stmt.setString(7, task.getState());
			stmt.executeUpdate();
			ConnectionFactory.close(stmt);
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		} finally {
			ConnectionFactory.close(con);
		}
	}

	public Map<String, String> getClerkIdName(String managerId)
			throws Exception {
		HashMap<String, String> map = new HashMap<String, String>();
		Connection con = null;
		try {
			con = ConnectionFactory.getConnection();
			PreparedStatement stmt = con.prepareStatement(sql_getClerkIdName);
			stmt.setString(1, managerId);
			ResultSet rs = stmt.executeQuery();
			while (rs.next()) {
				map.put(rs.getString(1), rs.getString(2));
			}
			ConnectionFactory.close(rs);
			ConnectionFactory.close(stmt);
			return map;
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		} finally {
			ConnectionFactory.close(con);
		}
	}

	public List<Task> getTask(String managerId, String state) throws Exception {
		Connection con = null;
		try {
			con = ConnectionFactory.getConnection();
			PreparedStatement stmt = con.prepareStatement(sql_getTask);
			stmt.setString(1, managerId);
			stmt.setString(2, state);
			ResultSet rs = stmt.executeQuery();
			List<Task> list = toTask(rs);
			ConnectionFactory.close(rs);
			ConnectionFactory.close(stmt);
			return list;
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		} finally {
			ConnectionFactory.close(con);
		}
	}

	public List<Task> getTaskForClerk(String clerkId, String state)
			throws Exception {
		Connection con = null;
		try {
			con = ConnectionFactory.getConnection();
			PreparedStatement stmt = con.prepareStatement(sql_getTaskForClerk);
			stmt.setString(1, clerkId);
			stmt.setString(2, state);
			ResultSet rs = stmt.executeQuery();
			List<Task> list = toTask(rs);
			ConnectionFactory.close(rs);
			ConnectionFactory.close(stmt);
			return list;
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		} finally {
			ConnectionFactory.close(con);
		}
	}

	public boolean validateUser(String user, String password, String role)
			throws Exception {
		Connection con = null;
		try {
			con = ConnectionFactory.getConnection();
			PreparedStatement stmt = con.prepareStatement(sql_validateUser);
			stmt.setString(1, user);
			stmt.setString(2, password);
			stmt.setString(3, role);
			ResultSet rs = stmt.executeQuery();
			boolean b = false;
			if (rs.next()) {
				int n = rs.getInt(1);
				if (n == 1) {
					return true;
				}
			}
			ConnectionFactory.close(rs);
			ConnectionFactory.close(stmt);
			return b;
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		} finally {
			ConnectionFactory.close(con);
		}
	}

	private List<Task> toTask(ResultSet rs) throws Exception {
		ArrayList<Task> list = new ArrayList<Task>();
		while (rs.next()) {
			Task task = new Task();
			task.setId(rs.getInt(c_task_id));
			task.setName(rs.getString(c_task_name));
			task.setDescription(c_task_description);
			task.setExpStart(rs.getDate(c_task_exp_start));
			task.setExpEnd(rs.getDate(c_task_exp_end));
			task.setStart(rs.getDate(c_task_start));
			task.setEnd(rs.getDate(c_task_end));
			task.setManagerId(rs.getString(c_task_manager_id));
			task.setClerkId(rs.getString(c_task_clerk_id));
			task.setState(rs.getString(c_task_state));
			list.add(task);
		}
		return list;
	}

}