usermanagement.java~1~

java系统通用框架 很实用的东东 一般人都看的懂,

	else
		operationtype = -1;
	
	return operationtype;
}
//导入SAP SALES USER
public String importSAPSales() throws Exception{
	
	String addresult = "";
	

	return addresult;
}
public static User loadUserFromDB(Connection conn, String userid)  throws Exception 
{

	System.out.println("user managerment -loadUserFromDB");
	
	User user = null;
	try{

		userid="'"+userid+"'";
		String sql = "select * from S_USER where userid = " + userid;
		System.out.println("user managerment -loadUserFromDB-sql="+sql);
		
		Statement stmt = conn.createStatement();
		ResultSet rs = (ResultSet)stmt.executeQuery(sql);
		
		
		String cmpType = "";
		String deptCode ="";
		if (rs.next()){
			
			cmpType = rs.getString("CMPTYPE");
		 	deptCode = rs.getString("DEPTCODE");
		
		
			System.out.println("user managerment -loadUserFromDB- cmpType="+cmpType);
			System.out.println("user managerment -loadUserFromDB- deptCode="+deptCode); 

			System.out.println("user managerment -loadUserFromDB- User.CMP_SONY="+User.CMP_SONY);
			System.out.println("user managerment -loadUserFromDB- User.DEPT_SALE="+User.DEPT_SALE);
			System.out.println("user managerment -loadUserFromDB- User.DEPT_SALE="+User.DEPT_MRKT);
		
			if (User.CMP_SONY.equals(cmpType)) {
			
				if (User.DEPT_SALE.equals(deptCode)) {
					user = new SalesUser(conn, rs);
				}
				
				if (User.DEPT_MRKT.equals(deptCode)) {
					user = new MarketUser(conn, rs);
				}
			}else {
			
			}

		}
		
	}catch(Exception e){
		e.printStackTrace(System.out);

		throw e;
	}

	return user;
}
//
/**
 * 此处插入方法描述。
 * 创建日期：(2002-7-16 15:00:36)
 * @param args java.lang.String[]
 */
public static void main(String[] args) { 

	try	{
		
		System.out.println("user managerment begin");
		
		//oracle use
		Class.forName("COM.ibm.db2.jdbc.app.DB2Driver");
		Connection conn = DriverManager.getConnection("jdbc:db2:sdcmdb", "db2admin", "db2admin");
		conn.setAutoCommit(false);
		System.out.println("user managerment begin-getConnection");

		RequestContext context=null;
		int userType=0;

		UserManagement usermanage=new UserManagement();
		usermanage.addUser(context,conn,userType);
		//usermanage.updUser(context,conn,userType);

		String deptCode="01";
		//usermanage.queryDeptUserList(context,conn,deptCode);

		String userid="00123480";
		//queryUserInfo(conn,userid);
		
		System.out.println("user managerment begin-adduer");

		conn.commit();
	
	}catch(Exception e){
		System.out.println(e);
	}
}
private int operateDB(Connection conn,String sql) throws SQLException{

	int result=-1;
	
	System.out.println("UserManagerment- operateDB");
	   
	Statement stat = conn.createStatement();

	System.out.println("UserManagerment- operateDB sql="+sql);
	   
	result=stat.executeUpdate(sql);
	stat.close();
	
	System.out.println("UserManagerment- operateDB result="+result);

	return result;
}
private ResultSet queryDB(Connection conn,String sql) throws SQLException{

	System.out.println("UserManagerment- queryDB");
	   
	Statement stat = conn.createStatement();
	
	
	ResultSet rs = stat.executeQuery(sql);
	rs.close();
	stat.close();
	
	System.out.println("UserManagerment- operateDB result="+rs);

	return rs;
}
/**
 * 查询用户
 * 创建日期：(2002-8-10 14:33:18)
 * @return BizComponent
 * @context RequestContext
 * 
 */
//
public static BizComponent queryDeptUserList(RequestContext context,Connection conn,String deptCode) throws Exception {

	try {

		BizComponent reBC=new BizComponent("userList");
		
	 	/*   
		String userid="00123480";
        deptCode="";

        userid=(String)context.getParameter("userid");
        deptCode=(String)context.getParameter("deptCode");
     	
     	if(userid.length()>32)
     		throw new InvalidParameterException("LoginID too long");
		*/		    	
     	 
		//超级管理员不可见
		//应该用StringBuffer阿，现在暂时不改吧

		String qSql ="";
		String countSql ="";
		/*
		qSql="select * from s_user where userid!= "+ADMINID;
     	countSql = "select count(*) as count from s_user where userid!= "+ADMINID;
     	
     	if(q_usrLogin.length() != 0){
     		qSql+=" and loginid='"+usrLogin+"'";
     		countSql+=" and loginid='"+usrLogin+"'";
     	}
     	*/
     	
     	if(deptCode!=null||deptCode.length() != 0){

	     	deptCode="'"+deptCode+"'";

	     	qSql="select USERID,NAME,deptCode from s_user where deptCode= "+deptCode;
	     	countSql="select count(*) as count from s_user where deptCode= "+deptCode;
	     		
     	}

     	System.out.println("UserManagerment- queryDeptUserList-sql="+qSql);
     	
	    Statement stmt = conn.createStatement();
        ResultSet rs = stmt.executeQuery(qSql);

        while(rs.next()){
	        
	        String s_userid= rs.getString("USERID");
	        String s_name= rs.getString("NAME");
	        String s_deptCode= rs.getString("deptCode");

	        System.out.println("UserManagerment- queryDeptUserList- s_userid="+s_userid);
	        System.out.println("UserManagerment- queryDeptUserList- s_name="+s_name);
	        System.out.println("UserManagerment- queryDeptUserList- s_deptCode="+s_deptCode);
	        
	        reBC.newRecord();
	        reBC.setFieldValue("userID",s_userid);
	        reBC.setFieldValue("name",s_name);
	        reBC.setFieldValue("deptCode",s_deptCode);
        }
        rs.close();

        
        
        rs = stmt.executeQuery(countSql);
        while(rs.next()){
	        String count = rs.getString("count");
	        reBC.newRecord();
	        reBC.setFieldValue("RecordCount",count); 
        }
        rs.close();
        stmt.close();
       
        return reBC;
        
    } catch (Exception e) {
        e.printStackTrace(System.out);
        throw e;
    }
    
}
/**
 * 查询用户
 * 创建日期：(2002-8-10 14:33:18)
 * @return BizComponent
 * @context RequestContext
 * 
 */
//
public static BizComponent queryUserInfo(Connection conn, String userid) throws Exception {

	System.out.println("user managerment -queryUserInfo");
	
	BizComponent reBC=new BizComponent("userList");
	reBC.newRecord();
	 
	User userinfo=loadUserFromDB(conn,userid);

	String userID="";
	String name="";
	String cmpCode="";
	String cmpName="";
	String cmpType="";
	String deptCode="";
	String mailAddress="";

	if(userinfo!=null){
		userID=userinfo.getUserID();
		name=userinfo.getName();
		cmpCode=userinfo.getCmpCode();
		cmpName=userinfo.getCmpName();
		cmpType=userinfo.getCmpType();
		deptCode=userinfo.getDeptCode();
		mailAddress=userinfo.getMailAddress();
	}
	System.out.println("user managerment -queryUserInfo- userID"+userID);
	System.out.println("user managerment -queryUserInfo- name"+name);
	System.out.println("user managerment -queryUserInfo- cmpCode"+cmpCode);
	System.out.println("user managerment -queryUserInfo- cmpName"+cmpName);
	System.out.println("user managerment -queryUserInfo- cmpType"+cmpType);
	System.out.println("user managerment -queryUserInfo- deptCode"+deptCode);
	System.out.println("user managerment -queryUserInfo- mailAddress"+mailAddress);

	reBC.setFieldValue("userID",userID);
	reBC.setFieldValue("name",name);
	reBC.setFieldValue("cmpCode",cmpCode);
	reBC.setFieldValue("cmpName",cmpName);
	reBC.setFieldValue("cmpType",cmpType);
	reBC.setFieldValue("deptCode",deptCode);
	reBC.setFieldValue("mailAddress",mailAddress);

	if(userinfo instanceof SalesUser){

		System.out.println("userinfo instanceof SalesUser");
		SalesUser sales=(SalesUser)userinfo;
		
		String level=sales.getSalesUserLevel();
		String subdept=sales.getSalesSubDept();
		String subdeptName=sales.getSalesSubDeptName();
		
		System.out.println("user managerment -queryUserInfo- level"+level);
		System.out.println("user managerment -queryUserInfo- subdept"+subdept);
		System.out.println("user managerment -queryUserInfo- subdeptName"+subdeptName);

		userID=sales.getUserID();
		System.out.println("user managerment -queryUserInfo- userID"+userID);

		reBC.setFieldValue("level",level);
		reBC.setFieldValue("subdept",subdept);

		Vector channelList=sales.getChannelList();
		int chansize=0;
		if(channelList!=null)
			chansize=channelList.size();
		System.out.println("--chansize="+chansize);

		
	
	}

	//MarketUser
	if(userinfo instanceof MarketUser){
		
		System.out.println("userinfo instanceof MarketUser");
		MarketUser market=(MarketUser)userinfo;
		
		userID=market.getUserID();
		
		System.out.println("user managerment -queryUserInfo- market userID"+userID);

		Vector categoryList=market.getCategoryList();
		int catsize=0;
		if(categoryList!=null)
			catsize=categoryList.size();
		System.out.println("--catsize="+catsize);

		
	}

	//取用户的权限
	Vector rights=null;
	
	if(userinfo!=null){
		
		rights=userinfo.getVtRight();
	
		System.out.println("##############  user managerment -queryUserInfo- rights.size()= "+rights.size());
		
		for (int i = 0;i < rights.size();i++ ){

			UserRight ur = (UserRight)rights.elementAt(i);
			String id=ur.getId();
			System.out.println("user managerment -queryUserInfo- id= "+id);
		
		}
	}
	System.out.println("user managerment -queryUserInfo- setFieldValue(userinfo)");
	reBC.setFieldValue("user",userinfo);
	System.out.println("user managerment -queryUserInfo- userinfo="+userinfo);

	reBC.setFieldValue("rights",rights);
	
	return reBC;
    
}
private int updMarket(RequestContext context,Connection conn,String userid) throws Exception{
	
	int result =-1;

	result=delMarket(userid,conn);
	System.out.println("delMarket(userid,conn) result="+result);

	result=addMarket(context,conn,userid);
	System.out.println("addMarket(userid,conn) result="+result);

	/*

	//取得页面参数
    //String categorycod[]=null;
    
    String categorycod=null;//category组合
    int idlength=0;//category列表长度
 
	categorycod=(String)context.getParameter("categorycod");
	System.out.println("user managerment addMarket categorycod="+categorycod);

	String cateCode=null;//category代码

	//分解category代码

	//分解记录
    String SEPARATOR = "|";	//记录分隔符号
	Vector v=decomposeString(categorycod,SEPARATOR);

   	//分解字段值
	//****-----取行数 line，字段的数目
	idlength=v.size();
	
	userid="'"+userid+"'";
	
	
	for(int i=0;i<idlength;i++){
	
		//cateCode[i]="CTV";
		//取一个字段  
		cateCode= (String) v.elementAt(i);
			
		cateCode="'"+cateCode+"'";

		String sql="insert into S_MARKETCAT(MARKETCOD,CATEGORYCOD)values("
				+userid+","+cateCode+")";
	
		result=operateDB(conn,sql);
	
	}

	*/

	return result;

}
private int updSales(RequestContext context,Connection conn,String userid) throws Exception{
	
	int result =-1;

	//取得页面参数
    //String userid ="00123480";
	String s_level="1";
	String subdeptcod="S001";
 
	
    //userid=(String)context.getParameter("userid");
    s_level=(String)context.getParameter("level");
    	
	subdeptcod=(String)context.getParameter("subdeptCode");
	
	//Channel 列表
	String channelList="";
	if(subdeptcod!=null)
		channelList=subdeptcod.trim();
	
	int level=0;
	if(s_level!=null){
		level=Integer.parseInt(s_level); 
	}
	
	

	String HQuserid="";
	//level=5,是HQ Manager,部门是HQ
	if(level==5){
		subdeptcod="HQ";
		HQuserid=userid;
	}
	userid="'"+userid+"'";
	subdeptcod="'"+subdeptcod+"'";
		
	String sql="update S_SALES set LEVEL="+level+",SUBDEPTCOD="+subdeptcod+" where SALESID="+userid;;
				
	result=operateDB(conn,sql);

	switch(level){
		
		case 5:
			delHQChannel(HQuserid,conn);
			addHQChannel(channelList,conn,HQuserid);
			
		break;	
		
	}
	
	return result;

}
//
//update user
public int updUser(RequestContext context,Connection conn,int userType) throws Exception{
	
	int addresult = 0;

	String userid="";
	userid=(String)context.getParameter("userid");
	System.out.println("UserManagerment-updUser userid="+userid);

	//更改用户基本信息
	updUserBaseInfo(context,conn,userid);

	//更改用户权限
	updUserRight(context,conn,userid);

	
	 
	switch(userType){

		case 0:
			//更改市场部用户属性
			updMarket(context,conn,userid);
		break;
		
		case 1:
			//更改销售部用户属性
			updSales(context,conn,userid);
		break;
	}
	
	

	return addresult;
}
//
private int updUserBaseInfo(RequestContext context,Connection conn,String userid) throws Exception{
	
	int result =-1;

	//定义参数
	String password="";
    String confirm_password="";
	String name = "";
	String cmpType="";
	String cmpCode="";
	String deptCode="";
	String mailAddress="";
	String keyin="Y";
	
	String s_status="";
	int status=1;

	//取得页面参数
	//userid = (String)context.getParameter("userid");
    
    password=(String)context.getParameter("password");
    confirm_password=(String)context.getParameter("confirm_password");
    
	name = (String)context.getParameter("name");
	
	cmpType=(String)context.getParameter("cmpType");
	cmpCode=(String)context.getParameter("cmpCode");
	deptCode=(String)context.getParameter("deptCode");
	mailAddress=(String)context.getParameter("mailAddress");
	keyin=(String)context.getParameter("keyin");
	
	//判断密码和确认密码是否相等
	if(!password.equals(confirm_password)){
		//exception
	}
	
	s_status=(String)context.getParameter("status");
	status=Integer.parseInt(s_status);

	//
	userid="'"+userid+"'";
	password="'"+password+"'";
	name="'"+name+"'";
	cmpType="'"+cmpType+"'";
	cmpCode="'"+deptCode+"'";
	deptCode="'"+deptCode+"'";
	mailAddress="'"+mailAddress+"'";
	keyin="'"+keyin+"'";
	
	String sql="update s_user set "
				+"password="+password+",NAME="+name+","+"CMPTYPE="+cmpType+",CMPCODE="+cmpCode
				+",DEPTCODE="+deptCode+",MAILADDRESS="+mailAddress+",KEYIN="+keyin+",STATUS="+status
				+" where USERID="+userid;
			
	result=operateDB(conn,sql);
	
	return result;
	
}
private int updUserRight(RequestContext context,Connection conn,String userid) throws Exception{
	
	int result =-1;

	//del
	delUserRight(userid,conn);

	//add
	result=addUserRight(context,conn,userid);

	return result;

}
}