userinterface.jad

短信开发汇总

                    comm.CloseSocket();
                    return 1;
                }
                break;

            case -2147483645: 
                SGIP_SubmitResp submit_resp = new SGIP_SubmitResp();
                ret = submit_resp.parseBuffer(buffer.getRecvBuffer());
                if(ret != 0)
                {
                    nErrorCode.setErrorCodeString("\u6536\u5230\u9519\u8BEF\u7684submit_resp \u683C\u5F0F");
                    comm.CloseSocket();
                    return 1;
                }
                if(submit_resp.getResult() == 0)
                {
                    nErrorCode.setErrorCodeString("SGIPSEND\u53D1\u9001\u5355\u6761\u6210\u529F\uFF01");
                } else
                {
                    nErrorCode.setErrorCodeString("SGIPSEND \u53D1\u9001\u6D88\u606F\u5931\u8D25\uFF0C\u670D\u52A1\u5668\u8FD4\u56DE\u503C=" + Integer.toString(submit_resp.getResult()));
                    nErrorCode.setErrorCodeValue(submit_resp.getResult());
                    return 1;
                }
                break label0;

            default:
                GlobalVar.WriteSysLog("UserInterface", "SGIPSend", "recv command unknows", 0);
                comm.CloseSocket();
                return 1;
            }
        } while(true);
        comm.CloseSocket();
        return 0;
    }

    public int SGIPDeliver(int nTimeOut, DeliverResp result, ErrorCode nErrorCode)
    {
        if(nErrorCode == null)
        {
            GlobalVar.WriteSysLog("UserInterface", "SGIPDeliver", "nErrorCode is null!", 0);
            return 1;
        }
        if(result == null)
        {
            nErrorCode.setErrorCodeString("result is null");
            return 1;
        }
        if(nTimeOut <= 20 || nTimeOut > 60)
            nTimeOut = 30;
        int ret = 0;
        if(recv_comm.socket == null)
        {
            ret = recv_comm.LoginSGIP(2, nErrorCode);
            if(ret != 0)
                return 1;
        }
        ret = recv_comm.setSoTimeout(nTimeOut);
        if(ret != 0)
        {
            nErrorCode.setErrorCodeString("\u8BBE\u7F6Etimeout \u5931\u8D25");
            recv_comm.CloseSocket();
            return 1;
        }
        ret = recv_comm.synRecvData(recv_buffer);
        if(ret != 0)
        {
            nErrorCode.setErrorCodeString("\u63A5\u6536deliver\u6D88\u606F\u5931\u8D25");
            recv_comm.CloseSocket();
            return 1;
        }
        DataInputStream data = new DataInputStream(new ByteArrayInputStream(recv_buffer.getRecvBuffer()));
        int PacketLen = 0;
        int CommandID = 0;
        try
        {
            PacketLen = data.readInt();
            CommandID = data.readInt();
        }
        catch(Exception ex)
        {
            GlobalVar.WriteSysLog("UserInterface", "SMGPDeliver", ex, 0);
            nErrorCode.setErrorCodeString("\u63A5\u6536deliver\u6D88\u606F\u5931\u8D25");
            recv_comm.CloseSocket();
            return 1;
        }
        switch(CommandID)
        {
        case 4: // '\004'
            SGIP_Deliver deliver = new SGIP_Deliver();
            ret = deliver.parseBuffer(recv_buffer.getRecvBuffer());
            if(ret != 0)
            {
                nErrorCode.setErrorCodeString("\u6536\u5230\u9519\u8BEF\u7684deliver\u683C\u5F0F");
                recv_comm.CloseSocket();
                return 1;
            }
            SGIP_DeliverResp deliver_resp = new SGIP_DeliverResp();
            deliver_resp.head.PacketLength = deliver_resp.Length();
            deliver_resp.head.RequestID = 0x80000004;
            deliver_resp.head.SequenceNumber = deliver.getSequenceNumber();
            deliver_resp.Result = 0;
            ret = deliver_resp.WriteProtocolData(recv_comm.getDataOutputStream());
            if(ret != 0)
            {
                nErrorCode.setErrorCodeString("\u53D1\u9001deliver resp \u6D88\u606F\u5931\u8D25");
                recv_comm.CloseSocket();
                return 1;
            }
            ret = recv_comm.FlushOutputData();
            if(ret != 0)
            {
                nErrorCode.setErrorCodeString("\u53D1\u9001Deliver resp \u6D88\u606F\u5931\u8D25");
                recv_comm.CloseSocket();
                return 1;
            } else
            {
                result.setSPNumber(deliver.getSPNumber());
                result.setUserNumber(deliver.getUserNumber());
                result.setTPpid(deliver.getTP_pid());
                result.setTPudhi(deliver.getTP_udhi());
                result.setMessageCoding(deliver.getMessageCoding());
                result.setMessageLength(deliver.getMessageLength());
                result.setMessageContent(deliver.getMessageContent());
                result.setReserve(deliver.getReserve());
                nErrorCode.setErrorCodeString("SGIPDeliver\u6210\u529F!");
                return 0;
            }
        }
        GlobalVar.WriteSysLog("UserInterface", "SMGPDeliver", "receive command unknown", 0);
        nErrorCode.setErrorCodeString("\u6536\u5230\u9519\u8BEF\u7684Command\uFF01");
        recv_comm.CloseSocket();
        return 1;
    }

    public int SGIPReport(int nTimeOut, ReportResp result, ErrorCode nErrorCode)
    {
        if(nErrorCode == null)
        {
            GlobalVar.WriteSysLog("UserInterface", "SGIPReport", "nErrorCode is null!", 0);
            return 1;
        }
        if(result == null)
        {
            nErrorCode.setErrorCodeString("result is null");
            return 1;
        }
        if(nTimeOut <= 20 || nTimeOut > 60)
            nTimeOut = 30;
        int ret = 0;
        if(recv_comm.socket == null)
        {
            ret = recv_comm.LoginSGIP(1, nErrorCode);
            if(ret != 0)
                return 1;
        }
        ret = recv_comm.setSoTimeout(nTimeOut);
        if(ret != 0)
        {
            nErrorCode.setErrorCodeString("\u8BBE\u7F6Etimeout \u5931\u8D25");
            recv_comm.CloseSocket();
            return 1;
        }
        ret = recv_comm.synRecvData(recv_buffer);
        if(ret != 0)
        {
            nErrorCode.setErrorCodeString("\u63A5\u6536Report\u6D88\u606F\u5931\u8D25");
            recv_comm.CloseSocket();
            return 1;
        }
        DataInputStream data = new DataInputStream(new ByteArrayInputStream(recv_buffer.getRecvBuffer()));
        int PacketLen = 0;
        int CommandID = 0;
        try
        {
            PacketLen = data.readInt();
            CommandID = data.readInt();
        }
        catch(Exception ex)
        {
            GlobalVar.WriteSysLog("UserInterface", "SMGPReport", ex, 0);
            nErrorCode.setErrorCodeString("\u63A5\u6536report\u6D88\u606F\u5931\u8D25");
            recv_comm.CloseSocket();
            return 1;
        }
        switch(CommandID)
        {
        case 5: // '\005'
            SGIP_Report report = new SGIP_Report();
            ret = report.parseBuffer(recv_buffer.getRecvBuffer());
            if(ret != 0)
            {
                nErrorCode.setErrorCodeString("\u6536\u5230\u9519\u8BEF\u7684report\u683C\u5F0F");
                recv_comm.CloseSocket();
                return 1;
            }
            SGIP_ReportResp report_resp = new SGIP_ReportResp();
            report_resp.head.PacketLength = report_resp.Length();
            report_resp.head.RequestID = 0x80000005;
            report_resp.head.SequenceNumber = report.getSequenceNumber();
            report_resp.Result = 0;
            ret = report_resp.WriteProtocolData(recv_comm.getDataOutputStream());
            if(ret != 0)
            {
                nErrorCode.setErrorCodeString("\u53D1\u9001Report resp \u6D88\u606F\u5931\u8D25");
                recv_comm.CloseSocket();
                return 1;
            }
            ret = recv_comm.FlushOutputData();
            if(ret != 0)
            {
                nErrorCode.setErrorCodeString("\u53D1\u9001Report resp \u6D88\u606F\u5931\u8D25");
                recv_comm.CloseSocket();
                return 1;
            } else
            {
                result.setSubmitSequenceNumber(report.getSubmitSequenceNumber());
                result.setReportType(report.getReportType());
                result.setUserNumber(report.getUserNumber());
                result.setState(report.getState());
                result.setErrorCode(report.getErrorCode());
                result.setReserve(report.getReserve());
                nErrorCode.setErrorCodeString("SGIPReport\u6210\u529F!");
                return 0;
            }
        }
        GlobalVar.WriteSysLog("UserInterface", "SMGPReport", "receive command unknown", 0);
        nErrorCode.setErrorCodeString("\u6536\u5230\u9519\u8BEF\u7684Command\uFF01");
        recv_comm.CloseSocket();
        return 1;
    }

    private static SynSocket recv_comm = new SynSocket();
    private static DataBuffer recv_buffer = new DataBuffer();
    private static SynSocket send_comm = new SynSocket();
    private static DataBuffer send_buffer = new DataBuffer();

}