mysmproxy30.java~20~

移动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]=new CMPP30DeliverMessage1(msg.getMsgContent(),msg.getSrcterminalId(),msg.getMsgLength());
                               num++;
                               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断开连接的处理代码
            }
    }