sendthread.java

一份java写的期货交易程序

// Decompiled by Jad v1.5.7g. Copyright 2000 Pavel Kouznetsov.
// Jad home page: http://www.geocities.com/SiliconValley/Bridge/8617/jad.html
// Decompiler options: packimports(3) fieldsfirst ansi 
// Source File Name:   SendThread.java

package gnnt.MEBS.HQApplet;

import gnnt.MEBS.hq.ProductDataVO;
import gnnt.util.service.HQVO.*;
import java.io.IOException;
import java.io.PrintStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.*;

// Referenced classes of package gnnt.MEBS.HQApplet:
//            HQApplet, ProductData

public class SendThread extends Thread
{

    private Vector vPacket;
    Calendar m_calCodeTable;
    Calendar m_calIndex;
    HQApplet m_applet;

    public SendThread(HQApplet applet)
    {
        vPacket = new Vector();
        m_calIndex = null;
        m_applet = applet;
    }

    synchronized void AskForData(CMDVO packet)
    {
        if(packet != null)
        {
            vPacket.addElement(packet);
            int iSize = vPacket.size();
            int iBuf = 3;
            if(iSize > iBuf)
            {
                for(int i = 0; i < iSize - iBuf; i++)
                    vPacket.removeElementAt(i);

            }
        }
        notify();
    }

    public void run()
    {
        while(m_applet != null && m_applet.bRunning) 
            if(m_applet.socket == null)
            {
                if(!ConnectToServer())
                    try
                    {
                        Thread.sleep(5000L);
                    }
                    catch(InterruptedException interruptedexception) { }
            } else
            {
                try
                {
                    Thread.sleep(100L);
                }
                catch(InterruptedException interruptedexception1) { }
                Calendar cal = Calendar.getInstance();
                if(m_applet.m_bShowIndexAtBottom == 1 && m_applet.indexMainCode.length() > 0)
                {
                    cal.add(13, -10);
                    if(m_calIndex == null || cal.after(m_calIndex))
                    {
                        AskForIndex();
                        m_calIndex = Calendar.getInstance();
                    }
                    cal.add(13, -10);
                }
                cal.add(12, -1);
                if(cal.after(m_calCodeTable))
                {
                    AskForDateAndCodeTable();
                    m_calCodeTable = Calendar.getInstance();
                }
                int iSize = vPacket.size();
                if(iSize > 0)
                {
                    CMDVO sendPacket = (CMDVO)vPacket.elementAt(iSize - 1);
                    vPacket.removeElementAt(iSize - 1);
                    try
                    {
                        if(HQApplet.bDebug != 0 && m_applet.socket != null)
                            switch(sendPacket.getCmd())
                            {
                            case 2: // '\002'
                                System.out.println("Send cmd:" + sendPacket.getCmd() + "-" + ((CMDQuoteVO)sendPacket).codeList[0][0] + "-" + ((CMDQuoteVO)sendPacket).codeList[0][1]);
                                break;

                            case 3: // '\003'
                                CMDSortVO packet = (CMDSortVO)sendPacket;
                                System.out.println("Send cmd:" + sendPacket.getCmd() + " sort by " + packet.sortBy + " start:" + packet.start + " end:" + packet.end);
                                break;

                            default:
                                System.out.println("Send cmd:" + sendPacket.getCmd());
                                break;
                            }
                        RequestUtil.sendRequest(sendPacket, m_applet.socket);
                    }
                    catch(IOException e)
                    {
                        HQApplet _tmp = m_applet;
                        if(HQApplet.bDebug != 0)
                        {
                            e.getMessage();
                            e.printStackTrace();
                        }
                        m_applet.socket = null;
                    }
                } else
                {
                    synchronized(this)
                    {
                        try
                        {
                            wait();
                        }
                        catch(InterruptedException e)
                        {
                            e.getMessage();
                        }
                    }
                }
            }
        try
        {
            if(m_applet != null && m_applet.socket != null)
            {
                m_applet.socket.close();
                m_applet.socket = null;
            }
        }
        catch(IOException ioexception) { }
        System.out.println("SendThread Exit !");
    }

    boolean ConnectToServer()
    {
        try
        {
            m_applet.socket = new Socket(m_applet.strSocketIP, m_applet.iSocketPort);
        }
        catch(UnknownHostException eHost)
        {
            HQApplet _tmp = m_applet;
            if(HQApplet.bDebug != 0)
                eHost.printStackTrace();
            return false;
        }
        catch(IOException eIO)
        {
            HQApplet _tmp1 = m_applet;
            if(HQApplet.bDebug != 0)
                eIO.printStackTrace();
            return false;
        }
        HQApplet _tmp2 = m_applet;
        if(HQApplet.bDebug != 0)
            System.out.println("connected");
        if(m_applet.socket == null)
            System.out.println("socket is null");
        m_calCodeTable = Calendar.getInstance();
        return true;
    }

    private void AskForDateAndCodeTable()
    {
        try
        {
            CMDDateVO packet1 = new CMDDateVO();
            RequestUtil.sendRequest(packet1, m_applet.socket);
            CMDProductInfoVO packet2 = new CMDProductInfoVO();
            packet2.date = m_applet.m_iCodeDate;
            packet2.time = m_applet.m_iCodeTime;
            RequestUtil.sendRequest(packet2, m_applet.socket);
        }
        catch(Exception e)
        {
            HQApplet _tmp = m_applet;
            if(HQApplet.bDebug != 0)
                e.printStackTrace();
            m_applet.socket = null;
        }
    }

    private void AskForIndex()
    {
        if(m_applet.indexMainCode.length() == 0)
            return;
        ProductData stock = m_applet.GetProductData(m_applet.indexMainCode);
        Date time = null;
        if(stock != null && stock.realData != null)
            time = stock.realData.time;
        CMDQuoteVO packet = new CMDQuoteVO();
        packet.codeList = new String[1][2];
        packet.codeList[0][0] = m_applet.indexMainCode;
        packet.isAll = 1;
        if(time != null)
            packet.codeList[0][1] = String.valueOf(time.getHours() * 10000 + time.getMinutes() * 100 + time.getSeconds());
        else
            packet.codeList[0][1] = "0";
        try
        {
            RequestUtil.sendRequest(packet, m_applet.socket);
        }
        catch(Exception e)
        {
            HQApplet _tmp = m_applet;
            if(HQApplet.bDebug != 0)
                e.printStackTrace();
            m_applet.socket = null;
        }
    }

    static void AskForRealQuote(String code, Date time, SendThread sendThread)
    {
        CMDQuoteVO packet = new CMDQuoteVO();
        packet.codeList = new String[1][2];
        packet.codeList[0][0] = code;
        packet.isAll = 1;
        if(time != null)
            packet.codeList[0][1] = String.valueOf(time.getHours() * 10000 + time.getMinutes() * 100 + time.getSeconds());
        else
            packet.codeList[0][1] = "0";
        sendThread.AskForData(packet);
    }
}