cmppquery.java

短信平台CMPP30 的JAVA程序,(含SQL数据库)

// 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:   CMPPQuery.java

package com.cmpp3_0.process;

import com.cmpp3_0.body.BodyQuery;
import com.cmpp3_0.body.Header;
import com.cmpp3_0.util.CMPPUtil;
import com.cmpp3_0.util.Logger;
import java.io.*;
import java.net.SocketException;

// Referenced classes of package com.cmpp3_0.process:
//            CMPPSocket, CMPPAPIs

public class CMPPQuery
{

    private byte bodyBytes[];
    private byte headBytes[];
    private Header headContent;
    private CMPPSocket socket;

    public CMPPQuery(CMPPSocket socket)
    {
        headContent = new Header(39, 6, 0);
        this.socket = socket;
        headBytes = new byte[12];
        bodyBytes = new byte[27];
        CMPPUtil.bytesCopy(CMPPUtil.intToFourBytes(headContent.getTotalLength()), headBytes, 0, 4, 0);
        CMPPUtil.bytesCopy(CMPPUtil.intToFourBytes(headContent.getCommandId()), headBytes, 0, 4, 4);
        CMPPUtil.bytesCopy(CMPPUtil.intToFourBytes(headContent.getSeqId()), headBytes, 0, 4, 8);
    }

    public int getSequenceId()
    {
        return headContent.getSeqId();
    }

    public int getTotalLength()
    {
        return headContent.getTotalLength();
    }

    public int sendQuery()
    {
        int result = 0;
        socket.out.write(headBytes);
        socket.out.write(bodyBytes);
        socket.out.flush();
        break MISSING_BLOCK_LABEL_94;
        SocketException se;
        se;
        Logger.writeLog(-2, "QUERY FAILURE: SOCKET_EXCEPTION!--可能是TCP/IP连接出现错误--链路将被断开--发送查询短信包失败!", "cmpp");
        result = -504;
        return result;
        IOException ie;
        ie;
        Logger.writeLog(-2, "QUERY FAILURE: IO_EXCEPTION! -- 发送查询短信包失败!", "cmpp");
        result = -114;
        return result;
        Exception e;
        e;
        Logger.writeLog(-2, "QUERY FAILURE: EXCEPTION! -- 发送查询短信包失败!", "cmpp");
        result = -115;
        return result;
        if(CMPPAPIs.isDebugMode())
            System.out.println("发送了查询短信包!");
        return result;
    }

    public void setBodyContent(BodyQuery bodyQuery)
    {
        CMPPUtil.bytesCopy(bodyQuery.time.getBytes(), bodyBytes, 0, 8, 0);
        bodyBytes[8] = (byte)bodyQuery.queryType;
        CMPPUtil.bytesCopy(bodyQuery.queryCode.getBytes(), bodyBytes, 0, 10, 9);
        CMPPUtil.bytesCopy(bodyQuery.reserve.getBytes(), bodyBytes, 0, 8, 19);
    }

    public void setSequenceId(int seqId)
    {
        headContent.setSeqId(seqId);
        CMPPUtil.bytesCopy(CMPPUtil.intToFourBytes(seqId), headBytes, 0, 4, 8);
    }
}