prepayment1.java

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

package org.tyler.ctiRadius;
import java.io.*;
import javax.servlet.*;
import javax.servlet.http.*;
import java.sql.*;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;

import javax.naming.*;
import javax.sql.DataSource;

public class PrePayment1 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);			//取被叫号码第一位赋值给F3
		out.println("	<RtnCode>"+f3+"</RtnCode>");
		int k=Integer.parseInt(f3);				//类型转换
		out.println("	<RtnCode>"+k+"</RtnCode>");
		String f4=request.getParameter("f4");	//取电话详单ID
		int id=Integer.parseInt(f4);			//类型转换
		String f5=request.getParameter("f5");	//判断是否需要还费标识
		String endtime=request.getParameter("endtime");	//通话结束时间
		out.println("	<RtnCode>"+endtime+"</RtnCode>");
		//String类型转换成Date类型，如果时间不为MULL，则需要修改通话结束时间。
		Date end = null;
		if(endtime!=null){
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			try {
				end = sdf.parse(endtime);
				} catch (ParseException pe) {
					System.out.println(pe.getMessage());
			}  
		}
		//判断主叫号是否为空
		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();
				//f5为判断是否需要还费的关键字，为空还费，否则，不还.
				if(f5==null){
				ResultSet rs=stmt.executeQuery("select * from addressnum where number=" + f1);
				if(rs.next()){
					float money1=rs.getFloat("money");	//余额
					out.println("	<RtnCode>"+money1+"</RtnCode>");
					rs.close();
					rs=stmt.executeQuery("select * from rate where prefix=" + k);
				if(rs.next()){
							
				}
				else{
					out.println("	<RtnCode>404</RtnCode>");
				}
				float rate=rs.getFloat("rate");	//费率
				out.println("	<RtnCode>"+rate+"</RtnCode>");
				rs.close();
					float money=money1+rate;
					out.println("	<RtnCode>"+money+"</RtnCode>");
					stmt.executeUpdate("update addressnum set money='"+money+"' where number='"+f1+"'");
				}
				else{
					out.println("	<RtnCode>404</RtnCode>");
				}
			}
				//判断时间时间是否为空，用来判断挂机类型，从而根据通话情况选择不同操作。
				if(endtime==null){
				//根据id修改表teleinfo（通话记录）中字段isthrough（是否通话，0.未通话1.已通话）
				stmt.executeUpdate("update teleinfo set isthrough=0 where id='"+id+"'");
				}
				else{
				ResultSet rs=stmt.executeQuery("select * from teleinfo where id='"+id+"'");
				rs.next();
				Date starttime=rs.getTimestamp("starttime");
				rs.close();
				out.println("	<RtnTime>"+starttime+"</RtnTime>");
				 long m1 = Math.abs(end.getTime() - starttime.getTime()) ; //两时间之差
				 out.println("	<RtnTime>"+m1+"</RtnTime>");
				 double t1=m1/60000.0;
				 out.println("	<RtnTime1>"+t1+"</RtnTime1>");
				 int t2=(int)Math.ceil(t1);
//				 long t2=(long)(t1+0.99);
				 out.println("	<RtnTime2>"+t2+"</RtnTime2>");
				 
				 rs=stmt.executeQuery("select * from rate where prefix=" + k);
				 rs.next();
				 float money2=rs.getFloat("rate")*t2;
				 out.println("	<Rtnmoney2>"+money2+"</Rtnmoney2>");
				 rs.close();
				//根据id修改表teleinfo（通话记录）中字段isthrough（是否通话，0.未通话1.已通话）和字段endtime（通话结束时间）	
				stmt.executeUpdate("update teleinfo set totalmoney='"+money2+"',endtime='"+end+"' where id='"+id+"'");	
				}
				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);
	}
}