sendthread.java

java 写的股票技术分析；软件

// NMI's Java Code Viewer 6.0a
// www.trinnion.com/javacodeviewer

// Registered to Evaluation Copy                                      
// Generated PGFZKD AyTB 14 2007 15:44:19 

//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();
        try {
            CMDDateVO packet1 = new CMDDateVO();
            RequestUtil.sendRequest(packet1, m_applet.socket);
            CMDTradeTimeVO packet = new CMDTradeTimeVO();
            RequestUtil.sendRequest(packet, m_applet.socket);
            CMDMinLineIntervalVO packet2 = new CMDMinLineIntervalVO();
            RequestUtil.sendRequest(packet2, m_applet.socket);
        }
        catch(Exception e) {
            HQApplet _tmp3 = m_applet;
            if(HQApplet.bDebug != 0)
                e.printStackTrace();
            m_applet.socket = null;
            return false;
        }
        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);
    }
}