bank.java

本工程模拟网上社区,其中包括银行,软件销售公司,软件投资公司,茶餐馆,和多个服务器.

   public  String editcode(String account,String newcode)  //修改密码
   {
       connection();
       try{
           PreparedStatement ps=con.prepareStatement("UPDATE Account set 密码=? where 账号=?");
           ps.setString(1,newcode);
           ps.setString(2,account);
           ps.executeUpdate();
           ps.close();
           con.close();
           return "success";
       }catch(SQLException e){ return "fail"; }
   }
   public  String create(String name,String sex,String cardnum,String address,String telnum,String memo)  //创建
   {
       connection();
        try{
            Statement s=con.createStatement();
            String r="insert into Account values(0,0,0,0,0,0,0,0,0.00,0)";
            s.executeUpdate(r);
            s.close();
            Statement st=con.createStatement();
            ResultSet rs=st.executeQuery("select * from Account");
            Calendar c=Calendar.getInstance();
            String account=String.valueOf(c.get(Calendar.MONTH))+String.valueOf(c.get(Calendar.DATE))+String.valueOf(c.get(Calendar.HOUR))+String.valueOf(c.get(Calendar.MINUTE))+String.valueOf(c.get(Calendar.SECOND));            
            Calendar c1=Calendar.getInstance();
            String newtime=String.valueOf(c1.get(Calendar.YEAR))+"-"+String.valueOf(c1.get(Calendar.MONTH)); 
            String code=cardnum.substring(12);
            PreparedStatement ps=con.prepareStatement("UPDATE Account set 账号=? ,密码=?, 姓名=?, 性别=?, 身份证号码=?, 地址=?, 固定电话=?,存款时间=?,余额=?, 备注=? where 余额=0.00");
            ps.setString(1,account);
            ps.setString(2,code);
            ps.setString(3,name);
            ps.setString(4,sex);
            ps.setString(5,cardnum);
            ps.setString(6,address);
            ps.setString(7,telnum);
            ps.setString(8,newtime);
            ps.setDouble(9,1.00);
            ps.setString(10,memo);
            ps.executeUpdate();
            ps.close();
            con.close();
            return "success+"+account+"+"+code;
   }catch(SQLException e){ return e.getMessage(); }
   }
   public  String  delete(String account)   //删除
   {
       connection();
        try{
            PreparedStatement ps=con.prepareStatement("delete from Account where 账号=?");
            ps.setString(1,account);
            ps.executeUpdate();
            ps.close();
            con.close();
            return "success";
        }catch(SQLException e){ return "fail"; }
   } 
   public  String edit(String account,String name,String sex,String cardnum,String address,String telnum,String memo)   //编辑
   {
            connection();
            try{
            PreparedStatement ps=con.prepareStatement("UPDATE Account set  姓名=?, 性别=?, 身份证号码=?, 地址=?, 固定电话=?,  备注=? where 账号=?");
            ps.setString(1,name);
            ps.setString(2,sex);
            ps.setString(3,cardnum);
            ps.setString(4,address);
            ps.setString(5,telnum);
            ps.setString(6,memo);
            ps.setString(7,account);
            ps.executeUpdate();
            ps.close();
            con.close();
            return "success";
            }catch(SQLException e){ return "fail"; }
   }
   public  String payloan(String number)
   {
       connection();
       try{
           Statement s=con.createStatement();
            ResultSet rs=s.executeQuery("select * from Loan");
            while(rs.next()){
                if(rs.getString("编号").equals(number)&&rs.getString("是否还款").equals("否")) break;
            } 
            double money=rs.getDouble("贷款金额");
            int time=rs.getInt("贷款时间");
            double interest=money*time*rs.getDouble("利率");
            String str="success+"+number+"+"+rs.getString("贷款人账号")+"+"+rs.getString("贷款人姓名")+"+"+String.valueOf(money)+"+"+String.valueOf(time)+"+"+String.valueOf(interest);
            PreparedStatement ps=con.prepareStatement("UPDATE Loan set 是否还款=? where 编号=?");
            ps.setString(1,"是");
            ps.setString(2,number);
            ps.executeUpdate();
            s.close();
            ps.close();
            con.close();
            return str;
       }catch(SQLException e){ return e.getMessage(); }
   }
     public String manager(String account,String str)throws IOException
  {
      connection();
      try{
           Statement s=con.createStatement();
            ResultSet rs=s.executeQuery("select * from Account");
            while(rs.next())
            {
                if(rs.getString("账号").equals(account)) break;
            }
            String name=rs.getString("姓名");
            String cstr=account+"  "+name+" :       "+str+"\n";
           FileWriter fout=new FileWriter("D:\\customer.txt",true);
           char b[]=new char[cstr.length()];
           b=cstr.toCharArray();
           fout.write(b);
           fout.flush();
           fout.close();
           return "success";
      }catch(SQLException e){ return "fail"; }
  }
  public void operate()throws IOException
   {
       toCompany=new ServerSocket(PORT);
       try{
           Socket socket=toCompany.accept();
           try{
           BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream()));
           PrintWriter out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
           while(true){
               String str=in.readLine();
               if(str.equals("END"))  break;
               StringTokenizer st=new StringTokenizer(str,"+");
               String temp[]=new String[st.countTokens()];
               for(int i=0;i<temp.length;i++)
              {
                     temp[i]=st.nextToken();
              }
               int op=Integer.parseInt(temp[0]);
               switch(op)
               {
                   case 1:
                       out.println(login(temp[1],temp[2]));
                       break;
                   case 2:
                       out.println(deposit(temp[1],Double.parseDouble(temp[2])));
                       break;
                   case 3:
                       out.println(withdraw(temp[1],Double.parseDouble(temp[2])));
                       break;
                   case 4:
                       out.println(shift(temp[1],temp[2],Double.parseDouble(temp[3])));
                       break;
                   case 5:
                       out.println(loan(temp[1],temp[2],Double.parseDouble(temp[3]),Integer.parseInt(temp[4]),Double.parseDouble(temp[5])));
                       break;
                   case 6:
                       out.println(ask(temp[1]));
                       break;
                   case 7:
                       out.println(editcode(temp[1],temp[2]));
                       break;
                   case 8:
                       out.println(create(temp[1],temp[2],temp[3],temp[4],temp[5],temp[6]));
                       break;
                   case 9: 
                       out.println(delete(temp[1]));
                       break;
                   case 10:
                       out.println(edit(temp[1],temp[2],temp[3],temp[4],temp[5],temp[6],temp[7]));
                       break;
                   case 11:
                       out.println(payloan(temp[1]));
                       break;
                   case 12:
                       out.println(manager(temp[1],temp[2]));
                   default:
                       out.println("fail");   
               }
           }
       }finally{
           socket.close();
       }
       }finally{
           toCompany.close();
       }
  }

}