Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package Server;
- import Users.*;
- import Products.ProductBase;
- import Products.ProductCart;
- import Orders.Order;
- import java.io.BufferedReader;
- import java.io.BufferedWriter;
- import java.io.IOException;
- import java.io.InputStreamReader;
- import java.io.ObjectInputStream;
- import java.io.ObjectOutputStream;
- import java.io.OutputStreamWriter;
- import java.io.PrintWriter;
- import java.net.ServerSocket;
- import java.net.Socket;
- import java.util.Collection;
- import java.util.logging.Level;
- import java.util.logging.Logger;
- class ServeOneJabber extends Thread {
- private Socket socket;
- private BufferedReader in;
- private PrintWriter out;
- public ServeOneJabber(Socket s) throws IOException {
- socket = s;
- in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
- // Включаем автоматическое выталкивание:
- out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket
- .getOutputStream())), true);
- // Если любой из вышеприведенных вызовов приведет к
- // возникновению исключения, то вызывающий отвечает за
- // закрытие сокета. В противном случае, нить
- // закроет его.
- start(); // вызываем run()
- }
- public void run() {
- try
- {
- while (true)
- {
- ObjectInputStream sois = new ObjectInputStream(socket.getInputStream()); //создание потока ввода
- ObjectOutputStream soos = new ObjectOutputStream(socket.getOutputStream());// создание потока вывода
- String string;
- string = (String)sois.readObject();
- if(string.equals("Authorization"))
- {
- string = (String)sois.readObject();
- User user = new User(string, (String)sois.readObject());
- int group = user.Get();
- if(group == 1)
- {
- soos.writeObject("admin");
- }
- if(group == 2)
- {
- soos.writeObject(user.GetLogin());
- }
- if(group == 0)
- {
- soos.writeObject("0");
- }
- }
- if(string.equals("Registration"))
- {
- string = (String)sois.readObject();
- User user = new User(string, (String)sois.readObject());
- user.setL();
- if(user.Get() == 3)
- {
- soos.writeObject("0");
- }
- else
- {
- user.Register();
- soos.writeObject("1");
- }
- }
- if(string.equals("GAddCart"))
- {
- String [] stringAddCard = (String[])sois.readObject();
- ProductCart cart = new ProductCart(stringAddCard[0]);
- cart.AddCart(stringAddCard[1], stringAddCard[2], stringAddCard[3]);
- }
- if(string.equals("GRemoveCart"))
- {
- String removeRow = (sois.readObject()).toString();
- ProductCart cartRemove = new ProductCart();
- cartRemove.remove(removeRow);
- }
- if(string.equals("GRemoveAllCart"))
- {
- String removeRow = (sois.readObject()).toString();
- ProductCart cartRemove = new ProductCart();
- cartRemove.removeAll(removeRow);
- }
- if(string.equals("GAddOrder"))
- {
- String order = (sois.readObject()).toString();
- ProductCart cartOrder = new ProductCart(order);
- cartOrder.setContact((sois.readObject()).toString());
- cartOrder.addOrder();
- }
- if(string.equals("GGetHistory"))
- {
- System.out.println("azazazaz");
- String Login = (sois.readObject()).toString();
- System.out.println("azazazaz");
- Order order = new Order(Login);
- String [][] base = order.getHistory();
- soos.writeObject(base);
- }
- if(string.equals("AAcceptOrder"))
- {
- String acceptId = (sois.readObject()).toString();
- Order acceptOrder = new Order();
- acceptOrder.accept(acceptId);
- }
- if(string.equals("AReturnAllOrders"))
- {
- Order allOrders = new Order();
- String [][] base = allOrders.getAllOrders();
- soos.writeObject(base);
- }
- if(string.equals("AUpdateBase"))
- {
- ProductBase productAUpdateBase = new ProductBase();
- String [][] base = productAUpdateBase.Get();
- soos.writeObject(base);
- }
- if(string.equals("ASaveBase"))
- {
- ProductBase productASaveBase = new ProductBase();
- String [][] baseNew = (String [][])sois.readObject();
- productASaveBase.SaveBase(baseNew);
- }
- if(string.equals("AReturnBase"))
- {
- ProductBase productAReturnBase = new ProductBase();
- String [][] base = productAReturnBase.ReturnBase();
- soos.writeObject(base);
- }
- if(string.equals("ReturnCart"))
- {
- String login = (String)sois.readObject();
- ProductCart cart = new ProductCart(login);
- String [][] base = cart.ReturnCart();
- soos.writeObject(base);
- }
- socket.close();
- }
- }
- catch (IOException e) {
- System.err.println("Socket not closed");
- } catch (ClassNotFoundException ex) {
- Logger.getLogger(ServeOneJabber.class.getName()).log(Level.SEVERE, null, ex);
- }
- }
- }
- public class ServerObject {
- static final int PORT = 2525;
- public static void main(String[] args) throws IOException {
- ServerSocket s = new ServerSocket(PORT);
- System.out.println("Server Started");
- try {
- while (true)
- {
- Socket socket = s.accept();
- try
- {
- new ServeOneJabber(socket);
- }
- catch (IOException e)
- {
- socket.close();
- }
- }
- }
- finally {
- s.close();
- }
- }
- } // /:~
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement