notification_t.java

经过反编译和部分代码修改后的ultraimpro java源代码。可在netbean环境下成功编译。供学习和分析用。

// Decompiled by DJ v3.9.9.91 Copyright 2005 Atanas Neshkov  Date: 2006-5-1 19:31:43
// Home Page : http://members.fortunecity.com/neshkov/dj.html  - Check often for new version!
// Decompiler options: packimports(3) 

import java.util.Hashtable;
import java.util.Vector;

public final class Notification_t
    implements ServerConnection_ar
{

    public Notification_t(String s, Integer integer)
    {
        iTraceId = 0;
        a_boolean_fld = false;
        f_int_fld = 0;
        g = 0;
        b_boolean_fld = false;
        strServerName = s;
        IServerPort = integer;
        a_java_util_Hashtable_fld = new Hashtable();
        a_java_util_Vector_fld = new Vector();
        a_e_fld = new e();
        b_java_util_Vector_static_fld = new Vector();
        ConnectionManage_ag.GetObject();
        c_int_fld = 20;
        d_int_fld = 0;
    }

    public final void ConnectServer(String s, String s1, String s2, String s3, int i1, boolean flag)
    {
        strSignState = s2;
        strSignPara = s3;
        strAccntName = s;
        strAccntPswd = s1;
        a_int_fld = i1;
        a_bp_fld = new SocketManage_bp(strServerName, IServerPort.intValue(), this);
        if(!IsSocketOpen())
        {
            d_int_fld = -200;
            return;
        }
        OutCommandComposit_ae ae1;
        (ae1 = new OutCommandComposit_ae(32, GetTraceId())).AddString("MSNP11");
        ae1.AddString("CVR0");
        a_bp_fld.Output(ae1);
        c_int_fld = c_int_fld + 20;
        if(flag && IsSocketOpen())
            try
            {
                synchronized(this)
                {
                    wait();
                }
                return;
            }
            catch(InterruptedException _ex) { }
    }

    public final String a_mod_tos()
    {
        return String.valueOf(e_int_fld);
    }

    public final void SendMsnMsg(String s, String s1, Object obj, int i1)
    {
        Object obj1 = a_java_util_Hashtable_fld.get(s);
        SwitchBoard_bf bf1 = null;
        boolean flag = false;
        if(obj1 == null)
        {
            if(s1.equals("Multiway"))
            {
                ConnectionManage_ag.GetObject().g(s);
                return;
            }
            if((obj1 = a_java_util_Hashtable_fld.get(s1)) == null)
            {
                bf1 = new SwitchBoard_bf(strAccntName, s1, this);
                a_java_util_Hashtable_fld.put(s1, bf1);
                flag = true;
            } else
            {
                bf1 = (SwitchBoard_bf)obj1;
            }
        } else
        {
            bf1 = (SwitchBoard_bf)obj1;
        }
        bf1.SendMsnMsg(flag, i1, obj);
    }

    public final void a(String s, String s1, String s2)
    {
        Object obj = a_java_util_Hashtable_fld.get(s);
        Object obj1 = null;
        if(obj == null)
        {
            if(s1.equals("Multiway"))
            {
                ConnectionManage_ag.GetObject().g(s);
                return;
            }
            SwitchBoard_bf bf1 = new SwitchBoard_bf(strAccntName, s1, this);
            a_java_util_Hashtable_fld.put(s1, bf1);
            bf1.SendMsnMsg(true, 4, null);
            try
            {
                while(!bf1.b_boolean_fld) 
                    Thread.sleep(300L);
            }
            catch(Exception _ex)
            {
                return;
            }
            bf1.a(s2);
            return;
        } else
        {
            ((SwitchBoard_bf)obj).a(s2);
            return;
        }
    }

    public final void a(String s)
    {
        Object obj;
        if((obj = a_java_util_Hashtable_fld.get(s)) == null)
        {
            return;
        } else
        {
            ((SwitchBoard_bf)obj).b();
            return;
        }
    }

    public final void a()
    {
        OutCommandComposit_ae ae1 = new OutCommandComposit_ae(22, -1);
        a_bp_fld.Output(ae1);
        a_e_fld.a();
        try
        {
            Thread.sleep(1000L);
        }
        catch(Exception _ex) { }
        a_bp_fld.CloseSocket();
    }

    public final void b(String s)
    {
        strSignState = s;
        b();
    }

    public final void c(String s)
    {
        strSignPara = s;
        b();
    }

    public final void b()
    {
        if(IsSocketOpen() && PresenceStringHash_az.a(strSignState).compareTo("UNKNOWN") != 0)
        {
            OutCommandComposit_ae ae1;
            (ae1 = new OutCommandComposit_ae(9, GetTraceId())).AddString(strSignState);
            //ae1.AddString(String.valueOf(0x10008005 + ConnectionManage_ag.a_int_static_fld)); for mobile
            ae1.AddString(String.valueOf(0x10008004 + ConnectionManage_ag.a_int_static_fld));
            if(strSignPara != null && strSignPara.length() > 0)
                ae1.AddString(u.a(strSignPara, 0));
            a_bp_fld.Output(ae1);
        }
    }

    public final void a(ab ab1)
    {
        if(a_e_fld.a(ab1.a_java_lang_String_fld) != null)
            return;
        if(IsSocketOpen())
        {
            String s = ab1.a_java_lang_String_fld;
            OutCommandComposit_ae ae1;
            (ae1 = new OutCommandComposit_ae(27, GetTraceId())).AddString("BL");
            ae1.AddString(s);
            a_bp_fld.Output(ae1);
            (ae1 = new OutCommandComposit_ae(2, GetTraceId())).AddString("AL");
            ae1.AddString("N=" + s);
            a_bp_fld.Output(ae1);
            b_java_util_Vector_static_fld.addElement(ab1);
            (ae1 = new OutCommandComposit_ae(2, GetTraceId())).AddString("FL");
            ae1.AddString("N=" + s);
            ae1.AddString("F=" + (ab1.b.equals("") ? s : u.b(ab1.b)));
            a_bp_fld.Output(ae1);
        }
    }

    public final void b(ab ab1)
    {
        if(IsSocketOpen())
        {
            OutCommandComposit_ae ae1;
            (ae1 = new OutCommandComposit_ae(27, GetTraceId())).AddString("FL");
            ae1.AddString(ab1.c);
            a_bp_fld.Output(ae1);
        }
    }

    public final void c(ab ab1)
    {
        if(IsSocketOpen())
        {
            String s = ab1.a_java_lang_String_fld;
            OutCommandComposit_ae ae1;
            (ae1 = new OutCommandComposit_ae(27, GetTraceId())).AddString("AL");
            ae1.AddString(s);
            a_bp_fld.Output(ae1);
            (ae1 = new OutCommandComposit_ae(2, GetTraceId())).AddString("BL");
            ae1.AddString("N=" + s);
            a_bp_fld.Output(ae1);
        }
    }

    public final void d(ab ab1)
    {
        if(IsSocketOpen())
        {
            String s = ab1.a_java_lang_String_fld;
            OutCommandComposit_ae ae1;
            (ae1 = new OutCommandComposit_ae(27, GetTraceId())).AddString("BL");
            ae1.AddString(s);
            a_bp_fld.Output(ae1);
            (ae1 = new OutCommandComposit_ae(2, GetTraceId())).AddString("AL");
            ae1.AddString("N=" + s);
            a_bp_fld.Output(ae1);
        }
    }

    public final void c()
    {
        if(IsSocketOpen())
        {
            OutCommandComposit_ae ae1;
            (ae1 = new OutCommandComposit_ae(30, GetTraceId())).AddString("0");
            ae1.AddString("0");
            a_e_fld.a();
            a_bp_fld.Output(ae1);
        }
    }

    public final boolean IsSocketOpen()
    {
        return a_bp_fld.blSocketOpen;
    }

    public final void d(String s)
    {
        String s1 = u.b(s);
        OutCommandComposit_ae ae1;
        (ae1 = new OutCommandComposit_ae(23, GetTraceId())).AddString("MFN");
        ae1.AddString(s1);
        a_bp_fld.Output(ae1);
    }

    private int GetTraceId()
    {
        iTraceId++;
        return iTraceId;
    }

    public final void a(InputCommandProcess_be be1, String s)
    {
        switch(be1.CommandIndex)
        {
        case 32: // ' '
            a(be1);
            return;

        case 34: // '"'
            b(be1);
            return;

        case 31: // '\037'
            c(be1);
            return;

        case 10: // '\n'
            d(be1);
            return;

        case 33: // '!'
            e(be1);
            return;

        case 29: // '\035'
            f(be1);
            return;

        case 13: // '\r'
            h(be1);
            return;

        case 21: // '\025'
            j(be1);
            return;

        case 11: // '\013'
            i(be1);
            return;

        case 18: // '\022'
            k(be1);
            return;

        case 17: // '\021'
            l(be1);
            return;

        case 30: // '\036'
            m(be1);
            return;

        case 23: // '\027'
            g(be1);
            return;

        case 2: // '\002'
            n(be1);
            return;

        case 27: // '\033'
            o(be1);
            return;

        case 36: // '$'
            b(be1, s);
            // fall through

        case 3: // '\003'
        case 4: // '\004'
        case 5: // '\005'
        case 6: // '\006'
        case 7: // '\007'
        case 8: // '\b'
        case 9: // '\Notification_t'
        case 12: // '\f'
        case 14: // '\016'
        case 15: // '\017'
        case 16: // '\020'
        case 19: // '\023'
        case 20: // '\024'
        case 22: // '\026'
        case 24: // '\030'
        case 25: // '\031'
        case 26: // '\032'
        case 28: // '\034'
        case 35: // '#'
        default:
            return;
        }
    }

    public final void d()
    {
        synchronized(this)
        {
            notifyAll();
        }
        if(a_boolean_fld)
        {
            a_boolean_fld = false;
            ConnectionManage_ag.GetObject().e();
        }
    }

    private void a(InputCommandProcess_be be1)
    {
        OutCommandComposit_ae ae1 = new OutCommandComposit_ae(34, GetTraceId());
        String s = "0x0409 winnt 5.1 i386 MSNMSGR 7.0.0816 MSMSGS " + strAccntName;
        ae1.AddString(s);
        a_bp_fld.Output(ae1);
    }

    private void b(InputCommandProcess_be be1)
    {
        c_int_fld = c_int_fld + 10;
        OutCommandComposit_ae ae1;
        (ae1 = new OutCommandComposit_ae(31, GetTraceId())).AddString("TWN");
        ae1.AddString("I");
        ae1.AddString(strAccntName);
        a_bp_fld.Output(ae1);
    }

    private void c(InputCommandProcess_be be1)
    {
        try
        {
            String s;
            if((s = be1.a()).equals(CommandProcess_aq.GetCommandName(14)))
            {
                c_int_fld = c_int_fld + 10;
                String s1 = null;
                String as[];
                if((as = af.a(strAccntName, strAccntPswd, be1.k(), a_int_fld)) == null)
                {
                    d_int_fld = -101;
                    throw new bq();
                }
                a_int_fld = Integer.parseInt(as[0]);
                if((s1 = as[1]) == null)
                {
                    d_int_fld = -101;
                    throw new bq();