cmpp2gatewayreceiver.java

采用JAVA开发

package com.gctech.sms.gateway.cmpp3;

import java.io.IOException;

import org.apache.log4j.Logger;

import com.gctech.cmpp3.client.CmppApi;
import com.gctech.cmpp3.client.Receiver;
import com.gctech.cmpp3.msg.DeliverRequest;
import com.gctech.cmpp3.msg.SubmitResponse;
import com.gctech.sms.core.Gateway;
import com.gctech.sms.gateway.basic.DataList;
import com.gctech.sms.gateway.cmpp3.CMPP2StructConverter;
import com.gctech.sms.msg.MOInfo;
import com.gctech.sms.msg.MTAck;
import com.gctech.util.Tools;


/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: gctech</p>
 * @author 王红宝
 * @version $Id: CMPP2GatewayReceiver.java,v 1.2 2004/07/16 08:34:16 wanghb Exp $
 */

public class CMPP2GatewayReceiver extends Receiver {

  public CMPP2GatewayReceiver() {
  }

  /**
   * 处理下行回复。
   * */
  protected void processSubmitRes(SubmitResponse resp) {
    //找不到消息，打印警告
    int nTry = 0;
    int seq = resp.getHead().getSequenceId();
    Object obj = DataList.getInstance().removeMtBySeq(seq);
    while ( obj == null ){
      nTry++;
      logger.warn("mt receive "+seq+" not found for "+nTry+"!");
      try {
        Thread.sleep(10);
      }
      catch (InterruptedException ex1) {
      }
      if ( nTry > 10 ){
        logger.warn("mt receive "+seq+" not found for "+nTry+"!");
        logger.warn("give up the find!");
        return;
      }else{
        obj = DataList.getInstance().removeMtBySeq(seq);
      }
    }
    //找到消息，回复到短信平台
    //MTInfo info = (MTInfo)obj;
    MTAck objMTAck = new MTAck();
    objMTAck.msgId = obj.toString();
    objMTAck.msgId2 = new String(resp.getMsgId());
    objMTAck.status = Tools.Bytes4ToInt(resp.getStatus());
	//objMTAck.seq = seq;
    try {
      CMPP2MTReceiver.getInstance().sendAck(objMTAck);
    }
    catch (IOException ex) {
      logger.error("下行消息回复短信平台失败！", ex);
    }
  }
  /**
   * 处理上行。
   * */
  protected void processDeliver(DeliverRequest deliver) {
    //添加到上行列表
    MOInfo moInfo = CMPP2StructConverter.Deliver2MOInfo(deliver);
    //增加网关信息，服务代码
    moInfo.gateway = Gateway.SHAN_DONG_MOBILE.getValue();
    moInfo.serviceNo = CmppApi.getInstance().getServiceNo();
    try{
      System.out.println("从山东读到了数据！"+ moInfo.content);
    }catch(Exception e){
      e.printStackTrace();
    }
    DataList.getInstance().addMo(moInfo);
  }

  static final Logger logger = Logger.getLogger(CMPP2GatewayReceiver.class);

}