MembershipControl.java

package src.anearcan;

import java.sql.*;
import java.util.Date;
import java.util.ArrayList;
import java.util.Date;
import java.util.logging.Level;
import java.util.logging.Logger;



class MembershipControl{
	Employee employee; //Employee performing the membership related functionality
	private MemberAccount member;
        private Date today = new Date();
        
        
	MembershipControl(Employee user){
		employee = user;
                member = new MemberAccount();
        }
        
	MembershipControl(Employee user, MemberAccount m){
		employee = user;
                member = m;
        }	
        
        
        //Renew Membership after suspension or after expiration. Expiry date is returned.
	public MemberAccount renew(MemberAccount member, Date now) throws ClassNotFoundException, SQLException{
		//check that all overdue payments have been made.
		if(member.getTotalCharge() >  0){
			System.out.println("To renew membership, account balance must be paid in full.");
                }else if((member.getStatus()=="Suspended") && now.before(member.getMembershipExpiryDate())){
			System.out.println("This member has been suspended. Member's account may be renewed "
                                + "when expiration date on account has been reached");                        
		}else{
                    member.setMembershipExpiryDate(new Utility().addDays(now, 365));
                    member.setStatus("Active");
                    Utility.connect();
                    ResultSet rs = Utility.stmt.executeQuery("SELECT * FROM  members WHERE memberID = " +Integer.toString(member.getMemberID()));
                    while(rs.next()){
                         rs.updateString("Status", "Active");
                         rs.updateDate("ExpiryDate", new java.sql.Date(member.getMembershipExpiryDate().getTime()));
                         rs.updateRow();
                    }
                }
                return member;
	}
	
	 public MemberAccount createAccount(String firstName, String lastName, String streetAddress, String addressCity,
            String addressProvince, String email, long phoneNo){
            int memberID = 0;
            String newMemberInformation = null;

            member.setFirstName(firstName);
            member.setLastName(lastName);
            member.setAddress(streetAddress);
            member.setCity(addressCity);
            member.setProvince(addressProvince);
            member.setEmail(email);
            member.setPhoneNumber(phoneNo);
            String fullAddress = member.getAddress()+", "+ member.getCity()+", "+ member.getProvince();
            ResultSet checkExistence = null;
            try {
                Utility.connect();
                newMemberInformation = "('"+member.getEmail()+"', '"+ member.getFirstName()+ "', '"+member.getLastName()
                        +"', '" + fullAddress+ "', "+Long.toString(member.getPhoneNumber())+")";
                try{
                checkExistence = Utility.stmt.executeQuery("SELECT email FROM members WHERE email = '" + member.getEmail()+"'"); 
                }catch(NullPointerException e){
                   System.out.println("This member  does not have an account");
                }
             
                    //Member does not exist in our database, and is eligible to create new account
                    ResultSet results;
                    try {
                        results = new Utility().stmt.executeQuery("SELECT * FROM members");
                        if (results.next()) {
                            // Retrieve the auto generated key(s).

                               /* memberID = results.getInt(1);
                                System.out.println(Integer.toString(results.getInt(1)));*/

                                results.moveToInsertRow();
                                results.updateString("email",member.getEmail());
                                results.updateString("FirstName", member.getFirstName());
                                results.updateString("LastName", member.getLastName());
                                results.updateString("Address", member.getAddress());
                                results.updateLong("PhoneNumber", member.getPhoneNumber());
                                results.updateString("currentItems", "");
                                results.updateString("pastItems", "");
                                results.updateString("reservations", "");                            
                                results.updateString("Status", "Active");
                           //     results.updateString("ExpiryDate", new Utility().addDays(today, 365).toString());
                                results.insertRow();
                                results.last();
                                memberID = results.getInt("MemberID");

                        }
                        member.setMemberID(memberID);
                        member.setStatus("Active");
                        member.setMembershipExpiryDate(new Utility().addDays(today,365));
               
                    } catch (SQLException ex) {
                        Logger.getLogger(MembershipControl.class.getName()).log(Level.SEVERE, null, ex);
                    }
                                /*int rs = Utility.stmt.executeUpdate("INSERT INTO members ('email', 'FirstName', 'LastName', 'Address', 'PhoneNumber')"
                            + " VALUES" + newMemberInformation, Statement.RETURN_GENERATED_KEYS);
                    ResultSet results = Utility.stmt.getGeneratedKeys();*/
               
                Utility.con.close();
            } //end try
            catch(ClassNotFoundException e) {
                e.printStackTrace();
            }
            catch(SQLException e) {
                e.printStackTrace();
            }
            return member;
	}
	
	//Suspend privileges
	public void suspend(MemberAccount member, String reason) throws ClassNotFoundException, SQLException{
            	Utility.connect();
                member.setStatus("Suspended");
                ResultSet rs = Utility.stmt.executeQuery("SELECT * FROM members WHERE memberID = "
                        +Integer.toString(member.getMemberID()));
                while(rs.next()){
                    rs.updateString("Status", "Suspended");
                }
                Utility.con.close();
        }
        
	public void pay(Payment p) throws ClassNotFoundException, SQLException{
		Utility.connect();
                ResultSet rs = Utility.stmt.executeQuery("SELECT * FROM members WHERE memberID = "
                         + Integer.toString(p.getAccount().getMemberID()));
                while(rs.next()){
                    rs.updateDouble("Balance", (rs.getDouble("Balance")- p.getAmount()));
                    member.setTotalCharge(rs.getDouble("Balance")- p.getAmount());
                    rs.updateRow();
                } 
	                Utility.con.close();
	}
        
	public void pay(Double amount) throws ClassNotFoundException, SQLException{
		Utility.connect();
                ResultSet rs = Utility.stmt.executeQuery("SELECT * FROM members WHERE memberID = "
                         + Integer.toString(member.getMemberID()));
                while(rs.next()){
                    rs.updateDouble("accountBalance", (rs.getDouble("accountBalance")- amount));
                    member.setTotalCharge(rs.getDouble("accountBalance")- amount);
                    rs.updateRow();
                } 
	        Utility.con.close();
	}

	
	//add overdue charge to member account for item(s) that are yet to be returned past the return date 
	public double addOverDue(MemberAccount member, Rental r) throws ClassNotFoundException, SQLException{
		
		double charge = r.getCharge();
		double overdueCharge = 30.00;
                if(r.getDueDate().before(today)){
                    member.setTotalCharge(member.getTotalCharge() + overdueCharge);
                    Utility.connect();
                    ResultSet rs= Utility.stmt.executeQuery("SELECT * FROM members WHERE memberID = "+ Integer.toString(member.getMemberID()));
                    while(rs.next()){
                        rs.updateDouble("Balance", member.getTotalCharge());
                        rs.updateRow();
                    }
                }
	        Utility.con.close();	
		return charge;
	
	}

}