guimsg.java.svn-base

通讯采集软件

             CFunction.writeLog("guirec",
                               "------FrontGuiDefine.m_TaskAssignFrame != null", null);

      }
      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) {
                if (objs[0] instanceof factory) {
                  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];
                      factory m_factory = (factory) (m_HashMap.get(key));
                      if (m_factory != null) {
                        CollectorDefine.m_HashFactory.put(key, m_factory);
                      }
                    }
                  }
                  keyArray = null;
                  key_set = null;
                }
              }
              System.out.println("***************    收到 参数检测 －－－－－ 要factory");
              System.out.println("***************    准备初始化参数检测界面");
            }
            break;
          }
          case 2: {
            HashMap m_HashMap = (HashMap) object;
            if (m_HashMap != null) {
              Object[] objs = m_HashMap.values().toArray();
              if (objs.length > 0) {
                if (objs[0] instanceof computer) {
                  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];
                      computer m_computer = (computer) (m_HashMap.get(key));
                      if (m_computer != null) {
                        CollectorDefine.m_HashComputer.put(key, m_computer);
                      }
                    }
                  }
                  keyArray = null;
                  key_set = null;
                }
              }
            }
            System.out.println("***************    收到 参数检测 －－－－－ 要computer");
            break;
          }
          case 3: {
            HashMap m_HashMap = (HashMap) object;
            if (m_HashMap != null) {
              Object[] objs = m_HashMap.values().toArray();
              if (objs.length > 0) {
                if (objs[0] instanceof channel) {
                  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];
                      channel m_channel = (channel) (m_HashMap.get(key));
                      if (m_channel != null) {
                        CollectorDefine.m_HashChannel.put(key, m_channel);
                      }
                    }
                  }
                  keyArray = null;
                  key_set = null;
                }
              }
            }
            System.out.println("***************    收到 参数检测 －－－－－ 要channel");
            break;
          }
          case 4: {
            HashMap m_HashMap = (HashMap) object;
            if (m_HashMap != null) {
              Object[] objs = m_HashMap.values().toArray();
              if (objs.length > 0) {
                if (objs[0] instanceof terminal_server) {
                  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];
                      terminal_server m_terminal_server = (terminal_server) (
                          m_HashMap.get(key));
                      if (m_terminal_server != null) {
                        CollectorDefine.m_HashTs.put(key, m_terminal_server);
                      }
                    }
                  }
                  keyArray = null;
                  key_set = null;
                }
              }