Y:/Code Backup/UDPserv/RFIDudpServer1Thread.java

Go to the documentation of this file.

/******************************************************************************                      
 *
 *       Copyright (C) 2006 J Team, Inc.
 *       All Rights Reserved
 *
 * File Name      : RFIDudpServer1Thread.java
 * Project Name   : UDPserv
 * Description    : This code was adapted from SunMicrosystem's example code.  
 *                  Datagram packets recceived by this code are in the following
 *                  format: 
 * 
 *                  CMD:SERIALNUMBER
 *                  where CMD is:
 *                  U => Get User Data
 *                  I => Get Item Data, Add to Shopping Cart
 *                  R => Remove Item from Shopping Cart
 *                  M => End + E-Mail
 *                  
 * Authors: Jared Suttles
 *          Jennifer Tietz
 *          Jonathan Chen
 *          Joshua Chapman
 *
 * Version : 1.2
 * Date    : 05/01/06
 *
 *****************************************************************************/

import java.io.*;
import java.net.*;
import java.text.DateFormat;
import java.text.NumberFormat;
import java.util.Date;
import java.util.GregorianCalendar;
import java.util.HashMap;
import java.util.Locale;

public class RFIDudpServer1Thread extends Thread {

    public boolean mailedFlag = true;
    protected DatagramSocket socket = null;
    protected BufferedReader in = null;
    protected HashMap ShoppingCart = null;

    public RFIDudpServer1Thread() throws IOException {
        this("RFIDudpServer1Thread");
    }

    public RFIDudpServer1Thread(String name) throws IOException {
        super(name);
        int i = 0;
        i = 2000;
        boolean flag = true;
        while (flag) {
          try
          {
            socket = new DatagramSocket(i);
            flag = false;
          } catch (SocketException e) {
                  System.out.println("Got an error on " + i);
          }
        }
        System.out.println("Got Socket " + i);
        ShoppingCart = new HashMap();
    
    }

    public void run() {
                while (true) {
            try {
                byte[] buf = new byte[14];

                // receive request
                DatagramPacket packet = new DatagramPacket(buf, buf.length);
                socket.receive(packet);
              
                // figure out response
                String FileLine = null;
                String GotString = new String(packet.getData());
                System.out.println("GOT PACKET WITH: " + GotString + " As its data");
                FileLine = getData(GotString);
                buf = FileLine.getBytes();

                    // send the response to the client at "address" and "port"
                InetAddress address = packet.getAddress();
                int port = packet.getPort();
                System.out.println("To port " + port);
                packet = new DatagramPacket(buf, buf.length, address, port);
                socket.send(packet);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    // Right now it will just get the next line of the file and return it.. later,
    // it should find the corresponding Serial number.
    protected String getData(String FromPacket) {
        String[] CmdSerial = null;
        String[] LineArray = null;
          String returnValue = null;
        String checkSerial = null;
        String SerialCMP = null;
        char CMD = 'V';
        boolean found = false;
        
                System.out.println("\nReceived Packet: "+FromPacket);

                try {
                
                // This should open the file and then read a line from it.
                in = new BufferedReader(new FileReader("RFIDXpr3ss.txt"));
        } catch (Exception e) {
            System.err.println("Could not open RFID Xpr3ss DB");
            System.exit(0);
        }
                //Split the packet input string to CMD and Serial#
                CmdSerial = FromPacket.split(":");
                System.out.println("After Split: " + CmdSerial[0]+ " - " + CmdSerial[1]);
                //Get the Serial number from the packet
                SerialCMP = CmdSerial[1];
                //Get the Command from the packet
                CMD = CmdSerial[0].charAt(0);
                
        
        
        try {
                // Set the file pointer
                if ((CMD == 'U') || (CMD == 'M')) {
                        while ((checkSerial = in.readLine()).compareTo("//USERS") != 0);
                } else if ((CMD == 'I') || (CMD == 'R')) {
                        while ((checkSerial = in.readLine()).compareTo("//ITEMS") != 0);
                } else if (CMD == 'T'){
                                System.out.println("Received Time Synch Request");
                                GregorianCalendar myDate = new GregorianCalendar();
                                Date d = myDate.getTime();
                                DateFormat df1 = DateFormat.getDateTimeInstance(DateFormat.SHORT, DateFormat.MEDIUM);
                                returnValue = df1.format(d);
                                System.out.println("Returning: " + returnValue);
                        found = true;
                        }

                while(found == false)
                {
                        if ((checkSerial = in.readLine()) == null)
                        {
                                returnValue = "~ERROR";
                            System.out.println("Invalid Serial Number");
                                break;
                        } else if ((checkSerial.charAt(0) == '/') && (checkSerial.charAt(1) == '/')) {
                                returnValue = "~ERROR";
                            System.out.println("Invalid Serial Number");
                                break;                          
                        }
                        //System.out.println("FROM File GOT:" + checkSerial);
                        LineArray = checkSerial.split(",");

                        if (SerialCMP.compareTo(LineArray[0]) == 0)
                        {
                                if (CMD == 'I'){
                                    returnValue = LineArray[1]+LineArray[2];
                                    System.out.println("Returning: " + returnValue);
                                AddToCart(LineArray);
                                    found = true;
                                }
                                else if (CMD == 'R'){
                                    returnValue = "ACK";
                                    System.out.println("Returning: " + returnValue);
                                RmFromCart(LineArray);
                                    found = true;
                                }
                                else if(CMD == 'U') {
                                        returnValue = LineArray[3]+LineArray[2]+LineArray[1];
                                        System.out.println("Returning User Info:" + returnValue);
                                        mailedFlag = false;
                                        found = true;
                                }
                                else if(CMD == 'M'){
                                        returnValue = "SENT";
                                        sendMail("smtp.purdue.edu", LineArray[2], LineArray[3]);
                                        System.out.println("Returning ACK:" + returnValue);
                                        found = true;
                                }
                                else {
                                    returnValue = "~ERROR";
                                    System.out.println("Returning ERR no packet");
                                    break;
                                }
                        }
                }
        } catch (IOException e) {
            returnValue = "IOException occurred in server.";
        }
        return returnValue;
    }
    
    public void Test() {
        String Items[] = {
                        "0413AADF243A,Toilet Paper 6pk         , 1630",
                        "0413AAC71B37,Hamburger                ,  129",
                        "0413AACDC145,Captain Crunch           ,  634",
                        "0413AAD7422B,Ritz Crackers            ,  315",
                        "0413AAC34F3A,The Fast and Furious DVD , 1570",
                        "0413AADB1132,Intro to Digital Systems ,34999"};
        String User = "041112BE8D2C,1464,jjchen@purdue.edu,Jonathan Chen";
        String temp = null;
        String LineArray[] = null;
        
        for (int Index = 0; Index < Items.length; Index++) {
                temp = Items[Index];
                LineArray = temp.split(",");
                AddToCart(LineArray);
                if (Index == 3) RmFromCart(LineArray);
        }

        LineArray = User.split(",");
        sendMail("smtp.purdue.edu", LineArray[2], LineArray[3]);
        
        return;
    }
    
    public void sendMail(String mailServer, String recipient, String username) {
        if (!mailedFlag) {
                mailedFlag = true;
        try {
              Socket s = new Socket(mailServer, 587);
              BufferedReader in = new BufferedReader
                  (new InputStreamReader(s.getInputStream(), "8859_1"));
              BufferedWriter out = new BufferedWriter
                  (new OutputStreamWriter(s.getOutputStream(), "8859_1"));

              String messageBody = MakeReceiptBody(username);
              send(in, out, "EHLO rfidXpr3ss");
              // warning : some mail server validate the sender address
              //           in the MAIL FROm command, put your real address here
              send(in, out, "AUTH LOGIN");
              send(in, out, "anN1dHRsZXM=");
              send(in, out, "amp0dXR0bGVzMTIxNw==");
              send(in, out, "MAIL FROM: <rfid_Xpr3ss@purdue.edu>");
              send(in, out, "RCPT TO: " + recipient);
              send(in, out, "DATA");
              send(out, "Subject: Receipt of Purchase");
              send(out, "From: rfid Xpr3ss <rfid_Xpr3ss@purdue.edu>");
              send(out, "\n");
              // message body
              send(out, messageBody);
              //send(out, "Thanks for your purchase\n");
              //send(out, "Hey, look it works!");
              send(out, "\n.\n");
              send(in, out, "QUIT");
              s.close();
              ShoppingCart = new HashMap();

              }
           catch (Exception e) {
              e.printStackTrace();
              }
        }
     }

         private String MakeReceiptBody(String username) {
                 String messageBody = "";
                 String myuser;
                 float Total = 0;
                 ItemStruct temp;
                 int i = 19;
                 
                 // Get time and date for email
                 GregorianCalendar myDate = new GregorianCalendar();
                 Date d = myDate.getTime();
                 DateFormat df1 = DateFormat.getDateTimeInstance(DateFormat.MEDIUM, DateFormat.MEDIUM);
                 String s1 = df1.format(d);
                 messageBody += s1 + "\n\n";
                 
                 while (username.charAt(i) == ' ') i--;
                 myuser = username.substring(0,i+1);
                 // Get user name
                 messageBody += myuser + ",\n\nPlease find your receipt below, courtesy of RFID Xpr3ss.\n\n\n";
                 
                 // Initialize message body
                 messageBody += "ITEM                           PRICE\n------                       -------\n";
                 
                 // Get array of keys from hash map
                 Object keys[] = ShoppingCart.keySet().toArray();
                 
                 for (int Index = 0; Index < keys.length; Index++) {
                         // Get current item from hash map
                         temp = (ItemStruct) ShoppingCart.get((String)keys[Index]);
                         
                         // Add item and price to message body
                         messageBody += temp.Name + "    " + GetCurrencyString(temp.Price,7) + "\n";
                         
                         // Add item price to total
                         Total += temp.Price;
                 }
                 // Append Total
                 messageBody += "                             -------\n" +
                                        "                    TOTAL:  " + GetCurrencyString(Total,8) + "\n";
                 
                 // Conclude message body
                 messageBody += "\nThank you for using RFID Xpr3ss!\n";
                 
                 return messageBody;
         }


                private String GetCurrencyString(float total, int fieldwidth) {
                        Locale locale = Locale.US;
                        String currency = NumberFormat.getCurrencyInstance(locale).format(total);
                        while(currency.length() < fieldwidth){
                                currency = currency.substring(0,1)+" "+currency.substring(1);
                        }
                        return currency;
        }

                public void send(BufferedReader in, BufferedWriter out, String s) {
           try {
              out.write(s + "\n");
              out.flush();
              System.out.println(s);
              s = in.readLine();
              //System.out.println(s);
              }
           catch (Exception e) {
              e.printStackTrace();
              }
           }

         public void send(BufferedWriter out, String s) {
           try {
              out.write(s + "\n");
              out.flush();
              System.out.println(s);
              }
           catch (Exception e) {
              e.printStackTrace();
              }
           }
         
         private void AddToCart(String LineArray[]) {
             ItemStruct temp = new ItemStruct(LineArray[1],getFloatVal(LineArray[2]));
             ShoppingCart.put(LineArray[0],temp);             
         }

         private void RmFromCart(String LineArray[]) {
             ShoppingCart.remove(LineArray[0]);
         }

         private float getFloatVal(String str) {
             float val = 0;
             for (int strIndex = str.length()-1; strIndex >= 0; strIndex--) {
                 if (str.charAt(strIndex) <= '9' && str.charAt(strIndex) >= '0') {
                     val += (str.charAt(strIndex) - '0') * Math.pow(10,(str.length()-strIndex-3));
                 }
             }
             return val;
         } 
}

---