provision.java

java支持的短信平台

package com.khan.sms.provision;

/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
import java.io.IOException;
import java.io.PrintWriter;
import java.util.HashMap;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import com.khan.util.*;


//import sms.khan.Log;
import com.khan.xml.XMLParse;
import sun.misc.BASE64Decoder;
import com.khan.file.Log;
import java.util.Iterator;

public class Provision extends HttpServlet {
  Log log=new Log("smsProvion_log.out");
  Log err=new Log("smsProvion_log.err");

  private static final String CONTENT_TYPE = "text/html; charset=GBK";

  /**
   */
  private static final long serialVersionUID = 1L;

  public void destroy() {

  }

  public void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
    XMLParse xml = new XMLParse();

    resp.setContentType(CONTENT_TYPE);
    PrintWriter out = resp.getWriter();

    int result = xml.parseXml(req.getInputStream());
/*
    Iterator it = xml.provisionMap.keySet().iterator();
    while (it.hasNext()) {
      String cs = (String) it.next();
      System.out.println(cs+":"+xml.provisionMap.get(cs));
    }
*/
    String sql = "";



    String command_order = (String) xml.provisionMap.get("FeatureStr");

    if (command_order != null) {
      BASE64Decoder decoder = new BASE64Decoder();
      try {
        byte[] b = decoder.decodeBuffer(command_order);
        command_order = new String(b);
      } catch (Exception e) {
        err.logOut("FeatureStr字段解码错误!", e);
      }
    }

    String port = "03409";
    String msg_content = "";
    String mobile = (String)xml.provisionMap.get("MSISDN");

    if ((mobile != null) && (mobile.startsWith("86"))) {
      mobile = mobile.substring(2);
    }

    if (command_order != null) {
      try {
        port = command_order.substring(0, command_order.indexOf(" "));
        port = common.isNumber(port) ? port : "03409";
        msg_content = command_order.substring(command_order.indexOf(" ") + 1, command_order.length());
      } catch (Exception e) {
        err.logOut("解析长端口定制失败!", e);
      }
    }

    int ActionID = Integer.parseInt((String) (xml.provisionMap .get("ActionID")));
    if ( xml.provisionMap .get("MsgType").equals("SyncOrderRelationReq")) {
      log.logOut("开始处理同步数据包 " + xml.provisionMap .get("MsgType"));
      switch (ActionID) {
      case 1: case 3:
        port = command_order.substring(0, command_order.indexOf(" "));

        sql = "INSERT INTO SP_User(MobileNO, ActionID, ServiceID, LogIn) "
              + "VALUES('" + mobile + "',"
              + ActionID + ", "
              + "'" + (String) (xml.provisionMap.get("SPServiceID")) + "',"
              + "getdate())";

        log.logOut("正向订购处理, TransactionID:" + (String) (xml.provisionMap.get("TransactionID"))
                   + ",ServiceID:" + (String) (xml.provisionMap.get("SPServiceID"))
                   + ",Port:" + port
                   + ",ActionID" + ActionID
                   + ",Command:" + msg_content
                   + ",MobileNO:" + mobile
                   + ",Command:" + command_order + " ");
        break;
      case 2: case 4:
        sql = "";
        sql = "INSERT INTO SP_User(MobileNO, ActionID, ServiceID, LogIn) "
              + "VALUES('" + mobile + "',"
              + ActionID + ", "
              + "'" + (String) (xml.provisionMap.get("SPServiceID")) + "',"
              + "getdate())";

        log.logOut("正向取消处理, TransactionID:" + (String) (xml.provisionMap.get("TransactionID"))
           + ",ServiceID:" + (String) (xml.provisionMap.get("SPServiceID"))
           + ",Port:" + port
           + ",ActionID" + ActionID
           + ",Command:" + msg_content
           + ",MobileNO:" + mobile
           + ",Command:" + command_order + " ");

        break;
      }
    }
    //System.out.println(sql);
    SyncOrderRelationResp sor = new SyncOrderRelationResp(0, (String) (xml.provisionMap .get("TransactionID")));
    out.print(sor.BuildSoapStruct());
    //System.out.println(sor.BuildSoapStruct());

    common.excuteSql(sql);

  }

  public static void main(String args[]) {

  }

  // Process the HTTP Post request
  public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    doGet(request, response);
  }

  // Initialize global variables
  public void init() throws ServletException {

  }
}