bankprocess.java

java版虚拟社区,在mysql上运行.

		       mm.SetType("false");
		       mm.SetNum(0);
		       System.out.println("No client for bank");
		       mo.appendmessage("No client for bank"+"\n");
		       rs.close();
		       stat.close();
		       return true;
			}
			else
			{
				rs.last();
				int num=rs.getRow();
				rs.beforeFirst();
				mm.SetNum(num*7);
				mm.SetType("true");
				int i=0,j=1;
				while(rs.next())
				{
					j=2;
					for(;j<=8;i++,j++)
					{
						if(j == 6 || j == 7)
						{
							mm.SetMes(df.format(rs.getFloat(j)),i);	
						}
						else
						{
							mm.SetMes(rs.getString(j), i);	
						}
					}
					
				}
				System.out.println("BankAllView success");
				mo.appendmessage("BankAllView success"+"\n");
				rs.close();
			    stat.close();
			    return true;
			}
			    
			
		}
		catch(SQLException e)
		{
			e.printStackTrace();
			System.out.println("SQLException!");
		 
		}
		return false;
	}
	public boolean Loan(MyMessage mm)
	{
		try
		{ 
			String id = new String(mm.GetMes(0));
			stat = conn.createStatement();
			ResultSet result = stat.executeQuery("SELECT * FROM login WHERE id = '"+mm.GetMes(0)+"'");
			result.next();
			String type = result.getString("type");
			String name = result.getString("name");
			
		
			stat.execute("INSERT INTO bank_loan VALUES(NULL,'"+type+"','"+mm.GetMes(0)+"'," +
					"'"+name+"','"+Float.parseFloat(mm.GetMes(1))+"',NULL,'N','N')");
			
			stat.execute("INSERT INTO bank_client VALUES(NULL,'"+mm.GetMes(0)+"','"+name+"'," +
					"'loan','"+Float.parseFloat(mm.GetMes(1))+"',NULL,'','')");
	
			result.close();
			stat.close();
			mm.SetType("true"); 
			System.out.println(id +" Loan success");
			mo.appendmessage(id +" Loan success"+"\n");
			mm.SetNum(0);
			return true;
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
	public boolean Transfer(MyMessage mm)
	{
		try
		{ 
			String id1 = new String(mm.GetMes(0));
			String id2 = new String(mm.GetMes(1));
			stat = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                    ResultSet.CONCUR_UPDATABLE);
			ResultSet result = stat.executeQuery("SELECT * FROM bank_account WHERE id = '"+mm.GetMes(1)+"'");
	
			
			if(result.next())
			{
				
				result = stat.executeQuery("SELECT * FROM bank_account WHERE id = '"+mm.GetMes(0)+"'");
				result.next();
				if(result.getFloat("account") > Float.parseFloat(mm.GetMes(2)))
				{
					String name = result.getString("name");
										
					float temp = result.getFloat("account") - Float.parseFloat(mm.GetMes(2));
					result.updateFloat("account", temp);
					result.updateRow();
					
					result = stat.executeQuery("SELECT * FROM bank_account WHERE id = '"+mm.GetMes(1)+"'");
					result.next();
					temp = result.getFloat("account") + Float.parseFloat(mm.GetMes(2));
					result.updateFloat("account", temp);
					result.updateRow();
					
					stat.execute("INSERT INTO bank_client VALUES(NULL,'"+mm.GetMes(0)+"','"+name+"'," +
							"'transfer','"+Float.parseFloat(mm.GetMes(2))+"',NULL,'"+mm.GetMes(1)+"','"+result.getString("name")+"')");
					System.out.println(id1+" transfer to "+id2+" success");
					mo.appendmessage(id1+" transfer to "+id2+" success"+"\n");
					mm.SetType("true"); 
					mm.SetNum(0);
				}
				else
				{
					mm.SetType("notenough");
					System.out.println(id1+" account not enough");
					mo.appendmessage(id1+" account not enough"+"\n");
					mm.SetNum(0);
				}
				
			}
			else
			{
				mm.SetType("notexsit");
				mm.SetNum(0);
			}
			result.close();
			stat.close();
			return true;
		
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
	public boolean Deposit(MyMessage mm)
	{
		try
		{ 
			String id = new String(mm.GetMes(0));
			stat = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                    ResultSet.CONCUR_UPDATABLE);
			
			stat2 = conn.createStatement();
			
			ResultSet result = stat.executeQuery("SELECT * FROM bank_account WHERE id = '"+mm.GetMes(0)+"'");
			result.next();
			
			stat2.execute("INSERT INTO bank_client VALUES(NULL,'"+mm.GetMes(0)+"','"+result.getString("name")+"'," +
					"'deposit','"+Float.parseFloat(mm.GetMes(1))+"',NULL,'','')");

			if(result.getFloat("cash") > Float.parseFloat(mm.GetMes(1)))
			{
				float temp = result.getFloat("account") + Float.parseFloat(mm.GetMes(1));
				float cash = result.getFloat("cash") - Float.parseFloat(mm.GetMes(1));
				result.updateFloat("account", temp);
				result.updateFloat("cash",cash);
				result.updateRow();
				System.out.println(id+" Deposit success");
				mo.appendmessage(id+" Deposit success"+"\n");
				mm.SetType("true");
			}
			else
			{
				System.out.println(id+" Deposit cash not enough");
				mo.appendmessage(id+" Deposit cash not enough"+"\n");
				mm.SetType("false");
			}
			mm.SetNum(0);
			result.close();
			stat.close();
			return true;
		
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
	public boolean Withdraw(MyMessage mm)
	{
		try
		{ 
			String id = new String(mm.GetMes(0));
			stat = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                    ResultSet.CONCUR_UPDATABLE);
			ResultSet result = stat.executeQuery("SELECT * FROM bank_account WHERE id = '"+mm.GetMes(0)+"'");
			result.next();
			
			if(result.getFloat("account") > Float.parseFloat(mm.GetMes(1)))
			{
		
				float temp = result.getFloat("account") - Float.parseFloat(mm.GetMes(1));
				result.updateFloat("account", temp);
				temp = result.getFloat("cash") + Float.parseFloat(mm.GetMes(1));
				result.updateFloat("cash", temp);
				result.updateRow();
				System.out.println(id+" Withdraw success");
				mo.appendmessage(id+" Withdraw success"+"\n");
				mm.SetType("true");
				mm.SetNum(0);
				
				stat.execute("INSERT INTO bank_client VALUES(NULL,'"+mm.GetMes(0)+"','"+result.getString("name")+"'," +
						"'withdraw','"+Float.parseFloat(mm.GetMes(1))+"',NULL,'','')");
				
			}
			else
			{
				mm.SetType("notenough");
				System.out.println(id+" account not enough");
				mo.appendmessage(id+" account not enough"+"\n");
				mm.SetNum(0);
			}
			result.close();
			stat.close();
			return true;
		
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
	public boolean CheckAccount(MyMessage mm)
	{
		try
		{ 
			String id = new String(mm.GetMes(0));
			stat = conn.createStatement();
			ResultSet result = stat.executeQuery("SELECT * FROM bank_account WHERE id = '"+mm.GetMes(0)+"'");
			result.next();
			
			mm.SetType("true");
			mm.SetNum(3);
			mm.SetMes(df.format(result.getFloat("account")), 0);
			mm.SetMes(df.format(result.getFloat("cash")), 1);
			mm.SetMes(result.getString("time"), 2);
			
			result.close();
			stat.close();
			System.out.println("CheckAccount success"); 
			System.out.println(id+" CheckAccount success");
			mo.appendmessage(id+" CheckAccount success"+"\n");
			return true;
		
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
	
	public boolean Loginbank(MyMessage mm)
	{
		try
		{ 
			stat = conn.createStatement();
			ResultSet result = stat.executeQuery("SELECT * FROM bank_account WHERE id = '"+mm.GetMes(0)+"'");
			if(result.next())
			{
				if(result.getString("password").equals(mm.GetMes(1)))
				{
					mm.SetType("OK");
					mm.SetNum(0);
					System.out.println(result.getString("id")+" Login bank success");
					mo.appendmessage(result.getString("id")+" Login bank success"+"\n");
				}
				else
				{
					mm.SetType("WPASS");	
					mm.SetNum(0);
					System.out.println(result.getString("id")+" Wrong password");
					mo.appendmessage(result.getString("id")+" Wrong password"+"\n");
				}
			}
			else
			{
				mm.SetType("WID");
				mm.SetNum(0);
				System.out.println(mm.GetMes(0)+" bank account not exsit");
				mo.appendmessage(mm.GetMes(0)+" bank account not exsit"+"\n");
			}
			result.close();
			stat.close();
			return true; 
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
	
	public boolean IfNewAccount(MyMessage mm)
	{
		try
		{ 
			stat = conn.createStatement();
			ResultSet result = stat.executeQuery("SELECT * FROM bank_account WHERE id = '"+mm.GetMes(0)+"'");
			if(result.next())
			{
				System.out.println(mm.GetMes(0)+" already hava a account");
				mo.appendmessage(mm.GetMes(0)+" already hava a account"+"\n");
				mm.SetType("false");
				mm.SetNum(0);
				
			}
			else
			{
				mm.SetType("true");
				mm.SetNum(0);
			}
			result.close();
			stat.close();
			return true; 
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
		
	public boolean NewAccount(MyMessage mm)
	{
		try
		{ 
			stat = conn.createStatement();
			
			ResultSet result = stat.executeQuery("SELECT * FROM login WHERE id = '"+mm.GetMes(1)+"'");
			result.next();
			String name = result.getString("name");
			
			stat.execute("INSERT INTO bank_account VALUES(NULL,'"+mm.GetMes(0)+"'," +
					"'"+mm.GetMes(1)+"','"+name+"','"+mm.GetMes(2)+"','"+mm.GetMes(3)+"'," +
							"'"+mm.GetMes(4)+"',NULL)");
			mm.SetType("true");
			mm.SetNum(0);
			result.close();
			stat.close();
			System.out.println(mm.GetMes(0)+" NewAccount success");
			mo.appendmessage(mm.GetMes(0)+" NewAccount success"+"\n");
			return true;     
		
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}

}