taskassignframe.java

通讯采集软件

            terminal m_Term = (terminal) TermsOfFac[j];
            AreaTaskList.add(HashTask.get(new Long(m_Term.getTerminalId())));
          }
        }
        Object[] AreaTaskArray = AreaTaskList.toArray();
        TermTaskDataAnalys m_TermTaskDataAnalys = new TermTaskDataAnalys();
        TermTaskTableModel m_TermTaskTableModel = null;
        int row_count = 0;
        for (int i = 0; i < AreaTaskArray.length; i++) {
          ArrayList m_list = new ArrayList();
          if (AreaTaskArray[i] instanceof TermTaskInfo) {
            m_list.add(AreaTaskArray[i]);
          }
          else if (AreaTaskArray[i] instanceof ArrayList) {
            m_list = new ArrayList( (ArrayList) AreaTaskArray[i]);
          }
          int listsize = m_list.size();
          for (int j = 0; j < listsize; j++) {
            Object m_Obj = m_list.remove(0);
            if (m_Obj instanceof TermTaskInfo) {
              TermTaskInfo m_Info = (TermTaskInfo) m_Obj;
              Object[] objs = m_TermTaskDataAnalys.AnalysTermTaskData(m_Info);
              m_TermTaskTableModel = (TermTaskTableModel) (TermTaskTable.
                  getModel());
              for (int k = 0; k < objs.length; k++) {
                m_TermTaskTableModel.setValueAt(objs[k], row_count, k);
              }
              row_count++;
            }
          }
        }
        if (row_count < TermTaskRowCount) {
          for (int m = row_count; m < TermTaskRowCount; m++) {
            m_TermTaskTableModel = (TermTaskTableModel) (HighTable.getModel());
            m_TermTaskTableModel.clearValueAt(m);
          }
        }
        TermTaskRowCount = row_count;
      }
      if (nodeInfo instanceof factory) {
        String fac_name = ( (factory) nodeInfo).getFacName();
        SelectedFacLabel.setText(fac_name);

        factory m_fac = (factory) nodeInfo;
        Object[] TermsOfThisFac = (m_fac.getTerminals()).toArray();
        ArrayList FacTaskList = new ArrayList();
        for (int i = 0; i < TermsOfThisFac.length; i++) {
          terminal m_term = (terminal) TermsOfThisFac[i];
          FacTaskList.add(HashTask.get(new Long(m_term.getTerminalId())));
        }

        Object[] FacTaskArray = FacTaskList.toArray();
        TermTaskDataAnalys m_TermTaskDataAnalys = new TermTaskDataAnalys();
        TermTaskTableModel m_TermTaskTableModel = null;
        int row_count = 0;
        for (int i = 0; i < FacTaskArray.length; i++) {
          ArrayList m_list = new ArrayList();
          if (FacTaskArray[i] instanceof TermTaskInfo) {
            m_list.add(FacTaskArray[i]);
          }
          else if (FacTaskArray[i] instanceof ArrayList) {
            m_list = new ArrayList( (ArrayList) FacTaskArray[i]);
          }
          int listsize = m_list.size();
          for (int j = 0; j < listsize; j++) {
            Object m_Obj = m_list.remove(0);
            if (m_Obj instanceof TermTaskInfo) {
              TermTaskInfo m_Info = (TermTaskInfo) m_Obj;
              Object[] objs = m_TermTaskDataAnalys.AnalysTermTaskData(m_Info);
              m_TermTaskTableModel = (TermTaskTableModel) (TermTaskTable.
                  getModel());
              for (int k = 0; k < objs.length; k++) {
                m_TermTaskTableModel.setValueAt(objs[k], row_count, k);
              }
              row_count++;
            }
          }
        }
        if (row_count < TermTaskRowCount) {
          for (int m = row_count; m < TermTaskRowCount; m++) {
            m_TermTaskTableModel = (TermTaskTableModel) (HighTable.getModel());
            m_TermTaskTableModel.clearValueAt(m);
          }
        }
        TermTaskRowCount = row_count;
      }
    }
    if (nodeInfo instanceof terminal) {
      terminal m_terminal = (terminal) nodeInfo;
      String term_name = m_terminal.getTerminalName();
    }
    TreeScrollPane.setViewportView(ParamTree);
    this.updateview();
  }

  public void initComputers() {
    if (CollectorDefine.m_HashComputer.size() <= 0) {
      CFunction.writeLog("guirec",
          "CollectorDefine.m_HashComputer.size() <=0 in initComputers", null);
      DefaultComboBoxModel m_combomodel = (DefaultComboBoxModel) (
          SelectComboBox.getModel());
      m_combomodel.removeAllElements();
      SelectComboBox.setModel(m_combomodel);
      if (this.computers.size() > 0) {
        this.computers.clear();
      }
      SelectComboBox.setSelectedIndex( -1);
      return;
    }
    else {
      ArrayList computers_bak = new ArrayList();
      computers_bak.addAll(this.computers);
      DefaultComboBoxModel m_model = (DefaultComboBoxModel) (SelectComboBox.
          getModel());
      HashMap m_HashComputers = new HashMap();
      m_HashComputers.putAll(CollectorDefine.m_HashComputer);
      int oldsize = this.computers.size();
      for (int i = 0; i < oldsize; i++) {
        computer m_comp = (computer) (this.computers.get(i));
        long m_comp_id = m_comp.getComputerId();
        computer m_HashComp = (computer) (m_HashComputers.get(new Long(
            m_comp_id)));
        if (m_HashComp != null) {
          String old_comp_name = m_comp.getComputerName();
          String new_comp_name = m_HashComp.getComputerName();
          int new_status = new Long(m_HashComp.getComputerStatus()).intValue();
          if (new_status == CollectorDefine.DEFAULT_MACHINE ||
              new_status == CollectorDefine.OUT_OF_RUNNING) {
            CFunction.writeLog("guirec",
                               "OUT_OF_RUNNING, name :" + new_comp_name +
                               " in initComputers", null);
            computers_bak.remove(m_comp);
            int index = m_model.getIndexOf(old_comp_name);
            if (index >= 0) {
              m_model.removeElementAt(index);
            }
          }
          if (! (old_comp_name.equals(new_comp_name))) {
            int index = computers_bak.indexOf(m_comp);
            if (index >= 0) {
              computers_bak.set(index, m_HashComp);
            }
            int model_index = m_model.getIndexOf(old_comp_name);
            if (model_index >= 0) {
              m_model.removeElementAt(model_index);
              m_model.insertElementAt(new_comp_name, model_index);
            }
          }
          m_HashComputers.remove(new Long(m_comp_id));
        }
        else if (m_HashComp == null) {
          computers_bak.remove(m_comp);
          if (m_model.getIndexOf(m_comp.getComputerName()) >= 0) {
            m_model.removeElement(m_comp.getComputerName());
          }
        }
      }
      this.computers = new ArrayList();
      this.computers.addAll(computers_bak);
      if (m_HashComputers.size() > 0) {
        Object[] Left_computers = m_HashComputers.values().toArray();
        int left_size = Left_computers.length;
        for (int i = 0; i < left_size; i++) {
          computer m_left_comp = (computer) (Left_computers[i]);
          int status = new Long(m_left_comp.getComputerStatus()).intValue();
          if (status == CollectorDefine.DEFAULT_MACHINE ||
              status == CollectorDefine.OUT_OF_RUNNING) {
            CFunction.writeLog("guirec",
                               "--OUT_OF_RUNNING, name :" +
                               m_left_comp.getComputerName() +
                               " in initComputers", null);

            continue;
          }
          else {
            String comp_name = m_left_comp.getComputerName();
            this.computers.add(m_left_comp);
            m_model.addElement(comp_name);
          }
        }
      }
      int Selected_comp_index = -1;
      for (int i = 0; i < this.computers.size(); i++) {
        computer m_comp = (computer) (this.computers.get(i));
        if (m_comp.getComputerId() == this.computerId) {
          Selected_comp_index = i;
          System.out.println("%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%");
          System.out.println("this.computerId = " + this.computerId);
          break;
        }
      }
      SelectComboBox.setModel(m_model);
      SelectComboBox.setSelectedIndex(Selected_comp_index);
      m_HashComputers = null;
    }
    this.updateview();
    /*
             for(int i=0; i<this.computers.size(); i++){
        computer m_comp = (computer)(this.computers.get(i));
             }
     */
  }

  public void initTaskList() {
    try {
      //初始化高，中，低优先级的任务列表（所有的任务）
      HighTaskList = new LinkedList(CollectorDefine.m_h_tasklist);
      MidTaskList = new LinkedList(CollectorDefine.m_m_tasklist);
      LowTaskList = new LinkedList(CollectorDefine.m_l_tasklist);

      Object[] PursueArray = CollectorDefine.m_pursue_tasklist.toArray();
      Object[] DialArray = CollectorDefine.m_dial_tasklist.toArray();
      Object[] NetArray = CollectorDefine.m_switchtasks.toArray();
      Object[] PursueLinkedArray = CollectorDefine.m_PursueLinkedList.toArray();
      Object[] OntimePursueLinkedArray = CollectorDefine.
          m_OntimePursueLinkedList.toArray();

      for (int i = 0; i < PursueArray.length; i++) {
        ArrayList m_list = new ArrayList();
        if (PursueArray[i] instanceof TermTaskInfo) {
          m_list.add(PursueArray[i]);
        }
        else if (PursueArray[i] instanceof ArrayList) {
          m_list = new ArrayList( (ArrayList) PursueArray[i]);
        }
        else {
          continue; //类型错误，不处理
        }
        int listsize = m_list.size();
        for (int j = 0; j < listsize; j++) {
          Object m_Obj = m_list.remove(0);
          if (m_Obj instanceof TermTaskInfo) {
            TermTaskInfo m_Info = (TermTaskInfo) m_Obj;
            switch (m_Info.getPri()) {
              case 0x01: //低
                LowTaskList.add(m_Info);
                break;
              case 0x02: //中
                MidTaskList.add(m_Info);
                break;
              case 0x03: //高
                HighTaskList.add(m_Info);
                break;
              default:
                break;
            }
          }
        }
      }
      //System.out.println("@@@@@@@@@@@@@@@@    CollectorDefine.m_pursue_tasklist OK");

      for (int i = 0; i < DialArray.length; i++) {
        ArrayList m_list = new ArrayList();
        if (DialArray[i] instanceof TermTaskInfo) {
          m_list.add(DialArray[i]);
        }
        else if (DialArray[i] instanceof ArrayList) {
          m_list = new ArrayList( (ArrayList) DialArray[i]);
        }
        else {
          continue; //类型错误，不处理
        }
        int listsize = m_list.size();
        for (int j = 0; j < listsize; j++) {
          Object m_Obj = m_list.remove(0);
          if (m_Obj instanceof TermTaskInfo) {
            TermTaskInfo m_Info = (TermTaskInfo) m_Obj;
            switch (m_Info.getPri()) {
              case 0x01: //低
                LowTaskList.add(m_Info);
                break;
              case 0x02: //中
                MidTaskList.add(m_Info);
                break;
              case 0x03: //高
                HighTaskList.add(m_Info);
                break;
              default:
                break;
            }
          }
        }
      }
      //System.out.println("@@@@@@@@@@@@@@@@    CollectorDefine.m_dial_tasklist OK");

      for (int i = 0; i < NetArray.length; i++) {
        ArrayList m_list = new ArrayList();
        if (NetArray[i] instanceof TermTaskInfo) {
          m_list.add(NetArray[i]);
        }
        else if (NetArray[i] instanceof ArrayList) {
          m_list = new ArrayList( (ArrayList) NetArray[i]);
        }
        else {
          continue; //类型错误，不处理
        }
        int listsize = m_list.size();
        for (int j = 0; j < listsize; j++) {
          Object m_Obj = m_list.remove(0);
          if (m_Obj instanceof TermTaskInfo) {
            TermTaskInfo m_Info = (TermTaskInfo) m_Obj;
            switch (m_Info.getPri()) {
              case 0x01: //低
                LowTaskList.add(m_Info);
                break;
              case 0x02: //中
                MidTaskList.add(m_Info);
                break;
              case 0x03: //高
                HighTaskList.add(m_Info);
                break;
              default:
                break;
            }
          }
        }
      }
      //System.out.println("@@@@@@@@@@@@@@@@    CollectorDefine.m_switchtasks OK");

      try {
        for (int i = 0; i < PursueLinkedArray.length; i++) {
          ArrayList m_list = new ArrayList();
          //20061204 pzy
          /*
                     if (PursueLinkedArray[i] instanceof terminal) {
            terminal m_terminal = (terminal) (PursueLinkedArray[i]);
            TermTaskInfo m_TermTaskInfo = new TermTaskInfo();
            m_TermTaskInfo.setTerminalName(m_terminal.getTerminalName());
            m_TermTaskInfo.setTerminalNo(m_terminal.getAddress());
            m_TermTaskInfo.setTaskType(CollectorDefine.SERVER_TASK);
            m_TermTaskInfo.setPri(m_terminal.getPri());
            m_list.add(m_TermTaskInfo);
                     }
           */
          if (PursueLinkedArray[i] instanceof TermTaskInfo) {
            m_list.add(PursueLinkedArray[i]);
          }
          else if (PursueLinkedArray[i] instanceof ArrayList) {
            m_list = new ArrayList( (ArrayList) PursueLinkedArray[i]);
          }
          //20061204 pzy
          else {
            continue; //类型错误，不处理