departmentaddmodel.java

eclipse java/jsp 航空管理系统

/**
 *<p>application name:        DepartmentAddModel.java</p>
 *<p>application describing:  this class handles the requesst
 *                            of the client that will operate 
 *                            the addaction
 *<p>copyright :              Copyright  东软 国际合作事业部版权所有</p>
 *<p>company:                 neusoft</p>
 *<p>time:                    2005.04.19</p>
 * @author:                   尹超
*/

package yinchao.model;
import java.sql.*; 
import java.util.Date;
import java.text.DateFormat;
import yinchao.form.DepartmentAddForm;
import yinchao.ConnectionPool.DbConnection;
import zhangchunliang.model.AppMode;

import org.apache.log4j.Logger;



/**
 * 处理部门的添加操作的Model
 * @author    尹超   
 * @version   1.0， 2005/04/19
 */

public class DepartmentAddModel 
{ 
	
    public DepartmentAddModel(){}
    
    /** 用户操作日志记录器 */
    static Logger userOperation = Logger.getLogger("userOperation");
    
    /** 用户异常日志记录器 */
    static Logger userError = Logger.getLogger("userError");

    

	
/**处理从表单中获得的汉字以免出现乱码方法是书上的*/
	 
	public String convert(String s) 
	{
        try 
		{   
        	s = "\"" + s + "\""; 
        byte b[]=s.getBytes("ISO-8859-1");
            s=new String(b);
            return s;
        } catch(Exception e) 
		{
            return s;
        }
    }
	
	/*
	 * name:   生成系统时间
	 * 静态方法 不用事例化直接调用 属于类方法
	 */
	public static String nowDate() {
		/** 系统时间变量 */
		Date nowdate = new Date();

		/** 格式化后时间变量 */
		String formatDate;

		/** 格式化为"YYYY-MM-DD" */
		formatDate = DateFormat.getDateInstance().format(nowdate);
		return formatDate;
	}

	/*生成系统时间*/
	String insert_date = convert(nowDate());

	/*生成系统时间*/
	String update_date = convert(nowDate());
	
    /**
     * 
     * 对depart做添加的方法
     *
     */
	
   public int addRecordModel(DepartmentAddForm departmentaddform)throws Exception, SQLException{
   	
   	AppMode.registerUser();
    
      /*获得FORM里的参数*/
        /**存放从form中得到的转换后的部门号*/
   	  String depno;
   	    /**存放从form中得到的转换后的部门名*/
   	  String depname;
   	    /**存放从form中得到的转换后的部门负责人*/
   	  String depleader;
   	    /**存放从form中得到的转换后的部门电话*/
   	  int deptel;
   	  /**存放从form中得到的转换后的部门工资*/
   	  int depsalary;
   	   /**存放对数据库进行操作的人的id*/
   	  String insertuser_id;
   	   /**存放对数据库进行操作的时间*/
   	  String insertuser_date;
   	  String[]groupNo = departmentaddform.getGroupNo();
   	  int k = groupNo.length;
   	  System.out.println(k);
   	  //得到转换后的数据
      depno=departmentaddform.getDepno();
  	  depname=convert(departmentaddform.getDepname());
     depleader=convert(departmentaddform.getDepleader());
  	  deptel=Integer.parseInt(departmentaddform.getDeptel());
  	  depsalary=Integer.parseInt(departmentaddform.getDepsalary());
  
   	
   	   /** 
        * 连接数据库操作操作
        */
   	     
   	     /** 连接数据库变量 */
     DbConnection db=null;
     Connection con=null;

         /** SQL语句执行变量 */
       Statement sql;
          /** SQL语句操作的结果集 */
       ResultSet rs;
       ResultSet rstmp1;
       ResultSet rstmp2;
        /** 
         * 执行SQL语句操作
         * @return 1:           表示成功
         * @return return 2:    表示失败
         * @throws Exception    没有配置MySQL数据库驱动
         * @throws SQLException SQL语句错误 
         */
        /**将转变后的部门号转变成整形*/
      	
        int depnum= Integer.parseInt(depno); 
        System.out.println(depnum);
          /** s1,s2:SQL语句字符串 */
         String s1 = "INSERT INTO depart"
         	                  + "(depno,depname,"
							  +"depleader,deptel,"
							  +"depsalary,insert_date)";
         String  s2 ="VALUES ( "
         	                  +depnum+"," 
							  + depname +","
							  + depleader + "," 
							  + deptel +","  
							  + depsalary + ","
							  + insert_date+")";
        
         System.out.println(s1+s2);
       
        try
		{
        	/**部门号是否存在,
        	 * 存在则返回3
        	 * 提示部门号已经存在的错误
        	 */
        	db=new DbConnection();
            con=db.getCon();
			sql = con.createStatement();
            rstmp1=sql.executeQuery("select count(*) as mycount1 from depart where depno="+depnum);
            rstmp1.next();
         //记录查询出来的部门号的个数
         int i=rstmp1.getInt("mycount1");

     	/**部门名是否存在,
     	 * 存在则返回3
     	 * 提示部门名已经存在的错误
     	 */
        
          rstmp2=sql.executeQuery("select count(*) as mycount2 from depart where depname="+depname);
          rstmp2.next();
         
      
         //记录查询出来的部门名的个数
          int j=rstmp2.getInt("mycount2");
         	
         if((i!=0||j!=0))   
         {
         
         	AppMode.loginoutUser();
         	return 3;
         }else
         {
         	//如果上述没有错则执行添加的操作返回1到执行正确页面
         	 
        for(int d =0;d < k;d++){
        
         sql.executeUpdate("INSERT INTO deptable"
                + "(depno,tablename)"+"VALUES ( "+depnum+"," +"\""+groupNo[d]+"\""+")");
         System.out.println(groupNo[d]);
        
        }
  
        sql.executeUpdate(s1+s2);
         if(userOperation.isInfoEnabled()){
        	/** 记录用户操作日志：添加组 */
            userOperation.info(" 操作：部门添加 " + depname 
            			+ "结果:成功");
        }
         
         AppMode.loginoutUser();
         
         return 1;
         } 
       }catch (SQLException e2)
	   {
       	
       	AppMode.loginoutUser();
       	
       	//如果添加语句有错则返回2，跳专到错误页面
       	System.out.println(e2.getMessage());
       	userError.error("部门添加错误：添加的SQL语句执行错误");
        return 2;
   }
   
		}
   }