busstaskmanager.java

一个小公司要求给写的很简单的任务管理系统。

package com.wykj.buss;

import java.util.*;
import java.sql.*;
import com.wykj.model.*;
import com.wykj.database.*;
import com.wykj.util.*;

public class BussTaskManager {
  public BussTaskManager() {
  }

  Connection conn = null;
  Statement stmt = null;
  ResultSet rset = null;

  public ArrayList getTaskList(String userName, String date) {
    return getTaskList(userName,date,date);
  }
  public ArrayList getTaskList(String userName,String date,String dateE){
    ArrayList list = new ArrayList();
   Statement stmt = null;
   ResultSet rset = null;
   try {
     conn = new ConnectDB().getConnection();
     stmt = conn.createStatement();
     String sql = "select * from 任务表 where 1=1 ";
     if (userName != null && userName.length() > 0) {
       sql += "and 责任人='" + userName + "'";
     }
     if (date != null && date.length() > 0) {
       sql += "  and 日期 between #" + date + "# and #"+dateE+"#";
     }
     sql += "  order by 日期,责任人";
     System.out.println("getTaskList sql==="+sql);
     rset = stmt.executeQuery(sql);
     while (rset.next()) {
       RwbModel rm = new RwbModel();
       rm.setId(rset.getString(1));
       rm.setRq(rset.getDate(2));
       rm.setAddUser(rset.getString(3));
       rm.setTaskContent(rset.getString(4));
       rm.setTaskEndR(rset.getString(5));
       rm.setTaskEff(rset.getString(6));
       rm.setReportType(rset.getString(7));
       rm.setTaskEnd(rset.getString(8));
       rm.setTaskCheck(rset.getString(9));
       rm.setTaskResult(rset.getString(10));
       rm.setPrize(rset.getString(11));
       rm.setOtherfactor(rset.getString(12));
       list.add(rm);
     }
   }
   catch (Exception ex) {
     ex.printStackTrace();
     System.out.print("BussUserManager.getUserList 读取任务表错误！");
   }
   finally {
     release();
   }
   return list;

  }

  public String addTasks(ArrayList array) {
    String resultStr = "成功添加任务";
    if (array == null || array.isEmpty()) {
      resultStr = "没有需要添加的任务";
    }
    else {
      try {
        conn = new ConnectDB().getConnection();
        Statement stmt = conn.createStatement();
        for (int i = 0; i < array.size(); i++) {
          RwbModel rm = (RwbModel) array.get(i);
          String sql =
              "insert into 任务表 (日期,责任人,任务描述,预计完成时间,影响因素,上报形式,实际完成时间,检查人,完成效果,奖惩,其他)";
          sql += "values ( ";
          sql += "'" + Util.trimNull(rm.getRqStr()) + "',";
          sql += "'" + Util.trimNull(rm.getAddUser()) + "',";
          sql += "'" + Util.trimNull(rm.getTaskContent()) + "',";
          sql += "'" + Util.trimNull(rm.getTaskEndR()) + "',";
          sql += "'" + Util.trimNull(rm.getTaskEff()) + "',";
          sql += "'" + Util.trimNull(rm.getReportType()) + "',";
          sql += "'" + Util.trimNull(rm.getTaskEnd()) + "',";
          sql += "'" + Util.trimNull(rm.getTaskCheck()) + "',";
          sql += "'" + Util.trimNull(rm.getTaskResult()) + "',";
          sql += "'" + Util.trimNull(rm.getPrize()) + "',";
          sql += "'" + Util.trimNull(rm.getOtherfactor()) + "'";
          sql += ") ";
          stmt.execute(sql);
        }
      }
      catch (Exception ex) {
        ex.printStackTrace();
        System.out.print("BussUserManager.getUserList 添加任务表错误！");
      }
      finally {
        release();
      }

    }

    return resultStr;
  }
  public ArrayList getTaskListSort(String userName, String date) {
    return getTaskListSort(userName,date,date);
  }
  public ArrayList getTaskListSort(String userName, String date,String dateE) {
    ArrayList list = new ArrayList();
    Statement stmt = null;
    ResultSet rset = null;
    Hashtable hash = new Hashtable();
    try {
      conn = new ConnectDB().getConnection();
      stmt = conn.createStatement();
      String sql = "select * from 任务表 where 1=1 ";
      if (userName != null && userName.length() > 0) {
        sql += "and 责任人='" + userName + "'";
      }
      if (date != null && date.length() > 0) {
        sql += "  and 日期 between #" + date + "# and #"+dateE+"#";
      }
      System.out.println("getTaskListSort=="+sql);
      sql += "  order by 日期,责任人";
      rset = stmt.executeQuery(sql);
      System.out.println("rset=="+rset);
      while (rset.next()) {
        RwbModel rm = new RwbModel();
        rm.setId(rset.getString(1));
        rm.setRq(rset.getDate(2));
        rm.setAddUser(rset.getString(3));
        rm.setTaskContent(rset.getString(4));
        rm.setTaskEndR(rset.getString(5));
        rm.setTaskEff(rset.getString(6));
        rm.setReportType(rset.getString(7));
        rm.setTaskEnd(rset.getString(8));
        rm.setTaskCheck(rset.getString(9));
        rm.setTaskResult(rset.getString(10));
        rm.setPrize(rset.getString(11));
        rm.setOtherfactor(rset.getString(12));
        if (hash.containsKey(rm.getAddUser())) {
          ( (ArrayList) hash.get(rm.getAddUser())).add(rm);
        }
        else {
          ArrayList a = new ArrayList();
          a.add(rm);
          hash.put(rm.getAddUser(), a);
          list.add(a);
        }
      }
    }
    catch (Exception ex) {
      System.out.print("BussUserManager.getUserList 读取任务表错误！");
    }
    finally {
      release();
    }
    return list;
  }
  public String delTask(String id) {
    String resultStr = "";
     try {
       conn = new ConnectDB().getConnection();
       Statement stmt = conn.createStatement();
         String sql =
             "delete from 任务表 where 记录编号="+id+"";
         System.out.println(sql);
         stmt.executeUpdate(sql);
     }
     catch (Exception ex) {
       ex.printStackTrace();
       System.out.print("BussUserManager.getUserList 添加任务表错误！");
     }
     finally {
       release();
     }
   return resultStr;
 }
 public String updateTasks(ArrayList array) {
   String resultStr = "成功添加任务";
   if (array == null || array.isEmpty()) {
     resultStr = "没有需要添加的任务";
   }
   else {
     try {
       conn = new ConnectDB().getConnection();
       Statement stmt = conn.createStatement();
       for (int i = 0; i < array.size(); i++) {
         RwbModel rm = (RwbModel) array.get(i);
         String sql =
             "update 任务表 set ";

             sql+="日期='"+Util.trimNull(rm.getRqStr())+"',";
              sql+="责任人='"+Util.trimNull(rm.getAddUser())+"',";
              sql+="任务描述='"+Util.trimNull(rm.getTaskContent())+"',";
              sql+="预计完成时间='"+Util.trimNull(rm.getTaskEndR())+"',";
              sql+="影响因素='"+Util.trimNull(rm.getTaskEff())+"',";
              sql+="上报形式='"+Util.trimNull(rm.getReportType())+"',";
              sql+="实际完成时间='"+Util.trimNull(rm.getTaskEnd())+"',";
              sql+="检查人='"+Util.trimNull(rm.getTaskCheck())+"',";
              sql+="完成效果='"+Util.trimNull(rm.getTaskResult())+"',";
              sql+="奖惩='"+Util.trimNull(rm.getPrize())+"',";
              sql+="其他='"+Util.trimNull(rm.getOtherfactor())+"'";
              sql += " where 记录编号="+rm.getId()+"";
 System.out.println(sql);
         stmt.execute(sql);
       }
     }
     catch (Exception ex) {
       ex.printStackTrace();
       System.out.print("BussUserManager.getUserList 更新任务表错误！");
     }
     finally {
       release();
     }

   }

   return resultStr;
 }

  private void release(){
    try {
          if (rset != null) rset.close();
        }
        catch (Exception ex) {
        }
        try {
          if (stmt != null) stmt.close();
        }
        catch (Exception ex) {

        }
        try {
          if (conn != null) conn.close();
        }
        catch (Exception ex) {
        }

  }

}