apis.java

移动短信网关接口源程序框架

// Decompiled by DJ v2.9.9.60 Copyright 2000 Atanas Neshkov  Date: 2004-4-16 11:12:39
// Home Page : http://members.fortunecity.com/neshkov/dj.html  - Check often for new version!
// Decompiler options: packimports(3)
// Source File Name:   Apis.java

package com.aspire.cmppApi;

import java.io.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.*;

// Referenced classes of package com.aspire.cmppApi:
//            RecCActiveTest, RecCActiveTestRep, RecCCMPPPacket, RecCCancel,
//            RecCCancelRep, RecCDeliver, RecCDeliverRcpt, RecCDeliverRep,
//            RecCQuery, RecCQueryRep, RecCSubmit, RecCSubmitRep,
//            RecCTerminate, RecCTerminateRep, RecCVerInfo, cmppActiveTest,
//            cmppActiveTestRep, cmppCancel, cmppCancelRep, cmppCommon,
//            cmppConnect, cmppConnectRep, cmppDeliver, cmppDeliverRep,
//            cmppPacket, cmppQuery, cmppQueryRep, cmppSocket,
//            cmppSubmit, cmppSubmitRep, cmppTerminate, cmppTerminateRep

public class Apis
{

    public Apis()
    {
        hostIp = "";
        SPID = "";
        SPPassword = "";
        hostIp = "";
        port = 0;
        version = 18;
        sversion = 0;
        apiVersion = "";
        sock = null;
    }

    static int getSendtimes(byte abyte0[])
    {
        int i = 1;
        byte byte0 = 30;
        for(i = 1; i < byte0; i++)
        {
            int j = abyte0.length - i * 140;
            if(j <= 0)
                break;
        }

        return i;
    }

    public int nCMPP_Connect()
    {
        SimpleDateFormat simpledateformat = new SimpleDateFormat("MMddHHmmss");
        Date date = new Date();
        String s = simpledateformat.format(date);
        if(hostIp == null)
            return -1;
        hostIp = hostIp.trim();
        if(hostIp.length() == 0)
            return -1;
        if(port <= 0)
            return -1;
        sock = new cmppSocket(hostIp, port);
        int i = sock.InitialSock();
        if(i < 0)
            return i;
        cmppConnect cmppconnect = new cmppConnect(sock);
        cmppconnect.setSequenceId(1);
        synchronized(sock)
        {
            sock.seq++;
        }
        cmppconnect.setcmppConnects(SPID, SPPassword, version, s);
        int j = cmppconnect.sendcmppConnect();
        if(j < 0)
            return j;
        cmppPacket cmpppacket = new cmppPacket(sock);
        byte abyte0[] = new byte[18];
        int k;
        do
        {
            int l = cmpppacket.readPacket();
            if(l < 0)
                return l;
            k = cmpppacket.getCommandID();
            abyte0 = cmpppacket.getPacketBody();
        } while(k != 0x80000001);
        cmppConnectRep cmppconnectrep = new cmppConnectRep(abyte0, 18);
        int i1 = cmppconnectrep.getStatus();
        String s1 = cmppconnectrep.getAuthenticatorISMG();
        sversion = cmppconnectrep.getVersion();
        return i;
    }

    public int nCMPP_GetApiVersion(RecCVerInfo reccverinfo)
    {
        if(reccverinfo == null)
        {
            return -1;
        } else
        {
            reccverinfo.sVerDesc = "Program cmppapi.jar( Java )ASPIRE CMPP 1.2.1 Application Program Interface - Java\nCMPPAPI v1.5 (WTBS Build 1.5.1-20020401-1)\n\nCopyright@ 2002 ASPire-Tech Ltd. Co.";
            reccverinfo.ApiVerInfo = 18;
            return 0;
        }
    }

    public int nCMPP_GetHostVersion()
    {
        return sversion;
    }

    public int nCMPP_Init(String s)
    {
        Properties properties = new Properties();
        byte byte0 = -1;
        if(s == null || s.equals(""))
            return byte0;
        try
        {
            properties.load(new FileInputStream(s));
        }
        catch(IOException _ex)
        {
            byte0 = -2;
            return byte0;
        }
        SPID = properties.getProperty("SP_ID", "");
        SPPassword = properties.getProperty("SP_Pwd", "");
        hostIp = properties.getProperty("HostAddr", "");
        String s1 = properties.getProperty("HostPort", "");
        if(s1 == null || s1.equals(""))
        {
            byte0 = -3;
            return byte0;
        }
        s1 = s1.trim();
        try
        {
            port = Integer.parseInt(s1);
        }
        catch(NumberFormatException _ex)
        {
            byte0 = -4;
            return byte0;
        }
        if(!hostIp.equals("") && !SPID.equals("") && !SPPassword.equals("") && port != 0)
        {
            byte0 = 0;
            hostIp = hostIp.trim();
        }
        return byte0;
    }

    public int nCMPP_ParseActive(cmppPacket cmpppacket, RecCActiveTest reccactivetest)
    {
        byte byte0 = -1;
        if(cmpppacket == null || reccactivetest == null)
        {
            return byte0;
        } else
        {
            int i = cmpppacket.getSequenceId();
            reccactivetest.nSeqId = i;
            return i;
        }
    }

    public int nCMPP_ParseActiveRep(cmppPacket cmpppacket, RecCActiveTestRep reccactivetestrep)
    {
        byte byte0 = -1;
        if(cmpppacket == null || reccactivetestrep == null)
        {
            return byte0;
        } else
        {
            int i = cmpppacket.getSequenceId();
            cmppActiveTestRep cmppactivetestrep = new cmppActiveTestRep(cmpppacket.getPacketBody(), cmpppacket.getPacketBody().length);
            reccactivetestrep.nSeqId = i;
            reccactivetestrep.ucSuccId = cmppactivetestrep.getSuccessId();
            return i;
        }
    }

    public int nCMPP_ParseCancelRep(cmppPacket cmpppacket, RecCCancelRep recccancelrep)
    {
        byte byte0 = -1;
        if(cmpppacket == null || recccancelrep == null)
        {
            return byte0;
        } else
        {
            int i = cmpppacket.getSequenceId();
            recccancelrep.nSeqId = i;
            cmppCancelRep cmppcancelrep = new cmppCancelRep(cmpppacket.getPacketBody(), cmpppacket.getPacketBody().length);
            recccancelrep.ucSuccId = cmppcancelrep.getSuccessId();
            return i;
        }
    }

    public int nCMPP_ParseDeliver(cmppPacket cmpppacket, RecCDeliver reccdeliver, RecCDeliverRcpt reccdeliverrcpt)
    {
        byte byte0 = -1;
        if(cmpppacket == null || reccdeliver == null || reccdeliverrcpt == null)
            return byte0;
        cmppDeliver cmppdeliver = new cmppDeliver(cmpppacket.getPacketBody(), cmpppacket.getPacketBody().length);
        int i = cmppdeliver.getRegisteredDelivery();
        if(i == 0)
        {
            reccdeliver.nSeqId = cmpppacket.getSequenceId();
            reccdeliver.usMsgId = cmppdeliver.getMsgId();
            reccdeliver.sDstAddr = cmppdeliver.getDestnationId();
            reccdeliver.sServiceId = cmppdeliver.getServiceId();
            reccdeliver.ucTpPid = cmppdeliver.getTPpid();
            reccdeliver.ucTpUdhi = cmppdeliver.getTPudhi();
            reccdeliver.ucMsgFmt = cmppdeliver.getMsgFmt();
            reccdeliver.sSrcAddr = cmppdeliver.getSrcTerminalId();
            reccdeliver.ucRegister = i;
            reccdeliver.ucMsgLen = cmppdeliver.getMsgLength();
            reccdeliver.usMsgContent = cmppdeliver.getMsgContent();
            reccdeliver.usReserve = cmppdeliver.getReverse();
        }
        if(i == 1)
        {
            reccdeliverrcpt.nSeqId = cmpppacket.getSequenceId();
            reccdeliverrcpt.usMsgId = cmppdeliver.getReceiptMsgId();
            reccdeliverrcpt.sStat = cmppdeliver.getReceiptStat();
            reccdeliverrcpt.sSubmitTime = cmppdeliver.getReceiptSubmitTime();
            reccdeliverrcpt.sDoneTime = cmppdeliver.getReceiptDoneTime();
            reccdeliverrcpt.sDstAddr = cmppdeliver.getReceiptDestTerminalId();
            reccdeliverrcpt.nSmscSeqId = cmppdeliver.getReceiptSMSCSequence();
        }
        return i;
    }

    public int nCMPP_ParseQueryRep(cmppPacket cmpppacket, RecCQueryRep reccqueryrep)
    {
        byte byte0 = -1;
        if(cmpppacket == null || reccqueryrep == null)
        {
            return byte0;
        } else
        {
            int i = cmpppacket.getSequenceId();
            cmppQueryRep cmppqueryrep = new cmppQueryRep(cmpppacket.getPacketBody(), cmpppacket.getPacketBody().length);
            System.out.println("Body Length:" + cmpppacket.getPacketBody().length);
            reccqueryrep.nSeqId = i;
            reccqueryrep.sTime = cmppqueryrep.getTime();
            reccqueryrep.ucQueryType = cmppqueryrep.getQueryType();
            reccqueryrep.sQueryCode = cmppqueryrep.getQueryCode();
            reccqueryrep.nMtTlMsg = cmppqueryrep.getMTTLMsg();
            reccqueryrep.nMtTlUsr = cmppqueryrep.getMTTlusr();
            reccqueryrep.nMtScs = cmppqueryrep.getMTScs();
            reccqueryrep.nMtWt = cmppqueryrep.getMTWT();
            reccqueryrep.nMtFl = cmppqueryrep.getMTFL();
            reccqueryrep.nMoScs = cmppqueryrep.getMOScs();
            reccqueryrep.nMoWt = cmppqueryrep.getMOWT();
            reccqueryrep.nMoFl = cmppqueryrep.getMOFL();
            return i;
        }
    }

    public int nCMPP_ParseSubmitRep(cmppPacket cmpppacket, RecCSubmitRep reccsubmitrep)
    {
        byte byte0 = -1;
        if(cmpppacket == null || reccsubmitrep == null)
        {
            return byte0;
        } else
        {
            int i = cmpppacket.getSequenceId();
            cmppSubmitRep cmppsubmitrep = new cmppSubmitRep(cmpppacket.getPacketBody(), cmpppacket.getPacketBody().length);
            reccsubmitrep.nSeqId = i;
            reccsubmitrep.usMsgId = cmppsubmitrep.getMsgId();
            reccsubmitrep.ucResult = cmppsubmitrep.getResult();
            return i;
        }
    }

    public int nCMPP_ParseTerminate(cmppPacket cmpppacket)
    {
        byte byte0 = -1;
        if(cmpppacket == null)
        {
            return byte0;
        } else
        {
            int i = cmpppacket.getSequenceId();
            return i;
        }
    }

    public int nCMPP_PrepSubmit(RecCSubmit reccsubmit, long l, int i, int j, int k, int i1,
            String s, int j1, String s1, int k1, int l1, int i2, String s2,
            String s3, String s4, String s5, String s6, String s7)
    {
        byte byte0 = -1;
        if(reccsubmit == null)
        {
            return byte0;
        } else
        {
            reccsubmit.usMsgId = l;
            reccsubmit.ucPkTotal = i;
            reccsubmit.ucPkNumber = j;
            reccsubmit.ucRegister = k;
            reccsubmit.ucMsgLevel = i1;
            reccsubmit.sServiceId = s;
            reccsubmit.ucFeeUserType = j1;
            reccsubmit.sFeeTermId = s1;
            reccsubmit.ucTpPid = k1;
            reccsubmit.ucTpUdhi = l1;
            reccsubmit.ucMsgFmt = i2;
            reccsubmit.sMsgSrc = s2;
            reccsubmit.sFeeType = s3;
            reccsubmit.sFeeCode = s4;
            reccsubmit.sAtTime = s5;
            reccsubmit.sSrcTermId = s6;
            reccsubmit.usReserve = s7;
            return 0;
        }
    }

    public int nCMPP_RecvPacket(RecCCMPPPacket recccmpppacket)
    {
        byte byte0 = -1;
        if(recccmpppacket == null)
            return byte0;
        int i = -1;
        cmppPacket cmpppacket = new cmppPacket(sock);
        int j = nCMPP_getPacket(cmpppacket);
        recccmpppacket.nCmdId = j;
        switch(j)
        {
        case 2: // '\002'
            i = nCMPP_ParseTerminate(cmpppacket);
            RecCTerminate reccterminate = new RecCTerminate();
            recccmpppacket.recTerminate = reccterminate;
            recccmpppacket.recTerminate.nSeqId = i;
            break;

        case -2147483644:
            RecCSubmitRep reccsubmitrep = new RecCSubmitRep();
            recccmpppacket.recSubmitRep = reccsubmitrep;
            i = nCMPP_ParseSubmitRep(cmpppacket, recccmpppacket.recSubmitRep);