notification_t.java

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

                }
                if(s1.equals(String.valueOf(401)))
                {
                    d_int_fld = 401;
                    throw new bq();
                }
                c_int_fld = 90;
                OutCommandComposit_ae ae1;
                (ae1 = new OutCommandComposit_ae(31, GetTraceId())).AddString(CommandProcess_aq.GetCommandName(14));
                ae1.AddString("S");
                ae1.AddString(s1);
                a_bp_fld.Output(ae1);
            } else
            if(s.equals("OK"))
            {
                c_int_fld = 100;
                synchronized(this)
                {
                    notifyAll();
                }
                ConnectionManage_ag.GetObject().f();
                a_boolean_fld = true;
            }
            return;
        }
        catch(Exception _ex)
        {
            a_bp_fld.CloseSocket();
        }
    }

    private void d(InputCommandProcess_be be1)
    {
        try
        {
            if(!b_boolean_fld)
            {
                b_boolean_fld = true;
                ConnectionManage_ag.GetObject().g();
            }
            OutCommandComposit_ae ae1;
            (ae1 = new OutCommandComposit_ae(24, GetTraceId())).AddString("PROD0101{0RM?UBW");
            ae1.AddString("32");
            ae1.AddString("\r\n");
            ae1.AddString((new aj()).a_mod_tos(be1.k()));
            a_bp_fld.Output(ae1);
            if(!a_bp_fld.b)
                a_bp_fld.b = true;
            return;
        }
        catch(Exception _ex)
        {
            return;
        }
    }

    private void e(InputCommandProcess_be be1)
    {
        String s;
        Object obj;
        SwitchBoard_bf bf1;
        String s1;
        int i1;
        String s2;
        try
        {
            /*
            if(!(s = be1.f()).equals("SB"))
                //break; // MISSING_BLOCK_LABEL_108;
                return;
            synchronized(a_java_util_Vector_fld)
            {
                obj = a_java_util_Vector_fld.lastElement();
                a_java_util_Vector_fld.removeElement(obj);
            }
            if(obj == null)
                return;
             */
             if((s = be1.f()).equals("SB"))
             {
                synchronized(a_java_util_Vector_fld)
                {
                    obj = a_java_util_Vector_fld.lastElement();
                    a_java_util_Vector_fld.removeElement(obj);
                }
                if(obj == null)
                    return;
        
                bf1 = (SwitchBoard_bf)obj;
                s1 = be1.g();
                i1 = be1.a_mod_toi();
                s2 = be1.k();
                bf1.a(s1, i1, null, s2);
                bf1.a_boolean_fld = true;
                bf1.SetupConnection(); 
             }
             else if(s.equals("NS"))
            {
                d_java_lang_String_fld = be1.g();
                e_int_fld = be1.a_mod_toi();
                d_int_fld = -500;
                a_bp_fld.CloseSocket();
            }             
         }
        catch(Exception _ex)
        {
            return;
        }

        //break MISSING_BLOCK_LABEL_147;

    }

    private void f(InputCommandProcess_be be1)
    {
        try
        {
            String s = be1.l();
            String s1 = be1.e();
            String s2 = be1.k();
            String s3 = be1.g();
            int i1 = be1.a_mod_toi();
            SwitchBoard_bf bf1 = new SwitchBoard_bf(strAccntName, s1, this);
            a_java_util_Hashtable_fld.put(s, bf1);
            bf1.a(s3, i1, s, s2);
            bf1.a_boolean_fld = false;
            bf1.SetupConnection();
            return;
        }
        catch(Exception _ex)
        {
            return;
        }
    }

    private void g(InputCommandProcess_be be1)
    {
        String s;
        if((s = be1.b_mod_tos()) != null)
            ConnectionManage_ag.GetObject().e(s);
    }

    private void h(InputCommandProcess_be be1)
    {
        try
        {
            ConnectionManage_ag.GetObject().a(be1.e(), be1.b_mod_tos(), new PresenceStringHash_az(be1.h()), be1.c());
            return;
        }
        catch(Exception _ex)
        {
            return;
        }
    }

    private void i(InputCommandProcess_be be1)
    {
        ConnectionManage_ag.GetObject().a(be1.e(), 6, be1.h());
    }

    private void j(InputCommandProcess_be be1)
    {
        try
        {
            ConnectionManage_ag.GetObject().a(be1.e(), be1.b_mod_tos(), new PresenceStringHash_az(be1.h()), be1.c());
            return;
        }
        catch(Exception _ex)
        {
            return;
        }
    }

    private void k(InputCommandProcess_be be1)
    {
        Hashtable hashtable = be1.a_mod_toh();
        String s = be1.e();
        ab ab1;
        (ab1 = new ab(s)).b = be1.b_mod_tos();
        ab1.a_java_util_Hashtable_fld = hashtable;
        if(hashtable.containsKey(e.a_mod_toI("FL")))
        {
            ab1.e_java_lang_String_fld = be1.i();
            ab1.c = be1.d();
            a_e_fld.a(ab1);
            ConnectionManage_ag.GetObject().f(ab1);
        } else
        if(hashtable.size() == 1 && hashtable.containsKey(e.a_mod_toI("RL")))
            ConnectionManage_ag.GetObject().e(ab1);
        if(hashtable.containsKey(e.a_mod_toI("PL")))
        {
            OutCommandComposit_ae ae1;
            (ae1 = new OutCommandComposit_ae(2, GetTraceId())).AddString("RL");
            ae1.AddString("N=" + s);
            a_bp_fld.Output(ae1);
            (ae1 = new OutCommandComposit_ae(27, GetTraceId())).AddString("PL");
            ae1.AddString(s);
            a_bp_fld.Output(ae1);
        }
        g++;
        if(f_int_fld > 0 && g == f_int_fld && !b_boolean_fld)
        {
            b_boolean_fld = true;
            ConnectionManage_ag.GetObject().g();
            f();
        }
    }

    private void l(InputCommandProcess_be be1)
    {
        String s = be1.i();
        String s1 = be1.j();
        ConnectionManage_ag.GetObject().a(s, s1);
    }

    private void m(InputCommandProcess_be be1)
    {
        f_int_fld = be1.c_mod_toi();
        b();
        ConnectionManage_ag.GetObject().a("0", "Individuals");
    }

    private void n(InputCommandProcess_be be1)
    {
        String s;
        if((s = be1.e()) == null || s.length() == 0)
            return;
        Hashtable hashtable = be1.a_mod_toh();
        Integer integer = e.a_mod_toI("AL");
        Integer integer1 = e.a_mod_toI("BL");
        ab ab2;
        if(hashtable.containsKey(e.a_mod_toI("FL")))
        {
            if(a_e_fld.a(s) == null)
            {
                ab ab1;
                (ab1 = new ab(s)).a_java_util_Hashtable_fld.put(integer, integer);
                ab1.b = be1.b_mod_tos();
                String s1 = be1.d();
                ab1.c = s1;
                a_e_fld.a(ab1);
                if(b_java_util_Vector_static_fld.size() > 0)
                {
                    ab ab3 = (ab)b_java_util_Vector_static_fld.firstElement();
                    b_java_util_Vector_static_fld.removeElementAt(0);
                    String s2 = ab3.e_java_lang_String_fld;
                    ab1.e_java_lang_String_fld = s2;
                    ConnectionManage_ag.GetObject().g(ab1);
                    if(!s2.equals("0"))
                    {
                        OutCommandComposit_ae ae1;
                        (ae1 = new OutCommandComposit_ae(2, GetTraceId())).AddString("FL");
                        ae1.AddString("C=" + s1);
                        ae1.AddString(s2);
                        a_bp_fld.Output(ae1);
                        return;
                    }
                }
            }
        } else
        if(hashtable.containsKey(e.a_mod_toI("RL")))
        {
            if(a_e_fld.a(s) == null)
            {
                ConnectionManage_ag.GetObject().e(new ab(s));
                return;
            }
        } else
        if(hashtable.containsKey(integer))
        {
            if((ab2 = a_e_fld.a(s)) != null && !ab2.a_java_util_Hashtable_fld.containsKey(integer))
            {
                if(ab2.a_java_util_Hashtable_fld.containsKey(integer1))
                    ab2.a_java_util_Hashtable_fld.remove(integer1);
                ab2.a_java_util_Hashtable_fld.put(integer, integer);
                ConnectionManage_ag.GetObject().a(ab2.a_java_lang_String_fld, 6, ab2.a_az_fld.CurrentStateAbbr);
                return;
            }
        } else
        if(hashtable.containsKey(integer1) && (ab2 = a_e_fld.a(s)) != null && !ab2.a_java_util_Hashtable_fld.containsKey(integer1))
        {
            if(ab2.a_java_util_Hashtable_fld.containsKey(integer))
                ab2.a_java_util_Hashtable_fld.remove(integer);
            ab2.a_java_util_Hashtable_fld.put(integer1, integer1);
            ConnectionManage_ag.GetObject().a(ab2.a_java_lang_String_fld, 6, ab2.a_az_fld.CurrentStateAbbr);
        }
    }

    private void o(InputCommandProcess_be be1)
    {
        Hashtable hashtable = be1.a_mod_toh();
        Integer integer = e.a_mod_toI("AL");
        Integer integer1 = e.a_mod_toI("BL");
        ab ab1 = null;
        if(hashtable.containsKey(e.a_mod_toI("FL")))
        {
            if((ab1 = a_e_fld.b(be1.d())) != null)
            {
                a_e_fld.b(ab1);
                ConnectionManage_ag.GetObject().h(ab1);
                return;
            }
        } else
        if(hashtable.containsKey(integer))
        {
            if((ab1 = a_e_fld.a(be1.e())) != null && ab1.a_java_util_Hashtable_fld.containsKey(integer))
            {
                ab1.a_java_util_Hashtable_fld.remove(integer);
                return;
            }
        } else
        if(hashtable.containsKey(integer1) && (ab1 = a_e_fld.a(be1.e())) != null && ab1.a_java_util_Hashtable_fld.containsKey(integer1))
            ab1.a_java_util_Hashtable_fld.remove(integer1);
    }

    private void b(InputCommandProcess_be be1, String s)
    {
        try
        {
            int i1 = be1.d_mod_toi();
            d_int_fld = i1;
        }
        catch(Exception _ex)
        {
            return;
        }
        if(s != null && s.indexOf("FL") > 0)
            ConnectionManage_ag.GetObject().f(s);
    }

    public final void e()
    {
        OutCommandComposit_ae ae1;
        (ae1 = new OutCommandComposit_ae(33, GetTraceId())).AddString("SB");
        a_bp_fld.Output(ae1);
    }

    public final void a(String s, String s1, SwitchBoard_bf bf1)
    {
        a_java_util_Hashtable_fld.remove(s1);
        a_java_util_Hashtable_fld.put(s, bf1);
    }

    public final void e(String s)
    {
        if(a_java_util_Hashtable_fld.containsKey(s))
            a_java_util_Hashtable_fld.remove(s);
    }

    public final void f()
    {
        (new Thread(new bo(this))).start();
    }

    public String strServerName;
    public Integer IServerPort;
    public String strAccntName;
    public String strAccntPswd;
    public int a_int_fld;
    public int iTraceId;
    public int c_int_fld;
    public SocketManage_bp a_bp_fld;
    public boolean a_boolean_fld;
    public int d_int_fld;
    public String d_java_lang_String_fld;
    public int e_int_fld;
    public String strSignState;
    public String strSignPara;
    public e a_e_fld;
    public int f_int_fld;
    public int g;
    public boolean b_boolean_fld;
    public Hashtable a_java_util_Hashtable_fld;
    public Vector a_java_util_Vector_fld;
    public static Vector b_java_util_Vector_static_fld;

    // Unreferenced inner class bo
    class bo_t_local
        implements Runnable
    {

        public final void run()
        {
            try
            {
                while(true) 
                {
                    Thread.sleep(0x15f90L);
                    if(!a.IsSocketOpen())
                        break;
                    OutCommandComposit_ae ae1 = new OutCommandComposit_ae(25, -1);
                    if(a.a_bp_fld.Output(ae1))
                        continue;
                    a.a_bp_fld.CloseSocket();
                    break;
                }
                return;
            }
            catch(Exception _ex)
            {
                return;
            }
        }

        private final Notification_t a;

            public bo_t_local()
            {
                a = Notification_t.this;
            }
    }

}