smsender.java

pk_Total - 相同msg_Id消息总条数 pk_Number - 相同msg_Id的消息序号 registered_Delivery - 是否要求返回状态报告 msg_Level - 信

package demo.cngpdemo;

import java.util.*;
import java.sql.*;
import java.io.*;
import com.huawei.smproxy.CNGPSMProxy;
import com.huawei.smproxy.comm.cngp.*;
import com.huawei.smproxy.comm.cngp.message.*;
import com.huawei.smproxy.util.*;

/**
 * <p>Web发送短消息管理操作类，具体负责将页面提交的短消息发送到infoX</p>
 */

public class SMSender extends CNGPSMProxy
{
    //系统配置信息
    private static Args arg = Env.getConfig().getArgs("CNGPConnect");

    private static SMSender instance;

    public static SMSender getInstance()
    {
        if (instance==null)
        {
            instance = new SMSender();
        }
        return instance;
    }

    protected SMSender()
    {
        super(SMSender.arg);
    }

    /**
     * 当与InfoX的连接被中断时的处理
     */
    public void OnTerminate()
    {
        System.out.println("Connection have been breaked! ");
    }
    /**
     * 对SMGW主动下发的消息的处理。此例中只返回一个成功的响应。
     * @param msg 收到的消息。
     * @return 返回的相应消息。
     */
    public CNGPMessage onDeliver(final CNGPDeliverMessage msg)
    {
        return new CNGPDeliverRespMessage(msg.getMsgId(),0);
    }

    /**
     * 发送一条消息，完成真正的消息发送。
     * @param msg 待发送的消息。
     * @return true：发送成功。false：发送失败。
     */
    public boolean send(CNGPSubmitMessage msg) {
      if ( msg == null ) {
        return false;
      }
      CNGPSubmitRespMessage reportMsg = null;
      PreparedStatement stat = null;
      try {
          reportMsg = (CNGPSubmitRespMessage)super.send(msg);
      }
      catch (IOException ex) {
        ex.printStackTrace();
        return false;
      }
      return true;
    }
}