smsinterface.java

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

package com.sxit.wap.sms;
import com.sxit.wap.common.*;
import com.sxit.wap.exception.*;
import com.tssx.ebiz.smscenter.SMSQueue;
import java.io.PrintStream;
import java.sql.Connection;
import java.sql.DriverManager;
import com.sxit.wap.cp.*;
import com.sxit.wap.user.*;
import java.util.*;

public class smsInterface {
  public String mobileNoPassword = "";
  public String content = "";
  public long queueID = 1L;
  public String sourceAddr = "";
  public String destinationAddr = "";
  public short submitMulti = 0;
  public int fileNum = 0;
  public String corpID = "15053";
  public String serviceType = "aaa";
  public String spNumber = "8888";
  public int feeType = 1;
  public String feeValue = "0";
  public String givenValue = "0";
  public int morelatetoMTFlag = 2;
  public int reportFlag = 1;
  private Connection createConnection(){
       Connection conn = null;
       try
          {
            conn = Database.getConnection();
            System.out.println("get connectin");
          }catch(Exception exe){
            this.closeConnection(conn);
            exe.printStackTrace();
            System.out.println("can not getconnection");
         }
         return conn;
  }
  public boolean sendMessage(String mdn,String msg){
    Connection conn=null;
    try {
          this.destinationAddr=mdn;
          this.content = msg;
          queueID = queueID + CpDao.getSequenceNextValue();
          SMSQueue smsqueue = new SMSQueue();
          conn = this.createConnection();
          smsqueue.insert(conn,queueID,"","86"+destinationAddr,content,submitMulti,fileNum,
                                       spNumber,corpID,serviceType,feeType,feeValue,givenValue,morelatetoMTFlag,reportFlag);
          this.closeConnection(conn);
          return true;
         }catch(Exception ex){
           ex.printStackTrace();
           System.out.println("信息发送失败");
           this.closeConnection(conn);
           return false;
         }
  }
  public boolean sendMessageByDate(String mdn,String msg,int hours){
    long time = System.currentTimeMillis() + hours*60*60*1000;
    java.sql.Timestamp ts = new java.sql.Timestamp(time);
    String dateSql = DateUtil.getDateSql(DBType.ORACLE,ts);
    Connection conn=null;
    try {
          this.destinationAddr=mdn;
          this.content = msg;
          queueID = queueID + CpBean.getSequenceNextValue();
          SMSQueue smsqueue = new SMSQueue();
          conn = this.createConnection();
          smsqueue.insertByDate(conn,queueID,"","86"+destinationAddr,content,submitMulti,fileNum,
                                       spNumber,corpID,serviceType,feeType,feeValue,givenValue,morelatetoMTFlag,reportFlag,dateSql);
          this.closeConnection(conn);
          return true;
        }catch(Exception ex){
           ex.printStackTrace();
           System.out.println("信息发送失败");
           this.closeConnection(conn);
           return false;
         }
  }
  public void sendMessageByAll(String msg) {
    try {
          Collection coll = UserDao.queryAll();
          Iterator it = coll.iterator();
          while (it.hasNext()) {
           UserModel user = new UserModel();
           this.sendMessage(user.getUserMdn(), msg);
         }
        }catch (Exception ex) {
         ex.printStackTrace();
       }
  }
  public void closeConnection(Connection conn){
    try{
         conn.close();
         System.out.println("Connection已经关闭");
        }catch(Exception ex){
          ex.printStackTrace();
          System.out.println(ex.getMessage());
        }
  }
  public static void main(String[] args) {

  }
}