servlet6_1.java

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

package com.skyhawk.hellen;



import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;


import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
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;

public class Servlet6_1 extends HttpServlet{
	
	Connection conn=null;
		 Statement stm=null;
		 Statement stm1=null;
		 ResultSet rs=null;
		 ResultSet rst=null;
	public void doPost(HttpServletRequest request,HttpServletResponse response) {
		try {
			request.setCharacterEncoding("GBK");
		} catch (UnsupportedEncodingException e2) {
			
			e2.printStackTrace();
		}
		HttpSession Session=null;
		Session=request.getSession();
		String mima=null;
		mima= (String) Session.getAttribute("to");
		
		
		System.out.println("++++++++++");
	String text1=request.getParameter("text1");
	String text2=request.getParameter("text2");
	String text3=request.getParameter("text3");
	String text4=request.getParameter("text4");
	
	String area=request.getParameter("area");
	String cod=request.getParameter("cod");
	
	System.out.println(text1);
	System.out.println(text2);
	System.out.println(text3);
	System.out.println(text4);
	System.out.println(area);
	System.out.println(mima);
	
	 ConnectionFactory con=new ConnectionFactory();
	 
	 conn=ConnectionFactory.getConnection();
	 
	 System.out.println(cod);
	 System.out.println(mima);
	 DatabaseUtils close=new DatabaseUtils();
	 
	
	 
	 if(cod.equals("sava"))
	 {
	 	try {
			stm=conn.createStatement();
			stm1=conn.createStatement();
			
		} catch (SQLException e) {
			
			e.printStackTrace();
		}
	 	try {
			rst=stm.executeQuery("select * from o_message where time=to_date('"+text4+"','yyyy-mm-dd')and contect='"+area+"'and tittle='"+text2+"'and empid='"+mima+"'and toname='"+text1+"'and fromname='"+text3+"'");
			System.out.println("first++++");
			if(!rst.next()){
				System.out.println("------");		
				stm.executeUpdate("insert into o_message values(to_date('"+text4+"','yyyy-mm-dd'),'"+area+"','"+text2+"','"+mima+"','"+text1+"','"+text3+"')");
				stm.executeUpdate("insert into o_mesrelation values('"+text2+"','"+mima+"','1','0','0',to_date('"+text4+"','yyyy-mm-dd'))");
			request.setAttribute("view","保存!!!!!!!!!");
			try {
				request.getRequestDispatcher("/mm.jsp").forward(request,response);
			} catch (ServletException e3) {
				
				e3.printStackTrace();
			} catch (IOException e3) {
				
				e3.printStackTrace();
			}
			finally{
				DatabaseUtils.closeObject(rst,stm,conn);
				DatabaseUtils.closeObject(stm1,conn);
			}
			}
			else
			{	
				rst=stm.executeQuery("select * from o_mesrelation where tittle='"+text2+"'and empid='"+mima+"'and send='0'");
				
				if(!rst.next()){
					System.out.println("second+++");
					stm1.executeUpdate("insert into o_mesrelation values('"+text2+"','"+mima+"','1','0','1',to_date('"+text4+"','yyyy-mm-dd'))");
					request.setAttribute("view","保存!!!!!!!!!");
							try {
								request.getRequestDispatcher("/mm.jsp").forward(request,response);
							} catch (ServletException e3) {
								
								e3.printStackTrace();
							} catch (IOException e3) {
								
								e3.printStackTrace();
							}
					finally{
									DatabaseUtils.closeObject(rst,stm,conn);
									
								}
				
			}
			}
		
			
		} catch (SQLException e1) {
			
			e1.printStackTrace();
		}
	 	
	 }
	 
	 else if(cod.equals("send")){
	 	System.out.println("enter send");
		try {
			stm=conn.createStatement();
			stm1=conn.createStatement();
		} catch (SQLException e) {
			
			e.printStackTrace();
		}
		
		
		int rowcount=0;
		if(text1.equals("All")){
			try {
				rs=stm.executeQuery("select * from o_message where time=to_date('"+text4+"','yyyy-mm-dd')and contect='"+area+"'and tittle='"+text2+"'and empid='"+mima+"'and toname='"+text1+"'and fromname='"+text3+"'");
			} catch (SQLException e3) {
				
				e3.printStackTrace();
			}	
			try {
				if(!rs.next()){
							stm.executeUpdate("insert into o_message values(to_date('"+text4+"','yyyy-mm-dd'),'"+area+"','"+text2+"','"+mima+"','"+text1+"','"+text3+"')");
				}
				else{
					System.out.println("zhe uer hava sava!!!!!");
				}
			} catch (SQLException e4) {
				
				e4.printStackTrace();
			}
			
			try {
				System.out.println("kankan");
				rst=stm.executeQuery("select empid from o_employee where empid!='"+mima+"'");
				while(rst.next()){
					String userid=null;
					userid=rst.getString("empid");
					System.out.println(userid);
					System.out.println(mima+"hfoad");
					if(userid.equals(mima)){
						stm1.executeUpdate("insert into o_mesrelation values('"+text2+"','"+mima+"','1','0','1',to_date('"+text4+"','yyyy-mm-dd'))"); 
					}
					else{
					
						stm1.executeUpdate("insert into o_mesrelation values('"+text2+"','"+userid+"','0','0','0',to_date('"+text4+"','yyyy-mm-dd'))"); 
					}
				}
				} catch (SQLException e1) {
				
				e1.printStackTrace();
			}
			
		
		
		request.setAttribute("view","发送!!!!!!!!!");
					try {
						request.getRequestDispatcher("/mm.jsp").forward(request,response);
					} catch (ServletException e3) {
						
						e3.printStackTrace();
					} catch (IOException e3) {
						
						e3.printStackTrace();
					}
			finally{
							DatabaseUtils.closeObject(rst,stm,conn);
							DatabaseUtils.closeObject(rs,stm1,conn);
						}		
		}
		else{
		System.out.println("send a user!!!!");
		try {
			rst=stm.executeQuery("select * from o_employee where empname='"+text1+"'");//取toname的编号
			
			if(rst.next()){
				String id=rst.getString("empid");
			System.out.println(id);
			rs=stm.executeQuery("select * from o_message where time=to_date('"+text4+"','yyyy-mm-dd')and contect='"+area+"'and tittle='"+text2+"'and empid='"+mima+"'and toname='"+text1+"'and fromname='"+text3+"'");
			System.out.println(id+"hao");
			if(!rs.next()){
			stm.executeUpdate("insert into o_message values(to_date('"+text4+"','yyyy-mm-dd'),'"+area+"','"+text2+"','"+mima+"','"+text1+"','"+text3+"')");
			stm.executeUpdate("insert into o_mesrelation values('"+text2+"','"+id+"','0','0','0',to_date('"+text4+"','yyyy-mm-dd'))"); 
			request.setAttribute("view","发送!!!!!!!!!");
			try {
				request.getRequestDispatcher("/mm.jsp").forward(request,response);
			} catch (ServletException e3) {
				
				e3.printStackTrace();
			} catch (IOException e3) {
				
				e3.printStackTrace();
			}
			finally{
							DatabaseUtils.closeObject(rst,stm,conn);
							
						}
			}
			else{
				System.out.println("id"+id);
				rs=stm.executeQuery("select * from o_mesrelation where tittle='"+text2+"'and empid='"+id+"'");
				if(!rs.next()){
					stm.executeUpdate("insert into o_mesrelation values('"+text2+"','"+id+"','0','0','0',to_date('"+text4+"','yyyy-mm-dd'))"); 
					request.setAttribute("view","发送!!!!!!!!!");
					try {
						request.getRequestDispatcher("/mm.jsp").forward(request,response);
					} catch (ServletException e3) {
						// TODO Auto-generated catch block
						e3.printStackTrace();
					} catch (IOException e3) {
						// TODO Auto-generated catch block
						e3.printStackTrace();
					}
				}
				
					else{
					
					try {
						
						request.getRequestDispatcher("/False.jsp").forward(request,response);
					} catch (ServletException e3) {						
						e3.printStackTrace();
					} catch (IOException e3) {						
						e3.printStackTrace();
					}
					finally{
									DatabaseUtils.closeObject(rst,stm,conn);
									DatabaseUtils.closeObject(rs,stm1,conn);
								}
					
			}
			}
			}
			else{
				try {
					request.setAttribute("tt","对不起没有这个人!!!!!!");
					request.getRequestDispatcher("/nuser.jsp").forward(request,response);
				} catch (ServletException e3) {					
					e3.printStackTrace();
				} catch (IOException e3) {					
					e3.printStackTrace();
				}
				
			}
		} catch (SQLException e1) {
			
			e1.printStackTrace();
		}
	 }
	
	 }
	 else if(cod.equals("Mody")){
		try {
					stm=conn.createStatement();
					stm1=conn.createStatement();
			
				} catch (SQLException e) {
			
					e.printStackTrace();
				}
				
				try {
					rs=stm.executeQuery("select * from o_message where tittle='"+text2+"'and empid='"+mima+"'");
					if(rs.next()){
				
					System.out.println("doa+++++");
					stm.executeQuery("update o_message set time=to_date('"+text4+"','yyyy-mm-dd'),contect='"+area+"',toname='"+text1+"' where tittle='"+text2+"'and empid='"+mima+"'");
					stm1.executeQuery("update o_mesrelation set time=to_date('"+text4+"','yyyy-mm-dd') where tittle='"+text2+"'and empid='"+mima+"'");
					request.setAttribute("view","保存!!!!!!!!!");
					try {
						request.getRequestDispatcher("/mm.jsp").forward(request,response);
					} catch (ServletException e3) {
						
						e3.printStackTrace();
					} catch (IOException e3) {
						
						e3.printStackTrace();
					}
					finally{
									DatabaseUtils.closeObject(rst,stm,conn);
									DatabaseUtils.closeObject(rs,stm1,conn);
								}
				}
				else{
					try {
						request.getRequestDispatcher("/False.jsp").forward(request,response);
					} catch (ServletException e1) {
						
						e1.printStackTrace();
					} catch (IOException e1) {
						e1.printStackTrace();
					}
				}
				} catch (SQLException e4) {
					
					e4.printStackTrace();
				}				
		
	 }
	 	
	
	}

	public static void main(String[] args) {
	}
}