Advertisement
Guest User

фффффф

a guest
Nov 28th, 2015
68
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 7.33 KB | None | 0 0
  1. package Server;
  2.  
  3. import Users.*;
  4. import Products.ProductBase;
  5. import Products.ProductCart;
  6. import Orders.Order;
  7. import java.io.BufferedReader;
  8. import java.io.BufferedWriter;
  9. import java.io.IOException;
  10. import java.io.InputStreamReader;
  11.  
  12. import java.io.ObjectInputStream;
  13. import java.io.ObjectOutputStream;
  14. import java.io.OutputStreamWriter;
  15. import java.io.PrintWriter;
  16. import java.net.ServerSocket;
  17. import java.net.Socket;
  18. import java.util.Collection;
  19. import java.util.logging.Level;
  20. import java.util.logging.Logger;
  21.  
  22.  
  23.  
  24.  
  25. class ServeOneJabber extends Thread {
  26. private Socket socket;
  27. private BufferedReader in;
  28. private PrintWriter out;
  29.  
  30. public ServeOneJabber(Socket s) throws IOException {
  31. socket = s;
  32. in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
  33. // Включаем автоматическое выталкивание:
  34. out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket
  35. .getOutputStream())), true);
  36. // Если любой из вышеприведенных вызовов приведет к
  37. // возникновению исключения, то вызывающий отвечает за
  38. // закрытие сокета. В противном случае, нить
  39. // закроет его.
  40. start(); // вызываем run()
  41. }
  42.  
  43. public void run() {
  44.  
  45. try
  46. {
  47. while (true)
  48. {
  49. ObjectInputStream sois = new ObjectInputStream(socket.getInputStream()); //создание потока ввода
  50. ObjectOutputStream soos = new ObjectOutputStream(socket.getOutputStream());// создание потока вывода
  51.  
  52. String string;
  53. string = (String)sois.readObject();
  54.  
  55. if(string.equals("Authorization"))
  56. {
  57. string = (String)sois.readObject();
  58. User user = new User(string, (String)sois.readObject());
  59. int group = user.Get();
  60. if(group == 1)
  61. {
  62. soos.writeObject("admin");
  63. }
  64. if(group == 2)
  65. {
  66. soos.writeObject(user.GetLogin());
  67. }
  68. if(group == 0)
  69. {
  70. soos.writeObject("0");
  71. }
  72. }
  73. if(string.equals("Registration"))
  74. {
  75. string = (String)sois.readObject();
  76. User user = new User(string, (String)sois.readObject());
  77. user.setL();
  78. if(user.Get() == 3)
  79. {
  80. soos.writeObject("0");
  81.  
  82. }
  83. else
  84. {
  85. user.Register();
  86. soos.writeObject("1");
  87. }
  88. }
  89. if(string.equals("GAddCart"))
  90. {
  91. String [] stringAddCard = (String[])sois.readObject();
  92. ProductCart cart = new ProductCart(stringAddCard[0]);
  93. cart.AddCart(stringAddCard[1], stringAddCard[2], stringAddCard[3]);
  94. }
  95. if(string.equals("GRemoveCart"))
  96. {
  97. String removeRow = (sois.readObject()).toString();
  98. ProductCart cartRemove = new ProductCart();
  99. cartRemove.remove(removeRow);
  100. }
  101. if(string.equals("GRemoveAllCart"))
  102. {
  103. String removeRow = (sois.readObject()).toString();
  104. ProductCart cartRemove = new ProductCart();
  105. cartRemove.removeAll(removeRow);
  106. }
  107. if(string.equals("GAddOrder"))
  108. {
  109. String order = (sois.readObject()).toString();
  110. ProductCart cartOrder = new ProductCart(order);
  111. cartOrder.setContact((sois.readObject()).toString());
  112. cartOrder.addOrder();
  113. }
  114. if(string.equals("GGetHistory"))
  115. {
  116. System.out.println("azazazaz");
  117. String Login = (sois.readObject()).toString();
  118. System.out.println("azazazaz");
  119. Order order = new Order(Login);
  120.  
  121. String [][] base = order.getHistory();
  122. soos.writeObject(base);
  123. }
  124. if(string.equals("AAcceptOrder"))
  125. {
  126. String acceptId = (sois.readObject()).toString();
  127. Order acceptOrder = new Order();
  128. acceptOrder.accept(acceptId);
  129. }
  130. if(string.equals("AReturnAllOrders"))
  131. {
  132. Order allOrders = new Order();
  133. String [][] base = allOrders.getAllOrders();
  134. soos.writeObject(base);
  135. }
  136.  
  137. if(string.equals("AUpdateBase"))
  138. {
  139. ProductBase productAUpdateBase = new ProductBase();
  140. String [][] base = productAUpdateBase.Get();
  141. soos.writeObject(base);
  142. }
  143. if(string.equals("ASaveBase"))
  144. {
  145. ProductBase productASaveBase = new ProductBase();
  146. String [][] baseNew = (String [][])sois.readObject();
  147. productASaveBase.SaveBase(baseNew);
  148. }
  149. if(string.equals("AReturnBase"))
  150. {
  151. ProductBase productAReturnBase = new ProductBase();
  152. String [][] base = productAReturnBase.ReturnBase();
  153. soos.writeObject(base);
  154. }
  155. if(string.equals("ReturnCart"))
  156. {
  157. String login = (String)sois.readObject();
  158. ProductCart cart = new ProductCart(login);
  159. String [][] base = cart.ReturnCart();
  160. soos.writeObject(base);
  161. }
  162.  
  163.  
  164.  
  165. socket.close();
  166. }
  167.  
  168. }
  169. catch (IOException e) {
  170. System.err.println("Socket not closed");
  171. } catch (ClassNotFoundException ex) {
  172. Logger.getLogger(ServeOneJabber.class.getName()).log(Level.SEVERE, null, ex);
  173. }
  174. }
  175. }
  176.  
  177.  
  178. public class ServerObject {
  179. static final int PORT = 2525;
  180.  
  181. public static void main(String[] args) throws IOException {
  182. ServerSocket s = new ServerSocket(PORT);
  183. System.out.println("Server Started");
  184. try {
  185. while (true)
  186. {
  187. Socket socket = s.accept();
  188. try
  189. {
  190. new ServeOneJabber(socket);
  191. }
  192. catch (IOException e)
  193. {
  194. socket.close();
  195. }
  196. }
  197. }
  198. finally {
  199. s.close();
  200. }
  201. }
  202. } // /:~
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement