taskdao.java

这是一个基于大唐电信的一个任务管理模块程序

package com.datang.struts.dao;

import java.sql.Connection;
import java.sql.Date;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

import com.datang.struts.common.JspTaskCommon;
import com.datang.struts.dto.Task;
import com.datang.struts.dto.TaskPlan;
import com.datang.struts.form.OrderEmployeeInfoForm;
import com.datang.struts.form.OrderTaskForm;
import com.datang.struts.util.DbUtil;

public class TaskDAO {

	public int taskAdd(Task task) {
		DbUtil db = new DbUtil();
		Connection conn = db.getConnection();
		String sql = "insert into tang_task (task_id,task_name,task_start,task_end,clerk_id,task_description,task_state) values (seq_tang_task.nextval,'"
				+ task.getTask_name()
				+ "',to_date('"
				+ task.getTask_start()
				+ "','yyyy-MM-dd'),to_date('"
				+ task.getTask_end()
				+ "','yyyy-MM-dd'),'"
				+ task.getClerk_id()
				+ "','"
				+ task.getTask_description()
				+ "','"
				+ task.getTask_state()
				+ "')";

		try {
			Statement stat = conn.createStatement();
			stat.execute(sql);
			return JspTaskCommon.OK;
		} catch (SQLException e) {
			e.printStackTrace();
			return JspTaskCommon.ERROR;
		}

	}

	public List taskSel() {
		List list = new ArrayList();
		DbUtil db = new DbUtil();
		
		Connection conn = db.getConnection();
		String sql = "select * from tang_task";
		try {
			Statement stat = conn.createStatement();
			ResultSet rs = stat.executeQuery(sql);
			while (rs.next()) {
				Task task = new Task();
				task.setTask_id(rs.getInt("task_id"));
				task.setTask_name(rs.getString("task_name"));
				task.setClerk_id(rs.getString("clerk_id"));
				task.setTask_start(rs.getDate("task_start"));
				task.setTask_end(rs.getDate("task_end"));
				task.setTask_state(rs.getString("task_state"));
				list.add(task);		
			}	
				
				return list;
		} catch (SQLException e) {
			e.printStackTrace();
				return null;
		}
		
	}

	public List taskSel1() {
		List list = new ArrayList();
		DbUtil db = new DbUtil();
		
		Connection conn = db.getConnection();
		String sql = "select * from tang_task where task_state = 'notdo'";
		try {
			Statement stat = conn.createStatement();
			ResultSet rs = stat.executeQuery(sql);
			while (rs.next()) {
				Task task = new Task();
				task.setTask_id(rs.getInt("task_id"));
				task.setTask_name(rs.getString("task_name"));
				task.setClerk_id(rs.getString("clerk_id"));

				task.setTask_start(rs.getDate("task_start"));
				task.setTask_end(rs.getDate("task_end"));
				task.setTask_state(rs.getString("task_state"));
				list.add(task);
				
			}
				return list;
		} catch (SQLException e) {
			e.printStackTrace();
				return null;
		}
		
	}

	public int taskup(Task task) {
		DbUtil db = new DbUtil();
		Connection conn = db.getConnection();
		String sql = "update tang_task set task_start = to_date('"
				+ task.getTask_start() + "','yyyy-MM-dd'),task_end = to_date('"
				+ task.getTask_end() + "','yyyy-MM-dd'),clerk_id = '"
				+ task.getClerk_id() + "',task_description = '"
				+ task.getTask_description() + "',task_state = '"
				+ task.getTask_state() + "' where task_id = '"
				+ task.getTask_id() + "'";
		try {
			Statement stat = conn.createStatement();
			stat.executeUpdate(sql);
			return JspTaskCommon.OK;
		} catch (SQLException e) {
			e.printStackTrace();
			return JspTaskCommon.ERROR;
		}
	}

	public int taskdel(int task_id) {
		DbUtil db = new DbUtil();
		Connection conn = db.getConnection();
		// int task_id_del = Integer.parseInt(task.getTask_id());
		String sql = "delete tang_task where task_id =" + task_id;
				
		try {
			Statement stat = conn.createStatement();
			stat.execute(sql);
			return JspTaskCommon.OK;
		} catch (SQLException e) {
			e.printStackTrace();
			return JspTaskCommon.ERROR;
		}
	}

	public List taskInfoSel(int task_id) {
		List list = new ArrayList();
		DbUtil db = new DbUtil();
		
		Connection conn = db.getConnection();

		String sql = "select * from tang_task where task_id = "+ task_id;
				

		try {
			Statement stat = conn.createStatement();
			ResultSet rs = stat.executeQuery(sql);
			
			while (rs.next()) {
				Task task = new Task();
				task.setTask_id(rs.getInt("task_id"));
				task.setTask_name(rs.getString("task_name"));
				task.setTask_description(rs.getString("task_description"));
				task.setClerk_id(rs.getString("clerk_id"));
				task.setTask_start(rs.getDate("task_start"));
				task.setTask_end(rs.getDate("task_end"));
				task.setTask_state(rs.getString("task_state"));
				list.add(task);
			}
			return list;

		} catch (SQLException e) {
			e.printStackTrace();
			return null;
		}
		
	}

	public List taskPlanInfo(int task_id) {
		List list = new ArrayList();
		DbUtil db = new DbUtil();
		
		Connection conn = db.getConnection();
		String sql = "select * from tang_plan where task_id = "+ task_id;
				

		try {
			Statement stat = conn.createStatement();
			ResultSet rs = stat.executeQuery(sql);
			while (rs.next()) {
				TaskPlan taskplan = new TaskPlan();
				taskplan.setPlan_id(rs.getInt("plan_id"));
				taskplan.setTask_id(rs.getInt("task_id"));
				taskplan.setPlan_name(rs.getString("plan_name"));
				taskplan.setClerk_id(rs.getString("clerk_id"));
				taskplan.setPlan_start(rs.getDate("plan_start"));
				taskplan.setPlan_end(rs.getDate("plan_end"));
				taskplan.setPlan_state(rs.getString("task_state"));
				list.add(taskplan);
				}
			return list;
		} catch (SQLException e) {
			e.printStackTrace();
			return null;
		}
		
	}

	public List getChoiceTaskPlanInfo(int plan_id) {
		List list = new ArrayList();
		DbUtil db = new DbUtil();
		
		Connection conn = db.getConnection();
		String sql = "select tp.plan_name,tp.plan_description,tp.plan_start,tp.plan_end,tt.task_name,tp.plan_state,tp.plan_feedback_msg from tang_plan tp,tang_task tt where plan_id = "
				+ plan_id + " and tp.task_id = tt.task_id";
		try{
			Statement stat = conn.createStatement();
			ResultSet rs = stat.executeQuery(sql);
			while(rs.next()){
				TaskPlan taskplan = new TaskPlan();
				taskplan.setPlan_name(rs.getString("plan_name"));
				taskplan.setPlan_description(rs.getString("plan_description"));
				taskplan.setPlan_start(rs.getDate("plan_start"));
				taskplan.setPlan_end(rs.getDate("plan_end"));
				taskplan.setTask_name(rs.getString("task_name"));
				taskplan.setPlan_state(rs.getString("plan_state"));
				taskplan.setPlan_feedback_msg(rs.getString("plan_feedback_msg"));
				list.add(taskplan);
			}
			return list;
		}catch(SQLException e){
			e.printStackTrace();
			return null;
		}
	}

}