specialmosender.java

中国联通短信通信协议

package com.wireless.sms.gwif.smsagent.workthread;

import java.util.*;
import org.apache.log4j.Logger;
import com.wireless.sms.pub.entity.MO;
//import com.wireless.sms.gwif.smsagent.workthread.MODeQueue;
import com.wireless.sms.gwif.smsagent.func.CommonData;
import com.wireless.sms.gwif.smsagent.global.LoggerConstant;
import com.wireless.sms.gwif.smsagent.global.GetMoMtGlobalForUsual;
//import com.wireless.sms.pub.mq.*;
import com.wireless.sms.gwif.smsagent.global.*;
import com.wireless.sms.pub.net.MOClientSocket;

public class SpecialMOSender extends Thread{
  private Logger molog = LoggerConstant.mo_log;
  private MO _mo = null;

  public SpecialMOSender(MO mo) {
    this._mo = mo;
  }

  public void run(){
    try{
      String srcTermid = _mo.getSrcTermID();
      Hashtable ht = CommonData.getTestData();
      String data = (String) ht.get(srcTermid);
      String d[] = data.split(":");
      String destTermid = d[0];
      String content = d[1];
      String ip = d[2];
      String port = d[3];
      if(!destTermid.equals("*")&&!destTermid.equals(_mo.getDestTermID())){
        _mo.setRemark1("true");//表示该mo已经被判断过
        GetMoMtGlobalForUsual.moqueue.add(_mo);
        return;
      }
      if(!content.equals("*")&&!content.equalsIgnoreCase(_mo.getMsgContent())){
        _mo.setRemark1("true");
        GetMoMtGlobalForUsual.moqueue.add(_mo);
        return;
      }

      SendMO(_mo,ip,port);
    }catch(Exception e){
      molog.error(e.getCause());
    }
  }


  private void SendMO(MO mo, String ip, String port){
    MOClientSocket moSender = new MOClientSocket(ip, port);
//      moSender.setMOQueue(moqueue);
    moSender.setLog(molog);
    moSender.setMonitor(SmsGWIFGlobal.monitorHosta, SmsGWIFGlobal.monitorPorta);

    if (moSender.sendMO(mo)) {
      molog.info("send mo to test Router " + ip + "  true");
    }
    else {
      //与路由连接不通，发送监控信息
      molog.info("send mo to test Router " + ip + "  failed");
      SmsGWIFGlobal.sendMonitor("R000101");
    }
  }

}