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);
	}

}