planinuse.java

APS(高级排产系统)

package com.power.pipeengine.DispatchReportMap;

import java.util.*;
import java.io.*;
import java.text.*;
import java.net.*;

import com.power.util.Message.*;
import com.power.pipeengine.Entity.*;
import com.power.pipe.*;
import com.power.util.urltools.*;
import com.power.pipeengine.*;
import com.power.pipeengine.InputData.*;

public class PlanInUse
    extends InputReader {
  static ResourceBundle res = ResourceBundle.getBundle(
      "com.power.pipeengine.Res",
      EngineConfig.getInstance().getLocale());
  private String _fileName = "dispatchlist";
  private Hashtable plan = new Hashtable();

  private static final PlanInUse INSTANCE =
      new PlanInUse();

  // Private constructor supresses
  // default public constructor
  private PlanInUse() {
  }

  public static PlanInUse getInstance() {
    return INSTANCE;
  }


  protected String getFileName() {
    return _fileName;
  }

  public int getNumOfRecords() {
    return plan.size();
  }

  public Plan getPlan( String key ) {
    return (Plan) plan.get( key );
  }

  public void genPlanByEmployee() {
    Enumeration allPlans = plan.elements();

    while( allPlans.hasMoreElements() ) {
      Plan aPlan = (Plan) allPlans.nextElement();
System.out.println( "debug 3" );
      aPlan.allocateOverEmployees();
    }
  }

  public boolean isExistingOrder( String orderID ) {
    Enumeration allPlans = plan.elements();

    while( allPlans.hasMoreElements() ) {
      Plan aPlan = (Plan) allPlans.nextElement();
      if( aPlan.getOrderID().equals( orderID ) ) {
        return true;
      }
    }
    return false;
  }

  public StringBuffer getSchedules() {
    Enumeration allPlans = plan.elements();
    StringBuffer rtn = new StringBuffer();

    while( allPlans.hasMoreElements() ) {
      Plan aPlan = (Plan) allPlans.nextElement();
      rtn.append( aPlan.getSchedules() );
    }

    return rtn;
  }


  public void readData() throws Exception {
    BufferedReader d = super.getReader();

    try{
        d = URLFileReader.getInstance().getReaderForURL(
                "http://" + GlobalConfig.getInstance().getHostName() + "/ChangRong/servlet/com.power.pipeengine.LP_ReadWriteFile",
                "ReadModel",
                "c:\\paraster\\output\\" + _fileName + ".csv" );

        if( null == d ) {
            return;
        }
    } catch (Exception e) {
        System.out.println( e.getMessage() );
    }


    String token = GlobalConfig.getInstance().getSeparator();
    String aLine = d.readLine();
    SimpleDateFormat sdfInput = new SimpleDateFormat("yyyy-MM-dd");
    sdfInput.setDateFormatSymbols(new DateFormatSymbols(Locale.CHINA));
    Calendar yesterday = Calendar.getInstance();
    yesterday.add( Calendar.DAY_OF_YEAR, -1 );

    while (aLine != null) {
      if (aLine.length() <= 1) {
        aLine = d.readLine();
        continue;
      }
//System.out.println( aLine );
      StringTokenizer st = new StringTokenizer(aLine, token);
      String equipID = new String(st.nextToken());
      String orderID = new String(st.nextToken());
      String styleID = new String(st.nextToken());
      Integer procID = new Integer(st.nextToken());
      Integer operatorID = new Integer(st.nextToken());
      Integer qty = new Integer(st.nextToken());
      Integer tmpQty = new Integer(st.nextToken());
      String  dateString = new String(st.nextToken());
      String  tmpDateString = new String(st.nextToken());
      String  tmpString = new String(st.nextToken());
      tmpString = new String(st.nextToken());

      Date date = sdfInput.parse( dateString );
      if( date.before( yesterday.getTime() ) ) {
        aLine = d.readLine();
        continue;
      }

      String key = orderID + "&" + styleID + "&" + procID.toString();
      Plan aPlan = (Plan) plan.get( key );
      if( aPlan == null ) {
        aPlan = new Plan( orderID, styleID, procID );
        plan.put( key, aPlan );
      }

      aPlan.addOriginalAssignedEmployee( date, operatorID, qty );
      aPlan.addRecord( date, qty );

      aLine = d.readLine();
    }

    d.close();
    super.closeURLConnection();
  }

  public void print() {
    Enumeration plans = plan.elements();

    while( plans.hasMoreElements() ) {
      Plan aPlan = (Plan) plans.nextElement();
      aPlan.print();
    }
  }

}