/* Class name: Crusher
 * Description: Truck units come to the "Crusher" to dump their ore. 
 * The original intention was to take a linear ammount of time to unload
 * trucks, however, due to homework limitations, the time it takes to unload
 * ore from trucks is set statically.
 * Absent Function: Trucks with other than 20T and 50T capacity all unload
 * within a preset ammount of time....
 * Class: SEG 2106
 */

package hw4_multithreadtrucks;
import java.util.*;
import pbxlogique.Pbx;
/**
 *
 * @author Peilos
 */
public class Crusher extends Thread
{
    private Vector truckList;
    
    //Rate at which to load trucks that do not come under the 20T or 50T
    //categories.
    private long defaultTonsLoadRate = 10;
    private long defaultMinTimeRate = 750;
    private long defaultMaxTimerate = 1250;
    
    //Hard coded definition for time to take to load a 20T truck
    private long iLoadRate1 = 1500;
    private long iLoadRate1Max = 2500;
    
    //Hard coded definition for time to take to load a 50T truck
    private long iLoadRate2 = 3500;
    private long iLoadRate2Max = 4500;
    
    //Helper variable for time calculations...
    private TimeCal myTimer = new TimeCal();
    
    //Is true if the instance is, or is still in a runnable state.
    private boolean bReady;
    
    //As *this* crusher crushes ore from trucks, the ammount of ore is added
    //to the oreCrushed variable.  This ammount is outputed on the console
    //when and if the crusher is normally shut down (by calling the
    //"shutDownCrusher" procedure.
    private int oreCrushed=0;
    
    /* Give higher priority to trucks assigned to Shovel #1?*/
    private boolean bUseHighPriorityScheme = false;
    private int iHighPrioShovelNumber = 0;
    private String sCrusherName;
    private double dIdleTime; //Stats, idle time after first truck arrives.
    private boolean bFirstTruckArrive;
    private double dTrucksWaitTime;
    
    /* Default Constrtuctor
     * MOD: bReady, truckList
     * */
    public Crusher()
    {
        super();
        sCrusherName = "";
        bReady = true;
        truckList = new Vector();
        dIdleTime = 0;
        bFirstTruckArrive = false;
        dTrucksWaitTime = 0;
    }
    
    public void setCrusherName(String sName)
    {
        sCrusherName = sName;
    }
    
    public String getCrusherName()
    {
        return sCrusherName;
    }
    /* procedure useHighPriority
     * Description: Assigns a shovel as a "high priority" shovel.  All trucks
     * assigned to that shovel are processed first! :)
     * IN:  doWeUseIt: true: Use high priority system
     *      priorityShovelNumber
     * MOD: bUseHighPriorityScheme,iHighPrioShovelNumber
     * */
    public void useHighPriority(boolean doWeUseIt, int priorityShovelNumber)
    {
        this.bUseHighPriorityScheme = doWeUseIt;
        this.iHighPrioShovelNumber = priorityShovelNumber;
    }
    
    /* Used by a TRUCK unit to place itself in line.
     * IN: Truck
     * MOD: truckList
     * */
    public synchronized void placeTruckInLine(Truck oTruck)
    {
        truckList.add(oTruck);
    }
        
    /* procedure loadNextTruck
     * Description: Unloads and crushes ore comming from trucks.  The trucks
     * should already be in line by teh time this procedure is called.
     * Trucks can place themselves in line by calling the "placeTruckInLine" 
     * procedure.
     * OUT: Console
     * MODIFIED: oreCrushed
     * */
    private synchronized void loadNextTruck()
    {
        double timeDelays=0; //Timed delay
        long tmpMin=0, tmpMax=0; //Used for timerDelays
        int iHelp;//Just a helper variable.  Used to extract data from truckList.
        int chosenOne = -1; //Used in the priority system.  Becomes >=0 if priority is given to a truck
        Truck currentTruck;//Helper variable to load the truck we are dealing with
        iHelp = truckList.size(); //Get the size of the vector array
        //Check to ensure the truckList
        if (0 == truckList.size())
            return;
        if ((!bUseHighPriorityScheme) || iHelp==1) //Priority 
        {//If the priority system is disabled, take the first truck in line
            currentTruck = (Truck) truckList.remove(0);
        }else
        {//Give higher priority to trucks comming from Shovel <iHighPrioShovelNumber
            //The following is outputed to the console if and only if
            //there is more than 1 truck in the truckList and that we actually
            //need to scan through.
            System.out.println("CRUSHER: PRIORITY SYSTEM SCANNING... (more than 1 truck waiting)");
            iHelp = truckList.size();
            for (int i=0; i<iHelp; i++)
            {
                currentTruck = (Truck) truckList.get(i);
                if (currentTruck.getShovelNumber() == iHighPrioShovelNumber) //check to see if the truck is in the 
                {
                    chosenOne = i;
                    break;
                }
                if (-1 != chosenOne) //Just a debug check to ensure the loop is not broken.
                    System.out.println("OH NO!!!!!!!!!!!!!!!!!!!!!!!! A bug -- this should never happen");
            }//END FOR
            if (-1 != chosenOne)
            {
                currentTruck = (Truck) truckList.remove(chosenOne);
                System.out.println("CRUSHER PRIORITY: Giving preferencial treatment to "+currentTruck.getTruckerName());
            }else
            {
                currentTruck = (Truck) truckList.remove(0);
            }
        }
        //Truck Pre-Processing
        dTrucksWaitTime += currentTruck.timeIt();
        //End of truck Pre-Processing
        //Output which truck the Crusher is handling at this time.
        System.out.println("Crusher is handling the "+
                currentTruck.getTruckerName()+" "+currentTruck.getTruckBucketSize()+
                "T Truck and unloading ore from it right now...");
        /*Ok, this is where because the homework has estrictions, we have to
         * factor in what the homework says and add the "normal" functionality
         * beside it...
        */
        if (50 == currentTruck.getTruckBucketSize())
        {
            //rate if this is a 50T truck
            timeDelays = myTimer.RunAtPreDefinedRate(iLoadRate2, iLoadRate2Max);
        }else
            if (20 == currentTruck.getTruckBucketSize())
            {//rate if this is a 20T truck
                timeDelays = myTimer.RunAtPreDefinedRate(iLoadRate1, iLoadRate1Max);
            }else
            {//rate for all other trucks
            if (0 == defaultTonsLoadRate) //Instead of throwing an exception.
                defaultTonsLoadRate = 1;//Just change it to 1.
            timeDelays = currentTruck.getTruckBucketSize() / defaultTonsLoadRate;
            tmpMin = this.defaultMinTimeRate * Math.round(timeDelays);
            tmpMax = this.defaultMaxTimerate * Math.round(timeDelays);
            timeDelays = myTimer.RunAtPreDefinedRate(tmpMin, tmpMax);
            }
        //Truck Post-Processing
        currentTruck.addWorkTime(timeDelays);
        //End truck post-processing
        //Add up how much ore has been crushed so far.
        oreCrushed = oreCrushed+currentTruck.getTruckBucketSize();
        if (!currentTruck.removeOre(currentTruck.getTruckBucketSize()))
        {
            System.out.println("There was a problem unloading the "+currentTruck.getTruckBucketSize()+
                "T Truck in "+timeDelays+" minutes.  The truck refused to go back to the Shovel.");
        }
        System.out.println("Crusher unloaded the "+
            currentTruck.getTruckerName()+" "+currentTruck.getTruckBucketSize()+
            "T Truck in "+timeDelays+" minutes.");
        notifyAll();
        return;
    }
 
    //What it says
    public synchronized void shutDownCrusher()//Attemps to shutdown the Crusher.
    {
        bReady = false;
        System.out.println("NOTICE: Order to shut down Crusher received.");
    }

    
    @Override
    public void run()
    {
        while (bReady)
        {
            System.out.println("Crusher here.  Waiting for the trucks.");
            if (bFirstTruckArrive)
            {
                myTimer.TakeStartTime();
            }
            while ((truckList.size()==0) && (bReady)) //Waiting for a truck
            {
                try
                {
                    Thread.sleep(1);
                }catch (Exception E)
                {
                    System.out.println("Oh noes!  The Crusher broke :(  Abandoning Crusher !");
                    bReady = false;
                }
            }//END While(truckList)
            if (bReady) 
            {
                if (bFirstTruckArrive)
                {
                    this.dIdleTime = dIdleTime + (myTimer.getNewTimeDifference() / 1000);
                }
                loadNextTruck();
                bFirstTruckArrive = true;
            }
        }
        System.out.println("SHUTDOWN: Crusher is shutting down now... ("+oreCrushed+
                " Tonnes of Ore processed. \r\n\t\tIdle time (after first truck passed through): "+
                Pbx.antiDecimal(this.dIdleTime,2)+
                " minutes.\r\n\t\tTotal Time Lost due to Trucks stuck in line: "+
                Pbx.antiDecimal(this.dTrucksWaitTime,2)+" minutes.");
    }
}