guimsg.java.svn-base

通讯采集软件

package collector.guimsg;

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

import javax.swing.*;

import collector.common.*;
import collector.common.queueobject.*;
import collector.control.*;
import collector.gui.method.*;
import collector.gui.view.*; //import collector.queue.*;//import pbs.service.eventobject.*;
import collector.jms.*;
//import collector.queue.*;
//import pbs.service.eventobject.*;
import pbs.service.struct.*;
import pbs.service.vo.*;
import pbs.service.function.*;

public class guimsg
    extends Thread {

private JmsSwitch m_jmsgui = null;
  private JmsSwitch m_jmsswitch = null;
  private static InetAddress remoteAddress;
  private long m_LastTime = 0;
  private long m_LastAliveTime = 0;
  private int counter = 0;
  private long m_nowTime = 0;
  public boolean InitFinished = false;

  private static final int REPORT = 0;
  private static final int CHANNEL = 1;
  private static final int EXPLAIN = 2;

  private DownParam m_downparam = null;

  public guimsg() throws IOException {
  }

  private void resetFlag() {
    CollectorDefine.TASK_ASSIGN_FLAG = false;
    CollectorDefine.TASK_ASSIGN_WARN_FLAG = false;
    CollectorDefine.taskwarnmsgArray.clear();

    CollectorDefine.PARA_PURSUE_FLAG = false;
    CollectorDefine.DATA_PURSUE_FLAG = false;
    CollectorDefine.SET_PARA_FLAG = false;
    CollectorDefine.IIOP_JMS_FLAG = false;
    CollectorDefine.PORT_MONITOR_FLAG = false;

    CollectorDefine.TITLE_MONITOR_FLAG = false;
    CollectorDefine.titalmsgArray.clear();

    System.out.println("    CollectorDefine.TITLE_MONITOR_FLAG :" + new
                       Boolean(CollectorDefine.TITLE_MONITOR_FLAG).toString());
  }

  private void resetAllFlag() {
    CollectorDefine.TASK_ASSIGN_FLAG = false;
    CollectorDefine.TASK_ASSIGN_WARN_FLAG = false;
    CollectorDefine.PARA_PURSUE_FLAG = false;
    CollectorDefine.DATA_PURSUE_FLAG = false;
    CollectorDefine.SET_PARA_FLAG = false;
    CollectorDefine.IIOP_JMS_FLAG = false;
    CollectorDefine.PORT_MONITOR_FLAG = false;
    CollectorDefine.UP_HINT_FLAG = false;
    CollectorDefine.WARN_HINT_FLAG = false;
    CollectorDefine.REPORT_MONITOR_FLAG = false;
    CollectorDefine.EXPLAIN_MONITOR_FLAG = false;
    CollectorDefine.CHAN_REPORT_MONITOR_FLAG = false;
    CollectorDefine.DATA_MONITOR_FLAG = false;
    CollectorDefine.TITLE_MONITOR_FLAG = false;
    CollectorDefine.LOGIN_FLAG = false;
  }

  private void resetFlag(int report_type) {
    if (report_type == CollectorDefine.WARN_HINT_JMS_TYPE ||
        report_type == CollectorDefine.REPORT_MONITOR_JMS_TYPE ||
        report_type == CollectorDefine.EXPLAIN_MONITOR_JMS_TYPE ||
        report_type == CollectorDefine.CHAN_REPORT_MONITOR_JMS_TYPE ||
        report_type == CollectorDefine.DATA_MONITOR_JMS_TYPE ||
        report_type == CollectorDefine.UP_HINT_JMS_TYPE) {
      CollectorDefine.TASK_ASSIGN_FLAG = false;
      CollectorDefine.TASK_ASSIGN_WARN_FLAG = false;
      CollectorDefine.PARA_PURSUE_FLAG = false;
      CollectorDefine.DATA_PURSUE_FLAG = false;
      CollectorDefine.SET_PARA_FLAG = false;
      CollectorDefine.PORT_MONITOR_FLAG = false;
      CollectorDefine.TASK_ASSIGN_FLAG = false;
      CollectorDefine.IIOP_JMS_FLAG = false;
    }
  }

/*  public int reConnectJMSFront() {
    try {
      long m_Time = System.currentTimeMillis() / 1000;
      if ( (m_Time / 60) != (this.m_LastTime / 60)) {
        this.m_LastTime = m_Time;
        this.m_jmsgui.reConnectJMSFront();
        int num = this.m_jmsgui.getMsgNum();
        int i = 0;
      }

      return 1;
    }
    catch (Exception m_Exception) {
      CFunction.writeLog("guirec", " reConnectJMS Error In guimsg #3",
                         m_Exception);
      return -1;
    }
  }
*/
/*  public int exitProcess() {
    this.m_jmsgui.close(JmsDefine.m_JmsHost1);
    return 1;
  }
*/
  private int writeObject(JmsObject m_JmsObject) {
    if (m_JmsObject == null) {
      return -1;
    }
    try {
      int m_SuccessFlag1 = -1;
      int m_SuccessFlag2 = -1;

      m_SuccessFlag1 = this.m_jmsgui.getJmsFront().broadcast(m_JmsObject);

      CFunction.writeLog("gui_send",m_JmsObject.toString() , null);
      this.m_jmsgui.adjustJmsFront1(m_SuccessFlag1);
      return 1;
    }
    catch (Exception m_Exception) {
      CFunction.writeLog("guirec", " sendInQuirReport Error In guimsg #1",
                         m_Exception);
      return -1;
    }
  }

  private IIopJmsObject assIIopJmsObject() {
    return null;
  }

  public int sendLoginMsg(int flag) {
    if (sendMsg( -1, CollectorDefine.LOGIN_JMS_TYPE, flag, null) > 0) { //第一次-1,重名以后1
      //多界面有用
      CFunction.writeLog("guirec", "send Login msg seccess ! ", null);
      CollectorDefine.LOGIN_FLAG = true;
      //多界面有用
      System.out.println("sendMsg to Collector ");
      return 1;
    }
    return -1;
  }

  public int sendTaskAssignMsg() {
    if (sendMsg( -1, CollectorDefine.TASK_ASSIGN_JMS_TYPE, -1, null) > 0) {
      CollectorDefine.TASK_ASSIGN_FLAG = true;
      return 1;
    }
    return -1;
  }

  public int sendTaskAssignWarnMsg(long reccomputerid) {
    if (sendMsg(reccomputerid, CollectorDefine.TASK_ASSIGN_WARN_JMS_TYPE, -1, null) >
        0) {
      CollectorDefine.TASK_ASSIGN_WARN_FLAG = true;
      return 1;
    }
    return -1;
  }

  public int sendParaPursueMsg(terminal m_terminal) {
    System.out.println("");
    System.out.println("@@@@@@@@@@@@@@@   召唤时间   @@@@@@@@@@@@@@@@@@");
    System.out.println("guimsg ----- sendParaPursueMsg:terminal_id = " +
                       m_terminal.getTerminalId());
    if (sendMsg( -1, CollectorDefine.PARA_PURSUE_JMS_TYPE, -1, m_terminal) > 0) {
      CollectorDefine.PARA_PURSUE_FLAG = true;
      return 1;
    }
    return -1;
  }

  public int sendDataPursueMsg(long terminalid, ArrayList m_array) {
    if (sendMsg( -1, CollectorDefine.DATA_PURSUE_JMS_TYPE, terminalid, m_array) >
        0) {
      CollectorDefine.DATA_PURSUE_FLAG = true;
      return 1;
    }
    return -1;
  }

  public int sendSetParaMsg(terminal m_terminal) {
    //现在是设系统时间，所以m_Date设置为null，如果指定时间，设定m_Date就好了
    System.out.println("");
    System.out.println("@@@@@@@@@@@@@@@   设置时间   @@@@@@@@@@@@@@@@@@");
    System.out.println("guimsg ---- sendSetParaMsg : terminal_id = " +
                       m_terminal.getTerminalId());

    if (sendMsg( -1, CollectorDefine.SET_PARA_JMS_TYPE, -1, m_terminal) >
        0) {
      CollectorDefine.SET_PARA_FLAG = true;
      return 1;
    }
    return -1;
  }

  public int sendPortMonitorMsg() {
    if (sendMsg( -1, CollectorDefine.PORT_MONITOR_JMS_TYPE, -1, null) > 0) {
      CollectorDefine.PORT_MONITOR_FLAG = true;
      return 1;
    }
    return -1;
  }

  public int sendUpHintMsg(long reccomputerid) {
    if (sendMsg(reccomputerid, CollectorDefine.UP_HINT_JMS_TYPE, -1, null) > 0) {
      CollectorDefine.UP_HINT_FLAG = true;
      return 1;
    }
    return -1;
  }

  public int sendWarnHintMsg(long reccomputerid) {
    if (sendMsg(reccomputerid, CollectorDefine.WARN_HINT_JMS_TYPE, -1, null) >
        0) {
      CollectorDefine.WARN_HINT_FLAG = true;
      return 1;
    }
    return -1;
  }

  public int sendReportMonitorMsg(long terminalid) {
    if (sendMsg( -1, CollectorDefine.REPORT_MONITOR_JMS_TYPE, terminalid, null) >
        0) {
      CollectorDefine.REPORT_MONITOR_FLAG = true;
      CollectorDefine.m_ReportTerminal = terminalid;
      String timeString = PublicMethod.StringTimeSecond(System.
          currentTimeMillis() / 1000l);
      //PublicMethod.WriteToFile("d:\\pbs_jiangsu\\log\\Report.log",timeString);
      //PublicMethod.WriteToFile("d:\\pbs_jiangsu\\log\\Report.log",
      //new Long(CollectorDefine.m_ReportTerminal).toString()+"  "+"guimsg.sendReportMonitorMsg()");
      return 1;
    }
    return -1;
  }

  public int sendExplainMonitorMsg(long terminalid) {
    if (sendMsg( -1, CollectorDefine.EXPLAIN_MONITOR_JMS_TYPE, terminalid, null) >
        0) {
      CollectorDefine.EXPLAIN_MONITOR_FLAG = true;
      CollectorDefine.m_ExplainTerminal = terminalid;
      String timeString = PublicMethod.StringTimeSecond(System.
          currentTimeMillis() / 1000l);
      //PublicMethod.WriteToFile("d:\\pbs_jiangsu\\log\\Explain.log",timeString);
      //PublicMethod.WriteToFile("d:\\pbs_jiangsu\\log\\Explain.log",
      //new Long(CollectorDefine.m_ReportTerminal).toString()+"  "+"guimsg.sendExplainMonitorMsg()");
      return 1;
    }
    return -1;
  }

  public int sendChReportMonitorMsg(long terminalid) {
    if (sendMsg( -1, CollectorDefine.CHAN_REPORT_MONITOR_JMS_TYPE, terminalid, null) >
        0) {
      CollectorDefine.CHAN_REPORT_MONITOR_FLAG = true;
      CollectorDefine.m_ReportTerminal = terminalid;
      String timeString = PublicMethod.StringTimeSecond(System.
          currentTimeMillis() / 1000l);
      //PublicMethod.WriteToFile("d:\\pbs_jiangsu\\log\\Channel.log",timeString);
      //PublicMethod.WriteToFile("d:\\pbs_jiangsu\\log\\Channel.log",
      //new Long(CollectorDefine.m_ReportTerminal).toString()+"  "+"guimsg.sendChReportMonitorMsg()");
      return 1;
    }
    return -1;
  }

  public int sendDataMonitorMsg(long terminalid) {
    if (sendMsg( -1, CollectorDefine.DATA_MONITOR_JMS_TYPE, terminalid, null) >
        0) {
      CollectorDefine.DATA_MONITOR_FLAG = true;
      CollectorDefine.m_DataTerminal = terminalid;
      String timeString = PublicMethod.StringTimeSecond(System.
          currentTimeMillis() / 1000l);
      //PublicMethod.WriteToFile("d:\\pbs_jiangsu\\log\\Data.log",timeString);
      terminal m_terminal = (terminal) (CollectorDefine.m_HashTerminal.get(new
          Long(terminalid)));
      //PublicMethod.WriteToFile("d:\\pbs_jiangsu\\log\\Data.log","监测的计量单元名： "+m_terminal.getTerminalName());
      //PublicMethod.WriteToFile("d:\\pbs_jiangsu\\log\\Data.log","CollectorDefine.m_DataTerminal = "+
      //new Long(CollectorDefine.m_DataTerminal).toString()+"  "+"guimsg.sendDataMonitorMsg("+terminalid+")");
      return 1;
    }
    return -1;
  }

  public int sendTitleMonitorMsg(long reccomputerid) {
    if (sendMsg(reccomputerid, CollectorDefine.TITLE_MONITOR_JMS_TYPE, -1, null) >
        0) {
      CollectorDefine.TITLE_MONITOR_FLAG = true;
      return 1;
    }
    return -1;
  }

  public int sendIIopJmsMsg(long reccomputerid) {
    if (sendMsg(reccomputerid, CollectorDefine.IIOP_JMS_JMS_TYPE, -1, null) > 0) {
      CollectorDefine.IIOP_JMS_FLAG = true;
      return 1;
    }
    return -1;
  }

  public int sendTerminalMsg(long reccomputerid, long term_id) {
    if (reccomputerid < 0) {
      if (sendMsg( -1, CollectorDefine.TERMINAL_JMS_TYPE, -1, new Long(term_id)) >
          0) {
        CollectorDefine.TERMINAL_FLAG = true;
        return 1;
      }
      return -1;
    }
    else {
      if (sendMsg(reccomputerid, CollectorDefine.TERMINAL_JMS_TYPE, -1,
                  new Long(term_id)) >
          0) {
        CollectorDefine.TERMINAL_FLAG = true;
        return 1;
      }
      return -1;
    }
  }

  private long Para_Computer_Id = -1;
  private long getParaCompId() {
    return this.Para_Computer_Id;
  }

  private void setParaCompId(long comp_id) {
    this.Para_Computer_Id = comp_id;
  }