Update QueueingApp/src/main/java/appQueue/CustomerQueue.java

QueueingApp/src/main/java/appQueue/CustomerQueue.java

@@ -163,8 +163,44 @@ public final class CustomerQueue{
 			} catch (SQLException e) {
 				e.printStackTrace();
 			}
+		
+		updateAvgTime();
 		updateQueue();
 	}
+	
+	public static void updateAvgTime() {
+		try {
+			Connection connection = dao.createConnection();
+			
+			//Update each position 
+			Statement sta = connection.createStatement(); 
+		    ResultSet res = sta.executeQuery("SELECT * FROM `registration`.`customers` ORDER BY `position`;" );
+					    
+			    while(res.next()) {
+			    	//prepare the statement
+					String update_customer = "UPDATE registration.customers SET avgWaiting = ? WHERE email = ? ;";
+					PreparedStatement prepared_statement = connection.prepareStatement(update_customer);
+					
+					//1st position customer should only have 5 mins of waiting time
+					if(Integer.parseInt(res.getString("position")) == 1) {
+						prepared_statement.setString(1, Integer.toString(5));
+						prepared_statement.setString(2, res.getString("email"));
+						
+					} else {
+						Integer newAvgTime = 10 * Integer.parseInt(res.getString("position"));
+
+						prepared_statement.setString(1, Integer.toString(newAvgTime));
+						prepared_statement.setString(2, res.getString("email"));
+					}
+					
+					//execute query
+					prepared_statement.executeUpdate();
+		
+			    }
+			} catch (SQLException e) {
+				e.printStackTrace();
+			}
+	}
 		
 	public static void updateQueue() {