中国银行.java

ATM系统存款取款用Java实现的源码文件

//服务器端程序
import java.io.*;import java.net.*;
import java.util.*;import java.sql.*;
public class 中国银行
{   public static void main(String args[])
    {  ServerSocket server=null;Server_thread thread;
       Socket you=null;
       while(true)
       {   try{server=new ServerSocket(4339);
              }
           catch(IOException e1)
             {System.out.println("正在监听");
             }
           try{you=server.accept();
              }
           catch(IOException e)
             {System.out.println("正在等待客户");
             }
           if(you!=null)
             {new Server_thread(you).start();
             }
           else  {continue;}
       }
    }
}





class Server_thread extends Thread
{Socket socket;Connection Con=null;Statement Stmt=null;
 DataOutputStream out=null;DataInputStream in=null;
 String s=null;
 Server_thread(Socket t)
   {socket=t;
    try{in=new DataInputStream(socket.getInputStream());
        out=new DataOutputStream(socket.getOutputStream());
       }
    catch(IOException e){}
    try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
       }
    catch(ClassNotFoundException e)
       {
       }
    try{Con=DriverManager.getConnection("jdbc:odbc:中国银行","hfgzxy","123456");
        Stmt=Con.createStatement();
       }
    catch(SQLException ee){}
   }







 public void run()
  {  while(true)
      {try{s=in.readUTF();
           String 客户帐号=null,客户密码=null,金额=null,转帐号=null,查询帐号=null,查询密码=null,存款=null,ss=null;
           float 转帐金额=0,存款金额=0,取款金额=0,余额=0;
           StringTokenizer fenxi=null;
           ResultSet rs=null,rs1=null;
           int n=0;


           if(s.startsWith("客户离开"))break;



           if(s.startsWith("验证帐号"))
             {fenxi=new StringTokenizer(s,",");
              fenxi.nextToken();
              客户帐号=fenxi.nextToken();
              rs=Stmt.executeQuery("SELECT * FROM 客户信息表 WHERE 帐号="+"'"+客户帐号+"'");
              while(rs.next())
                {查询帐号=rs.getString("帐号");
                 if(客户帐号.equals(查询帐号))
                   {out.writeUTF("有");
                    n=1;
                    break;
                   }
                }
              if(n==0)
                {out.writeUTF("无");
                }
             } 


     
           if(s.startsWith("验证密码"))
             {fenxi=new StringTokenizer(s,",");
              fenxi.nextToken();
              客户帐号=fenxi.nextToken();
              客户密码=fenxi.nextToken();
              rs=Stmt.executeQuery("SELECT * FROM 客户信息表 WHERE 帐号="+"'"+客户帐号+"'");
              while(rs.next())
                {查询帐号=rs.getString("帐号");查询密码=rs.getString("密码");
                 if(客户帐号.equals(查询帐号)&&客户密码.equals(查询密码))
                   {out.writeUTF("正确");
                    n=1;
                    break;
                   }
                }
              if(n==0)
                {out.writeUTF("错误");
                }
             }




           if(s.startsWith("取款"))
             {fenxi=new StringTokenizer(s,",");
              fenxi.nextToken();
              客户帐号=fenxi.nextToken();
              金额=fenxi.nextToken();
              rs=Stmt.executeQuery("SELECT * FROM 客户信息表 WHERE 帐号="+"'"+客户帐号+"'");
              while(rs.next())
                {查询帐号=rs.getString("帐号");存款=rs.getString("存款");
                 try{取款金额=Float.parseFloat(金额);存款金额=Float.parseFloat(存款);
                    if(客户帐号.equals(查询帐号))
                      {if(取款金额<=存款金额)
                        {余额=存款金额-取款金额;
                         ss="UPDATE 客户信息表 SET 存款="+"'"+String.valueOf(余额)+"'"+"WHERE 帐号="+"'"+客户帐号+"'";
                         Stmt.executeUpdate(ss);
                         out.writeUTF("成功");
                         break;
                        }
                       else
                        {out.writeUTF("失败");
                         break;
                        }
                      }
                    }
                catch(NumberFormatException ee){}
                } 
             }




           if(s.startsWith("查询余额"))
             {fenxi=new StringTokenizer(s,",");
              fenxi.nextToken();
              客户帐号=fenxi.nextToken();
              rs=Stmt.executeQuery("SELECT * FROM 客户信息表 WHERE 帐号="+"'"+客户帐号+"'");
              while(rs.next())
                {查询帐号=rs.getString("帐号");
                 if(客户帐号.equals(查询帐号))
                   {out.writeUTF(rs.getString("存款"));
                    break;
                   }
                }
             }





           if(s.startsWith("转帐"))
             {fenxi=new StringTokenizer(s,",");
              fenxi.nextToken();
              客户帐号=fenxi.nextToken();
              金额=fenxi.nextToken();
              转帐号=fenxi.nextToken();
              rs=Stmt.executeQuery("SELECT * FROM 客户信息表 WHERE 帐号="+"'"+客户帐号+"'");
              while(rs.next())
                {查询帐号=rs.getString("帐号");存款=rs.getString("存款");
                 try{转帐金额=Float.parseFloat(金额);存款金额=Float.parseFloat(存款);
                    if(客户帐号.equals(查询帐号))
                      {if(转帐金额<=存款金额)
                        {余额=存款金额-转帐金额;
                         ss="UPDATE 客户信息表 SET 存款="+"'"+String.valueOf(余额)+"'"+"WHERE 帐号="+"'"+客户帐号+"'";
                         Stmt.executeUpdate(ss);
                         rs1=Stmt.executeQuery("SELECT * FROM 客户信息表 WHERE 帐号="+"'"+转帐号+"'");
                         while(rs1.next())
                           {查询帐号=rs1.getString("帐号");存款=rs1.getString("存款");
                            try{转帐金额=Float.parseFloat(金额);存款金额=Float.parseFloat(存款);
                                if(转帐号.equals(查询帐号))
                                  {余额=存款金额+转帐金额;
                                   ss="UPDATE 客户信息表 SET 存款="+"'"+String.valueOf(余额)+"'"+"WHERE 帐号="+"'"+转帐号+"'";
                                   Stmt.executeUpdate(ss);out.writeUTF("成功");break;
                                  }
                               }
                            catch(NumberFormatException ee){}
                           }
                        }
                       else
                        {out.writeUTF("失败");
                        }
                     }
                   }
                 catch(NumberFormatException eee){}
               }
            }




           if(s.startsWith("修改密码"))
            {fenxi=new StringTokenizer(s,",");
              fenxi.nextToken();
              客户帐号=fenxi.nextToken();
              客户密码=fenxi.nextToken();
              rs=Stmt.executeQuery("SELECT * FROM 客户信息表 WHERE 帐号="+"'"+客户帐号+"'");
              while (rs.next())
               {查询帐号=rs.getString("帐号");
                 if(客户帐号.equals(查询帐号))
                   {ss="UPDATE 客户信息表 SET 密码="+"'"+客户密码+"'"+"WHERE 帐号="+"'"+客户帐号+"'";
                    Stmt.executeUpdate(ss);out.writeUTF("成功");
                    break;
                   }
               }
            }





           sleep(50);
        }
        catch(Exception ee)
          {
          }

     }
  }
}