recvmofromwapdm.java~4~

短信平台接口开发例子,java语言实现的。

              MSISDN + "'," + rs.getString("cxb001") + ",sysdate,'6883')";
          stmt.executeUpdate(cx05);


        }
        else if (LONG_CODE.equals("6893")) {


          sendSMSToWapdm1.SmbppSendUnicodeMessage(MO_MESSAGE_ID + "",
                                                  "4261KJCX4261T0050", "",
                                                  MSISDN,
                                                  MSISDN,
                                                  rs.getString("cxb002"), 0, 0,
                                                  0, 0, 0,
                                                  0);
          String cx05 =
              "insert into zhcwdx.cx05(CXC001,CXB001,cxc002,cxc003)values('" +
              MSISDN + "'," + rs.getString("cxb001") + ",sysdate,'6893')";

          stmt.executeUpdate(cx05);


        }

      }
    }
    catch (Exception e) {
      e.printStackTrace(System.out);
    }*/

  }

 public void getREPORT_MESSAGE(NodeList REPORT_MESSAGE) {

    Element node = (Element) REPORT_MESSAGE.item(0);

    //MO信息连接标识
    int CONNECT_ID = Integer.parseInt(node.getElementsByTagName("CONNECT_ID").
                                      item(0).getFirstChild().getNodeValue());

    //哪个业务的状态报告
    String BUSINESS_CODE = node.getElementsByTagName("BUSINESS_CODE").
        item(0).getFirstChild().getNodeValue();
    //哪条MT信息（或话单）的状态报告，应用程序要通过此ID与发送的信息去匹配
    String MESSAGE_ID = node.getElementsByTagName("MESSAGE_ID").
        item(0).getFirstChild().getNodeValue();
    //手机号码
    String MSISDN = node.getElementsByTagName("MSISDN").
        item(0).getFirstChild().getNodeValue();
    //MT信息（或话单）的提交时间，格式：YYMMDDHHMM（YY为年的后两位00-99，MM：01-12，DD：01-31，HH：00-23，MM：00-59）。
    String SUBMIT_TIME = node.getElementsByTagName("SUBMIT_TIME").
        item(0).getFirstChild().getNodeValue();
    //话单的完成时间，格式：YYMMDDHHMM（YY为年的后两位00-99，MM：01-12，DD：01-31，HH：00-23，MM：00-59）。
    String DONE_TIME = node.getElementsByTagName("DONE_TIME").
        item(0).getFirstChild().getNodeValue();
    //最终状态，只有值为DELIVRD状态为成功状态，其他为失败状态。
    String STATUS = node.getElementsByTagName("STATUS").
        item(0).getFirstChild().getNodeValue();

    //////////////////////////////////////////////////////////////////
    //////////////////////////////////////////////////////////////////
    ///////////下面商户可以对接收到的mo消息处理了/////////////////////
    System.out.println("CONNECT_ID-> " + CONNECT_ID);
    System.out.println("BUSINESS_CODE-> " + BUSINESS_CODE);
    System.out.println("MESSAGE_ID-> " + MESSAGE_ID);
    System.out.println("MSISDN-> " + MSISDN);
    System.out.println("SUBMIT_TIME-> " + SUBMIT_TIME);
    System.out.println("DONE_TIME-> " + DONE_TIME);
    System.out.println("STATUS-> " + STATUS);
    String str = "CONNECT_ID-> " + CONNECT_ID + "BUSINESS_CODE-> " +
        BUSINESS_CODE + "MESSAGE_ID-> " + MESSAGE_ID;

  }

  public void getUSER_ORDER(NodeList USER_ORDER) {

    Element node = (Element) USER_ORDER.item(0);

    //MO信息连接标识
    int CONNECT_ID = Integer.parseInt(node.getElementsByTagName("CONNECT_ID").
                                      item(0).getFirstChild().getNodeValue());

    //哪个业务的状态报告
    String BUSINESS_CODE = node.getElementsByTagName("BUSINESS_CODE").
        item(0).getFirstChild().getNodeValue();
    //手机号码
    String MSISDN = node.getElementsByTagName("MSISDN").
        item(0).getFirstChild().getNodeValue();
    //订阅日期
    String ORDER_DATE = node.getElementsByTagName("ORDER_DATE").
        item(0).getFirstChild().getNodeValue();
    //订阅时间
    String ORDER_TIME = node.getElementsByTagName("ORDER_TIME").
        item(0).getFirstChild().getNodeValue();
    //订阅模式
    String ORDER_MODE = node.getElementsByTagName("ORDER_MODE").
        item(0).getFirstChild().getNodeValue();
    //订阅参数
    String ORDER_PARAMETER = node.getElementsByTagName("ORDER_PARAMETER").
        item(0).getFirstChild().getNodeValue();
    //描述信息
    String ORDER_DESCRIPTION = node.getElementsByTagName("ORDER_DESCRIPTION").
        item(0).getFirstChild().getNodeValue();

    //////////////////////////////////////////////////////////////////
    //////////////////////////////////////////////////////////////////
    ///////////下面商户可以对接收到的mo消息处理了/////////////////////
    System.out.println("CONNECT_ID-> " + CONNECT_ID);
    System.out.println("BUSINESS_CODE-> " + BUSINESS_CODE);
    System.out.println("ORDER_DATE-> " + ORDER_DATE);
    System.out.println("MSISDN-> " + MSISDN);
    System.out.println("ORDER_TIME-> " + ORDER_TIME);
    System.out.println("ORDER_MODE-> " + ORDER_MODE);
    System.out.println("ORDER_PARAMETER-> " + ORDER_PARAMETER);
    System.out.println("ORDER_DESCRIPTION-> " + ORDER_DESCRIPTION);
    String str = "CONNECT_ID-> " + CONNECT_ID + "BUSINESS_CODE-> " +
        BUSINESS_CODE + "ORDER_PARAMETER-> " + ORDER_PARAMETER;
   /*  String sqlstr = "";
    sqlstr = "insert into zhcwdx.cx03(cxc001,cxa001,cxa002,aah003)values('" +
        MSISDN + "','9588','" + BUSINESS_CODE + "',sysdate)";

    String sqlstr1 = "insert into zhcwdx.cx06(cxf001,cxc001,cxa001,cxa002,cxc002,cxc003)values(zhcwdx.SEQ_CX06_CXF001.nextval,'" +
        MSISDN + "','9588','" + BUSINESS_CODE + "','1',sysdate)";

    try {
      dbConnection = getDBConnection();
      stmt = createStatement(dbConnection);
      stmt.executeUpdate(sqlstr);
      stmt.executeUpdate(sqlstr1);
    }
    catch (SQLException se) {
      se.printStackTrace();
    }
    finally {
      closeStatement(stmt);
      closeConnection(dbConnection);
    }*/

  }

  public void getUSER_CANCEL(NodeList USER_CANCEL) {

    Element node = (Element) USER_CANCEL.item(0);

    //MO信息连接标识
    int CONNECT_ID = Integer.parseInt(node.getElementsByTagName("CONNECT_ID").
                                      item(0).getFirstChild().getNodeValue());

    //哪个业务的状态报告
    String BUSINESS_CODE = node.getElementsByTagName("BUSINESS_CODE").
        item(0).getFirstChild().getNodeValue();
    //手机号码
    String MSISDN = node.getElementsByTagName("MSISDN").
        item(0).getFirstChild().getNodeValue();
    //退订日期
    String CANCEL_DATE = node.getElementsByTagName("CANCEL_DATE").
        item(0).getFirstChild().getNodeValue();
    //退订时间
    String CANCEL_TIME = node.getElementsByTagName("CANCEL_TIME").
        item(0).getFirstChild().getNodeValue();
    //退订模式
    String CANCEL_MODE = node.getElementsByTagName("CANCEL_MODE").
        item(0).getFirstChild().getNodeValue();
    //描述信息
    String CANCEL_DESCRIPTION = node.getElementsByTagName("CANCEL_DESCRIPTION").
        item(0).getFirstChild().getNodeValue();

    //////////////////////////////////////////////////////////////////
    //////////////////////////////////////////////////////////////////
    ///////////下面商户可以对接收到的mo消息处理了/////////////////////
    //System.out.println("CONNECT_ID-> " + CONNECT_ID);
    //System.out.println("BUSINESS_CODE-> " + BUSINESS_CODE);
    //System.out.println("CANCEL_DATE-> " + CANCEL_DATE);
    //System.out.println("MSISDN-> " + MSISDN);
    //System.out.println("CANCEL_TIME-> " + CANCEL_TIME);
    //System.out.println("CANCEL_MODE-> " + CANCEL_MODE);
    //System.out.println("CANCEL_DESCRIPTION-> " + CANCEL_DESCRIPTION);

    String str = "CONNECT_ID-> " + CONNECT_ID + "BUSINESS_CODE-> " +
        BUSINESS_CODE;

   /* String sqlstr = "";
    sqlstr = "delete from zhcwdx.cx03 where cxc001='" + MSISDN +
        "' and cxa001='9588' and cxa002='" + BUSINESS_CODE + "'";
    String sqlstr1 = "insert into zhcwdx.cx06(cxf001,cxc001,cxa001,cxa002,cxc002,cxc003)values(zhcwdx.SEQ_CX06_CXF001.nextval,'" +
        MSISDN + "','9588','" + BUSINESS_CODE + "','0',sysdate)";
    try {
      dbConnection = getDBConnection();
      stmt = createStatement(dbConnection);
      stmt.executeUpdate(sqlstr);
      stmt.executeUpdate(sqlstr1);
    }
    catch (SQLException se) {
      se.printStackTrace();
    }
    finally {
      closeStatement(stmt);
      closeConnection(dbConnection);
    }*/

  }

}