recvthread.java

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

                    packetArea.append("SequenceID_3: " + term.getSeqno_3() + "\n\n");
                }
                System.out.println(tmpCMD.getTotalLength());
                System.out.println(tmpCMD.getCommandID());
                System.out.println(tmpCMD.getSeqno_1());
                System.out.println(tmpCMD.getSeqno_2());
                System.out.println(tmpCMD.getSeqno_3());
                System.out.println(term.GetFlag());
                Unresp = new UnbindResp(tmpCMD.getMsgHead());
                Unresp.write(output);
                if(packetArea != null)
                {
                    packetArea.append(CTime.getStringDate() + "--SGIP12--UnbindResp: (SP->SMG)\n");
                    packetArea.append("TotalLength: " + Unresp.getTotalLength() + "\n");
                    packetArea.append("CommandID: " + Unresp.getCommandID() + "\n");
                    packetArea.append("SequenceID_1: " + Unresp.getSeqno_1() + "\n");
                    packetArea.append("SequenceID_2: " + Unresp.getSeqno_2() + "\n");
                    packetArea.append("SequenceID_3: " + Unresp.getSeqno_3() + "\n\n");
                }
                so.close();
                loop = false;
                break;

            case 4: // '\004'
                deliver = (Deliver)tmpCMD;
                result = deliver.readbody();
                if(packetArea != null)
                {
                    packetArea.append(CTime.getStringDate() + "--SGIP12--Deliver: (SMG->SP)\n");
                    packetArea.append("TotalLength: " + deliver.getTotalLength() + "\n");
                    packetArea.append("CommandID: " + deliver.getCommandID() + "\n");
                    packetArea.append("SequenceID_1: " + deliver.getSeqno_1() + "\n");
                    packetArea.append("SequenceID_2: " + deliver.getSeqno_2() + "\n");
                    packetArea.append("SequenceID_3: " + deliver.getSeqno_3() + "\n");
                    packetArea.append("UserNumber: " + deliver.getUserNumber() + "\n");
                    packetArea.append("SPNumber: " + deliver.getSPNumber() + "\n");
                    packetArea.append("TP_pid: " + deliver.getTP_pid() + "\n");
                    packetArea.append("TP_udhi: " + deliver.getTP_udhi() + "\n");
                    packetArea.append("MessageCoding: " + deliver.getMessageCoding() + "\n");
                    packetArea.append("MessageLength: " + deliver.getMessageLength() + "\n");
                    packetArea.append("MessageContent: " + deliver.getMessageContent() + "\n\n");
                }
                sgipPacket = new SGIPPacket();
                sgipPacket.CommandId = deliver.getCommandID();
                sgipPacket.deliverPacket = deliver;
                recvQueue.EnQueue(sgipPacket);
                for(int i = 0; i < recvQueue.size(); i++)
                {
                    SGIPPacket pp = (SGIPPacket)recvQueue.elementAt(i);
                    System.out.println("recvQueue中有包： " + pp.toString());
                }

                System.out.println(tmpCMD.getTotalLength());
                System.out.println(tmpCMD.getCommandID());
                System.out.println(tmpCMD.getSeqno_1());
                System.out.println(tmpCMD.getSeqno_2());
                System.out.println(tmpCMD.getSeqno_3());
                System.out.println(deliver.getUserNumber().trim());
                System.out.println(deliver.getSPNumber().trim());
                System.out.println(deliver.getTP_pid());
                System.out.println(deliver.getTP_udhi());
                System.out.println(deliver.getMessageCoding());
                System.out.println(deliver.getMessageLength());
                System.out.println(deliver.getMessageContent());
                deliverresp = new DeliverResp(tmpCMD.getMsgHead());
                deliverresp.SetResult(result);
                deliverresp.write(output);
                if(packetArea != null)
                {
                    packetArea.append(CTime.getStringDate() + "--SGIP12--DeliverResp: (SP->SMG)\n");
                    packetArea.append("TotalLength: " + deliverresp.getTotalLength() + "\n");
                    packetArea.append("CommandID: " + deliverresp.getCommandID() + "\n");
                    packetArea.append("SequenceID_1: " + deliverresp.getSeqno_1() + "\n");
                    packetArea.append("SequenceID_2: " + deliverresp.getSeqno_2() + "\n");
                    packetArea.append("SequenceID_3: " + deliverresp.getSeqno_3() + "\n");
                    packetArea.append("Result: " + deliverresp.getResult() + "\n\n");
                }
                break;

            case 5: // '\005'
                report = (Report)tmpCMD;
                result = report.readbody();
                if(packetArea != null)
                {
                    packetArea.append(CTime.getStringDate() + "--SGIP12--Report: (SMG->SP)\n");
                    packetArea.append("TotalLength: " + report.getTotalLength() + "\n");
                    packetArea.append("CommandID: " + report.getCommandID() + "\n");
                    packetArea.append("SequenceID_1: " + report.getSeq_1() + "\n");
                    packetArea.append("SequenceID_2: " + report.getSeq_2() + "\n");
                    packetArea.append("SequenceID_3: " + report.getSeq_3() + "\n");
                    packetArea.append("ReportType: " + report.getReportType() + "\n");
                    packetArea.append("UserNumber: " + report.getUserNumber() + "\n");
                    packetArea.append("State: " + report.getState() + "\n");
                    packetArea.append("ErrorCode: " + report.getErrorCode() + "\n\n");
                }
                sgipPacket = new SGIPPacket();
                sgipPacket.CommandId = report.getCommandID();
                sgipPacket.reportPacket = report;
                recvQueue.EnQueue(sgipPacket);
                System.out.println(tmpCMD.getTotalLength());
                System.out.println(tmpCMD.getCommandID());
                System.out.println(tmpCMD.getSeqno_1());
                System.out.println(tmpCMD.getSeqno_2());
                System.out.println(tmpCMD.getSeqno_3());
                System.out.println(report.getSeq_1());
                System.out.println(report.getSeq_2());
                System.out.println(report.getSeq_3());
                System.out.println(report.getReportType());
                System.out.println(report.getUserNumber());
                System.out.println(report.getState());
                System.out.println(report.getErrorCode());
                reportresp = new ReportResp(tmpCMD.getMsgHead());
                reportresp.SetResult(result);
                reportresp.write(output);
                if(packetArea != null)
                {
                    packetArea.append(CTime.getStringDate() + "--SGIP12--ReportResp: (SP->SMG)\n");
                    packetArea.append("TotalLength: " + reportresp.getTotalLength() + "\n");
                    packetArea.append("CommandID: " + reportresp.getCommandID() + "\n");
                    packetArea.append("SequenceID_1: " + reportresp.getSeqno_1() + "\n");
                    packetArea.append("SequenceID_2: " + reportresp.getSeqno_2() + "\n");
                    packetArea.append("SequenceID_3: " + reportresp.getSeqno_3() + "\n");
                    packetArea.append("Result: " + reportresp.getResult() + "\n");
                }
                break;

            case 17: // '\021'
                userrpt = (Userrpt)tmpCMD;
                result = userrpt.readbody();
                if(packetArea != null)
                {
                    packetArea.append(CTime.getStringDate() + "--SGIP12--Userrpt: (SMG->SP)\n");
                    packetArea.append("TotalLength: " + userrpt.getTotalLength() + "\n");
                    packetArea.append("CommandID: " + userrpt.getCommandID() + "\n");
                    packetArea.append("SequenceID_1: " + userrpt.getSeqno_1() + "\n");
                    packetArea.append("SequenceID_2: " + userrpt.getSeqno_2() + "\n");
                    packetArea.append("SequenceID_3: " + userrpt.getSeqno_3() + "\n");
                    packetArea.append("SPNumber: " + userrpt.getSPNumber() + "\n");
                    packetArea.append("UserNumber: " + userrpt.getUserNumber() + "\n");
                    packetArea.append("UserCondition: " + userrpt.getUserCondition() + "\n");
                }
                sgipPacket = new SGIPPacket();
                sgipPacket.CommandId = userrpt.getCommandID();
                sgipPacket.userrptPacket = userrpt;
                recvQueue.EnQueue(sgipPacket);
                System.out.println(tmpCMD.getTotalLength());
                System.out.println(tmpCMD.getCommandID());
                System.out.println(tmpCMD.getSeqno_1());
                System.out.println(tmpCMD.getSeqno_2());
                System.out.println(tmpCMD.getSeqno_3());
                System.out.println(userrpt.getSPNumber());
                System.out.println(userrpt.getUserNumber());
                System.out.println(userrpt.getUserCondition());
                userrptresp = new UserrptResp(tmpCMD.getMsgHead());
                userrptresp.SetResult(result);
                userrptresp.write(output);
                if(packetArea != null)
                {
                    packetArea.append(CTime.getStringDate() + "--SGIP12--UserrptResp: (SP->SMG)\n");
                    packetArea.append("TotalLength: " + userrptresp.getTotalLength() + "\n");
                    packetArea.append("CommandID: " + userrptresp.getCommandID() + "\n");
                    packetArea.append("SequenceID_1: " + userrptresp.getSeqno_1() + "\n");
                    packetArea.append("SequenceID_2: " + userrptresp.getSeqno_2() + "\n");
                    packetArea.append("SequenceID_3: " + userrptresp.getSeqno_3() + "\n");
                    packetArea.append("Result: " + userrptresp.getResult() + "\n");
                }
                break;

            default:
                SGIPLog.WriteLog(-2, "错误的CommandID！", logFile);
                break;
            }
        }
        try
        {
            Thread.sleep(10L);
            if(so != null)
                so.close();
        }
        catch(Exception s)
        {
            System.out.println(s.toString());
        }
        break MISSING_BLOCK_LABEL_4841;
        SocketTimeoutException te;
        te;
        try
        {
            Thread.sleep(10L);
            if(so != null)
                so.close();
        }
        catch(Exception s)
        {
            System.out.println(s.toString());
        }
        break MISSING_BLOCK_LABEL_4841;
        Exception e;
        e;
        SGIPLog.WriteLog(-2, "Receive: " + e.toString(), logFile);
        System.out.println("Receive: " + e.toString());
        try
        {
            Thread.sleep(10L);
            if(so != null)
                so.close();
        }
        catch(Exception s)
        {
            System.out.println(s.toString());
        }
        break MISSING_BLOCK_LABEL_4841;
        Exception exception;
        exception;
        try
        {
            Thread.sleep(10L);
            if(so != null)
                so.close();
        }
        catch(Exception s)
        {
            System.out.println(s.toString());
        }
        throw exception;
        if(running) goto _L2; else goto _L1
_L1:
        if(stateArea != null)
            stateArea.append(CTime.getStringDate() + " SGIP12模块服务器端已经退出！\n\n");
        destroy = 2;
        return;
    }

    public void setDestroy(int dsty)
    {
        destroy = dsty;
    }
}