/* * ServerThread.java * * Created on 13 November 2006, 16:07 * * To change this template, choose Tools | Template Manager * and open the template in the editor. */
import java.io.*;import java.net.*;import java.util.*;
/** * The threads spun from the NewShop server to process client requests * @author dsi06dh Dave Hollowell * @version 0.1 23rd November 2006 */public class ServerThread implements Runnable { /** * reference to the server GUI display */ private ServerGui theDisplay; /** * Reference to the warehaouse instance to use */ private Warehouse theWarehouse; /** * reference to the client socket */ private Socket theSocket; /** * Reference to the client number */ private int theClient; /** * The incoming object data stream */ private ObjectInputStream in = null; /** * The outgoing object data stream */ private ObjectOutputStream out = null; /** * Continue to process the requests */ private boolean process = true; /** * the customer details */ private Customer cust; /** * The branch details */ private Branch theBranch; /** * End of line character */ private static final String NEWLINE = System.getProperty("line.separator"); /** * Creates a new instance of ServerThread * @param clientNo Numeric reference to the client * @param clientSocket Socket number for the client * @param aWarehouse Reference to the required warehouse instance * @param display Reference to the required server GUI display */ public ServerThread(int clientNo, Socket clientSocket, Warehouse aWarehouse, ServerGui display) { theClient = clientNo; theSocket = clientSocket; theWarehouse = aWarehouse; theDisplay = display; } /** * Runnable implementation of the server thread */ public void run() { theDisplay.statusMessage("Client " + theClient + " Thread started" + NEWLINE); try { in = new ObjectInputStream((theSocket.getInputStream())); } catch (IOException e) { theDisplay.statusMessage("Client " + theClient + " inbound connection failed" + NEWLINE); System.exit(-1); } try { out = new ObjectOutputStream((theSocket.getOutputStream())); } catch (IOException e) { theDisplay.statusMessage("Client " + theClient + " outbound connection failed" + NEWLINE); System.exit(-1); } while(process) { // get incoming details TransmissionData mess = null; try { mess = (TransmissionData) in.readObject(); } catch (IOException e) { theDisplay.statusMessage("Client " + theClient + " read failed" + NEWLINE); System.exit(-1); } catch (ClassNotFoundException e) { theDisplay.statusMessage(e.getMessage()); } // procees the incoming message mess = processRequest(mess); if (process) { try { out.writeObject((TransmissionData) mess); } catch (IOException e) { theDisplay.statusMessage("Client " + theClient + " send failed" + NEWLINE); System.exit(-1); } } } theDisplay.statusMessage("Client " + theClient + " Thread completed" + NEWLINE); } /** * Process requests from the transmission details * @param details Incoming transmission details * @return Outqoing transmission details */ private TransmissionData processRequest(TransmissionData details) { TransmissionData input = details; TransmissionData output = null; // login requested if (input.getDataType() == TransmissionData.CLT_LOGIN) { output = processLogin(input); } // branch selected if (input.getDataType() == TransmissionData.CLT_BRANCH) { output = processBranch(input); } // client order completion requested if (input.getDataType() == TransmissionData.CLT_COMPLETE) { output = processOrder(input); } // client closedown requested if (input.getDataType() == TransmissionData.CLT_CLOSE) { processClose(); output = null; } return output; } /** * Process a login request * @param details incoming transmission details * @return Outgoing transmission details */ private TransmissionData processLogin(TransmissionData details) { TransmissionData input = details; TransmissionData output = null; // determine customer sent String custCode; custCode = (String) input.getData(); theDisplay.statusMessage("Client " + theClient + " Login request " + custCode + NEWLINE); cust = theWarehouse.getCustomer(custCode); // customer exists? if (cust == null) { theDisplay.statusMessage("Client " + theClient + " Customer refused" + NEWLINE); output = new TransmissionData(TransmissionData.SRV_ERROR, "Customer does not exist."); } else { String data1, data2; // send branch details String branchData = theWarehouse.getBranchCodes_Names(); StringTokenizer st = new StringTokenizer(branchData, "*"); Vector<Branch> branchList = new Vector<Branch>(); while (st.hasMoreTokens()) { data1 = st.nextToken(); if (!(data1.equals("END"))) { data2 = st.nextToken(); Branch tempBranch = new Branch(data1, data2); branchList.addElement(tempBranch); } } theDisplay.statusMessage("Client " + theClient + " Customer accepted" + NEWLINE); output = new TransmissionData(TransmissionData.SRV_BRANCHLIST, branchList); } return output; } /** * Process a branch request * @param details incoming transmission details * @return Outgoing transmission details */ private TransmissionData processBranch(TransmissionData details) { TransmissionData input = details; TransmissionData output = null; String branchRequest = (String) input.getData(); theDisplay.statusMessage("Client " + theClient + " Branch request " + branchRequest + NEWLINE); //theBranch = theWarehouse.getBranch(branchRequest); String stockData = theWarehouse.getBranchStockList(branchRequest); String data1, data2, data3; int data4; // send branch item details StringTokenizer st = new StringTokenizer(stockData, "*"); Vector<StockItem> stockList = new Vector<StockItem>(); while (st.hasMoreTokens()) { data1 = st.nextToken(); if (!(data1.equals("END"))) { data2 = st.nextToken(); data3 = st.nextToken(); data4 = Integer.parseInt(st.nextToken()); StockItem tempItem = new StockItem(data1, data2, data3, data4); stockList.addElement(tempItem); } } theDisplay.statusMessage("Client " + theClient + " Branch accepted" + NEWLINE); output = new TransmissionData(TransmissionData.SRV_STOCKLIST, stockList); return output; } /** * Process a client complete order request * @param details incoming transmission details * @return outgoing transmission details */ private TransmissionData processOrder(TransmissionData details) { theDisplay.statusMessage("Client " + theClient + " complete Order requested" + NEWLINE); TransmissionData input = details; TransmissionData output = null; String basketDetails; basketDetails = cust.getCustomerCode() + "*"; // warning issued in compilation due to unchecked cast from // input.getData() returning an object - see Generics Vector<BasketItem> items = (Vector<BasketItem>) input.getData(); Iterator it = items.iterator(); while (it.hasNext()) { BasketItem line = (BasketItem) it.next(); basketDetails = basketDetails + line.getItemCode() + "*"; basketDetails = basketDetails + line.getDescription() + "*"; basketDetails = basketDetails + line.getPrice() + "*"; basketDetails = basketDetails + line.getNumberOrdered() + "*"; } basketDetails = basketDetails + "END*"; String orderNo = theWarehouse.processBasket(basketDetails); output = new TransmissionData(TransmissionData.SRV_ORDER, orderNo); theDisplay.statusMessage("Client " + theClient + " Order " + orderNo + " completed" + NEWLINE); return output; } /** * Process a client closedown request */ private void processClose() { theDisplay.statusMessage("Client " + theClient + " shutdown requested." + NEWLINE); try { theSocket.close(); } catch (IOException e) { theDisplay.statusMessage("Client " + theClient + " shutdown exception " +e.getMessage() + NEWLINE); } try { in.close(); } catch (IOException e) { theDisplay.statusMessage("Client " + theClient + " read close exception " +e.getMessage() + NEWLINE); } try { out.close(); } catch (IOException e) { theDisplay.statusMessage("Client " + theClient + " write close exception " +e.getMessage() + NEWLINE); } process = false; }}
