trainchannel.java

JAVA邮件系统

								tqshijian=Integer.valueOf(tqtx).intValue();
									//设置当前日历
								try{
									calendar.set (nian,yue,ri,shi,fen);
									}catch(Exception e){
									desHtml.setErrorID (desHtml.SHOW_SIMPLE_MESSAGE ,"",
														"输入的日期不合法!"
														,"EditChannel?channel=train");

									return false;
									}
								//计算提前后的日历
								calendar.add (calendar.HOUR_OF_DAY,-tqshijian);
								nian=calendar.get(Calendar.YEAR);
								yue=calendar.get(Calendar.MONTH);
								yue=yue+1;
								ri=calendar.get(Calendar.DATE ); 
								shi=calendar.get(Calendar.HOUR_OF_DAY); 
								fen=calendar.get(Calendar.MINUTE);  
							  //类型调整
								riqi[0]=String.valueOf (nian).toString ();
								riqi[1]=String.valueOf (yue).toString ();
								riqi[2]=String.valueOf (ri).toString ();
								shijian[0]=String.valueOf (shi).toString ();
								shijian[1]=String.valueOf (fen).toString ();
								
								//格式调整
								if(yue<10)
									riqi[1]="0"+riqi[1];
							
								if(ri<10)
									riqi[2]="0"+riqi[2];
							
								if(shi<10)
									shijian[0]="0"+shijian[0];
								
								if(fen<10)
									shijian[1]="0"+shijian[1];
							
								txdate=riqi[0]+"-"+riqi[1]+"-"+riqi[2]+" "+shijian[0]+":"+shijian[1];
							//退出while循环
								break;
								
							}
								
								
							
							
						}
						//若当前到站时间要比上一站到站时间小
						else
						{
							//分离日期时间
							i=0;
							start=0;
							posi=tempdate.indexOf (" ",0);
							s_riqi=tempdate.substring (0,posi);
							posi=posi+1;
							s_shijian=tempdate.substring (posi,tempdate.length ());
							//分离日期
							
							while(true)
							{
								posi =s_riqi.indexOf("-",start);
								if(posi==-1)
								{
									riqi[i]=s_riqi.substring (tempposi,s_riqi.length ());
									break;
								}
								riqi[i]=s_riqi.substring (start,posi);
								tempposi=posi+1;
								start=start+riqi[i].length()+1;
								i=i+1;
							}
							//分离时间
							i=0;
							start=0;
							while(true)
							{
								posi =s_shijian.indexOf(":",start);
								if(posi==-1)
									posi =s_shijian.indexOf(".",start);
								if(posi==-1)
								{
									shijian[i]=s_shijian.substring (tempposi,s_shijian.length ());
									break;
								}
								shijian[i]=s_shijian.substring (start,posi);
								tempposi=posi+1;
								start=start+riqi[i].length()+1 ;
								i=i+1;
							}
						//分离出来的整型日期时间值
							nian=Integer.valueOf(riqi[0]).intValue();
							yue=Integer.valueOf(riqi[1]).intValue();
							yue=yue-1;
							ri=Integer.valueOf(riqi[2]).intValue();
							shi=Integer.valueOf(shijian[0]).intValue();
							fen=Integer.valueOf(shijian[1]).intValue();
							tqshijian=Integer.valueOf(tqtx).intValue();
							//设置当前日历
							try{
								calendar.set (nian,yue,ri,shi,fen);
								}catch(Exception e){
								desHtml.setErrorID (desHtml.SHOW_SIMPLE_MESSAGE ,"",
													"输入的日期不合法!"
													,"EditChannel?channel=train");

								return false;
								}
							//计算提前后的日历
							calendar.add (calendar.DATE ,1);
							nian=calendar.get(Calendar.YEAR);
							yue=calendar.get(Calendar.MONTH);
							yue=yue+1;
							ri=calendar.get(Calendar.DATE ); 
							shi=calendar.get(Calendar.HOUR_OF_DAY); 
							fen=calendar.get(Calendar.MINUTE); 
							 //类型调整
							riqi[0]=String.valueOf (nian).toString ();
							riqi[1]=String.valueOf (yue).toString ();
							riqi[2]=String.valueOf (ri).toString ();
							shijian[0]=String.valueOf (shi).toString ();
							shijian[1]=String.valueOf (fen).toString ();
							 //格式调整
							if(yue<10)
								riqi[1]="0"+riqi[1];
							if(ri<10)
								riqi[2]="0"+riqi[2];
							if(shi<10)
								shijian[0]="0"+shijian[0];
							if(fen<10)
								shijian[1]="0"+shijian[1];
							txdate=riqi[0]+"-"+riqi[1]+"-"+riqi[2]+" "+shijian[0]+":"+shijian[1];
							//若当前站为下车站
							if(tempstation.compareTo(station)==0)
							{
								
								calendar.add (calendar.HOUR_OF_DAY  ,-tqshijian);
								nian=calendar.get(Calendar.YEAR);
								yue=calendar.get(Calendar.MONTH);
								yue=yue+1;
								ri=calendar.get(Calendar.DATE ); 
								shi=calendar.get(Calendar.HOUR_OF_DAY); 
								fen=calendar.get(Calendar.MINUTE); 
								 //类型调整
								riqi[0]=String.valueOf (nian).toString ();
								riqi[1]=String.valueOf (yue).toString ();
								riqi[2]=String.valueOf (ri).toString ();
								shijian[0]=String.valueOf (shi).toString ();
								shijian[1]=String.valueOf (fen).toString ();
								//格式调整
								if(yue<10)
									riqi[1]="0"+riqi[1];
								if(ri<10)
									riqi[2]="0"+riqi[2];
								if(shi<10)
									shijian[0]="0"+shijian[0];
								if(fen<10)
									shijian[1]="0"+shijian[1];
								txdate=riqi[0]+"-"+riqi[1]+"-"+riqi[2]+" "+shijian[0]+":"+shijian[1];
								//退出while循环
								break;
							}
							ccrq=riqi[0]+"-"+riqi[1]+"-"+riqi[2];
						}	
					}
				
				}
				
			}catch(Exception e){
						 }
		}
		
		queryString="insert into traintx(username,trainid,station,txdate,station_start,name,srdate) values('"
					+CommonMethods.DealWithSQLParameter(p.username) +"','"
					+CommonMethods.DealWithSQLParameter(trainid)+"','"	
					+CommonMethods.DealWithSQLParameter(station)+"','"
					+CommonMethods.DealWithSQLParameter(txdate)+"','"
					+CommonMethods.DealWithSQLParameter(station_start)+"','"
					+CommonMethods.DealWithSQLParameter(name)+"','"
					+CommonMethods.DealWithSQLParameter(srdate)+"')";
		DB.executeUpdate (queryString);
		DB.close ();
		return true;
	}
	
	// 删除
	boolean deleteTrain(String srdate,String trainid,String station,Person p,HtmlOut desHtml)
	{
		if(!checkusertrainid(srdate,station,trainid,p))
		{
			desHtml.setErrorID (desHtml.SHOW_SIMPLE_MESSAGE ,"",
								"还没有定制该车次!"
								,"EditChannel?channel=train");
			
			return false;
		}
		String queryString;
		ResultSet rs;
		DBOperater DB = new DBOperater ("train");
		queryString = "delete from traintx where username='" +
					CommonMethods.DealWithSQLParameter(p.getName()) 
					  + "' AND trainid ='" + CommonMethods.DealWithSQLParameter(trainid) 
					+ "' AND srdate ='" + CommonMethods.DealWithSQLParameter(srdate) 
					  + "' AND station ='" + CommonMethods.DealWithSQLParameter(station) 
					  + "'";
		DB.executeUpdate (queryString);
		
		DB.close ();
		
		return true;

	}
// 检查车次是否合法
	boolean checktrainid(String trainid)
	{
		DBOperater DB = new DBOperater ("train");
		
		ResultSet rs = DB.executeQuery ("select id from train_id where id='"
										+CommonMethods.DealWithSQLParameter(trainid)+"'");
		if(rs==null)
		{
			DB.close();
			return false;
		}
		try{
			if(rs.next()){
				DB.close ();
				return true;
			}
		}catch(Exception e){
		}
		DB.close ();
		return false;
	}
// 检查车次是否已有
	boolean checkusertrainid(String srdate,String station,String trainid,Person p)
	{
		DBOperater DB = new DBOperater ("train");
		
		ResultSet rs = DB.executeQuery ("select trainid from traintx where trainid='"
										+CommonMethods.DealWithSQLParameter(trainid)+"' and "
										+"username='"+CommonMethods.DealWithSQLParameter(p.username )
										+ "' AND srdate ='" + CommonMethods.DealWithSQLParameter(srdate) 
										+"' and station='"+CommonMethods.DealWithSQLParameter(station)+"'");
		if(rs==null)
		{
			DB.close();
			return false;
		}
		try{
			if(rs.next()){
				DB.close ();
				return true;
			}
		}catch(Exception e){
		}
		DB.close ();
		return false;
	}

// 检查站的顺序是否合理
	boolean checkstation(String station,String station_start,String trainid)
	{
		int s_start=0,s_end=0;
		DBOperater DB = new DBOperater ("train");
		
		ResultSet rs = DB.executeQuery ("select stationno from train_info  where station='"
										+CommonMethods.DealWithSQLParameter(station)+"' and "
										+"id='"+CommonMethods.DealWithSQLParameter(trainid)+"'");
		if(rs==null)
		{
			DB.close();
			return false;
		}
		try{
			if(rs.next()){
				s_end=rs.getInt (1);
			}
			else
				return false;
		}catch(Exception e){
		}
		 rs = DB.executeQuery ("select stationno from train_info  where station='"
								+CommonMethods.DealWithSQLParameter(station_start)+"' and "
							+"id='"+CommonMethods.DealWithSQLParameter(trainid)+"'");
		if(rs==null)
		{
			DB.close();
			return false;
		}
		try{
			if(rs.next()){
				s_start=rs.getInt (1);
			}
			else 
				return false;
		}catch(Exception e){
		}
		if(s_end>=s_start)
		{
			DB.close ();
			return true;
		}
		DB.close ();
		return false;
	}
	boolean makeTX(Person p,HtmlOut desHtml,HttpServletRequest request)
	{
		String sSet= request.getParameter ("set");

		String sSet1= request.getParameter ("warnby1");
		String sSet2= request.getParameter ("warnby2");
		
		DBOperater DB = new DBOperater ("train");
		String queryString;

	   	int nTrainTX = 0;
		if( sSet!=null ){
			if( sSet1!=null ){
				nTrainTX |= 1;	
			}
			if( sSet2!=null ){
				nTrainTX |= 2;	
			}
			DB.executeUpdate ( "update person set traintx="
							   +nTrainTX +" where username='"
							   +p.getName()+"'" );
			DB.close ();
			desHtml.setErrorID (desHtml.SHOW_SIMPLE_MESSAGE_WITHCLOSE  ,
								"","设置成功！"
								,"");
			return true;									   
		}
		
		ResultSet rs ;
		try{
			rs= DB.executeQuery ("select traintx from person where username='"
										+p.getName()+"'" );
			if(rs.next ())
				nTrainTX=rs.getInt (1);
		}catch(Exception e){
		}
	   	    
		DB.close();
		
		TemplateList tempList = CommonMethods.getDZTemplate();
		SingleTemplate st = tempList.searchTemplate ("ROOT");
		String sKey;
		for( int i=0;i<st.getKeyNum ();i++){
			sKey=st.getKeyAt (i);
			desHtml.addString(st.getStringAt (i));
			if( sKey .compareTo("cgi-path")==0 )
				desHtml.addString (CommonMethods.sHostNameCGI);
			if( sKey.compareTo ("warnby")==0)
				desHtml.addString (Integer.toString (nTrainTX));
			if( sKey.compareTo ("warncgi")==0)
				desHtml.addString ("ServeTrain");
		}
		desHtml.addString(st.getEndString ());
		
		return true;
	}
	
	
}