downts.java

通讯采集软件

package collector.checkts;

import java.rmi.*;
import java.util.*;
import javax.ejb.*;

import collector.common.*;
import collector.iiop.*;

public class DownTs {

  public IIopSwitch m_iiopswitch = null;
  public IIopDown m_iiopdown = null;

  public DownTs() {
  }

  public void intIIop() {
    int i = 0;
    this.m_iiopswitch = new IIopSwitch();
    this.m_iiopswitch.setIIopParam(collector.common.CollectorDefine.
                                   INITIAL_CONTEXT_FACTORY,
                                   collector.common.CollectorDefine.IIOP_URL1,
                                   collector.common.CollectorDefine.IIOP_URL2);
    this.m_iiopswitch.setIIopDownParam(collector.common.CollectorDefine.
                                       FSESSION_SERVER_JNDI);
    this.m_iiopswitch.setIIopSendDataParam(IIopDefine.INVALID_DEFINE);
    this.m_iiopswitch.setIIopEventParam(collector.common.CollectorDefine.
                                        PROCESSEVENT_JNDI);
    this.m_iiopswitch.setReconnectCounter(1);
    this.m_iiopswitch.initIIopSwitch(1);
    int num = this.m_iiopswitch.getMsgNum();
    for (i = 0; i < num; i++) {
      CFunction.writeLog("CheckTs", (String)this.m_iiopswitch.getMsg(), null);
      System.out.println( (String)this.m_iiopswitch.getMsg());
    }
  }

  public int initHashTs() {
    try {
      ArrayList m_tses = null;
      try {
        m_iiopdown = this.m_iiopswitch.getIIopDown();
        if (m_iiopdown == null) {
          return -1;
        }
        m_iiopdown.connect();
        m_tses = (ArrayList) m_iiopdown.findAllTs(143);
        m_iiopdown.close();
      }
      catch (CreateException m_CreateException) {
        //CFunction.writeLog("CheckTs","initHashTs CreateException Error In DownTs ",null);
        System.out.println("initHashTs CreateException Error In DownTs");
        return -1;
      }
      catch (RemoveException m_RemoveException) {
        //CFunction.writeLog("CheckTs","initHashTs RemoveException Error In DownTs ",null);
        System.out.println("initHashTs RemoveException Error In DownTs");
        return -1;
      }
      catch (RemoteException m_RemoteException) {
        //CFunction.writeLog("CheckTs","initHashTs RemoteException Error In DownTs ",null);
        System.out.println("initHashTs RemoteException Error In DownTs");
        return -1;
      }
      if (m_tses == null || m_tses.size() <= 0) {
        System.out.println("ts信息表无记录");
        return -1;
      }

      pbs.service.vo.terminal_server m_terminal_server = null;
      Iterator m_it_tses = m_tses.iterator();
      //pzy 20060801
      CheckDefine.m_HashTs = null;
      CheckDefine.m_HashTs = new HashMap();
      //pzy 20060801
      while (m_it_tses.hasNext()) {
        m_terminal_server = (pbs.service.vo.terminal_server) m_it_tses.next();
        if (m_terminal_server != null) {
          pbs.service.vo.terminal_server_type m_terminal_server_type =
              m_terminal_server.
              getTerminalServerType();
          if (m_terminal_server_type == null) {
            //CFunction.writeLog("initHashTs DownTs Error #1,ts_id :" +m_terminal_server.getTsId(), null);
            System.out.println("initHashTs DownTs Error #1,ts_id :" +
                               m_terminal_server.getTsId());
            return -1;
          }
          ArrayList m_portdefines = (ArrayList) m_terminal_server.
              getPortdefines();
          if (m_portdefines == null) {
            //CFunction.writeLog("initHashTs DownTs Error #2,ts_id :" +m_terminal_server.getTsId(), null);
            System.out.println("initHashTs DownTs Error #2,ts_id :" +
                               m_terminal_server.getTsId());
            return -1;
          }
          for (int i = 0; i < m_portdefines.size(); i++) {
            pbs.service.vo.portdefine m_portdefine = (pbs.service.vo.portdefine)
                m_portdefines.get(i);
          }
          if (m_portdefines.size() != m_terminal_server_type.getTsPortNum()) {
            //CFunction.writeLog("initHashTs DownTs Error #3,ts_id :" +m_terminal_server.getTsId(), null);
            System.out.println("initHashTs DownTs Error #3,ts_id :" +
                               m_terminal_server.getTsId());
            return -1;
          }
          long tsid = m_terminal_server.getTsId();
          CheckDefine.m_HashTs.put(new Long(tsid), m_terminal_server);
        }
        else {
          //CFunction.writeLog("CheckTs","initHashTs Error In DownTs #1",null);
          System.out.println("initHashTs Error In DownTs #1");
        }
      }
    }
    catch (Exception exception) {
      //CFunction.writeLog("CheckTs"," initHashTs Error In DownTs #2"+exception.getMessage(),null);
      System.out.println("initHashTs Error In DownTs #2" + exception.getMessage());
      return -1;
    }
    return 1;
  }

  public int initHashProtocol() {
    try {
      ArrayList m_protocols = null;
      try {
        m_iiopdown = this.m_iiopswitch.getIIopDown();
        if (m_iiopdown == null) {
          return -1;
        }
        m_iiopdown.connect();
        m_protocols = (ArrayList) m_iiopdown.findAllProtocol(123);
        m_iiopdown.close();
      }
      catch (CreateException m_CreateException) {
        //CFunction.writeLog("CheckTs","initHashProtocol CreateException Error In DownParam ",null);
        System.out.println(
            "initHashProtocol CreateException Error In DownParam ");
        return -1;
      }
      catch (RemoveException m_RemoveException) {
        //CFunction.writeLog("CheckTs","initHashProtocol RemoveException Error In DownParam ",null);
        System.out.println(
            "initHashProtocol RemoveException Error In DownParam ");
        return -1;
      }
      catch (RemoteException m_RemoteException) {
        //CFunction.writeLog("CheckTs","initHashProtocol RemoteException Error In DownParam ",null);
        System.out.println(
            "initHashProtocol RemoteException Error In DownParam ");
        return -1;
      }
      catch (Exception exception) {
        //CFunction.writeLog("CheckTs"," initHashProtocol Error In DownParam #1",null);
        System.out.println("initHashProtocol Error In DownParam #1");
        return -1;
      }

      if (m_protocols == null || m_protocols.size() <= 0) {
        System.out.println("规约信息表无记录");
        return -1;
      }
      Iterator m_it_protocols = m_protocols.iterator();
      pbs.service.vo.protocol m_Protocol = null;
      while (m_it_protocols.hasNext()) {
        m_Protocol = (pbs.service.vo.protocol) m_it_protocols.next();
        if (m_Protocol != null) {
          collector.common.CollectorDefine.m_HashProtocol.put(new Long(
              m_Protocol.getProtocolId()),
              m_Protocol);
          System.out.println("m_protocolid:" + m_Protocol.getProtocolId() +
                             "m_protocolno:" + m_Protocol.getProtocolNo() +
                             "m_protocolname:" + m_Protocol.getProtocolName());
        }
        else {
          //CFunction.writeLog("CheckTs","initHashProtocol Error In DownParam #1",null);
          System.out.println("initHashProtocol Error In DownParam #1");
        }
      }
    }
    catch (Exception exception) {
      //CFunction.writeLog("CheckTs","initHashProtocol Error In DownParam #2" + exception.getMessage(),null);
      System.out.println("initHashProtocol Error In DownParam #2");
      return -1;
    }
    return 1;
  }

  public int initHashSampleEventType() {
    System.out.println("begin to down sample_event_type param  ");
    try {
      ArrayList m_sampleeventtypes = null;
      try {
        m_iiopdown = this.m_iiopswitch.getIIopDown();
        if (m_iiopdown == null) {
          return -1;
        }
        m_iiopdown.connect();
        m_sampleeventtypes = (ArrayList) m_iiopdown.findAllSampleEventType(123);
        m_iiopdown.close();
      }
      catch (CreateException m_CreateException) {
        //CFunction.writeLog("CheckTs","initHashSampleEventType CreateException Error In DownParam ",null);
        System.out.println(
            "initHashSampleEventType CreateException Error In DownParam");
        return -1;
      }
      catch (RemoveException m_RemoveException) {
        //CFunction.writeLog("CheckTs","initHashSampleEventType RemoveException Error In DownParam ",null);
        System.out.println(
            "initHashSampleEventType RemoveException Error In DownParam");
        return -1;
      }
      catch (RemoteException m_RemoteException) {
        //CFunction.writeLog("CheckTs","initHashSampleEventType RemoteException Error In DownParam ",null);
        System.out.println(
            "initHashSampleEventType RemoteException Error In DownParam ");
        return -1;
      }
      catch (Exception exception) {
        //CFunction.writeLog("CheckTs","initHashSampleEventType Error In DownParam #1",null);
        System.out.println("initHashSampleEventType Error In DownParam #1");
        return -1;
      }

      if (m_sampleeventtypes == null || m_sampleeventtypes.size() <= 0) {
        System.out.println("事件配置信息表无记录");
        return -1;
      }
      Iterator m_it_sampleeventtypes = m_sampleeventtypes.iterator();
      pbs.service.vo.sample_event_type m_sampleeventtype = null;
      long protocolid = -1;
      while (m_it_sampleeventtypes.hasNext()) {
        m_sampleeventtype = (pbs.service.vo.sample_event_type)
            m_it_sampleeventtypes.next();
        if (m_sampleeventtype != null) {
          protocolid = m_sampleeventtype.getProtocolId();
          ArrayList array = (ArrayList) collector.common.CollectorDefine.
              m_HashSampleEventType.
              get(new Long(protocolid));
          if (array == null) {
            array = new ArrayList();
            array.add(m_sampleeventtype);
            collector.common.CollectorDefine.m_HashSampleEventType.put(new Long(
                protocolid),
                (ArrayList) array);
          }
          else {
            array.add(m_sampleeventtype);
            collector.common.CollectorDefine.m_HashSampleEventType.put(new Long(
                protocolid),
                (ArrayList) array);
          }
        }
        else {
          //CFunction.writeLog("CheckTs","initHashSampleEventType Error In DownParam #1",null);
          System.out.println("initHashSampleEventType Error In DownParam #1");
        }
      }
    }
    catch (Exception exception) {
      //CFunction.writeLog("CheckTs","initHashSampleEventType Error In DownParam #2" +exception.getMessage(),null);
      System.out.println("initHashSampleEventType Error In DownParam #2" +
                         exception.getMessage());
      return -1;
    }
    return 1;
  }

}