mult.java

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

package investcompanyserver;

import java.net.*;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.io.*;
import java.util.*;
import java.sql.*;

public class Mult extends Thread {
	private Socket socket;

	private BufferedReader in;

	private PrintWriter out;

	public Mult(Socket s) throws IOException {
		socket = s;
		in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket
				.getOutputStream())), true);
		start();

	}

	public void run() {

		try {
			while (true) {
				String str = in.readLine();
				StringTokenizer stn = new StringTokenizer(str.trim(), "/");
				String[] temp = { " ", " ", " ", " ", " ", " ", "", "", "", "",
						"", "" };
				int i = 0;
				while (stn.hasMoreTokens()) {
					temp[i] = stn.nextToken();
					i++;
				}
				if (temp[0].equals("login")) {
					String url = sqlready.sqlready();
					boolean flag = false; // see if the ID and code is
					// righr
					try {
						Connection con = DriverManager.getConnection(url);
						Statement s = con.createStatement();
						ResultSet rs = s.executeQuery("select * from IDBase");
						while (rs.next()) {
							if (rs.getString("id").equals(temp[1])
									&& rs.getString("code").equals(temp[2])) {
								flag = true;
								break;
							}
						}
						if (flag) {
							out.println("true");
							out.flush();
						} else {
							out.println("false");
							out.flush();
						}
						s.close();
						con.close();
					} catch (SQLException e) {
						System.out.println(e);
					}
				}
				if (temp[0].equals("enroll")) {
					String ual = sqlready.sqlready();
					boolean flag = false;
					try {
						Connection con = DriverManager.getConnection(ual);
						Statement q = con.createStatement();
						ResultSet rs = q
								.executeQuery("select * from IDBase where type = 'investor'");
						while (rs.next()) {
							if (rs.getString("id").equals(temp[1])) {
								flag = true;
								break;
							}
						}

						if (flag) {
							out.println("idexists");
						} else {
							PreparedStatement s = con
									.prepareStatement("insert into IDBase values(?,?,?,?,?,?,?)");
							s.setString(1, temp[1]);
							s.setString(2, temp[2]);
							s.setString(3, temp[3]);
							s.setString(4, temp[4]);
							s.setString(5, temp[5]);
							s.setString(6, temp[6]);
							s.setString(7, temp[7]);
							s.executeUpdate();

							out.println("eok");
						}
					} catch (SQLException e) {

					}

				}
				if (temp[0].equals("bid")) {
					String ual = sqlready.sqlready();
					String name = temp[1];
					String id = temp[2];

					String cost = temp[3];

					String bidder = "";
					String detail = "";
					String duetime = "";

					boolean flag = false, mark = false;
					try {
						Connection con = DriverManager.getConnection(ual);
						PreparedStatement s = con
								.prepareStatement("select * from gss where project =?");
						s.setString(1, name);
						ResultSet rs = s.executeQuery();
						while (rs.next()) {

							bidder = rs.getString("bidder");
							detail = rs.getString("detail");
							duetime = rs.getString("duetime");
							String s12 = rs.getString("developer");

							if (s12.equals("?")) {
								mark = true;
								break;
							} else if (s12.equals(id)) {

								flag = true;
								break;
							}
						}

						if (mark) {

							PreparedStatement r = con
									.prepareStatement("update gss set developer = ?,cost=? where project = ? ");
							r.setString(1, id);
							r.setDouble(2, Double.parseDouble(cost));
							r.setString(3, name);
							r.executeUpdate();
						} else if (flag) {
							PreparedStatement r = con
									.prepareStatement("update gss set developer = ?,cost=? where project = ?");
							r.setString(1, id);
							r.setDouble(2, Double.parseDouble(cost));
							r.setString(3, name);
							r.executeUpdate();
						} else {
							PreparedStatement r = con
									.prepareStatement("insert into gss values(?,?,?,?,?,?,'no')");
							r.setString(1, name);
							r.setString(2, id);
							r.setString(3, bidder);
							r.setDouble(4, Double.parseDouble(cost));
							r.setString(5, detail);
							r.setString(6, duetime);
							r.executeUpdate();
						}
						out.println("bok");

					} catch (SQLException e) {
						System.out.println("SQLException :" + e.getMessage());
					}

				}
				if (temp[0].equals("validate")) {
					String name = "";
					String url = sqlready.sqlready();
					boolean flag = false; // see if the ID and code is
					try {
						Connection con = DriverManager.getConnection(url);
						Statement s = con.createStatement();
						ResultSet rs = s
								.executeQuery("select * from IDBase where type = 'investor'");
						while (rs.next()) {
							if (rs.getString("id").equals(temp[1])
									&& rs.getString("code").equals(temp[2])) {
								flag = true;
								name = rs.getString("monicker");
								break;
							}
						}
						if (flag) {
							out.println("true" + "/" + name);
							out.flush();
						} else {
							out.println("false");
							out.flush();
						}
						s.close();
						con.close();
					} catch (SQLException e) {
						System.out.println(e);
					}
				}
				if (temp[0].equals("top")) {
					String y = "yes";
					String br = temp[2];
					String p = temp[1];

					String url = sqlready.sqlready();
					try {

						out.flush();
						Connection connect = DriverManager.getConnection(url);
						Statement state = connect.createStatement(
								ResultSet.TYPE_SCROLL_INSENSITIVE,
								ResultSet.CONCUR_UPDATABLE);

						String sq = "select * from gss where  project = '"
								+ p.trim() + "'and developer = '" + br.trim()
								+ "'";
						ResultSet rs = state.executeQuery(sq);

						rs.absolute(1);
						rs.updateString("isComplete", "yes");
						rs.updateRow();
						PreparedStatement gs = connect
								.prepareStatement("delete from gss where project= ? and  isComplete =? ");

						gs.setString(1, p);
						gs.setString(2, "no");

						gs.executeUpdate();

						out.println("biok");
					} catch (SQLException e) {
						System.out.println("错误" + e);
					}

				}
				if (temp[0].equals("bidhandle")) {
					String bidder = temp[1];

					String url = sqlready.sqlready();
					try {
						out.println("vectorstart");
						out.flush();
						Connection connect = DriverManager.getConnection(url);
						PreparedStatement state = connect
								.prepareStatement("select * from gss where bidder= ? ");
						state.setString(1, bidder);
						ResultSet rs = state.executeQuery();

						while (rs.next()) {
							String iscomplete = rs.getString("isComplete");
							String project = rs.getString("project");
							String developer = rs.getString("developer");
							String b = bidder;
							String cost = rs.getString("cost");
							String detail = rs.getString("detail");
							String duetime = rs.getString("duetime");

							String transfer = project + "/" + developer + "/"
									+ b + "/" + cost + "/" + detail + "/"
									+ duetime + "/" + iscomplete;
							out.println(transfer);
							out.flush();
						}

						out.println("Vectorover");
						out.flush();

					} catch (SQLException e) {
						System.out.println("错误" + e);
					}

				}
				if (temp[0].equals("validate02")) {
					String name = "";
					String url = sqlready.sqlready();
					boolean flag = false; // see if the ID and code is
					try {
						Connection con = DriverManager.getConnection(url);
						Statement s = con.createStatement();
						ResultSet rs = s
								.executeQuery("select * from IDBase where type = 'developer'");
						while (rs.next()) {
							if (rs.getString("id").equals(temp[1])
									&& rs.getString("code").equals(temp[2])) {
								flag = true;
								name = rs.getString("monicker");
								break;
							}
						}
						if (flag) {
							out.println("true" + "/" + name);
							out.flush();
						} else {
							out.println("false");
							out.flush();
						}
						s.close();
						con.close();
					} catch (SQLException e) {
						System.out.println(e);
					}
				}
				if (temp[0].equals("list")) {
					out.println("start");
					String url = sqlready.sqlready();
					try {
						Connection connect = DriverManager.getConnection(url);
						Statement state = connect.createStatement();
						ResultSet rs = state
								.executeQuery("select * from IDBase where type = 'developer'");

						while (rs.next()) {
							String name = rs.getString("monicker");
							String detail = rs.getString("detail");
							String bonds = rs.getString("bonds");
							String peo = rs.getString("people");
							String t = name + "/" + detail + "/" + bonds + "/"
									+ peo;
							out.println(t);

						}

						out.println("over");
					} catch (SQLException e) {
						System.out.println("错误" + e);
					}
				}
				if (temp[0].equals("flesh")) {
					String url = sqlready.sqlready();
					try {
						out.println("vector3");
						out.flush();
						Connection connect = DriverManager.getConnection(url);
						Statement state = connect.createStatement();
						ResultSet rs = state
								.executeQuery("select * from gss where isComplete ='no' ");

						while (rs.next()) {
							String iscomplete = rs.getString("isComplete");
							String project = rs.getString("project");
							String developer = rs.getString("developer");
							String bidder = rs.getString("bidder");

							String detail = rs.getString("detail");
							String duetime = rs.getString("duetime");

							String transfer = project + "/" + developer + "/"
									+ bidder + "/" + detail + "/" + duetime
									+ "/" + iscomplete;
							out.println(transfer);
							out.flush();
						}

						out.println("3over");
						out.flush();
						rs = state
								.executeQuery("select * from gss where isComplete ='yes' ");
						out.println("vector4");
						while (rs.next()) {
							String iscomplete = rs.getString("isComplete");
							String project = rs.getString("project");
							String developer = rs.getString("developer");
							String bidder = rs.getString("bidder");
							Double pay = rs.getDouble("cost");
							String detail = rs.getString("detail");
							String duetime = rs.getString("duetime");
							String transfer = project + "/" + developer + "/"
									+ bidder + "/" + pay.toString() + "/"
									+ detail + "/" + duetime + "/" + iscomplete;

							out.println(transfer);
						}
						out.println("4over");
					} catch (SQLException e) {
						System.out.println("错误" + e);
					}

				}
				if (temp[0].equals("bh")) {
					String bidder = temp[1];
					String ual = sqlready.sqlready();
					try {
						out.println("vectorstart");
						out.flush();
						Connection connect = DriverManager.getConnection(ual);
						PreparedStatement state = connect
								.prepareStatement("select * from gss where bidder= ? ");
						state.setString(1, bidder);
						ResultSet rs = state.executeQuery();

						while (rs.next()) {
							String iscomplete = rs.getString("isComplete");
							String project = rs.getString("project");
							String developer = rs.getString("developer");
							String b = bidder;
							String cost = rs.getString("cost");
							String detail = rs.getString("detail");
							String duetime = rs.getString("duetime");

							String transfer = project + "/" + developer + "/"
									+ b + "/" + cost + "/" + detail + "/"
									+ duetime + "/" + iscomplete;
							out.println(transfer);
							out.flush();
						}

						out.println("Vectorover");
						out.flush();

					} catch (SQLException e) {
						System.out.println("错误" + e);
					}
				}
				if (temp[0].equals("show")) {

					String ual = sqlready.sqlready();
					String m = temp[1];
					String d = "?";
					String project = temp[2];
					String detail = temp[3];
					String duetime = temp[4];

					boolean flag = false, mark = false;
					try {
						Connection con = DriverManager.getConnection(ual);
						Statement s = con.createStatement();
						ResultSet rs = s.executeQuery("select * from gss ");
						while (rs.next()) {
							if (rs.getString("project").equals(project)) {
								out.println("has");
								flag = true;
								break;
							}

						}

						if (!flag) {
							PreparedStatement r = con
									.prepareStatement("insert into gss values(?,?,?,?,?,?,?)");

							r.setString(1, project);
							r.setString(2, d);
							r.setString(3, m);
							r.setDouble(4, 0.00);
							r.setString(5, detail);
							r.setString(6, duetime);
							r.setString(7, "no");
							r.executeUpdate();

							out.println("hok");
						}

					} catch (SQLException e) {
						System.out.println("SQLException :" + e.getMessage());
					}
				}
				if (temp[0].equals("developframe")) {
					String url = sqlready.sqlready();
					try {
						out.println("vector1");
						out.flush();
						Connection connect = DriverManager.getConnection(url);
						Statement state = connect.createStatement();
						ResultSet rs = state
								.executeQuery("select * from gss where isComplete ='no' ");

						while (rs.next()) {
							String iscomplete = rs.getString("isComplete");
							String project = rs.getString("project");
							String developer = rs.getString("developer");
							String bidder = rs.getString("bidder");

							String detail = rs.getString("detail");
							String duetime = rs.getString("duetime");

							String transfer = project + "/" + developer + "/"
									+ bidder + "/" + detail + "/" + duetime
									+ "/" + iscomplete;
							out.println(transfer);
							out.flush();
						}

						out.println("1over");
						out.flush();
						rs = state
								.executeQuery("select * from gss where isComplete ='yes' ");
						out.println("vector2");
						while (rs.next()) {
							String iscomplete = rs.getString("isComplete");
							String project = rs.getString("project");
							String developer = rs.getString("developer");
							String bidder = rs.getString("bidder");
							Double pay = rs.getDouble("cost");
							String detail = rs.getString("detail");
							String duetime = rs.getString("duetime");
							String transfer = project + "/" + developer + "/"
									+ bidder + "/" + pay.toString() + "/"
									+ detail + "/" + duetime + "/" + iscomplete;

							out.println(transfer);
						}
						out.println("2over");
					} catch (SQLException e) {
						System.out.println("错误" + e);
					}
				}
			}
		} catch (IOException e) {
			System.out.println("与客户端断开连接！");
		}

	}
}