stockchannel.java

JAVA邮件系统

								"证券代码不正确!"
								,"EditChannel?channel=stock" );
			return false;
		}
		
		DBOperater DB = new DBOperater ("stock");
		String queryString;
		ResultSet rs;

		try 
		{
			queryString = "select count(*) from userstock where username='" +
			      CommonMethods.DealWithSQLParameter (p.getName()) + "' AND stockcode = '" + stockcode + "'";						
	   	    rs = DB.executeQuery(queryString);
	   	    if(rs!=null){
	   			rs.next();
	   			int n = rs.getInt(1);
	   			if(n!=0)
	   			{ // 该股票已经存在
					
	   	    		desHtml.setErrorID (desHtml.SHOW_SIMPLE_MESSAGE ,
										"","你已经选择过该股票！"
									,"EditChannel?channel=stock" );	
					DB.close ();
					return false;
	   			}else
	   			{
	   				queryString = "insert into userstock (username,stockcode,warntype,warnmax,warnmin) values('" +
					  CommonMethods.DealWithSQLParameter (p.getName()) + "','" + stockcode + "',0,1000.0,0.0)";	
					DB.executeUpdate (queryString);
	   			}   		   	    	
			}
		} catch(Exception ex) {
		}
		DB.close ();
		return true;
	}
	
	// 删除股票
	boolean deleteStock(String stockcode,Person p,HtmlOut desHtml)
	{
		if(!checkStockCode(stockcode))
		{
			desHtml.setErrorID (desHtml.SHOW_SIMPLE_MESSAGE ,"",
								"证券代码不正确!"
								,"EditChannel?channel=stock" );
			return false;
		}
		
		DBOperater DB = new DBOperater ("stock");
		String queryString;
		ResultSet rs;


		try 
		{
			queryString = "select count(*) from userstock where username='" +
			      CommonMethods.DealWithSQLParameter (p.getName()) + "' AND stockcode = '" + stockcode + "'";						
	   	    rs = DB.executeQuery(queryString);
	   	    
			if(rs!=null){
	   			rs.next();
	   			int n = rs.getInt(1);
	   			if(n==0)
	   			{ // 该股票不存在
	   	    			
					desHtml.setErrorID (desHtml.SHOW_SIMPLE_MESSAGE ,
										"","证券代码不正确!"
									,"EditChannel?channel=stock" );
					DB.close ();
					return false;
	   			}
				else
	   			{
	   				queryString = "delete from userstock where username='" +
						CommonMethods.DealWithSQLParameter (p.getName()) 
								  + "' AND stockcode ='" + stockcode + "'";						
	   	    		DB.executeUpdate (queryString);
	   	    			
	   			}   		   	    	
			}
		}catch(Exception ex) {
			desHtml.setErrorID (desHtml.SHOW_SIMPLE_MESSAGE ,
									"","数据库操作失败!"
		
									,"EditChannel?channel=stock" );
			DB.close ();
			return false;
		}
		DB.close ();
		return true;

	}
	
	
	// 编辑股票警报页面
	boolean editWarn(String stockcode,Person p,HtmlOut desHtml)
	{
		if(!checkStockCode(stockcode))
		{
			desHtml.setErrorID (desHtml.SHOW_SIMPLE_MESSAGE ,"",
								"证券代码不正确!"
								,"EditChannel?channel=stock" );
			return false;
		}
		
		DBOperater DB = new DBOperater ("stock");
		String queryString;
		
		ResultSet rs;
		
		int warntype=0;
		String warnmax="",warnmin="";


		try 
		{
			queryString = "select * from userstock where username='" +
			      CommonMethods.DealWithSQLParameter (p.getName()) + "' AND stockcode = '" + stockcode + "'";						
	   	    rs = DB.executeQuery(queryString);
	   	    if(rs!=null){
	   			if(!rs.next())
	   			{ // 该股票不存在
	   	    			
					desHtml.setErrorID (desHtml.SHOW_SIMPLE_MESSAGE ,"",
										"你没有选择过该股票!"
									,"EditChannel?channel=stock" );
					DB.close ();
					return false;
	   			}else
	   			{
	   	    			warntype = rs.getInt("warntype");
	   	    			warnmax = rs.getString("warnmax");
	   	    			warnmin = rs.getString("warnmin");
						double warnminv,warnmaxv;
						warnminv= CommonMethods.GetDouble (warnmin,0);
						warnmaxv= CommonMethods.GetDouble (warnmax,1000);
						warnmin= CommonMethods.FormatDouble(warnminv,2);
						warnmax= CommonMethods.FormatDouble(warnmaxv,2);
						if( warnminv<=0 )
							warnmin = "";
						if( warnmaxv>=999 )
							warnmax = "";
	   			}   		   	    	
			}
		} catch(Exception ex) {
			
		}
		DB.close ();
		
		KeyResultList kr = new KeyResultList();
		TemplateList tl = CommonMethods.getEditStockTemplate1();
		SingleTemplate st = tl.searchTemplate("ROOT");
		
		kr.setKeyResult("cgi-path",CommonMethods.sHostNameCGI);
		kr.setKeyResult("warnmax",warnmax);
		kr.setKeyResult("warnmin",warnmin);
		kr.setKeyResult("股票名称",stockcode);
		if(warntype==0)
		{
			kr.setKeyResult("warnon","");
			kr.setKeyResult("warnoff","checked");
		}else
		{
			kr.setKeyResult("warnon","checked");
			kr.setKeyResult("warnoff","");
		}
		
		desHtml.addString(st.makeResult(kr));
		
		return true;
	}

	// 编辑股票警报内容
	boolean makeWarn(String stockcode,Person p,HtmlOut desHtml,HttpServletRequest request)
	{
		if(!checkStockCode(stockcode))
		{
			desHtml.setErrorID (desHtml.SHOW_SIMPLE_MESSAGE ,"",
								"证券代码不正确!"
								,"EditChannel?channel=stock" );
			return false;
		}
		
		DBOperater DB = new DBOperater ("stock");
		String queryString;

		try 
		{
			int warntype=1;
			double warnmax,warnmin;
		
			// 提醒开关
			String sMax = request.getParameter("warnmax");
			String sMin = request.getParameter("warnmin");
			try{
				warnmax = Double.valueOf (sMax).doubleValue ();
			}catch(Exception e){
				warnmax = 1000;
			}
			try{
				warnmin = Double.valueOf (sMin).doubleValue ();
			}catch(Exception e){
				warnmin = -1;
			}

			queryString = "update userstock SET warntype = " + warntype +
				",warnmax = " + warnmax + ",warnmin = " + warnmin + 
				" where username='" +
			      CommonMethods.DealWithSQLParameter (p.getName()) 
						  + "' AND stockcode = '" + stockcode + "'";
	   	    DB.executeUpdate(queryString);
	   	    	
	   	    
		} catch(Exception ex) {
			
		}
		DB.close();
		return true;
	}
	

	// 检查股票代码是否合法
	static public boolean checkStockCode(String stockcode)
	{
		DBOperater DB = new DBOperater ("stock");
		
		ResultSet rs = DB.executeQuery ("select ZQID from ZQ_ZQINFO where ZQID='"
										+stockcode+"'");
		if(rs==null)
		{
			DB.close();
			return false;
		}
		try{
			if(rs.next()){
				DB.close ();
				return true;
			}
		}catch(Exception e){
		}
		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 ("stock");
		String queryString;

	   	int nStockTX = 0;
		if( sSet!=null ){
			if( sSet1!=null ){
				nStockTX |= 1;	
			}
			if( sSet2!=null ){
				nStockTX |= 2;	
			}
			DB.executeUpdate ( "update person set stocktx="
							   +nStockTX +" where username='"
							   +p.getName()+"'" );
			DB.close ();
			desHtml.setErrorID (desHtml.SHOW_SIMPLE_MESSAGE_WITHCLOSE  ,
								"","设置成功！"
								,"");
			return true;									   
		}
		
		ResultSet rs ;
		try{
			rs= DB.executeQuery ("select stocktx from person where username='"
										+p.getName()+"'" );
			if(rs.next ())
				nStockTX=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 (nStockTX));
			if( sKey.compareTo ("warncgi")==0)
				desHtml.addString ("ServeStock");
		}
		desHtml.addString(st.getEndString ());
		
		return true;
	}
	
}