downts.java.svn-base

通讯采集软件

package collector.checkts;

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

import collector.common.*;
import collector.iiop.*;
import pbs.service.vo.*;

public class DownTs {
    
    public IIopSwitch m_iiopswitch = null;
    public IIopDown m_iiopdown = null;
    
    public DownTs() {
        int i = 0;
        this.m_iiopswitch = new IIopSwitch();
        this.m_iiopswitch.setIIopParam(CollectorDefine.INITIAL_CONTEXT_FACTORY,
        CollectorDefine.IIOP_URL1,
        CollectorDefine.IIOP_URL2);
        this.m_iiopswitch.setIIopDownParam(CollectorDefine.FSESSION_SERVER_JNDI);
        this.m_iiopswitch.setIIopSendDataParam(IIopDefine.INVALID_DEFINE);
        this.m_iiopswitch.setIIopEventParam(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;
            }
            
            terminal_server m_terminal_server = null;
            Iterator m_it_tses = m_tses.iterator();
            while (m_it_tses.hasNext()) {
                m_terminal_server = (terminal_server) m_it_tses.next();
                if (m_terminal_server != null) {
                    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++) {
                        portdefine m_portdefine = (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();
            protocol m_Protocol = null;
            while (m_it_protocols.hasNext()) {
                m_Protocol = (protocol) m_it_protocols.next();
                if (m_Protocol != null) {
                    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();
            sample_event_type m_sampleeventtype = null;
            long protocolid = -1;
            while (m_it_sampleeventtypes.hasNext()) {
                m_sampleeventtype = (sample_event_type) m_it_sampleeventtypes.next();
                if (m_sampleeventtype != null) {
                    protocolid = m_sampleeventtype.getProtocolId();
                    ArrayList array = (ArrayList) CollectorDefine.m_HashSampleEventType.
                    get(new Long(protocolid));
                    if (array == null) {
                        array = new ArrayList();
                        array.add(m_sampleeventtype);
                        CollectorDefine.m_HashSampleEventType.put(new Long(protocolid),
                        (ArrayList) array);
                    }
                    else {
                        array.add(m_sampleeventtype);
                        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;
    }
    
}