smsmanager.java

jsp网站开发四“酷”全书原码

package net.acai.forum;
/**
 * Title:        清清网络
 * Description:
 * Copyright:    Copyright (c) 2002
 * Company:      www.qingqing.com
 * @author:       qingqing
 * @version 1.0
 */
import net.acai.forum.*;
import net.acai.database.*;
import javax.servlet.http.*;
import java.sql.*;
import net.acai.util.*;
import java.util.Vector;
public class SMSManager{
	String userName,sql;
	User theUser;
	public SMSManager(HttpServletRequest request,HttpServletResponse response) throws Exception{
		userName=GCookie.getCookieValue(request,"UJBBUName","");
		theUser=SkinUtil.checkUser(request,response,4);
	}
	public SMSMSG getSMSMSG(HttpServletRequest request) throws Exception {
		return this.getSMSMSG(request,"inbox");
	}
	public static boolean checkSMS(HttpServletRequest request){
		String userName=GCookie.getCookieValue(request,"UJBBUName","");
		boolean smsSign=false;

		try{
			DBConnect dbc=new DBConnect();
			String sql="Select Count(id) From bbs.Message Where flag=0 and issend=1 and delR=0 And incept=?";
			dbc.prepareStatement(sql);
			dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
			ResultSet rs=dbc.executeQuery();
			if(rs.next())
				smsSign=true;
			dbc.close();
		}
		catch(Exception e){

			e.printStackTrace();
		}
		return smsSign;

	}
	public static SMSMSG getNewSMS(HttpServletRequest request){
		String userName=GCookie.getCookieValue(request,"UJBBUName","");


		try{
			DBConnect dbc=new DBConnect();
			String sql="Select  id,sender From bbs.Message Where flag=0 and issend=1 and delR=0 And incept=?";
			dbc.prepareStatement(sql);
			dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
			ResultSet rs=dbc.executeQuery();
			if(!rs.next()){
				dbc.close();
				return null;
			}
			SMSMSG sms=new SMSMSG();
			sms.setID(rs.getInt(1));
			sms.setSender(rs.getString(2));
			dbc.close();
			return sms;
		}
		catch(Exception e){

			e.printStackTrace();
			return null;
		}

	}
	public SMSMSG getSMSMSG(HttpServletRequest request,String sign) throws Exception {
		DBConnect dbc=new DBConnect();
		int ID=0;
		try{
			ID=ParamUtil.getInt(request,"id");
		}
		catch(Exception e){
			throw new Exception("请指定相关参数。");
		}
		if(sign.equals("fw")){
			sql="select * from bbs.message where (incept=? or sender=?) and id="+ID;
			dbc.prepareStatement(sql);
			dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
			dbc.setBytes(2,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
		}
		else if(sign.equals("edit")){
			sql="select * from bbs.message where sender=? and issend=0 and id="+ID;
			dbc.prepareStatement(sql);
			dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
		}
		else if(sign.equals("read")){
			sql="update bbs.message set flag=1 where ID="+ID;
			dbc.executeUpdate(sql);
			sql="select * from bbs.message where (incept=? or sender=?) and id="+ID;
			dbc.prepareStatement(sql);
			dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
			dbc.setBytes(2,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
		}
		else {
			sql="select * from bbs.message where incept=? and id="+ID;
			dbc.prepareStatement(sql);
			dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());

		}
		ResultSet rs=dbc.executeQuery();
		rs.next();
		SMSMSG sms=new SMSMSG();
		sms.setID(rs.getInt(1));
		sms.setSender(rs.getString(2));
		sms.setIncept(rs.getString(3));
		sms.setTitle(rs.getString(4));
		sms.setContent(rs.getString(5));
		sms.setFlag(rs.getInt(6));
		sms.setSendtime(rs.getString(7));
		sms.setDelR(rs.getInt(8));
		sms.setDelS(rs.getInt(9));
		sms.setIsSend(rs.getInt(10));
		dbc.close();
		return sms;
	}
	public Vector getInBox() throws Exception{
		Vector smsVector=new Vector();
		DBConnect dbc=new DBConnect();
		sql="select * from bbs.message where incept=? and issend=1 and delR=0 order by flag,sendtime desc";
		dbc.prepareStatement(sql);
		dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
		ResultSet rs=dbc.executeQuery();
		while(rs.next()){
			SMSMSG sms=new SMSMSG();
			sms.setID(rs.getInt(1));
			sms.setSender(rs.getString(2));
			sms.setIncept(rs.getString(3));
			sms.setTitle(rs.getString(4));
			sms.setContent(rs.getString(5));
			sms.setFlag(rs.getInt(6));
			sms.setSendtime(rs.getString(7));
			sms.setDelR(rs.getInt(8));
			sms.setDelS(rs.getInt(9));
			sms.setIsSend(rs.getInt(10));
			smsVector.add(sms);
		}
		dbc.close();
		return smsVector;

	}
	public Vector getOutBox() throws Exception{
		Vector smsVector=new Vector();
		DBConnect dbc=new DBConnect();
		sql="select * from bbs.message where sender=? and issend=0 and delS=0 order by sendtime desc";
		dbc.prepareStatement(sql);
		dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
		ResultSet rs=dbc.executeQuery();
		while(rs.next()){
			SMSMSG sms=new SMSMSG();
			sms.setID(rs.getInt(1));
			sms.setSender(rs.getString(2));
			sms.setIncept(rs.getString(3));
			sms.setTitle(rs.getString(4));
			sms.setContent(rs.getString(5));
			sms.setFlag(rs.getInt(6));
			sms.setSendtime(rs.getString(7));
			sms.setDelR(rs.getInt(8));
			sms.setDelS(rs.getInt(9));
			sms.setIsSend(rs.getInt(10));
			smsVector.add(sms);
		}
		dbc.close();
		return smsVector;

	}
	public Vector getRecycle() throws Exception{
		Vector smsVector=new Vector();
		DBConnect dbc=new DBConnect();
		sql="select * from bbs.message where ((sender=? and delS=1) or (incept=? and delR=1)) and delS!=2 order by sendtime desc";
		dbc.prepareStatement(sql);
		dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
		dbc.setBytes(2,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
		ResultSet rs=dbc.executeQuery();
		while(rs.next()){
			SMSMSG sms=new SMSMSG();
			sms.setID(rs.getInt(1));
			sms.setSender(rs.getString(2));
			sms.setIncept(rs.getString(3));
			sms.setTitle(rs.getString(4));
			sms.setContent(rs.getString(5));
			sms.setFlag(rs.getInt(6));
			sms.setSendtime(rs.getString(7));
			sms.setDelR(rs.getInt(8));
			sms.setDelS(rs.getInt(9));
			sms.setIsSend(rs.getInt(10));
			smsVector.add(sms);
		}
		dbc.close();
		return smsVector;

	}
	public Vector getIsSend() throws Exception{
		Vector smsVector=new Vector();
		DBConnect dbc=new DBConnect();
		sql="select * from bbs.message where sender=? and issend=1 and delS=0 order by sendtime desc";
		dbc.prepareStatement(sql);
		dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
		ResultSet rs=dbc.executeQuery();
		while(rs.next()){
			SMSMSG sms=new SMSMSG();
			sms.setID(rs.getInt(1));
			sms.setSender(rs.getString(2));
			sms.setIncept(rs.getString(3));
			sms.setTitle(rs.getString(4));
			sms.setContent(rs.getString(5));
			sms.setFlag(rs.getInt(6));
			sms.setSendtime(rs.getString(7));
			sms.setDelR(rs.getInt(8));
			sms.setDelS(rs.getInt(9));
			sms.setIsSend(rs.getInt(10));
			smsVector.add(sms);
		}
		dbc.close();
		return smsVector;

	}
	public void  delInBox(HttpServletRequest request) throws Exception{
		int ID=0;
        String[] ids = request.getParameterValues("id");
		if(ids.length==0)
			throw new Exception("请指定相关参数。");
        for(int i=0;i<ids.length;i++)
        {
            ID = Integer.parseInt(ids[i]);