guimsg.java~1~

通讯采集软件

                                 m_param_modify.m_ids[k]
                  /*(vo)(((ArrayList)m_param_modify.vos).get(k)).toString()*/, null);
              this.m_downparam = new DownParam();
              this.m_downparam.modiHashTable(func_no, table_no,
                                             m_param_modify.m_ids[k],
                                             m_param_modify.m_nos[k],
                                             (Object) ( (ArrayList)
                  m_param_modify.vos).get(k),
                                             m_param_modify, k);

            }

//          m_arraylist = null;
          }
        }
      }
    }
    catch (Exception e) {
      CFunction.writeLog("guirec","getNotifyProcess In AutoCollector Error 2 ", e);

    }
    return 1;
  }

  private int recMsgProcess(JmsObject m_jmsobject) {
    Object object = null;
    int report_type = 0;
    long reccomputerid = 0;
    long sendcomputerid = 0;
    long terminalid = -1;
    if (m_jmsobject == null) {
      return -1;
    }
    try {
      System.out.println("recmsg");
      report_type = m_jmsobject.getJmsReportType();
      reccomputerid = m_jmsobject.getRecComputerId();
      sendcomputerid = m_jmsobject.getSendComputerId();
      terminalid = m_jmsobject.getTerminalId();
      object = m_jmsobject.getObject();
      m_jmsobject.getReportNo();
      if (reccomputerid != CollectorDefine.GUI_COMPUTER) {
        return -1;
      }
      MsgProcess(report_type, terminalid, sendcomputerid, object);
      m_jmsobject = null;
    }
    catch (Exception ee) {
      return -1;
    }
    return 1;
  }

  private int MsgProcess(int report_type, long terminalid, long sendcomputerid,
                         Object object) {
    try {
      if (report_type == CollectorDefine.LOGIN_JMS_TYPE) {
        System.out.println("***********   收到 LOGIN_JMS_TYPE ！！！");
        System.out.println("***********   terminal_id = " + terminalid);
        System.out.println("***********   object --user count = " +
                           ( (ArrayList) object).size());
        if (CollectorDefine.LOGIN_FLAG != true) {
          return -1;
        }
        if (terminalid == 1) {
          //不能登陆
          //显示一下已经有的所有用户
          Object[] name = new Object[] {
              "确定", "注销重名用户"};
          Object[] initvalue = new Object[] {
              new Integer(1), new Integer(2)};
          JOptionPane m_JOptionPane = new JOptionPane();
          int value = JOptionPane.showOptionDialog(FrontGuiDefine.m_FrontFrame,
              "已经有该用户登陆", "option",
              JOptionPane.YES_NO_OPTION,
              JOptionPane.QUESTION_MESSAGE,
              null, name, null);
          if (value == 0) {
            return -1;
          }
          else {
            sendLoginMsg(1);
            return -1;
          }
        }
        if (terminalid == -1) {
          ArrayList m_list = (ArrayList) (object);
          CollectorDefine.GuiArray = m_list;
          System.out.println("@@@@@@@@@@@@@@@@@@@@@@@@@用户列表");
          for (int i = 0; i < CollectorDefine.GuiArray.size(); i++) {
            GuiObject m_GuiObject = (GuiObject) (CollectorDefine.GuiArray.get(i));
            System.out.print(m_GuiObject.getUserName() + " ; ");
          }
          System.out.println();
          System.out.println("@@@@@@@@@@@@@@@@@@@@@@@@@用户列表");

          System.out.println("***********   马上初始化主界面！！！！！");
          CollectorDefine.LOGIN_FLAG = false;
          if (FrontGuiDefine.m_FrontFrame != null) {
            FrontGuiDefine.m_FrontFrame.EnableComponents();
            FrontGuiDefine.m_FrontFrame.initComputersPanel(false);
            this.InitFinished = true;
            CFunction.writeLog("guirec","***********   马上初始化主界面 ,this.InitFinished = true ",null);
            CollectorDefine.m_InitFinished = true;
          }
        }
      }
      else if (report_type == CollectorDefine.GET_LOGIN_USER) {
        System.out.println("***********   收到 GET_LOGIN_USER ！！！");
        System.out.println("***********   user count = " +
                           ( (ArrayList) (object)).size());
        ArrayList m_list = (ArrayList) (object);
        CollectorDefine.GuiArray = m_list;
        FrontGuiDefine.m_UserListDispDialog = null;
        FrontGuiDefine.m_UserListDispDialog = new UserListDispDialog(
            FrontGuiDefine.m_FrontFrame, false);
        FrontGuiDefine.m_UserListDispDialog.show();
      }
      else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_H) {
        if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
          return -1;
        }
        CollectorDefine.m_h_tasklist = (LinkedList) object;
      }
      else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_M) {
        if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
          return -1;
        }
        CollectorDefine.m_m_tasklist = (LinkedList) object;
      }
      else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_L) {
        if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
          return -1;
        }
        CollectorDefine.m_l_tasklist = (LinkedList) object;
      }
      else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_PURSUE_T) {
        if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
          return -1;
        }
        CollectorDefine.m_pursue_tasklist = (LinkedList) object;
      }
      else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_D) {
        if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
          return -1;
        }
        CollectorDefine.m_dial_tasklist = (LinkedList) object;
      }
      else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_S) {
        if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
          return -1;
        }
        CollectorDefine.m_switchtasks = (LinkedList) object;
      }
      else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_PURSUE_L) {
        if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
          return -1;
        }
        CollectorDefine.m_PursueLinkedList = (LinkedList) object;
      }
      else if (report_type == CollectorDefine.TASK_ASSIGN_JMS_TYPE_O) {
        if (CollectorDefine.TASK_ASSIGN_FLAG != true) {
          return -1;
        }
        CollectorDefine.m_OntimePursueLinkedList = (LinkedList) object;
        if (FrontGuiDefine.m_TaskAssignFrame != null) {
          FrontGuiDefine.m_TaskAssignFrame.initTaskList();
        }
      }
      else if (report_type == CollectorDefine.TASK_ASSIGN_WARN_JMS_TYPE) {
        if (CollectorDefine.TASK_ASSIGN_WARN_FLAG != true) {
          return -1;
        }
      }
      else if (report_type == CollectorDefine.DATA_PURSUE_JMS_TYPE) {
        if (CollectorDefine.DATA_PURSUE_FLAG == false) {
          return -1;
        }
        if (terminalid != CollectorDefine.m_DataTerminal) {
          return -1;
        }
      }
      else if (report_type == CollectorDefine.PARA_PURSUE_JMS_TYPE) {
        System.out.println("guimsg--收到类型为PARA_PURSUE_JMS_TYPE的jms消息");
        //pzy modi 20061205
        //if (FrontGuiDefine.m_ParaSetFrame != null) {
        if (FrontGuiDefine.m_ParaCallSetFrame != null) {
        //pzy modi 20061205
          if (CollectorDefine.PARA_PURSUE_FLAG) {
            ArrayList m_list = (ArrayList) object;
            if (m_list == null || m_list.size() <= 0) {
              System.out.println("guimsg--通讯程序返回设备时间不正常");
              return -1;
            }
            else {
              System.out.println("guimsg--收到时间召唤返回值, 个数: " + m_list.size());
              for (int i = 0; i < m_list.size(); i++) {
                meter_time m_metertime = (meter_time) (m_list.get(i));
                System.out.println("guimsg--" + m_metertime.toString());
              }
              //pzy modi 20061205
              //FrontGuiDefine.m_ParaSetFrame.setReturnTime(m_list);
              FrontGuiDefine.m_ParaCallSetFrame.setReturnTime(m_list);
              //pzy modi 20061205
            }
          }
          else {
            System.out.println(
                "guimsg--CollectorDefine.PARA_PURSUE_FLAG = false");
          }
        }
      }
      else if (report_type == CollectorDefine.SET_PARA_JMS_TYPE) {
        System.out.println("&&&&&&&&&&&&&&& guimsg 收到了类型为 SET_PARA_JMS_TYPE 的消息");
        //pzy modi 20061205
        //if (FrontGuiDefine.m_ParaSetFrame != null) {
        if(FrontGuiDefine.m_ParaCallSetFrame == null) {
          System.out.println("&&&&&&&&&&&&&&& guimsg FrontGuiDefine.m_ParaCallSetFrame == null");
        }
        if (FrontGuiDefine.m_ParaCallSetFrame != null) {
        //pzy modi 20061205
          if (CollectorDefine.SET_PARA_FLAG) {
            ArrayList ReturnList = (ArrayList) object;
            if (ReturnList == null || ReturnList.size() <= 0) {
              String filename = "d:\\users\\gui\\log\\" + "SetParaReturn.log";
              String timeString = PublicMethod.StringTimeSecond(System.
                  currentTimeMillis() / 1000l);
              System.out.println("guimsg--通讯程序返回设置结果不正常");
              return -1;
            }
            else {
              String filename = "d:\\users\\gui\\log\\SetParaReturn.log";
              String timeString = PublicMethod.StringTimeSecond(System.
                  currentTimeMillis() / 1000l);
              System.out.println("收到设置时间返回值，个数：" + ReturnList.size());
              for (int i = 0; i < ReturnList.size(); i++) {
                System.out.println(ReturnList.get(i));
              }
              //pzy modi 20061205
              //FrontGuiDefine.m_ParaSetFrame.setReturnString(ReturnList);
              System.out.println("&&&&&&&&&&&&&&& guimsg 调用了setReturnString");
              FrontGuiDefine.m_ParaCallSetFrame.setReturnString(ReturnList);
              System.out.println("&&&&&&&&&&&&&&& guimsg 调用setReturnString over");
              //pzy modi 20061205
            }
          }
        }
      }
      else if (report_type == CollectorDefine.PORT_MONITOR_JMS_TYPE) {
        if (CollectorDefine.PORT_MONITOR_FLAG == false) {
          return -1;
        }
        HashMap m_hashmap = (HashMap) object;
        if (m_hashmap == null) {
          return -1;
        }
        CollectorDefine.m_HashTs = m_hashmap;
        m_hashmap = null;
      }
      else if (report_type == CollectorDefine.UP_HINT_JMS_TYPE) {
        if (CollectorDefine.UP_HINT_FLAG == false) {
          return -1;
        }
        if (FrontGuiDefine.m_UpHintFrame == null) {
          FrontGuiDefine.m_UpHintFrame = new UpHintFrame(sendcomputerid);
          FrontGuiDefine.m_UpHintFrame.show();
        }
        if (FrontGuiDefine.m_UpHintFrame.isShowing() == false) {
          FrontGuiDefine.m_UpHintFrame.show();
        }
        FrontGuiDefine.m_UpHintFrame.appendElement(sendcomputerid,
            (String) object);
      }
      else if (report_type == CollectorDefine.WARN_HINT_JMS_TYPE) {
        if (CollectorDefine.WARN_HINT_FLAG == false) {
          return -1;
        }
        if (FrontGuiDefine.m_WarnInfoFrame == null) {
          FrontGuiDefine.m_WarnInfoFrame = new WarnInfoFrame(sendcomputerid);
          FrontGuiDefine.m_WarnInfoFrame.show();
        }
        if (FrontGuiDefine.m_WarnInfoFrame.isShowing() == false) {
          FrontGuiDefine.m_WarnInfoFrame.show();
        }
        FrontGuiDefine.m_WarnInfoFrame.appendElement(sendcomputerid,
            (String) object);
      }
      else if (report_type == CollectorDefine.REPORT_MONITOR_JMS_TYPE) {
        if (CollectorDefine.REPORT_MONITOR_FLAG == false) {
          String timeString = PublicMethod.StringTimeSecond(System.
              currentTimeMillis() / 1000l);
          return -1;
        }
        if (terminalid != CollectorDefine.m_ReportTerminal) {
          String timeString = PublicMethod.StringTimeSecond(System.
              currentTimeMillis() / 1000l);
          return -1;
        }
        if (FrontGuiDefine.m_ReportDispFrame != null) {
          String timeString = PublicMethod.StringTimeSecond(System.
              currentTimeMillis() / 1000l);
          FrontGuiDefine.m_ReportDispFrame.appendElement(sendcomputerid,
              (String) object, REPORT, terminalid);
        }
      }
      else if (report_type == CollectorDefine.EXPLAIN_MONITOR_JMS_TYPE) {
        if (CollectorDefine.EXPLAIN_MONITOR_FLAG == false) {
          String timeString = PublicMethod.StringTimeSecond(System.
              currentTimeMillis() / 1000l);
          return -1;
        }
        if (terminalid != CollectorDefine.m_ExplainTerminal) {
          String timeString = PublicMethod.StringTimeSecond(System.
              currentTimeMillis() / 1000l);
          return -1;
        }
        if (FrontGuiDefine.m_ReportDispFrame != null) {
          String timeString = PublicMethod.StringTimeSecond(System.
              currentTimeMillis() / 1000l);
          FrontGuiDefine.m_ReportDispFrame.appendElement(sendcomputerid,
              (String) object, EXPLAIN, terminalid);
        }
      }
      else if (report_type == CollectorDefine.CHAN_REPORT_MONITOR_JMS_TYPE) {
        if (CollectorDefine.CHAN_REPORT_MONITOR_FLAG == false) {
          String timeString = PublicMethod.StringTimeSecond(System.
              currentTimeMillis() / 1000l);
          return -1;
        }
        if (terminalid != CollectorDefine.m_ChannelTerminal) {
          String timeString = PublicMethod.StringTimeSecond(System.
              currentTimeMillis() / 1000l);
          return -1;
        }
        if (FrontGuiDefine.m_ReportDispFrame != null) {
          String timeString = PublicMethod.StringTimeSecond(System.
              currentTimeMillis() / 1000l);
          FrontGuiDefine.m_ReportDispFrame.appendElement(sendcomputerid,
              (String) object, CHANNEL, terminalid);
        }
      }
      else if (report_type == CollectorDefine.DATA_MONITOR_JMS_TYPE) {
        if (CollectorDefine.DATA_MONITOR_FLAG == false) {
          String timeString = PublicMethod.StringTimeSecond(System.
              currentTimeMillis() / 1000l);
          return -1;
        }
        if (terminalid != CollectorDefine.m_DataTerminal) {
          String timeString = PublicMethod.StringTimeSecond(System.
              currentTimeMillis() / 1000l);
          return -1;
        }
        if (FrontGuiDefine.m_DataDispFrame != null) {
          ArrayList m_meterDataList = (ArrayList) object;
          String timeString = PublicMethod.StringTimeSecond(System.
              currentTimeMillis() / 1000l);
          FrontGuiDefine.m_DataDispFrame.initDataTable(m_meterDataList,
              sendcomputerid, terminalid);
        }
      }
      else if (report_type == CollectorDefine.ALL_PARA_MONITOR_JMS_TYPE) {

      }
      else if (report_type == CollectorDefine.TITLE_MONITOR_JMS_TYPE) {
        if (CollectorDefine.TITLE_MONITOR_FLAG == false) {
          return -1;
        }
      }
      else if (report_type == CollectorDefine.IIOP_JMS_JMS_TYPE) {
        if (CollectorDefine.IIOP_JMS_FLAG == false) {
          return -1;
        }
      }
      else if (report_type == CollectorDefine.PARA_MONITOR_JMS_TYPE) {
        if (CollectorDefine.PARA_MONITOR_FLAG == false) {
          return -1;
        }

        int type = (int) terminalid;
        switch (type) {
          case 0: {
            System.out.println("***************    收到 参数检测 －－－－－ 要area");
            HashMap m_HashMap = (HashMap) object;
            if (m_HashMap != null) {
              Object[] objs = m_HashMap.values().toArray();
              if (objs.length > 0) {
                if (objs[0] instanceof area) {
                  Set key_set = m_HashMap.keySet();
                  Object[] keyArray = key_set.toArray();
                  if (keyArray.length > 0) {
                    for (int i = 0; i < keyArray.length; i++) {
                      Object key = keyArray[i];
                      area m_area = (area) (m_HashMap.get(key));
                      if (m_area != null) {
                        CollectorDefine.m_HashArea.put(key, m_area);
                      }
                    }
                  }
                  keyArray = null;
                  key_set = null;
                }
              }
            }
            this.sendParaMonitorMsg(sendcomputerid, 1, null);
            System.out.println("***************    发送 参数检测 －－－－－ 要factory");
            break;
          }
          case 1: {
            HashMap m_HashMap = (HashMap) object;
            if (m_HashMap != null) {
              Object[] objs = m_HashMap.values().toArray();
              if (objs.length > 0) {