prepayment.java

一个用java写的简单的计费系统

package org.tyler.ctiRadius;
import java.io.*;
import javax.servlet.*;
import javax.servlet.http.*;
import java.sql.*;
import javax.naming.*;
import javax.sql.DataSource;

public class PrePayment extends HttpServlet{
	public void doGet(HttpServletRequest request,
						HttpServletResponse response)
			throws IOException,ServletException{
		response.setContentType("text/xml;charset=UTF-8");
		PrintWriter out=response.getWriter();
		out.println("<PrePayment>");

		String f1=request.getParameter("f1");	//取主叫号码
//		out.println("	<RtnCode>"+f1+"</RtnCode>");
		String f2=request.getParameter("f2");	//取被叫号码
//		out.println("	<RtnCode>"+f2+"</RtnCode>");
		String f3=f2.substring(0,1);			//取被叫号码第一位
//		out.println("	<RtnCode>"+f3+"</RtnCode>");
		int k=Integer.parseInt(f3);
//		out.println("	<RtnCode>"+k+"</RtnCode>");
		//判断主叫号码是否为空
		if(f1==null){
			out.println("	<RtnCode>501</RtnCode>");
		}
		else{
			Connection conn = null;
			try{
				Context ctx = new InitialContext(); //得到初始化上下文
				Object obj = ctx.lookup("java:PostgresDS");//查找连接池
				DataSource ds = (DataSource) obj;//转换成DataSource
				conn=ds.getConnection();
				Statement stmt=conn.createStatement();
				//根据主叫号码查询表addressnum
				ResultSet rs=stmt.executeQuery("select * from addressnum where number=" + f1);
				if(rs.next()){
					//定义剩余金额为money1
					float money1=rs.getFloat("money");
					rs.close();
					//根据字冠查询表rate
					rs=stmt.executeQuery("select * from rate where prefix=" + k);
				if(rs.next()){
							
				}
				else{
					out.println("	<RtnCode>404</RtnCode>");
				}
				//定义资费为rate
				float rate=rs.getFloat("rate");
				rs.close();
					//判断余额是否大于等于资费，如果大于资费可以通话，打印200
					if(money1>=rate){
					out.println("	<RtnCode>200</RtnCode>");
//					out.println("	<id>" + rs.getString("numid") + "</id>");
					//预先扣除第一分钟资费
					float money=money1-rate;
//					out.println("	<RtnCodeMoney>"+money+"</RtnCodeMoney>");
					//根据主叫号码修改剩余余额
					stmt.executeUpdate("update addressnum set money='"+money+"' where number='"+f1+"'");
					}
					else{
					out.println("	<RtnCode>403</RtnCode>");
					}
				}
				else{
					out.println("	<RtnCode>404</RtnCode>");
				}
				//查询序列ID
				rs=stmt.executeQuery("select nextval('preson_id_seq')");
				rs.next();
				String id=rs.getString(1);
				int id1=Integer.parseInt(id);
				rs.close();
				out.println("	<RtnCodeID>"+id1+"</RtnCodeID>");
				rs=stmt.executeQuery("select * from rate where prefix=" + k);
				rs.next();
				//插入通话详单
				stmt.execute("insert into teleinfo(id,rate,isthrough,callerid,destcode)values('"+id1+"','"+rs.getFloat("rate")+"',0,'"+f1+"','"+f2+"')");
				rs.close();
				stmt.close();
				conn.close();

			}
			catch(SQLException e){
				out.println("	<RtnCode>502</RtnCode>");
				out.print("	<ErrText>");
				out.print(e.getMessage());
				out.print("</ErrText>");
			}
			catch(NamingException e){
				out.println("	<RtnCode>503</RtnCode>");
			}

		}
		out.println("</PrePayment>");
	}
	
	public void doPost(HttpServletRequest request,
						HttpServletResponse response)
			throws IOException,ServletException{
		doGet(request,response);
	}

}