appendbean.java

eclipse java/jsp 航空管理系统

/*
 * Copyright Neusoft Dalian Center,All Rights Reserved
 *
 * WEB Application Apply Struts Platform
 * 
 * PackageName shengjb.model
 * ClassName AppendBean.java
 *
 * @author shengjb  | [e-mail]
 *
 * Created on 2005-4-15
 *
 */
package shengjb.model;

import java.sql.Connection; 
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.ResultSet;

import org.apache.log4j.Logger;
import java.util.StringTokenizer;

import kangyi.ConnectionPool.DbConnection;

import shengjb.form.AppendForm;
import zhangchunliang.model.AppMode;

/**
 * AppendnBean BeanClass
 * 
 * @author shengjb ver.0.7
 */
public class AppendBean {
	
	 /** 用户操作日志记录器 */
    static Logger userOperation = Logger.getLogger("userOperation");
    
    /** 用户异常日志记录器 */
    static Logger userError = Logger.getLogger("userError");

    /** 系统调试日志记录器 */
    static Logger systemDebug = Logger.getLogger(AppendBean.class);

	/**
	 * load MySQL database driver
	 */
	//public AppendBean(){
	//	try{
    //        Class.forName("com.mysql.jdbc.Driver");   
    //    }
    //    catch(ClassNotFoundException e){
    //        e.getMessage();
    //        userError.error("数据库驱动没有配置");
    //    }
	//}

	/**
     * name:         转换字符串方法
     * Description:  把屏幕上获取的中文字符串正确的传入MODEL中
     * @return       Str 转换完的字符串 
     */
    public String convert(String s){
        String str=s;
        try{
            byte b[]=str.getBytes("ISO-8859-1");
            str=new String(b);
            return str;
        }
        catch(Exception e){
            return str;
        }
    }
    
    /**
     * name:         转换字符数组方法
     * Description:  把接受到的组号的字符数组中的各字符中间追加一个分号并转换成字符串
     * @return       s 转换完的字符串 
     */
    public String convertGroupNo(String[]sss){
    	String s;
    	StringBuffer ss = new StringBuffer(200);
    	//String[] strss = sss;
    	for(int i=0 ; i < sss.length ; i++){
    		ss.append(sss[i]);
    		ss.append(";");
    	}
    	s = ss.toString();
    	System.out.println(s);
    	return s;
    }
	/**
	 * insert a record to database
	 */
	public String append(AppendForm appendForm){
		
		AppMode.registerUser();
		
		/* 连接 database*/
		//StringBuffer conSql = new StringBuffer(500);
        //conSql.append("jdbc:mysql://192.168.219.148/ciqms?user=");
        //conSql.append("shengjb");
        //conSql.append("&password=");
        //conSql.append("sunny");
        //conSql.append("&useUnicode=true&characterEncoding=GBK");
        //String conmysql=conSql.toString();
		DbConnection db=null;
        Connection con = null;
        Statement sql = null;
        ResultSet rs = null;
        ResultSet rs1 = null;
        ResultSet rs2 = null;
        
        /*在AppendAction中根据此变量进行跳转*/
        String info = null;
        
        /*获得AppendForm里的userID并转换成字符串*/
        String userID = appendForm.getUserID();
		userID = convert(userID);
		
		/*获得AppendForm里的userName并转换成字符串*/
		String userName = appendForm.getUserName();
		userName = convert(userName);
		
		/*获得AppendForm里的password并转换成字符串*/
		String password = appendForm.getPassword();
		password = convert(password);
		
		/*获得AppendForm里的groupNo并转换成字符串*/
		String[]groupNo = appendForm.getGroupNo();
		String convertGroupNo = convertGroupNo(groupNo);
		
		/*获得AppendForm里的departmentNo并转换成字符串*/
		String departmentNo = appendForm.getDepartmentNo();
		departmentNo = convert(departmentNo);
		
		try{
			/*获取数据库连接*/
			db=new DbConnection();
            con=db.getCon();
		    sql=con.createStatement();
		    /*查询stuff表中是否已经存在sid等于userID的记录*/
		    String condition = "SELECT COUNT(*)FROM stuff WHERE sid = '"+userID+"'";
		    /*返回可滚动的结果集*/
		    rs = sql.executeQuery(condition);
		    /* 记录用户操作日志：查询用户输入的sid是否已经存在 */
            userOperation.info("userId:" + userID+ " ，操作：查询是否已存在sid为" + userID 
            			+ "的记录，结果:成功");
		    /*游标向下移一位*/
		    rs.next();
		    /*将结果集转化为整形赋给i,当 i != 0 时表明已存在sid = userID 的记录*/
		    int i = rs.getInt(1);
		    
		    /* 用StringTokenizer方法来将字符串区分开，存入feixi对象中 */
			StringTokenizer fenxi = new StringTokenizer(convertGroupNo, ";");
			while (fenxi.hasMoreTokens()){
				String s = fenxi.nextToken();
				if ((s.equals("1")||s.equals("2"))&& convertGroupNo.length()>2){
					return info = "adminothererror";
				   }
				}
			
		    	if(i != 0){
		    	userError.error("userId:"+userID+",用户添加错误：该用户ID已存在");
		    	/*当用户ID重复时，返回提示信息*/
		        return info ="sidrepeation";
		    	}else{
		    	String condition1 = "INSERT INTO stuff"+"(sid,sname,password,groupstring,depno)"; 
		    	String condition2 = "VALUES (" + userID + ",'" + userName + "','" + password + "'," +
		    			                   "'" + convertGroupNo +"'," + departmentNo + ")";
		    	/*执行INSERT操作*/
		    	sql.executeUpdate(condition1+condition2);
		    	/** 记录用户操作日志：添加用户 */
	            userOperation.info("userId:"+userID+", 操作：添加组,结果:成功");
		    	/*返回操作成功信息*/
		    	return info = "appendsuccess";
		    }
		   
	    }catch(SQLException se){
            System.out.print("操作失败");
            userError.error("userId:"+userID+",用户添加错误：用户添加SQL语句执行错误");
            /*返回操作失败信息*/
            return info = "appendfaile";
        }finally{
        	
        	AppMode.loginoutUser();
        	
     	    try{
   		        sql.close();
   		        con.close();
   		        rs.close();
   		        rs1.close();
   		        rs2.close();
   	       }catch(Exception e){}
        }
	}
}