office_sendmsgaction.java

这个程序是花了好几十万请人开发的

/*
 * 
 * @author 郑文金
 *
 * 这个action用于在"网上办公室"中给好友发送邮件 
 *
 */
 package struts.action;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import struts.form.Office_sendmsgForm;
import java.sql.*;
import javabean.*;

public class Office_sendmsgAction extends Action {
	private ConnectionPool pool;
	private Connection con;
	public Office_sendmsgAction() throws SQLException
	{
		pool=ConnectionPool.getInstance();               //初始化连接池
			
	}
	public ActionForward execute(
		ActionMapping mapping,
		ActionForm form,
		HttpServletRequest request,
		HttpServletResponse response)
		throws Exception 
	{
		CodeString getstring=new CodeString();
		con=pool.getConnection();  //从池中获得一个连接
		Mail_inboxdao inboxdao=new Mail_inboxdao(con);
		PubDate date=new PubDate();
		Office_sendmsgForm sendmsg=(Office_sendmsgForm) form; 
		
		String uuid=sendmsg.getUUID();//获取发件人的UID
		int rid=sendmsg.getRID();//获取收件人的ID
		int inbox_Id=0;//获取收件箱的ID
		String s1="select max(ID) as n from mail_inbox";
		ResultSet rs1=inboxdao.query(s1);
		while(rs1.next())
		{
			inbox_Id=rs1.getInt("n");
		}
		inbox_Id=inbox_Id+1;
		
		int outbox_Id=0;//获取发件箱的ID
		String s4="select max(ID) as n from mail_outbox";
		ResultSet rs3=inboxdao.query(s4);
		while(rs3.next())
		{
			outbox_Id=rs3.getInt("n");
		}
		outbox_Id=outbox_Id+1;//编号自动加1
		
		
		String Date=date.getshortPubdate();//获取发件的时间
		
		String Rname_out="";//获取发件人的姓名
		int fid=0;//获取发件人的id
		String s2="select * from MEMBER where UUID="+"'"+uuid+"'";
		ResultSet rs2=inboxdao.query(s2);
		while(rs2.next())
		{
			Rname_out=rs2.getString("RNAME");	
			fid=rs2.getInt("id");	
		}
		String Rname_in="";//获取收件人的姓名
		String s5="select * from MEMBER where ID="+rid;
		ResultSet rs4=inboxdao.query(s5);
		while(rs4.next())
		{
			Rname_in=rs4.getString("RNAME");			
		}
		
		String Readflag="true";//设置是否已读的标志
		
		String Title=sendmsg.getTITLE();//获取回复的标题
		Title=getstring.getString(Title);
		String Content=sendmsg.getCONTENT();//获取回复的内容
		Content=getstring.getString(Content);
		
		String s3="insert into mail_inbox values( "+"'"+inbox_Id+"'"+","+"'"+Title+"'"+","+"'"+Content
		+"'"+","+"'"+Rname_out+"'"+","+"'"+Date+"'"+","+"'"+Readflag+"'"+","+"'"+rid+"'"+
		","+"'"+uuid+"'"+","+"'"+fid+"'"+" )";//将回复的邮件发到mail_inbox表中，对方根据Mail_inbox中的Suid来获取他对应的邮件
		
		String s6="insert into mail_outbox values( "+"'"+outbox_Id+"'"+","+"'"+Title+"'"+","+"'"+Content
		+"'"+","+"'"+Date+"'"+","+"'"+Rname_in+"'"+","+"'"+uuid+"'"+","+"'"+rid+"'"+" )";//将回复的信息保存到发件箱中
		
		inboxdao.update(s3);//将信息加到收件箱中
		inboxdao.update(s6);//将信息加到发件箱中
		sendmsg.reset(mapping,request);
		String msg=inboxdao.update(s3);//获取修改是否成功的标志!
		inboxdao.con.commit();
		if(inboxdao.con!=null)
		{
			inboxdao.con.close();
		}
		if(msg.equals("failure"))
		{
			return mapping.findForward("office_sendmsg_confirm");
		}
		else
			return mapping.findForward("office_sendmsg");	
	}

}