smssubmitreportthread.java

WAP PUSH后台源码,WAP PUSH后台源码

package com.tssx.ebiz.sgip;

import java.sql.*;
import java.io.*;
import java.util.*;
/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Company: </p>
 * @author unascribed
 * @version 1.0
 */

public class SMSSubmitReportThread implements Runnable {

//     Connection m_dbConn=null;

     private int m_seqAddr;
     private int m_seqDate;
     private int m_sequence;
     private int m_messageLength;
     private int m_commandID;
     private int m_submitSeqAddr;
     private int m_submitSeqDate;
     private int m_submitSequence;
     private int m_reportType;
     private String m_userNumber;
     private int m_state;
     private int m_errorCode;
     private String m_reserve;
     public SMSSubmitReportThread(int seqAddr,int seqDate,int sequence,int messageLength,int commandID,
                                  int submitSeqAddr,int submitSeqDate,int submitSequence,int reportType,String userNumber,
                                  int state,int errorCode,String reserve) {
          super();
          m_seqAddr=seqAddr;
          m_seqDate=seqDate;
          m_sequence=sequence;
          m_messageLength=messageLength;
          m_commandID=commandID;
          m_submitSeqAddr=submitSeqAddr;
          m_submitSeqDate=submitSeqDate;
          m_submitSequence=submitSequence;
          m_reportType=reportType;
          m_userNumber=userNumber;
          m_state=state;
          m_errorCode=errorCode;
          m_reserve=reserve;
     }
//     public SMSSubmitReportThread(Connection con,int seqAddr,int seqDate,int sequence,int messageLength,int commandID,
//                                  int submitSeqAddr,int submitSeqDate,int submitSequence,int reportType,String userNumber,
//                                  int state,int errorCode,String reserve) {
//          super();
//          m_dbConn=con;
//          m_seqAddr=seqAddr;
//          m_seqDate=seqDate;
//          m_sequence=sequence;
//          m_messageLength=messageLength;
//          m_commandID=commandID;
//          m_submitSeqAddr=submitSeqAddr;
//          m_submitSeqDate=submitSeqDate;
//          m_submitSequence=submitSequence;
//          m_reportType=reportType;
//          m_userNumber=userNumber;
//          m_state=state;
//          m_errorCode=errorCode;
//          m_reserve=reserve;
//     }
     protected static Connection getConnection() throws Exception {
          String driverName = SMReceiver.driverName;
          String url = SMReceiver.url;
          String user=SMReceiver.user;
          String password=SMReceiver.password;
          Connection con = null;

          //连接数据库
          Class.forName(driverName).newInstance();
          con = DriverManager.getConnection(url,user,password);
          return con;
     }
     public void run() {
          Connection m_dbConn=null;
          PreparedStatement stmt=null;
          try{
               m_dbConn = getConnection();
               String myDay=Integer.toString(m_submitSeqDate);
               if(myDay.length()==9){
                    myDay=myDay.substring(1,3);
               }else{
                    myDay=myDay.substring(2,4);
               }

               String biao="TSMS10"+myDay;

               String sql="";
               sql="insert into "+biao+" "
                  +"(seqAddr,seqDate,sequence,messageLength,commandID,"
                  +"submitSeqAddr,submitSeqDate,submitSequence,reportType,userNumber,"
                  +"state,errorCode,reserve) values (?,?,?,?,?,?,?,?,?,?,?,?,?)";
               stmt=m_dbConn.prepareStatement(sql);
               stmt.setInt(1,m_seqAddr);
               stmt.setInt(2,m_seqDate);
               stmt.setInt(3,m_sequence);
               stmt.setInt(4,m_messageLength);
               stmt.setInt(5,m_commandID);
               stmt.setInt(6,m_submitSeqAddr);
               stmt.setInt(7,m_submitSeqDate);
               stmt.setInt(8,m_submitSequence);
               stmt.setInt(9,m_reportType);
               stmt.setString(10,m_userNumber);
               stmt.setInt(11,m_state);
               stmt.setInt(12,m_errorCode);
               stmt.setString(13,m_reserve);
               stmt.executeUpdate();
               stmt.close();

               //插入或者更新状态报告
          }catch(Exception e){
               System.out.println(e);
               System.out.println("SMSSubmitReportThread error:"+e);
          }finally{
               try {
                    if (stmt != null) {
                         stmt.close();
                    }
                    if (m_dbConn != null) {
                         m_dbConn.close();
                    }
               } catch (Exception ee) {
                    System.out.println(ee);
               }
          }

     }
}