operationyx.java

sp最新短信API(综合网关)

package com.wayout.wayoutsp.operation.packageYX;

/**
 * <p>Title: </p>
 * <p>Description: 短信互动平台</p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Company: wayout</p>
 * @author [e-mail]
 * @version 1.0
 */
import java.sql.*;
import java.util.*;
import java.io.*;
import com.wayout.wayoutsp.publics.*;
import com.wayout.wayoutsp.operation.Operation;

public class OperationYX  extends Operation {
  public OperationYX() {
  }

  private final String publicID = com.wayout.wayoutsp.communication.ComConstants.o_IsmgInfo.spCode;

  protected boolean isOwnBusi(Object obj){
    if(!(obj instanceof ReceiveDataBean)){
      return false;
    }

    ReceiveDataBean receive = (ReceiveDataBean)obj;
    String temp = receive.msgContent.trim().toUpperCase();

    //除去STK卡附加字符
    if(temp.startsWith("+#")){
      temp = temp.substring(2);
    }

    if(receive.destAddr.trim().startsWith(publicID+10)){//短信
      return true;
    }

    else return false;

  }

  /**
   * 业务处理
   * @param obj
   */
  protected void handBusi(Object obj){
    ReceiveDataBean receive = (ReceiveDataBean)obj;

    //判断是否是STK卡发送的信息
    if(receive.msgContent.startsWith("+#")){
      //除去STK卡的附加信息
      receive.msgContent = receive.msgContent.substring(2);
      //设置STK的处理标志位
      //user.stkFlag = 1;
    }
    cServerYX.addBusi(receive);
  }

  /**
   *初始化加载类
   * @return
   */
  protected  boolean initDefaultConfig(){

    try{

      cServerYX = new conncetionServerYX();
      cServerYX.start();

      rServerYX = new receiveServerYX();
      rServerYX.start();

    }catch(Exception e ){
      System.out.println("initDefaultConfig OperationYX::;;"+e.toString());
    }
     return true;
  }


  private conncetionServerYX cServerYX;
  private receiveServerYX rServerYX;
}