investprocess.java

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

				pstat1.close();
				pstat2.close();
				mm.SetType("finish");
				mm.SetNum(0);
				return true;
			}
			else{
				ResultSet rsOfDevelopLogin=stat1.executeQuery("select * from login where id='"+mm.GetMes(2)+"'");
				rsOfDevelopLogin.first();
				ResultSet rsOfInvestLogin=stat2.executeQuery("select * from login where id='"+mm.GetMes(0)+"'");
				rsOfInvestLogin.first();
				rsOfMyInvest.moveToInsertRow();
				rsOfMyInvest.updateString("softname",mm.GetMes(1));
				rsOfMyInvest.updateString("description",rsOfSoftDevelop.getString("description"));
				rsOfMyInvest.updateNull("time");
				rsOfMyInvest.updateFloat("account",Float.parseFloat(rsOfSoftDevelop.getString("cost")));
				rsOfMyInvest.updateFloat("retail",Float.parseFloat(rsOfSoftDevelop.getString("retail")));
				rsOfMyInvest.updateString("bider_id",mm.GetMes(2));
				rsOfMyInvest.updateString("bider_name",rsOfDevelopLogin.getString("name"));
				rsOfMyInvest.updateString("if_done","N");
				rsOfMyInvest.updateFloat("profit", 0);
				rsOfMyInvest.insertRow();
				rsOfSoftDevelop.updateString("if_invested", "Y");
				rsOfSoftDevelop.updateString("investor", rsOfInvestLogin.getString("name"));
				rsOfSoftDevelop.updateRow();
				
				if(rsOfInvestInBank.getFloat("account")<rsOfSoftDevelop.getFloat("cost"))
				{
					System.out.println(id+" investcorp funds inadequate");
					mo.appendmessage(id+" investcorp funds inadequate"+"\n");
					mm.SetType("notenough");
					mm.SetNum(0);
					rsOfMyInvest.close();
					rsOfSoftDevelop.close();
					rsOfDevelopLogin.close();
					rsOfInvestLogin.close();
					rsOfInvestInBank.close();
					stat1.close();
					stat2.close();
					stat3.close();
					stat4.close();
					pstat1.close();
					pstat2.close();
					return true;
				}
				else
				{
					
					float newaAccountOfInvest=rsOfInvestInBank.getFloat("account")-rsOfSoftDevelop.getFloat("cost");
					float newaAccountOfDevelop=rsOfDevelopInBank.getFloat("account")+rsOfSoftDevelop.getFloat("cost");
					rsOfDevelopInBank.updateFloat("account",newaAccountOfDevelop);
					rsOfInvestInBank.updateFloat("account",newaAccountOfInvest);
					rsOfDevelopInBank.updateRow();
					rsOfInvestInBank.updateRow();
					ResultSet rsOfBankClient=stat5.executeQuery("select * from bank_client");
					rsOfBankClient.moveToInsertRow();
					rsOfBankClient.updateString("id",mm.GetMes(0));
					rsOfBankClient.updateString("name",rsOfInvestLogin.getString("name"));
					rsOfBankClient.updateString("h_type","transfer");
					rsOfBankClient.updateString("to_id",mm.GetMes(2));
					rsOfBankClient.updateString("to_name",rsOfDevelopLogin.getString("name"));
					rsOfBankClient.updateFloat("account",Float.parseFloat(rsOfSoftDevelop.getString("cost")));
					rsOfBankClient.insertRow();
					
					rsOfBankClient.close();
				}
				mm.SetType("true");
				mm.SetNum(0);
				System.out.println(id+" InvestCorpInvest success");
				mo.appendmessage(id+" InvestCorpInvest success"+"\n");
				rsOfMyInvest.close();
				rsOfSoftDevelop.close();
				rsOfDevelopLogin.close();
				rsOfInvestLogin.close();
				rsOfInvestInBank.close();
				rsOfDevelopInBank.close();
				stat1.close();
				stat2.close();
				stat3.close();
				stat4.close();
				stat5.close();
				pstat1.close();
				pstat2.close();
				return true;
			}
		}
		catch(SQLException e)
		{
			System.out.println("SQLException!");
			e.printStackTrace();
		}
		return false;
	}
	public boolean InvestCorpSoftDevelopView(MyMessage mm)
	{
		try{
			String id = new String(mm.GetMes(0));
			String cmd="select * from softdevelop_all_".concat(mm.GetMes(0));
			PreparedStatement pstat=conn.prepareStatement(cmd);
			ResultSet rsOfSoftDevelop=pstat.executeQuery();
			if(!rsOfSoftDevelop.next())
			{
				System.out.println("No such a softdevelop company!");//will not excute 
				mm.SetType("false");
				mm.SetNum(0);
				rsOfSoftDevelop.close();
				pstat.close();
				return true;
			}
			else{
			rsOfSoftDevelop.beforeFirst();
			int count=0;
			while(rsOfSoftDevelop.next())
			{
				mm.SetMes(rsOfSoftDevelop.getString("softname"),count++);
				mm.SetMes(rsOfSoftDevelop.getString("description"),count++);
				mm.SetMes(rsOfSoftDevelop.getString("time"),count++);
				mm.SetMes(df.format(rsOfSoftDevelop.getFloat("cost")),count++);
				mm.SetMes(rsOfSoftDevelop.getString("if_done"),count++);
				mm.SetMes(df.format(rsOfSoftDevelop.getFloat("retail")),count++);
				mm.SetMes(rsOfSoftDevelop.getString("ordered"),count++);
				mm.SetMes(rsOfSoftDevelop.getString("sold"),count++);
				mm.SetMes(df.format(rsOfSoftDevelop.getFloat("profit")),count++);
				mm.SetMes(rsOfSoftDevelop.getString("if_invested"),count++);
				mm.SetMes(rsOfSoftDevelop.getString("investor"),count++);
				
				}
				rsOfSoftDevelop.close();
				pstat.close();
				mm.SetType("true");
				mm.SetNum(count);
				System.out.println(id+" InvestCorpSoftDevelopView success");
				mo.appendmessage(id+" InvestCorpSoftDevelopView success"+"\n");
				return true;
			}
		}
		catch(SQLException e)
		{
			System.out.println("SQLException!");
			e.printStackTrace();
		}
		return false;
	}
	public boolean InvestCorpProjectView(MyMessage mm)
	{
		int count=0;
		try
		{
			String id = new String(mm.GetMes(0));
			stat=conn.createStatement();
			PreparedStatement pstat;
			ResultSet rs1=stat.executeQuery("select * from login where type='softdevelop'");
			if(!rs1.next())
			{
				System.out.println("there is no softdevelop companies");
				mm.SetNum(0);
				mm.SetType("false");
				rs1.close();
				stat.close();
				return true;
			}
			else{
				rs1.beforeFirst();
				while(rs1.next())
				{
				String cmd="select * from softdevelop_all_".concat(rs1.getString("id"));
				cmd=cmd.concat(" where if_done='N' and if_invested='N'");
				pstat=conn.prepareStatement(cmd);
				ResultSet rs2=pstat.executeQuery();
				if(!rs2.next())
				{
					continue;
				}
				else
				{
					rs2.beforeFirst();
					while(rs2.next())
					{
						mm.SetMes(rs2.getString("softname"),count++);
						mm.SetMes(rs2.getString("Description"),count++);
						mm.SetMes(rs2.getString("Time"),count++);
						mm.SetMes(df.format(rs2.getFloat("cost")),count++);
						mm.SetMes(rs1.getString("id"),count++);
						mm.SetMes(rs1.getString("name"),count++);
					}
				}
			}
			}
			mm.SetNum(count);
			if(count==0)
			{
				System.out.println(id+" no soft which can be invested");
				mo.appendmessage(id+" no soft which can be invested"+"\n");
				mm.SetType("false");
				mm.SetNum(0);
				rs1.close();
				stat.close();
				return true;
			}
			else
			{
				System.out.println(id+" InvestCorpProjectView success");
				mo.appendmessage(id+" InvestCorpProjectView success"+"\n");
				mm.SetType("true");
				rs1.close();
				stat.close();
				return true;
			}
		}
		catch(SQLException e)
		{
			System.out.println("SQLException!");
			e.printStackTrace();
		}
		return false;
	}
	public boolean InvestCorpMyInvestView(MyMessage mm)
	{
		String cmd="select * from investcorp_myinvest_".concat(mm.GetMes(0));
		try
		{
			String id = new String(mm.GetMes(0));
			PreparedStatement pstat=conn.prepareStatement(cmd);
			ResultSet rs=pstat.executeQuery();
			if(!rs.next())
			{
				System.out.println(id+" no investment");
				mo.appendmessage(id+" no investment"+"\n");
				mm.SetType("false");
				mm.SetNum(0);
				rs.close();
				pstat.close();
				return true;
			}
			else
			{
				rs.last();
				int num=9*rs.getRow();
				mm.SetNum(num);/////
				rs.beforeFirst();
				int count=0;
				while(rs.next())
				{
					mm.SetMes(rs.getString("softname"), count++);
					mm.SetMes(rs.getString("description"), count++);
					mm.SetMes(rs.getString("time"), count++);
					mm.SetMes(df.format(rs.getFloat("account")), count++);
					mm.SetMes(df.format(rs.getFloat("retail")), count++);
					mm.SetMes(rs.getString("bider_id"), count++);
					mm.SetMes(rs.getString("bider_name"), count++);
					mm.SetMes(rs.getString("if_done"), count++);
					mm.SetMes(df.format(rs.getFloat("profit")), count++);
				}
				mm.SetType("true");
				mm.SetNum(count);
				System.out.println(id+" InvestCorpMyInvestView success");
				mo.appendmessage(id+" InvestCorpMyInvestView success"+"\n");
				rs.close();
				pstat.close();
				return true;
			}
		}
		catch(SQLException e)
		{
			System.out.println("SQLException");
			e.printStackTrace();
		}
		return false;
	}
		
	public boolean Release(MyMessage mm)
	{
		try
		{
			String id = new String(mm.GetMes(0));
			String cmd="select * from investcorp_myinvest_".concat(mm.GetMes(0));
			PreparedStatement pstat=conn.prepareStatement(cmd,ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
			stat=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
			Statement stat2=conn.createStatement();
			ResultSet rs=pstat.executeQuery();
			ResultSet rsOfBid=stat.executeQuery("select * from bid where soft_name='"+mm.GetMes(1)+"'");
			Statement stat1=conn.createStatement();
			ResultSet rsOfDevelopLogin=stat1.executeQuery("select * from login where type='softdevelop'");
	    	while(rsOfDevelopLogin.next())
	    	{
	    		ResultSet rsOfDevelop=stat2.executeQuery(("select * from softdevelop_all_".concat(rsOfDevelopLogin.getString("id"))).concat(" where softname='"+mm.GetMes(1)+"'"));
	    		if(rsOfDevelop.next())
	    		{
	    			System.out.println(id+" soft name already exist");
					mo.appendmessage(id+" soft name already exist"+"\n");
	    			mm.SetType("samename");
	    			mm.SetNum(0);
	    			rsOfDevelopLogin.close();
	    			rsOfDevelop.close();
	    			pstat.close();
	    			stat1.close();
	    			stat2.close();
	    			return true;
	    		}
	    	}
			if(rsOfBid.next())
			{
				System.out.println(id+" soft name already exist");
				mo.appendmessage(id+" soft name already exist"+"\n");
				mm.SetType("samename");
				mm.SetNum(0);
				rs.close();
				rsOfBid.close();
				pstat.close();
				stat.close();
				stat2.close();
				return true;
			}
			else{
				rs.moveToInsertRow();
				rs.updateString("softname",mm.GetMes(1));
				rs.updateString("description",mm.GetMes(2));
				rs.updateFloat("account",Float.parseFloat(mm.GetMes(3)));
				rs.updateFloat("retail",Float.parseFloat(mm.GetMes(4)));
				rs.updateFloat("profit",0);
				rs.updateNull("time");
				rs.updateString("bider_id","no one");
				rs.updateString("bider_name","no one");
				rs.updateString("if_done","N");
				rs.insertRow();
				rsOfBid.moveToInsertRow();
				rsOfBid.updateString("soft_name", mm.GetMes(1));
				rsOfBid.updateString("description", mm.GetMes(2));
				rsOfBid.updateNull("time");
				rsOfBid.updateFloat("invest_amount",Float.parseFloat( mm.GetMes(3)));
				ResultSet rsOfLogin=stat2.executeQuery("select * from login where id='"+mm.GetMes(0)+"'");
				rsOfLogin.first();
				rsOfBid.updateString("investor", rsOfLogin.getString("name"));
				rsOfBid.updateString("if_got", "N");
				rsOfBid.insertRow();
				rs.close();
				rsOfBid.close();
				rsOfLogin.close();
				pstat.close();
				stat.close();
				stat2.close();
				mm.SetNum(0);
				mm.SetType("true");
				System.out.println(id+" Release success");
				mo.appendmessage(id+" Release success"+"\n");
				return true;
			}
		}
		catch(SQLException e)
		{
			System.out.println("SQLException!");
			e.printStackTrace();
		}
		return false;
	}

}