smssubmitthread.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 SMSSubmitThread 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 String m_spNumber;
     private String m_chargeNumber;
     private int m_userCount;
     private String m_userNumber;
     private String m_corpId;
     private String m_serviceType;
     private int m_feeType;
     private String m_feeValue;
     private String m_givenValue;
     private int m_agentFlag;
     private int m_morelatetoMTFlag;
     private int m_priority;
     private String m_expireTime;
     private String m_scheduleTime;
     private int m_reportFlag;
     private int m_tp_pid;
     private int m_tp_udhi;
     private int m_messageCoding;
     private int m_messageType;
     private int m_msgLen;
     private String m_messageContent;
     private String m_reserve;
     public SMSSubmitThread(int seqAddr,int seqDate,int sequence,int messageLength,int commandID,
                            String spNumber,String chargeNumber,int userCount,String userNumber,String corpId,
                            String serviceType,int feeType,String feeValue,String givenValue,int agentFlag,
                            int morelatetoMTFlag,int priority,String expireTime,String scheduleTime,int reportFlag,
                            int tp_pid,int tp_udhi,int messageCoding,int messageType,int msgLen,
                            String messageContent,String reserve) {
          super();
          m_seqAddr=seqAddr;
          m_seqDate=seqDate;
          m_sequence=sequence;
          m_messageLength=messageLength;
          m_commandID=commandID;
          m_spNumber=spNumber;
          m_chargeNumber=chargeNumber;
          m_userCount=userCount;
          m_userNumber=userNumber;
          m_corpId=corpId;
          m_serviceType=serviceType;
          m_feeType=feeType;
          m_feeValue=feeValue;
          m_givenValue=givenValue;
          m_agentFlag=agentFlag;
          m_morelatetoMTFlag=morelatetoMTFlag;
          m_priority=priority;
          m_expireTime=expireTime;
          m_scheduleTime=scheduleTime;
          m_reportFlag=reportFlag;
          m_tp_pid=tp_pid;
          m_tp_udhi=tp_udhi;
          m_messageCoding=messageCoding;
          m_messageType=messageType;
          m_msgLen=msgLen;
          m_messageContent=messageContent;
          m_reserve=reserve;
     }
//     public SMSSubmitThread(Connection con,String resp,String sourceAddr,String destinationAddr,
//                            String content,String spNumber,String corpId,
//                            String serviceType,int feeType,String feeValue,String givenValue,
//                            int morelatetoMTFlag,int reportFlag,int messageCoding,String expireTime,String scheduleTime) {
//          super();
//          m_dbConn=con;
//          StringTokenizer st=new StringTokenizer(resp, ";");
//
//          String seq[]=new String[3];
//          int i=0;
//          while (i<3) {
//               seq[i]=st.nextToken();
//               i++;
//          }
//
//          m_seqAddr=Integer.parseInt(seq[0]);
//          m_seqDate=Integer.parseInt(seq[1]);
//          m_sequence=Integer.parseInt(seq[2]);
//          m_chargeNumber=sourceAddr;
//          m_userNumber=destinationAddr;
//          m_messageContent=content;
//          m_spNumber=spNumber;
//          m_corpId=corpId;
//          m_serviceType=serviceType;
//          m_feeType=feeType;
//          m_feeValue=feeValue;
//          m_givenValue=givenValue;
//          m_morelatetoMTFlag=morelatetoMTFlag;
//          m_expireTime=expireTime;
//          m_messageCoding=messageCoding;
//          m_scheduleTime=scheduleTime;
//          m_reportFlag=reportFlag;
//     }
     public SMSSubmitThread(String resp,String sourceAddr,String destinationAddr,
                            String content,String spNumber,String corpId,
                            String serviceType,int feeType,String feeValue,String givenValue,
                            int morelatetoMTFlag,int reportFlag,int messageCoding,String expireTime,String scheduleTime) {
          super();
          StringTokenizer st=new StringTokenizer(resp, ";");

          String seq[]=new String[3];
          int i=0;
          while (i<3) {
               seq[i]=st.nextToken();
               i++;
          }

          m_seqAddr=Integer.parseInt(seq[0]);
          m_seqDate=Integer.parseInt(seq[1]);
          m_sequence=Integer.parseInt(seq[2]);
          m_chargeNumber=sourceAddr;
          m_userNumber=destinationAddr;
          m_messageContent=content;
          m_spNumber=spNumber;
          m_corpId=corpId;
          m_serviceType=serviceType;
          m_feeType=feeType;
          m_feeValue=feeValue;
          m_givenValue=givenValue;
          m_morelatetoMTFlag=morelatetoMTFlag;
          m_expireTime=expireTime;
          m_messageCoding=messageCoding;
          m_scheduleTime=scheduleTime;
          m_reportFlag=reportFlag;
     }
     public SMSSubmitThread(int seqAddr,int seqDate,int sequence,int messageLength,int commandID,
                            String spNumber,String chargeNumber,int userCount,String[] userNumber,String corpId,
                            String serviceType,int feeType,String feeValue,String givenValue,int agentFlag,
                            int morelatetoMTFlag,int priority,String expireTime,String scheduleTime,int reportFlag,
                            int tp_pid,int tp_udhi,int messageCoding,int messageType,int msgLen,
                            String messageContent,String reserve) {
          super();
          m_seqAddr=seqAddr;
          m_seqDate=seqDate;
          m_sequence=sequence;
          m_messageLength=messageLength;
          m_commandID=commandID;
          m_spNumber=spNumber;
          m_chargeNumber=chargeNumber;
          m_userCount=userCount;
          int i=0;
          if(userNumber!=null){
               m_userNumber="";
               while(i<userNumber.length){
                    m_userNumber=m_userNumber+userNumber[i]+",";
                    i++;
               }
          }
          m_corpId=corpId;
          m_serviceType=serviceType;
          m_feeType=feeType;
          m_feeValue=feeValue;
          m_givenValue=givenValue;
          m_agentFlag=agentFlag;
          m_morelatetoMTFlag=morelatetoMTFlag;
          m_priority=priority;
          m_expireTime=expireTime;
          m_scheduleTime=scheduleTime;
          m_reportFlag=reportFlag;
          m_tp_pid=tp_pid;
          m_tp_udhi=tp_udhi;
          m_messageCoding=messageCoding;
          m_messageType=messageType;
          m_msgLen=msgLen;
          m_messageContent=messageContent;
          m_reserve=reserve;
     }
//     public SMSSubmitThread(Connection con,String resp,String sourceAddr,String[] destinationAddr,
//                            String content,String spNumber,String corpId,
//                            String serviceType,int feeType,String feeValue,String givenValue,
//                            int morelatetoMTFlag,int reportFlag,int messageCoding,String expireTime,String scheduleTime) {
//          super();
//          m_dbConn=con;
//          StringTokenizer st=new StringTokenizer(resp, ";");
//          String seq[]=new String[3];
//          int i=0;
//          while (i<3) {
//               seq[i]=st.nextToken();
//               i++;
//          }
//
//          m_seqAddr=Integer.parseInt(seq[0]);
//          m_seqDate=Integer.parseInt(seq[1]);
//          m_sequence=Integer.parseInt(seq[2]);
//          m_chargeNumber=sourceAddr;
//          i=0;
//          if(destinationAddr!=null){
//               m_userNumber="";
//               while(i<destinationAddr.length){
//                    m_userNumber=m_userNumber+destinationAddr[i]+",";
//                    i++;
//               }
//          }
//          m_messageContent=content;
//          m_spNumber=spNumber;
//          m_corpId=corpId;
//          m_serviceType=serviceType;
//          m_feeType=feeType;
//          m_feeValue=feeValue;
//          m_givenValue=givenValue;
//          m_morelatetoMTFlag=morelatetoMTFlag;
//          m_expireTime=expireTime;
//          m_scheduleTime=scheduleTime;
//          m_reportFlag=reportFlag;
//          m_messageCoding=messageCoding;
//     }
     public SMSSubmitThread(String resp,String sourceAddr,String[] destinationAddr,
                            String content,String spNumber,String corpId,
                            String serviceType,int feeType,String feeValue,String givenValue,
                            int morelatetoMTFlag,int reportFlag,int messageCoding,String expireTime,String scheduleTime) {
          super();
          StringTokenizer st=new StringTokenizer(resp, ";");
          String seq[]=new String[3];
          int i=0;
          while (i<3) {
               seq[i]=st.nextToken();
               i++;
          }

          m_seqAddr=Integer.parseInt(seq[0]);
          m_seqDate=Integer.parseInt(seq[1]);
          m_sequence=Integer.parseInt(seq[2]);
          m_chargeNumber=sourceAddr;
          i=0;
          if(destinationAddr!=null){
               m_userNumber="";
               while(i<destinationAddr.length){
                    m_userNumber=m_userNumber+destinationAddr[i]+",";
                    i++;
               }
          }
          m_messageContent=content;
          m_spNumber=spNumber;
          m_corpId=corpId;
          m_serviceType=serviceType;
          m_feeType=feeType;
          m_feeValue=feeValue;
          m_givenValue=givenValue;
          m_morelatetoMTFlag=morelatetoMTFlag;
          m_expireTime=expireTime;
          m_scheduleTime=scheduleTime;
          m_reportFlag=reportFlag;
          m_messageCoding=messageCoding;
     }
     protected static Connection getConnection() throws Exception {
          String driverName = SMSender.driverName;
          String url = SMSender.url;
          String user=SMSender.user;
          String password=SMSender.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();


               Calendar myDate=java.util.Calendar.getInstance();
               String myDay=Integer.toString(myDate.get(myDate.DATE));
               if(myDay.length()==1) myDay="0"+myDay;
               String biao="TSMS00"+myDay;

               String sql="";
               sql="insert into "+biao+" "
                  +"(seqAddr,seqDate,sequence,messageLength,commandID,"
                  +"spNumber,chargeNumber,userCount,userNumber,corpId,"
                  +"serviceType,feeType,feeValue,givenValue,agentFlag,"
                  +"morelatetoMTFlag,priority,expireTime,scheduleTime,reportFlag,"
                  +"tp_pid,tp_udhi,messageCoding,messageType,msgLen,"
                  +"messageContent,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.setString(6,m_spNumber);
               stmt.setString(7,m_chargeNumber);
               stmt.setInt(8,m_userCount);
               stmt.setString(9,m_userNumber);
               stmt.setString(10,m_corpId);
               stmt.setString(11,m_serviceType);
               stmt.setInt(12,m_feeType);
               stmt.setString(13,m_feeValue);
               stmt.setString(14,m_givenValue);
               stmt.setInt(15,m_agentFlag);
               stmt.setInt(16,m_morelatetoMTFlag);
               stmt.setInt(17,m_priority);
               stmt.setString(18,m_expireTime);
               stmt.setString(19,m_scheduleTime);
               stmt.setInt(20,m_reportFlag);
               stmt.setInt(21,m_tp_pid);
               stmt.setInt(22,m_tp_udhi);
               stmt.setInt(23,m_messageCoding);
               stmt.setInt(24,m_messageType);
               stmt.setInt(25,m_msgLen);
               stmt.setString(26,m_messageContent);
               stmt.setString(27,m_reserve);
               stmt.executeUpdate();
               stmt.close();

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

     }

}