setagent.java

个人办公平台,用JAVA开发的TOMCAT的服务器

/*
 * Created on 2006-9-23
 *
 * To change the template for this generated file go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */
package com.skyhawk.richeng.setagent;

import java.io.IOException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import com.skyhawk.db.ConnectionFactory;
import com.skyhawk.db.DatabaseUtils;
import com.skyhawk.richeng.setreader.Reader;

/**
 * @author Administrator
 *
 * To change the template for this generated type comment go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */
public class SetAgent {

	public ArrayList viewAgent(HttpServletRequest request,HttpServletResponse response,String empid) {
	    Statement stmt = null;
		ResultSet rs1 = null;
			HttpSession sess=request.getSession();
			String empid1=(String) sess.getAttribute("empid1");
			System.out.println("++++++agent=========1========"+empid1);
			
			ArrayList arraylist = new ArrayList();
			 Connection conn =  ConnectionFactory.getConnection();
			 try {
				stmt=conn.createStatement();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			 String datequery ="select agentid,empname from o_readerseter,o_employee where o_readerseter.empid='"+empid+"' and o_readerseter.agentid=o_employee.empid";
			 System.out.println("====agent-=="+datequery);
			 try {
				rs1=stmt.executeQuery(datequery);
			} 
			catch (SQLException e1) {
				e1.printStackTrace();
			}
			  try {
			  
				while(rs1.next()){
				 Agent agent=new Agent();
			
				    agent.setAgentName(rs1.getString("empname"));
				    agent.setAgentId(Integer.parseInt(rs1.getString("agentid")));
				 	arraylist.add(agent);
				}
			    } catch (SQLException e2) {
				e2.printStackTrace();
				
			}
			finally{
			DatabaseUtils coldat =new DatabaseUtils();
			DatabaseUtils.closeObject(rs1,stmt,conn);
			System.out.println("+++++close agent++++");
		}
		     return arraylist;
		}
	public void addAgent(HttpServletRequest request,HttpServletResponse response){
		 Statement stmt = null;
			ResultSet rs1 = null;
			 Connection conn =  ConnectionFactory.getConnection();

			 HttpSession sess=request.getSession();
				String empid1=(String) sess.getAttribute("empid1");
		String emp=request.getParameter("right");
		
		System.out.println("right"+emp);

		//String emp=(String)sess.getAttribute("emp");
		String insert="insert into o_readerseter values('"+empid1+"','"+emp+"')";
		System.out.println("insert=========="+insert);
		try {
			 stmt = conn.createStatement();
			int amount = stmt.executeUpdate(insert);
			
			System.out.println("=amount=1="+amount);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		try {
			System.out.println("=====before===succe");
			request.getRequestDispatcher("/shezhidaiban.jsp").forward(request,response);
		} 
		  catch (Exception e) {
			e.printStackTrace();
			try {
				try {
					request.getRequestDispatcher("/fail.jsp").forward(request,response);
				} catch (ServletException e2) {
					e2.printStackTrace();
				}
			} catch (IOException e1) {
				e1.printStackTrace();
			}
		  }
			finally{
				DatabaseUtils coldat =new DatabaseUtils();
				DatabaseUtils.closeObject(rs1,stmt,conn);
				System.out.println("+++++close agent++++");
			}
	}


		
	public void deleteAgent(HttpServletRequest request,HttpServletResponse response){
		 try {
		Statement stmt = null;
			ResultSet rs1 = null;
			 Connection conn =  ConnectionFactory.getConnection();
				HttpSession sess=request.getSession();
				String empid1=(String) sess.getAttribute("empid1");
		String agentid=request.getParameter("left");
		stmt = conn.createStatement();
		System.out.println("left"+agentid);
		//String agentid=(String)sess.getAttribute("agent");
		String del="delete from o_readerseter where empid='"+empid1+"' and agentid='"+agentid+"'";
		
	    System.out.println("del==="+del);
	    int amount = stmt.executeUpdate(del);
	    System.out.println("del==="+amount);
	    
	    request.getRequestDispatcher("/shezhidaiban.jsp").forward(request,response);
	 }
	  catch (Exception e) {
		e.printStackTrace();
		try {
			try {
				request.getRequestDispatcher("/fail.jsp").forward(request,response);
			} catch (ServletException e2) {
				// TODO Auto-generated catch block
				e2.printStackTrace();
			}
		} catch (IOException e1) {
			e1.printStackTrace();
		}
		
	}
	}
}