operationhelp.java

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

package com.wayout.wayoutsp.operation.packageHELP;

import java.sql.*;
import java.util.*;
import java.io.*;
import com.wayout.wayoutsp.publics.*;
import com.wayout.wayoutsp.operation.*;

/**
 * Title:        公司运营项目
 * Description:  实现短信SP之功能.短信互动系统
 * Copyright:    Copyright (c) 2002
 * Company:      wayout
 * @author wayout Software
 * @version 1.01
 */

public class OperationHELP extends Operation{

  public OperationHELP() {
  }
  private final String shortMsgID = Config.shortMsgIDTest;//特服短信代码
//  private final String shortMsgContentID = Config.shortMsgContentTest;//特服短信代码
  private final String publicID = com.wayout.wayoutsp.communication.ComConstants.o_IsmgInfo.spCode;//特服号
  private final String serviceName = Config.serviceNameTest ;//短信征集
  private final String dbURL =com.wayout.wayoutsp.publics.PublicConstants.CONNECTION_URL;//数据库URL
  private final String dbUSER =com.wayout.wayoutsp.publics.PublicConstants.DB_USER;//数据库用户
  private final String dbPWD =com.wayout.wayoutsp.publics.PublicConstants.DB_PASS;//数据库密码
  private final String dbDriver = com.wayout.wayoutsp.publics.PublicConstants.DB_DRIVER;//数据库驱动
  private  static java.sql.Connection conn = null;
//  private

  private int procResult =99;
    private int procExecFlag =1;
    private String procErrMsg ="";

    //private static CallableStatement callProc;


  /**
   * 判断是否是自己业务
   * @param obj 要读入的包
   * @return 是否是自己业务
   */
  protected boolean isOwnBusi(Object obj){
    if(!(obj instanceof ReceiveDataBean)){
      return false;
    }

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

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

    if(temp.equals(Config.cmdCMCCTEST)){//测试
      return true;
    }
    else if(temp.startsWith(Config.cmdQX)){//退订指定项
      try {
//        temp=ReplaceString.replace(temp," ","");
//        temp=ReplaceString.replace(temp,"+","");
//        temp=ReplaceString.replace(temp,"＋","");
//        if(temp.equals(Config.cmdQX0)){
//          return true;
//        }else if(temp.equals(Config.cmdQX1)){
//          return true;
//        }else if(temp.equals(Config.cmdQwayout)){
//          return true;
//        }else if(temp.equals(Config.cmdQX3)){
//          return true;
//        }else{
//          return false;
//        }
        return true;
      }
      catch (Exception ex) {
        return false;
      }
    }
    else if(temp.equals(Config.cmd0000)){//退订菜单
      return true;
    }
    else if(temp.equals(Config.cmd00000)){//一步退订
      return true;
    }
    else if(temp.equals(Config.cmdSpCode)){//获取客服资料
      return true;
    }
    else if(receive.destAddr.equals(Config.cmdSpCode)&&(temp.equals(receive.srcAddr)||("86"+temp).equals(receive.srcAddr))){//获取SP业务推荐
      return true;
    }
    else return false;

  }

  /**
   * 做业务处理
   * @param obj 要读入的包
   */
  protected void handBusi(Object obj){
    ReceiveDataBean receive = (ReceiveDataBean)obj;
    String MTcontent = "";
    String temp = receive.msgContent.toUpperCase();

    //除去STK卡附加字符
    if(temp.startsWith("+#")){
      temp = temp.substring(2);
    }
    SendDataBean send= new SendDataBean();
    if(temp.equals(Config.cmdCMCCTEST)){//测试
      send.clearAllDest();
      send.addDestAddr(receive.srcAddr);
      send.feeTerminalId=receive.srcAddr;
      send.sendData=Config.msgRepCMCCTEST;
      //<ServiceNameTest>，<SpName>，<SpCode>，<SpId>，<SubmitTime>（本消息收取信息费0.01元）
      send.sendData=ReplaceString.replace(send.sendData,"<SectionName>",Config.sectionName);
      send.sendData=ReplaceString.replace(send.sendData,"<SpName>",Config.spName);
      send.sendData=ReplaceString.replace(send.sendData,"<SpCode>",Config.publicID);
      send.sendData=ReplaceString.replace(send.sendData,"<SpId>",Integer.toString(com.wayout.wayoutsp.communication.ComConstants.o_IsmgInfo.spId));
      send.sendData=ReplaceString.replace(send.sendData,"<SubmitTime>",PublicFuction.getSysTime());
      send.msgSrc=Config.publicID;
      send.srcAddr=Config.publicID;
      send.servieceType="CMCCTEST";
      send.registeredDelivery=1;
      send.feeType=2;
      send.infoFee=1;
      StringTokenizer st = new StringTokenizer(send.sendData,"##");
      int index = 0;
      while (st.hasMoreTokens()) {
        send.pkTotal = (byte)st.countTokens();
        send.pkNumber = (byte)++index;
        send.sendData = st.nextToken().trim() ;
        if(send.getDestAddrs()[0].startsWith("129")){
          com.wayout.wayoutsp.operation.attendChat.AttendChat.saveUserToAttendDB(send);
        }
        else{
          OperManager.getInstance().sendShortMessage(send) ;
        }
      }
    }
    else if(temp.startsWith(Config.cmdQX)){//退订指定项
      try {
        temp=ReplaceString.replace(temp," ","");
        temp=ReplaceString.replace(temp,"+","");
        temp=ReplaceString.replace(temp,"＋","");
        if(temp.equals(Config.cmdQX0)){
          send.clearAllDest();
          send.addDestAddr(receive.srcAddr);
          send.feeTerminalId=receive.srcAddr;
//          delUserFormMOLO(receive.srcAddr);
//          delUserFormSEED(receive.srcAddr);
//          delUserFormMisery(receive.srcAddr);
//          delUserFormMYSTERY(receive.srcAddr);
          send.sendData=Config.msgRep00000;
          send.sendData=ReplaceString.replace(send.sendData,"<SpName>",Config.spName);
          send.sendData=ReplaceString.replace(send.sendData,"<CustomNum>",Config.customNum);
          send.msgSrc=Config.publicID;
          send.srcAddr=Config.publicID;
          send.servieceType="0000";
          send.registeredDelivery=1;
          send.feeType=1;
          send.infoFee=0;
          StringTokenizer st = new StringTokenizer(send.sendData,"##");
          int index = 0;
          while (st.hasMoreTokens()) {
            send.pkTotal = (byte)st.countTokens();
            send.pkNumber = (byte)++index;
            send.sendData = st.nextToken().trim() ;
            if(send.getDestAddrs()[0].startsWith("129")){
              com.wayout.wayoutsp.operation.attendChat.AttendChat.saveUserToAttendDB(send);
            }
            else{
              OperManager.getInstance().sendShortMessage(send) ;
            }
          }
        }else if(temp.equals(Config.cmdQX1)){
          send.clearAllDest();
          send.addDestAddr(receive.srcAddr);
          send.feeTerminalId=receive.srcAddr;
//          delUserFormMOLO(receive.srcAddr);
          send.sendData=Config.msgRepQX;
//您已经取消了<ServiceName>，谢谢您的参与！如果您满意，请告诉您的朋友，如果不满意，请告诉我：客服热线<CustomNum>
          send.sendData=ReplaceString.replace(send.sendData,"<ServiceName>",Config.serviceName1);
          send.sendData=ReplaceString.replace(send.sendData,"<CustomNum>",Config.customNum);
          send.msgSrc=Config.publicID;
          send.srcAddr=Config.publicID;
          send.servieceType="0000";
          send.registeredDelivery=1;
          send.feeType=1;
          send.infoFee=0;
          StringTokenizer st = new StringTokenizer(send.sendData,"##");
          int index = 0;
          while (st.hasMoreTokens()) {
            send.pkTotal = (byte)st.countTokens();
            send.pkNumber = (byte)++index;
            send.sendData = st.nextToken().trim() ;
            if(send.getDestAddrs()[0].startsWith("129")){
              com.wayout.wayoutsp.operation.attendChat.AttendChat.saveUserToAttendDB(send);
            }
            else{
              OperManager.getInstance().sendShortMessage(send) ;
            }
          }

        }else if(temp.equals(Config.cmdQwayout)){
          send.clearAllDest();
          send.addDestAddr(receive.srcAddr);
          send.feeTerminalId=receive.srcAddr;
//          delUserFormSEED(receive.srcAddr);
          send.sendData=Config.msgRepQX;
//您已经取消了<ServiceName>，谢谢您的参与！如果您满意，请告诉您的朋友，如果不满意，请告诉我：客服热线<CustomNum>
          send.sendData=ReplaceString.replace(send.sendData,"<ServiceName>",Config.serviceName2);
          send.sendData=ReplaceString.replace(send.sendData,"<CustomNum>",Config.customNum);
          send.msgSrc=Config.publicID;
          send.srcAddr=Config.publicID;
          send.servieceType="0000";
          send.registeredDelivery=1;
          send.feeType=1;
          send.infoFee=0;
          StringTokenizer st = new StringTokenizer(send.sendData,"##");
          int index = 0;
          while (st.hasMoreTokens()) {
            send.pkTotal = (byte)st.countTokens();
            send.pkNumber = (byte)++index;
            send.sendData = st.nextToken().trim() ;
            if(send.getDestAddrs()[0].startsWith("129")){
              com.wayout.wayoutsp.operation.attendChat.AttendChat.saveUserToAttendDB(send);
            }
            else{
              OperManager.getInstance().sendShortMessage(send) ;
            }
          }
        }else if(temp.equals(Config.cmdQX3)){
          send.clearAllDest();
          send.addDestAddr(receive.srcAddr);
          send.feeTerminalId=receive.srcAddr;
//          delUserFormMisery(receive.srcAddr);
          send.sendData=Config.msgRepQX;
          send.sendData=ReplaceString.replace(send.sendData,"<ServiceName>",Config.serviceName3);
          send.sendData=ReplaceString.replace(send.sendData,"<CustomNum>",Config.customNum);
          send.msgSrc=Config.publicID;
          send.srcAddr=Config.publicID;
          send.servieceType="0000";
          send.registeredDelivery=1;
          send.feeType=1;
          send.infoFee=0;
          StringTokenizer st = new StringTokenizer(send.sendData,"##");
          int index = 0;
          while (st.hasMoreTokens()) {
            send.pkTotal = (byte)st.countTokens();
            send.pkNumber = (byte)++index;
            send.sendData = st.nextToken().trim() ;
            if(send.getDestAddrs()[0].startsWith("129")){
              com.wayout.wayoutsp.operation.attendChat.AttendChat.saveUserToAttendDB(send);
            }
            else{
              OperManager.getInstance().sendShortMessage(send) ;
            }
          }
        }else if(temp.equals(Config.cmdQX4)){
          send.clearAllDest();
          send.addDestAddr(receive.srcAddr);
          send.feeTerminalId=receive.srcAddr;
//          delUserFormMYSTERY(receive.srcAddr);