hbtx.java

JAVA邮件系统

/**
*
* Hbdt.java
*
*/

import java.io.*;
import java.sql.*;

/*

 @author Liyan

*/

public class Hbtx
{
	//航班基本信息：
	//航班提醒的基本信息：
	
	//航班号、进出港、提醒地名、日期、提前提醒时间、提醒类型
	String sHbh,sInout,sDmdm,sZxrq,sTqtx,sType;
	
	//数据库：
	DBOperater DBtx;
	ResultSet rstx;
		
	Hbtx()
	{
		//构造函数
	}
	
		
	
	//航班动态提醒验证：
	public int isDttxValid(Person p,String sHbh,String sInout,String sDmdm)
	{
		String sJc="";
		if(sInout.compareTo("o")==0)
			sJc="qfjc";
		else
			sJc="ldjc";
		String sSql="";
		System.out.println("1:"+sDmdm); 
		sSql+="SELECT * FROM hbjh WHERE hbh='"+sHbh+"' and "+sJc+"='"+this.zwqcToSzdm(sDmdm)+"'";
		DBOperater DB = new DBOperater("hb");
		System.out.println(sSql); 
		ResultSet rs = DB.executeQuery(sSql);
		try
		{
			if(rs.next()==false){
				DB.close();
				int nTemp=1;
				return nTemp;
			}
		}catch(Exception ex){
		}
		sSql="SELECT * FROM hbtx WHERE username='"+p.getName()+"' and hbh='"+sHbh+"' and dmdm='"+sDmdm+"'";
		rs = DB.executeQuery(sSql);
		try
		{
			if(rs.next()){
				DB.close();
				int nTemp=2;
				return nTemp;
			}
		}catch(Exception ex){
		}
		DB.close();
		return 0;
	}
	
	
	//动态提醒数据入库：
	public void addDttx(String sUserName,String sHbh,String sDmdm,String sInout,String sZxrq,
						   String sTqtx,String sType)
	{
		String sSql="INSERT INTO hbtx (username, hbh, inout, dmdm, zxrq, tqtx,type)";
		sSql+="VALUES ('"+sUserName+"', '"+sHbh+"', '"+sInout+"', '"+sDmdm+"', '"+sZxrq+"', '"+sTqtx+"','"+sType+"')";
		DBOperater DB = new DBOperater("hb");
		DB.executeUpdate(sSql);
		DB.close();
	}
	
//动态提醒从库中取数据
	//设置：
	public void setTxQuery(Person p)
	{
		String sSql="SELECT hbh, inout, dmdm, zxrq, tqtx ,type FROM hbtx WHERE username='"+p.getName()+"'";
		DBtx = new DBOperater("hb");
		rstx = DBtx.executeQuery(sSql);
	}
	
	//取数据：
	public boolean getTxQuery()
	{
		try
		{
			if(rstx.next())
			{
				sHbh = rstx.getString(1);
				sInout = rstx.getString(2);
				sDmdm = rstx.getString(3);
				sZxrq = rstx.getString(4);
				sTqtx = rstx.getString(5);
				sType = rstx.getString(6);
			}else{
				return false;
			}
		}catch(Exception ex){
			return false;
		}
		return true;
	}
	
	//关闭：
	public void closeTxQuery()
	{
		DBtx.close();
	}
	
//动态提醒从库中删除数据
	public void deleteTxData(Person p,String sHbh,String sDmdm)
	{
		String sSql="DELETE FROM hbtx WHERE username='"+p.getName()+"' AND hbh='"+sHbh;
		sSql+="' and dmdm='"+sDmdm+"'";
		DBOperater DB = new DBOperater("Hb");
		DB.executeUpdate(sSql);
		DB.close();
	}
	
	//把中文地名转换成四字代码
	public String zwqcToSzdm(String sZwqc)
	{
		System.out.println("2:"+sZwqc); 
		if(sZwqc!=null){
			if(sZwqc.trim().length()==0)
				return "";
			String sSql="SELECT szdm FROM dmdm WHERE zwqc like'%"+sZwqc.trim()+"%'";
			DBOperater DB = new DBOperater("hb");
			ResultSet rs = DB.executeQuery(sSql);
			System.out.println("3:"+sSql); 
			try
			{
				if(rs.next()){
					String sSzdm=rs.getString(1);
					System.out.println("4:"+sSzdm); 
					if(sSzdm.trim().compareTo("")==0){
						DB.close();
						return "未找到"+sZwqc+"的四字代码！";
					}
					else{
						DB.close();
						return sSzdm;
					}
				}else{
					System.out.println("5:"+"中文名称未找到"); 
					DB.close();
					return "中文名称未找到！";
				}
			}catch(Exception ex){
				DB.close();
			}
			return "sZwqc为空！";
		}
		return "未输入";
	}
	
	
	//取得数据：
	public String getHbh()
	{
		return sHbh;
	}
	
	public String getInout()
	{
		if(sInout.compareTo("o")==0)
			sInout="出港";
		else
			sInout="进港";
		return sInout;
	}
	
	public String getDmdm()
	{
		return sDmdm;
	}
	
	public String getZxrq()
	{
		return sZxrq;
	}
	
	public String getTqtx()
	{
		return sTqtx;
	}
	
	public String getType()
	{
		String sTmp="<font size=1>";
		if((CommonMethods.GetInt(sType,10)&1)!=0)
			sTmp+="<INPUT CHECKED type=checkbox disabled>手机";
		else
			sTmp+="<INPUT type=checkbox disabled>手机";
		if((CommonMethods.GetInt(sType,10)&2)!=0)
			sTmp+="<INPUT CHECKED name=type2 type=checkbox value=2 disabled>呼机</font>";
		else
			sTmp+="<INPUT name=type2 type=checkbox value=2 disabled>呼机</font>";
		return sTmp;
	}

}