cmppsavedata.java

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

            "\nsm.msgMode:"+sm.msgMode+
            "\nsm.msgPriority:"+sm.msgPriority+
            "\nsm.msgServiceType:"+sm.msgServiceType+
            "\nsm.msgFeeUserType:"+sm.msgFeeUserType+
            "\nsm.msgDataCoding:"+sm.msgDataCoding+
            "\nsm.spId:"+sm.spId+
            "\nsm.msgFeeType:"+sm.msgFeeType+
            "\nsm.msgInfoFee:"+sm.msgInfoFee+
            "\nsm.msgValidityPeriod:"+sm.msgValidityPeriod+
            "\nsm.msgSchedule:"+sm.msgSchedule+
            "\nsm.spCode:"+sm.spCode+
            "\nsm.msgDestAddr:"+sm.msgDestAddr+
            "\nsm.msgLength:"+sm.msgLength+
            "\nsm.msgContent:"+sm.msgContent);
       */
       synchronized  ( pstmt1){  //lock pstmt1
           pstmt1.setInt   (1, sm.headSeqcNo);      //cmpp head
           pstmt1.setString(2, Long.toString(sm.submit_msg_id) );          //MO MSG_ID
           pstmt1.setInt   (3, sm.msgPkTotal);
           pstmt1.setInt   (4, sm.msgPkNumber);
           pstmt1.setInt   (5, sm.msgMode );
           pstmt1.setInt   (6, sm.msgPriority );
           pstmt1.setString(7, sm.msgServiceType);
           pstmt1.setInt   (8, sm.msgFeeUserType );
           pstmt1.setString(9, sm.feeTerminalId); //FEE_TERMINAL_ID
           pstmt1.setInt   (10, 0); //TP_pId
           pstmt1.setInt   (11, 0); //TP_udhi
           pstmt1.setInt   (12, sm.msgDataCoding );  //Msg_Fmt
           pstmt1.setString(13, sm.msgSrcAddr );//MSG_SRC
           pstmt1.setString(14, Integer.toString(sm.msgFeeType) );
           pstmt1.setString(15, Integer.toString(sm.msgInfoFee) );
           pstmt1.setString(16, sm.msgValidityPeriod );
           pstmt1.setString(17, sm.msgSchedule );
           pstmt1.setString(18, sm.spId );
           pstmt1.setInt   (19, sm.submit_destusr_tl );   //DestUsr_tl
           pstmt1.setString(20, stringArray2String(sm.msgSubmitDest,","));
           pstmt1.setInt   (21, sm.msgLength );
           pstmt1.setString(22, sm.msgContent );
           pstmt1.setString(23, sm.msgLinkId);
           pstmt1.setInt   (24, sm.activeResult);//SUBMIT_RESULT
           pstmt1.setInt   (25, sm.sendCount);//SEND_COUNTER
           pstmt1.setInt   (26, sm.operateSeqId);//operateSeqId
           pstmt1.setInt(27,IsmgSectionFlag);
           if( bMsgExecBatch )
              pstmt1.addBatch();
           else
              pstmt1.executeUpdate();
       } //end lock
       conn1NeedCommit = true;
       return true;
    }catch(Exception e)
    {
        PublicConstants.writeLog.error("CmppSaveData save submit data failed."
          +"\nmsgId:"+sm.msgId
          +"\nmsgMode:"+sm.msgMode
          +"\nmsgDestAddr:"+sm.msgDestAddr
          +"\nmsgSrcAddr:"+sm.msgSrcAddr
          +"\nmsgContent:"+sm.msgContent
          +"\nexception:"+e.toString() );
        bConnectState=DatabaseAccess.isConnectDB(conn1);
        if(bConnectState==false)//假如是数据库连接的原因
        {
          bConnectFlag=false;
          conn1NeedCommit = false;
          disconnectConn1();
          PublicConstants.writeLog.error("Mbcp saveMbcpMsg conn1 not connected to database!");
          connectDatabase();
        }
        return false;
    }

  }

  /**
   * 写Cmpp_Deliver.Report消息到数据库
   * @param smResp ShortMsgcmpp对象
   * @return
   *    true :成功
   *    false:失败
   */
  public boolean saveCmppReportMsg(ShortMsgCmpp sm){
    boolean bConnectState=false;
    if(bConnectFlag == false) return false;
    try
    {
        /*
            System.out.println("Before save to DB ........."+
            "\nsm.msgid:["+sm.msgId+"]"+
            "\nsm.msgDestAddr:"+sm.msgDestAddr+
            "\nsm.msgServiceType:"+sm.msgServiceType+
            "\nsm.msgDataCoding:"+sm.msgDataCoding+
            "\nsm.msgSrcAddr:"+sm.msgSrcAddr+
            "\nsm.msgMode:"+sm.msgMode+
            "\nsm.msgLength:"+sm.msgLength+
            "\nsm.msgContent:"+sm.msgContent);*/
       synchronized  ( pstmt2){  //lock pstmt2
           pstmt2.setString(1, Long.toString(sm.submit_msg_id) );          //MO MSG_ID
           pstmt2.setString(2, sm.msgDestAddr );
           pstmt2.setString(3, sm.msgServiceType);
           pstmt2.setString(4, sm.msgSrcAddr ) ;
           pstmt2.setInt   (5, sm.msgLength );
           pstmt2.setString(6, Long.toString(sm.reportMsgId)) ;//ReportMsg_Id
           pstmt2.setString(7, sm.reportStat ) ;
           pstmt2.setString(8, sm.reportSubmitTime ) ;
           pstmt2.setString(9, sm.reportDoneTime ) ;
           pstmt2.setString(10, sm.reportDestAddr ) ;
           pstmt2.setInt   (11, sm.reportSmscSequence );
           pstmt2.setString(12, sm.msgLinkId );
           pstmt2.setInt   (13, sm.getParseResult() );
           pstmt2.setInt(14,IsmgSectionFlag);

           if( bMsgExecBatch )
              pstmt2.addBatch();
           else
              pstmt2.executeUpdate();
       } //end lock
       conn2NeedCommit = true;
       return true;
    }catch(Exception e)
    {
        PublicConstants.writeLog.error("CmppSaveData save submit data failed."
          +"\nmsgId:"+sm.msgId
          +"\nmsgMode:"+sm.msgMode
          +"\nmsgDestAddr:"+sm.msgDestAddr
          +"\nmsgSrcAddr:"+sm.msgSrcAddr
          +"\nmsgContent:"+sm.msgContent
          +"\nexception:"+e.toString() );
        bConnectState=DatabaseAccess.isConnectDB(conn2);
        if(bConnectState==false)//假如是数据库连接的原因
        {
          bConnectFlag=false;
          conn2NeedCommit = false;
          disconnectConn2();
          PublicConstants.writeLog.error("Cmpp SaveCmppData conn2 not connected to database!");
          connectDatabase();
        }
        return false;
    }

  }//end

  /**
   * 写Cmpp_Deliver.消息到数据库
   * @param smResp ShortMsgcmpp对象
   * @return
   *    true :成功
   *    false:失败
   */

  public boolean saveCmppDeliverMsg(ShortMsgCmpp sm){
    boolean bConnectState=false;
    if(bConnectFlag == false) return false;
    try
    {
       synchronized  ( pstmt3){  //lock pstmt3
           pstmt3.setString(1, Long.toString(sm.submit_msg_id));          //MO MSG_ID
           pstmt3.setString(2, sm.msgDestAddr );
           pstmt3.setString(3, sm.msgServiceType);
           pstmt3.setInt   (4, sm.msgDataCoding );  //Msg_Fmt
           pstmt3.setString(5, sm.msgSrcAddr ) ;
           pstmt3.setInt   (6, sm.msgMode );
           pstmt3.setInt   (7, sm.msgLength );
           pstmt3.setString(8, sm.msgContent ) ;
           pstmt3.setString(9, sm.msgLinkId);
           pstmt3.setInt(10,IsmgSectionFlag);
           if( bMsgExecBatch ){
              pstmt3.addBatch();
           }
           else{
             pstmt3.executeUpdate();
           }
       } //end lock
       conn3NeedCommit = true;
       return true;
    }catch(Exception e)
    {
        PublicConstants.writeLog.error("CmppSaveData save Deleive data failed."
          +"\nmsgId:"+sm.submit_msg_id
          +"\nmsgMode:"+sm.msgMode
          +"\nmsgServiceType:"+sm.msgServiceType
          +"\nmsgDestAddr:"+sm.msgDestAddr
          +"\nmsgDataCoding:"+sm.msgDataCoding

          +"\nmsgSrcAddr:"+sm.msgSrcAddr
          +"\nmsgContent:"+sm.msgContent
          +"\nexception:"+e.toString() );
        bConnectState=DatabaseAccess.isConnectDB(conn3);
        if(bConnectState==false)//假如是数据库连接的原因
        {
          bConnectFlag=false;
          conn3NeedCommit = false;
          disconnectConn3();
          PublicConstants.writeLog.error("Cmpp SaveCmppData conn2 not connected to database!");
          connectDatabase();
        }
        return false;
    }

  }//end

  /**
   * 断开连接一
   */
  public void disconnectConn1(){
    try{
      pstmt1.close();
    }catch(Exception eSQL){}
    try{
      conn1.close();
    }catch(Exception eSQL){}
    conn1 = null;
  }

  /**
   * 断开连接二
   */
  public void disconnectConn2(){
    try{
      pstmt2.close();
    }catch(Exception eSQL){}
    try{
      conn2.close();
    }catch(Exception eSQL){}

    conn2 = null;
  }

  /**
   * 断开连接三
   */
  public void disconnectConn3(){
    try{
      pstmt3.close();
    }catch(Exception eSQL){}
    try{
      conn3.close();
    }catch(Exception eSQL){}

    conn3 = null;
  }

   public boolean getConnectStatus(){
     if (conn1 !=null & conn2 !=null & conn3 !=null  )
        return true;
     else return false;
   }
  /*
   * 把字符串数组用separator衔接为一个字符串
   * @param srcArray 源数组
   * @param separator 分隔符
   * @return 目的串
   */
  private static final String stringArray2String(String [] srcArray,String separator)
  {
      StringBuffer buffer = new StringBuffer();
      for(int i = 0; i< srcArray.length-1; i++)
      {
          buffer.append(srcArray[i]);
          buffer.append(separator);
      }
      buffer.append(srcArray[srcArray.length-1]);
      return buffer.toString();
  }


}