defaultgroup.java

eclipse java/jsp 航空管理系统

package kangyi.model;

import java.sql.*;
import java.util.Date;
import java.text.DateFormat;

import javax.servlet.http.HttpServletRequest;

import zhangchunliang.model.AppMode;


import kangyi.form.DefaultGroupForm;
import kangyi.ConnectionPool.DbConnection;

/**
 * <p>Description  :  国家和城市数据字典中所有对数据库的操作 </p>
 * <p>Project      :  ciqms
 * <p>Company      :  东软股份国际合作事业部</p>
 * <p>Create Date  :  2005.4.17</P>
 * @author         :  康毅 | [e-mail]
 * @version        :  0.3
 * @see            :  kangyi.form.DefaultGroupForm
 */


public class DefaultGroup {

	/**
	 * 
	 * @uml.property name="db"
	 * @uml.associationEnd multiplicity="(0 1)"
	 */
	DbConnection db = null;

    Connection con=null; 
    
    /*
     * name:         转换字符串方法
     * Description:  把屏幕上获取的中文字符串正确的传入MODEL中
     * @return       Str 转换完的字符串 
     */
    public String change(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:   生成系统时间
     * 静态方法 不用事例化直接调用 属于类方法
     * @add by qujl@neusoft
     */
    public static String nowDate() {
        /** 系统时间变量 */
        Date nowdate = new Date();
        
        /** 格式化后时间变量 */ 
        String formatDate; 
        
        /** 格式化为"YYYY-MM-DD" */
        formatDate = DateFormat.getDateInstance().format(nowdate);
        return formatDate;
    }
    /*生成系统时间*/
    String insert_date=nowDate();
    /*生成系统时间*/
    String update_date=nowDate();
    
    /*
     * name:         admin组和other组成员
     * describing:   查询数据库中admin组，other组成员个数
     * @return       Stringbuffer 在JSP上直接显示一个表格
     */
    public StringBuffer defaultSelect(){
    	
    	AppMode.registerUser();
       
        Statement sql=null;
        ResultSet rs=null;
        /*other组成员个数*/
        int i=0;
        /*admin组成员个数*/
        int j=0;
        StringBuffer buffer=new StringBuffer();
        try{    
            db=new DbConnection();
            con=db.getCon();
            sql=con.createStatement();
            rs=sql.executeQuery("SELECT * from stuff where groupstring=\"2;\"");
            buffer.append("<Table Border>");
            buffer.append("<tr>");
            buffer.append("<TH width=100>"+"组名");
            buffer.append("<TH width=100>"+"组内人数");
            buffer.append("</tr>");
            while(rs.next()){
                i++;
            }
            buffer.append("<TR>");
            buffer.append("<TD>"+"other组"+"</TD>");
            buffer.append("<TD>"+i+"</TD>");
            buffer.append("</TR>");
            rs=sql.executeQuery("SELECT * from stuff where groupstring=\"1;\"");
            while(rs.next()){
                j++;
            }
            buffer.append("<TR>");
            buffer.append("<TD>"+"admin组"+"</TD>");
            buffer.append("<TD>"+j+"</TD>");
            buffer.append("</TR>");
            buffer.append("</Table>");
            con.close();
            db.d_close();
            
            AppMode.loginoutUser();
            
            return buffer;
        }
        catch(Exception e){
        	
        	AppMode.loginoutUser();
            return new StringBuffer("无法建立连接");
        }
    }
    
    /*
     * name:         admin组做添加和删除
     * describing:   对admin组做添加和删除的修改
     * @param        DefaultGroupForm dgf
     * @return       int info 
     *               
     */
    public int adminModify(DefaultGroupForm dgf,HttpServletRequest request){
    	
    	AppMode.registerUser();
        
        String  userAddGrant = (String) request.getSession().getAttribute("userAddGrant");
        String  userDeleteGrant = (String) request.getSession().getAttribute("userDeleteGrant");
        System.out.println(userAddGrant);
        System.out.println(userDeleteGrant);
        /*获得FORM里的参数*/
        DefaultGroupForm defaultgroupform=dgf;
        /*根据返回值的不同跳转页面*/
        int info;
        Statement sql=null;
        ResultSet rs=null;
        String sid;
        String name;
        String addordelete;
        sid=defaultgroupform.getSid();
        addordelete=defaultgroupform.getAddordelete();
        name=defaultgroupform.getName();
        sid=change(sid);
        addordelete=change(addordelete);
        name=change(name);
        //System.out.println(addordelete);
        /*存放数据库中取出的员工姓名和JSP获取的姓名做比较*/
        String tempname=null;
        try{
            db=new DbConnection();
            con=db.getCon();
            sql=con.createStatement();
            rs=sql.executeQuery("SELECT * from stuff where sid="+"'"+sid+"'");
            /*游标锁定在第一条记录上也是唯一一条查询出来的记录*/
            rs.first();
            /*从数据库中获取的中文字符串不用经过转换*/
            tempname=rs.getString(2);
            //System.out.println(tempname);
            String condition="where sname="+"'"+name+"'"+"and sid="+"'"+sid+"'";
            String condition1="update stuff set groupstring=\"2;\" "
                              +", update_date='"
                              +update_date+"' "
                              +condition;
            String condition2="update stuff set groupstring=\"1;\" "
                              +", update_date='"
                              +update_date+"' "
                              +condition;
            /*必须判断addordelte是否为空，否则出错*/
            if(name.equals(tempname)&&(addordelete!=null)){
                if(addordelete.equals("删除")&&userDeleteGrant=="Y"){
                    sql.executeUpdate(condition1);
                    con.close();
                    db.d_close();
                    
                    AppMode.loginoutUser();
                    
                    return info=1;
                }else if(addordelete.equals("添加")&&userAddGrant=="Y"){
                          sql.executeUpdate(condition2);
                          con.close();
                          db.d_close();
                          
                          AppMode.loginoutUser();
                          
                          return info=1;
                      }
                else{
                    con.close();
                    db.d_close();
                    
                    AppMode.loginoutUser();
                    
                    return info=3;
                }
            }
            else{
                con.close();
                db.d_close();
                
                AppMode.loginoutUser();
                
                return info=2;
            }
        }
        catch(SQLException e){
        	
        	AppMode.loginoutUser();
			
            System.out.print("操作失败");
            return info=7;
        }
    }
    
    /*
     * name:         处理other组数据
     * describing:   添加 other组内的成员到其他组中
     * @param        DefaultGroupForm dgf
     * @return      int info
     *               
     */
    public int otherGroupAdd(DefaultGroupForm dgf){
    	
    	AppMode.registerUser();
        
        String tempsid=null;
        String tempgroupno=null;
        /*获得FORM里的参数*/
        DefaultGroupForm defaultgroupform=dgf;
        int info;
        Statement sql=null;
        ResultSet rs=null;
        String sid;
        String groupnumber;
        sid=defaultgroupform.getSid();
        groupnumber=defaultgroupform.getGroupnumber();
        sid=change(sid);
        groupnumber=change(groupnumber);
        //System.out.println(sid);
        //System.out.println(groupnumber);
        try{
            db=new DbConnection();
            con=db.getCon();   
            sql=con.createStatement();
            rs=sql.executeQuery("SELECT * from stuff where sid="+"'"+sid+"'");
            /*游标锁定在第一条记录上也是唯一一条查询出来的记录*/
            rs.first();
            /*从数据库中获取的中文字符串不用经过转换*/
            tempsid=rs.getString(1);
            tempgroupno=rs.getString(5);
            //System.out.println(tempsid);
            String condition="where sid="+"'"+sid+"'"; 
            String condition1="update stuff set groupstring=\""
                              +groupnumber+"\" "
                              +", update_date='"
                              +update_date+"' "
                              +condition;
            /*不属于other组的ID不能添加到别的组*/
            if(sid.equals(tempsid)&&tempgroupno.equals("2")){
                sql.executeUpdate(condition1);
                con.close();
                db.d_close();
                
                AppMode.loginoutUser();
                
                return info=1;
            }
            else{
                con.close();
                db.d_close();
                
                AppMode.loginoutUser();
                return info=2;
            }
        }
        catch(SQLException e){
        	
        	AppMode.loginoutUser();
        	
            info=7;
            System.out.print("操作失败");
            return info;
        }
    }
}