mysmproxy30.java~14~

移动CMPP3.0协议短信网关连接程序

import java.util.*;
import com.huawei.smproxy.*;
import com.huawei.insa2.comm.cmpp.message.*;
import com.huawei.insa2.comm.cmpp30.message.*;
import com.huawei.insa2.util.*;

public  class MySMProxy30 extends SMProxy30//在完成接受短信网关下发消息的功能时,需要自己实现抽象类SMProxy30
    {
        CMPP30DeliverMessage1 UpMessage[];
        public boolean connected1 = false;
        int num=0;
        public MySMProxy30(Args args) {
            //调用父类的构造函数，完成初始化和登录ISMG的功能，不能省略
            //登陆之后产生两个线程?
            super(args);
            UpMessage=new CMPP30DeliverMessage1[10];
                     }
            public CMPPMessage onDeliver(CMPP30DeliverMessage msg) {
                //添加收到短消息中心下发消息的处理代码

                System.out.println("onDeliver函数启动。。。。。。。。。。。。");
                System.out.println("发送号码：" + msg.getSrcterminalId());
                System.out.println("是否为状态报告：" + msg.getRegisteredDeliver());
                if (msg.getMsgContent() != null) {
                    try {
                        System.out.println("短信内容:" +new String(msg.getMsgContent(), "GB2312"));
                        CMPP30DeliverMessage1 UpMessage1;
                        UpMessage1=new CMPP30DeliverMessage1(msg.getMsgContent(),msg.getSrcterminalId(),msg.getMsgLength());
/*                        for (int j = 0; j < 10; j++) {
                            //(UpMessage[j].mark == 0)
                            if (true) {
                                System.out.println("手机号码:" +new String(msg.getMsgContent(),"GB2312"));
                                UpMessage[j]=UpMessage1;
//                              System.out.println("手机号码:" +new String(msg.getMsgContent(),"GB2312"));
                                UpMessage[j].mark = 1;
                                break;
                            }
 }
*/                           if(num<10)
                           {
                               UpMessage[num]=UpMessage1;
                               System.out.println("手机号码:" +new String(msg.getMsgContent(),"GB2312"));
                           }



//          UpMessage=new CMPP30DeliverMessage1(msg.getMsgContent(),msg.getSrcterminalId(),msg.getMsgLength());
                    } catch (Exception e) {
                        e.printStackTrace();
                    }

                }
                return super.onDeliver(msg);
                //实际上是返回响应消息，一定要有
            }

            public void OnTerminate() {
                //可以添加ISMG和SMProxy30断开连接的处理代码
            }
    }